实时计算 Flink版
-
请教下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…
-
跨云公网传输,大家基于flink有无比较好的数据安全方案?-[阿里云_云淘科技]
跨云公网传输,大家基于flink有无比较好的数据安全方案? 以下为热心网友提供的参考意见 对于基于Flink的数据跨云公网传输,以下是一些数据安全措施: a. 加密传输:确保在公网…
-
Flink 双流union,故障恢复后,一条流没有数据的情况下,有知道这个怎么解决吗?-[阿里云_云淘科技]
Flink 双流union,故障恢复后,一条流没有数据的情况下,watermark不生成,有小伙伴知道这个怎么解决吗? 以下为热心网友提供的参考意见 当Flink双流union中的…
-
Flink withIdleness 如果一直没有数据进入会触发吗?-[阿里云_云淘科技]
Flink withIdleness 如果一直没有数据进入会触发吗? 以下为热心网友提供的参考意见 在Flink中,存在一种被称为空闲窗口的现象。这通常发生在多并行处理时,如果有一…
-
有人遇到flink打不开web界面吗?-[阿里云_云淘科技]
有人遇到flink打不开web界面吗?我打开是白色页面,什么也没有 以下为热心网友提供的参考意见 如果你在打开Flink的Web界面时遇到白色页面,可能的原因和解决方案如下: 检查…
-
Flink进行keyby以后,每个流的状态和定时器是独立的,还是共享同一个状态和定时器?-[阿里云_云淘科技]
Flink进行keyby以后,每个流的状态和定时器是独立的,还是共享同一个状态和定时器? 以下为热心网友提供的参考意见 在Apache Flink中,KeyBy算子是一种根据指定K…