流计算
-
guava包的问题-[阿里云_云淘科技]
在解决Flink1.13.3和FlinkCDC2.4.1的guava冲突时,将Flink中的guava排除,加上30.1.1-jre-16.0报org.apache.flink.s…
-
flink cdc mysql 表数据 sink 到elasticsearch -[阿里云_云淘科技]
当sink到elasticsearch 时,可以指定es的指定字段吗?比如es索引有 10个字段,我只需要插入或者更新 其中5个字段,当更新时,不会影响其他5个字段的原来的值! 以…
-
有知道在使用flink cdc实现数据同步,如何实现如果服务停止了对数据源表的某个数据进行删除操作?-[阿里云_云淘科技]
有大佬知道在使用flink cdc实现数据同步,如何实现如果服务停止了对数据源表的某个数据进行删除操作,重启服务之后目标表能进行对源表删除的数据进行删除吗? 以下为热心网友提供的参…
-
请问在flink同步数据到doris的任务中,在继续同步后再次点击下线无法下线的问题有办法解决吗?-[阿里云_云淘科技]
请问在flink同步数据到doris的任务中,任务上线后第一次下线可以正常产生savepoint并且可以从savepoint开始继续同步,但是在继续同步后再次点击下线无法下线的问题…
-
请问一下Flink怎么给join设置parallelism?-[阿里云_云淘科技]
请问一下Flink怎么给join设置parallelism? 以下为热心网友提供的参考意见 在Flink中,可以通过设置ExecutionConfig的parallelism属性来…
-
请教下Flink,一直有个问题,代码打包好后在客户端是怎么提交到JOBMANAGER上去的?-[阿里云_云淘科技]
请教下Flink,一直有个问题,FLINK的CLIENT提交任务到JOBMANAGER上,那客户端是一台独立机器,JOBMANAGER在另外一台机器上,代码打包好后在客户端是怎么提…
-
Flink 有没有和 session 模式通过-C 指定额外的 jar 的相同功能啊?-[阿里云_云淘科技]
Flink application on k8s 有没有和 session 模式通过-C 指定额外的 jar 的相同功能啊? 以下为热心网友提供的参考意见 Flink在Kubern…
-
flink的 设置的关联区间是基于watermark的 而不是事件时间是吗?-[阿里云_云淘科技]
flink的 interval join 设置的关联区间是基于watermark的 而不是事件时间是吗? 以下为热心网友提供的参考意见 Flink的Interval Join关联区…
-
有知道使用flink cdc 重启服务之后目标数据库不会进行删除是什么原因吗?-[阿里云_云淘科技]
有大佬知道使用flink cdc 在服务启动时候进行增删除操作都是可以的,但在服务关闭后对源数据库进行删除操作,重启服务之后目标数据库不会进行删除是什么原因吗? 以下为热心网友提供…
-
Flink设置之后报错:仅能绑定要插入 LONG 列的 LONG 值 主键必须是数字类型吗?-[阿里云_云淘科技]
Flink设置之后报错:java.sql.BatchUpdateException: ORA-01461: 仅能绑定要插入 LONG 列的 LONG 值 主键必须是数字类型吗? 以…
-
谁有flink+prometheus对于每个flink job失败或异常进行告警的rule配置?-[阿里云_云淘科技]
谁有flink+prometheus对于每个flink job失败或异常进行告警的rule配置? 以下为热心网友提供的参考意见 要实现Flink job失败或异常的告警,首先需要确…
-
请问flink 如何监听任何job失败则告警并输出jobid?-[阿里云_云淘科技]
请问flink push Prometheus PushGateway 有多个job,如何监听任何job失败则告警并输出jobid? 以下为热心网友提供的参考意见 要监听Flink…