备案控制台

我很饿很薄啊_个人页

个人头像照片 我很饿很薄啊
个人头像照片
文章
0
问答
292
视频
0

个人介绍

暂无个人介绍

擅长的技术

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

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

云产品技术能力：

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

阿里云技能认证

详细说明
暂无更多信息

2024年07月

正在加载, 请稍后...
暂无更多信息
  • 回答了问题 2024-07-02

    MaxCompute怎样查看执行 odps任务所在机器的公网ip出口 ？

    公有云看不了，限制访问ip，只允许执行odps任务的机器访问。此回答整理自钉群“MaxCompute开发者社区1群”

    踩0 评论0
  • 回答了问题 2024-07-02

    大数据计算MaxComputer中dataworks 里面的参数调度中括号和花括号有什么区别吗 ？

    取N年前、N月前的时间数据需使用${…}参数。取N小时前、N分钟前的时间数据需使用$[…]参数此回答整理自钉群“MaxCompute开发者社区1群”

    踩0 评论0
  • 回答了问题 2024-07-02

    对于Flink CDC，MySQL TimeStamp不都带时区吗？

    有timestamp without time zone-此回答整理自钉群“Flink CDC 社区”

    踩0 评论0
  • 回答了问题 2024-07-02

    对于Flink CDC, MySQL的DATETIME的name是io.debezium.time?

    TimeStamp对应的应该是io.debezium.time.ZonedTimestamp-此回答整理自钉群“Flink CDC 社区”

    踩0 评论0
  • 回答了问题 2024-07-02

    对于Flink CDC，datetime和timestamp不带时区的name是不是一样的？

    io.debezium.time.ZonedTimestamp -> Timestamp，io.debezium.time.Timestamp -> DATETIME，io.debezium.time.MicroTimestamp -> DATETIME timeStamp和datetime的映射是不一样的，datetime和datetime(6)的映射也是不一样的，处理逻辑不同-此回答整理自钉群“Flink CDC 社区”

    踩0 评论0
  • 回答了问题 2024-07-02

    对于Flink CDC，schema中fields的name是指字段名字吗？

    name应该就是文档的Semantic type-此回答整理自钉群“Flink CDC 社区”

    踩0 评论0
  • 回答了问题 2024-07-02

    对于Flink CDC，timestamp的长度是19或21？

    iwEdAqNwbmcDAQTRA6YF0QEwBrB_Qm7rhPA1gQZncg7LZo0AB9ICJ4RYCAAJomltCgAL0gAA0_E.png_720x720q90.jpg-此回答整理自钉群“Flink CDC 社区”

    踩0 评论0
  • 回答了问题 2024-07-02

    对于Flink CDC，怎么在解析binlog的时候判断是datetime类型，然后减8小时给它？

    判断长度等于19或者21 即为datetime类型用new JsonDebeziumDeserializationSchema(true)，根据schema中fields的name确认的-此回答整理自钉群“Flink CDC 社区”

    踩0 评论0
  • 回答了问题 2024-07-02

    对于Flink CDC，在哪里-8？

    上边那段文字解释了，转成时间戳的时候时区变成UTC了，所以就会加8小时-此回答整理自钉群“Flink CDC 社区”

    踩0 评论0
  • 回答了问题 2024-07-02

    对于Flink CDC，这个问题怎么解？

    应该是时区的问题，解析之前先加-8-此回答整理自钉群“Flink CDC 社区”

    踩0 评论0
  • 回答了问题 2024-07-02

    咨询一个flink mysql cdc的问题，一个表的字段a在建表的时候设置的默认值是1？

    这个可能和cdc的解析有关。-此回答整理自钉群“Flink CDC 社区”

    踩0 评论0
  • 回答了问题 2024-07-02

    对于Flink CDC，这个tables支持多张表吗 ？

    支持。-此回答整理自钉群“Flink CDC 社区”

    踩0 评论0
  • 回答了问题 2024-07-02

    FlinkCDC对于删除数据，flink前面对加-D,+U，-U等状态，我这边可以拿到写库？

    有before数据 https://debezium.io/documentation/reference/1.9/connectors/mysql.html#mysql-connector-properties -此回答整理自钉群“Flink CDC 社区”

    踩0 评论0
  • 回答了问题 2024-07-02

    有没有办法用flinksql同步cdc数据的时候获取到数据的操作类型，比如是新增或者是修改这种?

    iwEeAqNwbmcDAQTRB0AF0QVKBrBg48gQ4gurVQZmaozfNTwAB9Ih_TPCCAAJomltCgAL0gAElhk.png_720x720q90.jpg-此回答整理自钉群“Flink CDC 社区”

    踩0 评论0
  • 回答了问题 2024-07-02

    flink cdc 读取mysql 。我们希望拿到增和删，改的数据都拿到。存到odps中。可以做嘛？

    可以-此回答整理自钉群“Flink CDC 社区”

    踩0 评论0
  • 回答了问题 2024-07-02

    用FlinkCDC 做MySQL数据同步速度不高，观察日志发现耗时在了Finished？

    增加了些日志点位，应该是Json序列化把CPU打满了搞个火焰图 分析一下就可以了-此回答整理自钉群“Flink CDC 社区”

    踩0 评论0
  • 回答了问题 2024-07-02

    对于Flink CDC，主流的都是有哪些，能给两个参考下吗？

    stream park dinky-此回答整理自钉群“Flink CDC 社区”

    踩0 评论0
  • 回答了问题 2024-07-02

    CDC是不是，我要先把数据提取到kafka，然后再去分析处理？不是每个脚本都去cdc一次？

    可以，也可以整库同步-此回答整理自钉群“Flink CDC 社区”

    踩0 评论0
  • 回答了问题 2024-07-02

    对于Flink CDC，为什么flink的managed memory都满了？

    Managed Memory保存的是中间处理数据，例如序缓冲区、连接操作的哈希表等中间结果数据。checkpoint是实现容错机制，定期保存任务的状态快照和进度等关键信息。
    很多计算可以基于保存的状态从原始数据重新计算中间结果，因此checkpoint无需保存Managed Memory中的每个中间结果数据，所以就会少。-此回答整理自钉群“Flink CDC 社区”

    踩0 评论0
  • 回答了问题 2024-07-02

    对于Flink CDC，发现3.1.1中没有相关的类了，请问需要下载哪个jar包？

    3.01 之后的版本 包名改为 org.apache 了-此回答整理自钉群“Flink CDC 社区”

    踩0 评论0
正在加载, 请稍后...
滑动查看更多
正在加载, 请稍后...
暂无更多信息