哈喽!小陈_个人页

个人头像照片 哈喽!小陈
个人头像照片
0
1934
0

个人介绍

暂无个人介绍

擅长的技术

获得更多能力
通用技术能力:

暂时未有相关通用技术能力~

云产品技术能力:

暂时未有相关云产品技术能力~

阿里云技能认证

详细说明
暂无更多信息

2023年03月

正在加载, 请稍后...
暂无更多信息
  • 提交了问题 2023-03-10

    如何介绍视觉智能开放平台人脸识别各服务API接口请求和返回示例?

  • 回答了问题 2023-03-07

    flink13 checkpoint进度卡住不动,导致超时,可以从哪里进行排查呢?

    可以用web ui看一下吧,看一下数据传输,是否是数据倾斜造成的。此回答整理自钉钉群”【③群】Apache Flink China社区“
    踩0 评论0
  • 回答了问题 2023-03-07

    请问下一个并行度占用1核吗?我并行度设置的是10,solt为5,在yarn上看,核数是11。

    你的job也要占用一个。此回答整理自钉钉群”【③群】Apache Flink China社区“
    踩0 评论0
  • 回答了问题 2023-03-07

    rocketmq-flink ,支持flink sql 方式写rocketmq时这个连接器怎么用呢?

    看这包的体积就知道是依赖类冲突, 全家桶打包不清楚里边flink打的啥版本的 都不管和集群是否冲突,依赖最小化原则。此回答整理自钉钉群”【③群】Apache Flink China社区“
    踩0 评论0
  • 回答了问题 2023-03-07

    设置rocksdb之后,checkpoint应该是增量了吗?

    不会,默认false。此回答整理自钉钉群”【③群】Apache Flink China社区“
    踩0 评论0
  • 回答了问题 2023-03-07

    这里checkpoint超时是为什么呢?

    sink并行度是1的话,写kafka会有问题的,不能命中分区写,可以按照kafka分区设置并行。此回答整理自钉钉群”【③群】Apache Flink China社区“
    踩0 评论0
  • 回答了问题 2023-03-07

    Flink CDC在支持 AWS的5.7.mysql_aurora.2.10.2 版本吗?

    2个办法试一下 此回答整理自钉钉群”【③群】Apache Flink China社区“
    踩0 评论0
  • 回答了问题 2023-03-07

    下面问题怎么处理呢?

    flink cep可以在不停任务的情况下动态修改规则:修改或者新增规则,你可以找找思路。此回答整理自钉钉群”【③群】Apache Flink China社区“
    踩0 评论0
  • 回答了问题 2023-03-07

    目前任务运行在yarn上,如果调整了flink的并行度,需要手动重启,有什么解决办法吗?

    如果用阿里云的全托管,好像是可以动态调整的。不过应该还是先savepoint,然后根据新参数重启,只是给你封装好了。此回答整理自钉钉群”【③群】Apache Flink China社区“
    踩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
  • 回答了问题 2023-03-07

    全局并行度3,执行sql只能1是吗?

    检查一下是不是sink 算子 单独设置了。此回答整理自钉钉群”【③群】Apache Flink China社区“
    踩0 评论0
  • 回答了问题 2023-03-07

    代码只有一次,但是同一条数据用了两次udf函数是为什么?

    不要create view as的语法,把两个sql合并在一起。如果要debug排查,改写成table api排查问题(只调用udf函数)。此回答整理自钉钉群”【③群】Apache Flink China社区“
    踩0 评论0
  • 回答了问题 2023-03-07

    web-ui 加载会非常慢是什么原因呢?

    建议改conf目录的配置文件试试。此回答整理自钉钉群”【③群】Apache Flink China社区“
    踩0 评论0
  • 回答了问题 2023-03-07

    如果用dataStream 怎么反序列化 avro的数据呀?

    代码里指定org.apache.kafka.common.serialization.StringDeserializer反序列化。此回答整理自钉钉群”【③群】Apache Flink China社区“
    踩0 评论0
  • 回答了问题 2023-03-07

    通过flink sql 消费这个avro后的数据改了半天 又报了这个错误是什么原因啊?

    可以尝试排查一下有没有脏数据或者数据不规则,或者格式、序列化的问题。此回答整理自钉钉群”【③群】Apache Flink China社区“
    踩0 评论0
  • 回答了问题 2023-03-07

    这种情况是什么原因啊?

    建议考虑一下是不是某一个源很长时间没有数据来,另外一个源数据来了,由于是barra 对齐,多以在join 的时候,等待barria 超时了。此回答整理自钉钉群”【③群】Apache Flink China社区“
    踩0 评论0
  • 回答了问题 2023-03-07

    这个用flink sql 读取也是报错是为什么?

    可能kafka里面混入了脏数据,导致那一条的格式跟你其他的格式不一样。此回答整理自钉钉群”【③群】Apache Flink China社区“
    踩0 评论0
  • 回答了问题 2023-03-07

    我的richmap有600个并发度,如果同时访问hive,hive能撑住吗?

    这要看你配置,但是总觉得 hive的并发支持应该不是很好 毕竟是做批处理的。此回答整理自钉钉群”【③群】Apache Flink China社区“
    踩0 评论0
  • 回答了问题 2023-03-07

    flink 消费Kafka的数据乱码,怎么解决?

    大概率就是原始数据是乱码,可以从上游看看。此回答整理自钉钉群”【③群】Apache Flink China社区“
    踩0 评论0
  • 回答了问题 2023-03-07

    一直重启,是线程崩了吗?

    是线程dump不是报错。此回答整理自钉钉群”【③群】Apache Flink China社区“
    踩0 评论0
正在加载, 请稍后...
滑动查看更多
正在加载, 请稍后...
暂无更多信息