哈喽！小陈
哈喽！小陈_个人页
哈喽！小陈
文章
0
问答
1933
视频
0
个人介绍
暂无个人介绍
擅长的技术
暂无更多信息
2023年03月
-
03.10 10:09:30
提交了问题
2023-03-10 10:09:30
-
03.07 14:27:22
回答了问题
2023-03-07 14:27:22
-
03.07 14:27:18回答了问题
2023-03-07 14:27:18
-
03.07 14:25:49回答了问题
2023-03-07 14:25:49
-
03.07 14:24:54回答了问题
2023-03-07 14:24:54
设置rocksdb之后，checkpoint应该是增量了吗？
赞0 踩0 评论0 -
03.07 14:24:50回答了问题
2023-03-07 14:24:50
这里checkpoint超时是为什么呢？
赞0 踩0 评论0 -
03.07 14:23:46回答了问题
2023-03-07 14:23:46
-
03.07 14:23:41回答了问题
2023-03-07 14:23:41
下面问题怎么处理呢？
赞0 踩0 评论0 -
03.07 14:23:37回答了问题
2023-03-07 14:23:37
-
03.07 14:22:19回答了问题
2023-03-07 14:22:19
在flink中的log4j2中怎么添加mdc日志啊？
赞0 踩0 评论0 -
03.07 14:21:16回答了问题
2023-03-07 14:21:16
全局并行度3，执行sql只能1是吗？
赞0 踩0 评论0 -
03.07 14:20:09回答了问题
2023-03-07 14:20:09
代码只有一次,但是同一条数据用了两次udf函数是为什么？
赞0 踩0 评论0 -
03.07 14:20:05回答了问题
2023-03-07 14:20:05
web-ui 加载会非常慢是什么原因呢？
赞0 踩0 评论0 -
03.07 14:20:01回答了问题
2023-03-07 14:20:01
如果用dataStream 怎么反序列化 avro的数据呀？
赞0 踩0 评论0 -
03.07 14:18:58回答了问题
2023-03-07 14:18:58
-
03.07 14:18:54回答了问题
2023-03-07 14:18:54
这种情况是什么原因啊？
赞0 踩0 评论0 -
03.07 14:18:51回答了问题
2023-03-07 14:18:51
这个用flink sql 读取也是报错是为什么？
赞0 踩0 评论0 -
03.07 14:17:31回答了问题
2023-03-07 14:17:31
我的richmap有600个并发度，如果同时访问hive，hive能撑住吗？
赞0 踩0 评论0 -
03.07 14:17:27回答了问题
2023-03-07 14:17:27
flink 消费Kafka的数据乱码，怎么解决？
赞0 踩0 评论0 -
03.07 14:17:21回答了问题
2023-03-07 14:17:21
一直重启，是线程崩了吗？
赞0 踩0 评论0 -
03.07 14:16:16回答了问题
2023-03-07 14:16:16
这种写入最后需要做什么结尾吗？
赞0 踩0 评论0 -
03.07 14:16:12回答了问题
2023-03-07 14:16:12
报这种错误怎么解决啊？
赞0 踩0 评论0 -
03.07 14:16:08回答了问题
2023-03-07 14:16:08
流式flink任务失败后，日志怎么找呢？
赞0 踩0 评论0 -
03.07 14:14:45回答了问题
2023-03-07 14:14:45
对于checkpoint 跑几天就会checkpoint超时过期这种怎么排查啊？
赞0 踩0 评论0 -
03.07 14:14:41回答了问题
2023-03-07 14:14:41
下面的情况怎么处理呢？
赞0 踩0 评论0 -
03.07 14:14:37回答了问题
2023-03-07 14:14:37
把flink日志发送到kafka怎么实现啊？
赞0 踩0 评论0 -
03.07 14:13:23回答了问题
2023-03-07 14:13:23
sqlclient 打印全部异常的 set 命令是什么？
赞0 踩0 评论0 -
03.07 14:13:19回答了问题
2023-03-07 14:13:19
Java 的Integer 怎么转成 scala 的 Int类型呢？
赞0 踩0 评论0 -
03.07 14:13:14回答了问题
2023-03-07 14:13:14
taskmanager.memory.flink.size不是节点分配内存吗？
赞0 踩0 评论0 -
03.07 14:12:06回答了问题
2023-03-07 14:12:06
配置 state.backend: rocksdb 导致节点oom怎么处理？
赞0 踩0 评论0 -
03.07 14:12:03回答了问题
2023-03-07 14:12:03
下面这种情况是为什么啊？
赞0 踩0 评论0 -
03.07 14:11:59回答了问题
2023-03-07 14:11:59
数据写入HDFS 我想指定压缩格式，不想指定存储格式 可以吗 ？
赞0 踩0 评论0 -
03.07 14:10:55回答了问题
2023-03-07 14:10:55
flinksql里面有禁用局部chain的配置吗?
赞0 踩0 评论0 -
03.07 14:10:51回答了问题
2023-03-07 14:10:51
ck 是按时间设置的，还是按容量大小来的，还是可以 min(时间，容量) 啊？
赞0 踩0 评论0 -
03.07 14:10:48回答了问题
2023-03-07 14:10:48
请问下flinkcdc能不能从指定时间开始同步数据？
赞0 踩0 评论0 -
03.07 14:09:29回答了问题
2023-03-07 14:09:29
-
03.07 14:09:26回答了问题
2023-03-07 14:09:26
-
03.07 14:09:23回答了问题
2023-03-07 14:09:23
checkpoint保存kafka offset吗？
赞0 踩0 评论0 -
03.07 14:07:21回答了问题
2023-03-07 14:07:21
-
03.07 14:06:45回答了问题
2023-03-07 14:06:45
这种情况怎么处理啊？
赞0 踩0 评论0 -
03.07 14:06:41回答了问题
2023-03-07 14:06:41
做checkpoint的时候内存没怎么变 ，cpu高了一点是为什么？
赞0 踩0 评论0 -
03.07 14:05:03回答了问题
2023-03-07 14:05:03
-
03.07 14:04:49回答了问题
2023-03-07 14:04:49
这种是不是要加配置了啊？
赞0 踩0 评论0 -
03.07 14:04:33回答了问题
2023-03-07 14:04:33
为什么只用一个路径有时候找不到某个表的chk了？
赞0 踩0 评论0 -
03.03 13:15:13回答了问题
2023-03-03 13:15:13
-
03.03 13:13:06回答了问题
2023-03-03 13:13:06
dataphin有没有价格跌倒一定程度或行业平均水平有一个预警机制？
赞0 踩0 评论0 -
03.03 13:13:02回答了问题
2023-03-03 13:13:02
-
03.03 13:12:58回答了问题
2023-03-03 13:12:58
暂无更多信息
-
提交了问题
2023-03-10
如何介绍视觉智能开放平台人脸识别各服务API接口请求和返回示例？
-
回答了问题
2023-03-07
flink13 checkpoint进度卡住不动，导致超时，可以从哪里进行排查呢？
可以用web ui看一下吧，看一下数据传输，是否是数据倾斜造成的。此回答整理自钉钉群”【③群】Apache Flink China社区“赞0 踩0 评论0 -
回答了问题
2023-03-07
请问下一个并行度占用1核吗？我并行度设置的是10，solt为5，在yarn上看，核数是11。
你的job也要占用一个。此回答整理自钉钉群”【③群】Apache Flink China社区“赞1 踩0 评论0 -
回答了问题
2023-03-07
rocketmq-flink ，支持flink sql 方式写rocketmq时这个连接器怎么用呢？
看这包的体积就知道是依赖类冲突， 全家桶打包不清楚里边flink打的啥版本的 都不管和集群是否冲突，依赖最小化原则。此回答整理自钉钉群”【③群】Apache Flink China社区“赞0 踩0 评论0 -
回答了问题
2023-03-07
设置rocksdb之后，checkpoint应该是增量了吗？
不会，默认false。此回答整理自钉钉群”【③群】Apache Flink China社区“赞0 踩0 评论0 -
回答了问题
2023-03-07
这里checkpoint超时是为什么呢？
sink并行度是1的话，写kafka会有问题的，不能命中分区写，可以按照kafka分区设置并行。此回答整理自钉钉群”【③群】Apache Flink China社区“赞0 踩0 评论0 -
回答了问题
2023-03-07
Flink CDC在支持 AWS的5.7.mysql_aurora.2.10.2 版本吗？
2个办法试一下 此回答整理自钉钉群”【③群】Apache Flink China社区“赞0 踩0 评论0 -
回答了问题
2023-03-07
下面问题怎么处理呢？
flink cep可以在不停任务的情况下动态修改规则：修改或者新增规则，你可以找找思路。此回答整理自钉钉群”【③群】Apache Flink China社区“赞0 踩0 评论0 -
回答了问题
2023-03-07
目前任务运行在yarn上，如果调整了flink的并行度，需要手动重启，有什么解决办法吗？
如果用阿里云的全托管，好像是可以动态调整的。不过应该还是先savepoint，然后根据新参数重启，只是给你封装好了。此回答整理自钉钉群”【③群】Apache Flink China社区“赞0 踩0 评论0 -
回答了问题
2023-03-07
在flink中的log4j2中怎么添加mdc日志啊？
MDC（Mapped Diagnostic Context）是Log4j2中的一个功能，用于在同一个日志消息中添加额外的诊断信息。在Flink中，要添加MDC日志，需要在log4j2.xml配置文件中添加MDC拦截器，如下所示： 上面的配置将在每条日志消息中添加MDC诊断信息，其中mdcKey是MDC中的一个键。此回答整理自钉钉群”【③群】Apache Flink China社区“赞0 踩0 评论0 -
回答了问题
2023-03-07
全局并行度3，执行sql只能1是吗？
检查一下是不是sink 算子 单独设置了。此回答整理自钉钉群”【③群】Apache Flink China社区“赞0 踩0 评论0 -
回答了问题
2023-03-07
代码只有一次,但是同一条数据用了两次udf函数是为什么？
不要create view as的语法，把两个sql合并在一起。如果要debug排查，改写成table api排查问题(只调用udf函数)。此回答整理自钉钉群”【③群】Apache Flink China社区“赞0 踩0 评论0 -
回答了问题
2023-03-07
web-ui 加载会非常慢是什么原因呢？
建议改conf目录的配置文件试试。此回答整理自钉钉群”【③群】Apache Flink China社区“赞0 踩0 评论0 -
回答了问题
2023-03-07
如果用dataStream 怎么反序列化 avro的数据呀？
代码里指定org.apache.kafka.common.serialization.StringDeserializer反序列化。此回答整理自钉钉群”【③群】Apache Flink China社区“赞0 踩0 评论0 -
回答了问题
2023-03-07
通过flink sql 消费这个avro后的数据改了半天 又报了这个错误是什么原因啊？
可以尝试排查一下有没有脏数据或者数据不规则，或者格式、序列化的问题。此回答整理自钉钉群”【③群】Apache Flink China社区“赞0 踩0 评论0 -
回答了问题
2023-03-07
这种情况是什么原因啊？
建议考虑一下是不是某一个源很长时间没有数据来，另外一个源数据来了，由于是barra 对齐，多以在join 的时候，等待barria 超时了。此回答整理自钉钉群”【③群】Apache Flink China社区“赞0 踩0 评论0 -
回答了问题
2023-03-07
这个用flink sql 读取也是报错是为什么？
可能kafka里面混入了脏数据，导致那一条的格式跟你其他的格式不一样。此回答整理自钉钉群”【③群】Apache Flink China社区“赞0 踩0 评论0 -
回答了问题
2023-03-07
我的richmap有600个并发度，如果同时访问hive，hive能撑住吗？
这要看你配置，但是总觉得 hive的并发支持应该不是很好 毕竟是做批处理的。此回答整理自钉钉群”【③群】Apache Flink China社区“赞0 踩0 评论0 -
回答了问题
2023-03-07
flink 消费Kafka的数据乱码，怎么解决？
大概率就是原始数据是乱码，可以从上游看看。此回答整理自钉钉群”【③群】Apache Flink China社区“赞0 踩0 评论0 -
回答了问题
2023-03-07
一直重启，是线程崩了吗？
是线程dump不是报错。此回答整理自钉钉群”【③群】Apache Flink China社区“赞0 踩0 评论0
滑动查看更多
暂无更多信息