阿里云
-
flinkcdc读取mysql的启动模式是不是不支持timestamp模式?-[阿里云_云淘科技]
flinkcdc读取mysql的启动模式是不是不支持timestamp模式? 以下为热心网友提供的参考意见 是2.3還是2.4以上已經支持了 ,此回答整理自钉群“【③群】Apach…
-
把mysql-cdc的jar挂到/opt/flink/lib目录下提示找不到该连接器?-[阿里云_云淘科技]
把mysql-cdc的jar挂到/opt/flink/lib目录下了。但是启动sql-client时,提示找不到该连接器? 以下为热心网友提供的参考意见 如果您将mysql-cdc…
-
请教一下怎么用flinksql 写一个连接带有kerberos 认证的 hive 的catalog?-[阿里云_云淘科技]
请教一下怎么用flinksql 写一个连接带有kerberos 认证的 hive 的catalog? 以下为热心网友提供的参考意见 flink必须写到配置文件里,kerberos配…
-
Flink1.18.0 拿rancher k8s部署 taskmanager报连不上见过这种情况吗?-[阿里云_云淘科技]
Flink1.18.0 拿rancher k8s部署 taskmanager报连不上taskmanager 然后一直重启,大家有见过这种情况吗? 以下为热心网友提供的参考意见 你看…
-
coordinate字段 是point类型 flink不支持怎么办 ? -[阿里云_云淘科技]
coordinate字段 是point类型 flink不支持怎么办 ? 我在flinksql改成string的话 写入时报错 以下为热心网友提供的参考意见 如果Flink不支持co…
-
请教一个flink-stream 的问题,在自定义sink中如何读取该广播流 的数据?-[阿里云_云淘科技]
请教一个flink-stream 的问题,在作业中我定义了一个 广播流,将该广播流将一些配置信息动态广播到下游算子中,也实现了BroadcastProcessFunction 类,…
-
Flink凌晨的时候有些tm重启是什么原因?-[阿里云_云淘科技]
Flink凌晨的时候有些tm重启是什么原因? 以下为热心网友提供的参考意见 Apache Flink 提供了一种机制允许 TaskManager 自动检测故障情况并在必要时重新启动…
-
怎么查看flink任务cpu的使用率?-[阿里云_云淘科技]
怎么查看flink任务cpu的使用率? 以下为热心网友提供的参考意见 拿不到的,只能拿到机器的接了prometheus也拿不到cpu使用率,所以你只能拿机器的cpu使用率 ,此回答…
-
Flink如果有两条流join,两条流的可变化时间周期跨度很大,这种场景应该怎么解决?-[阿里云_云淘科技]
Flink如果有两条流join,两条流的可变化时间周期跨度很大,这种场景应该怎么解决? 以下为热心网友提供的参考意见 云上有双流不同ttl可以解一下state太大的问题 ,此回答整…
-
有没部署过flink sql gateway的呀?一直报错?-[阿里云_云淘科技]
有没部署过flink sql gateway的呀?一直报错 org.apache.thrift.protocol.TProtocolException: Missing versi…
-
为什么我用Flink docker-compose up -d 这个配置文件就会变成root ?-[阿里云_云淘科技]
为什么我用Flink docker-compose up -d 这个配置文件就会变成root 了 是怎么回事啊? 以下为热心网友提供的参考意见 当你使用docker-compose…
-
如果Flink能知道配置一个slot的cpu使用率,比如20%。那么配置2个slot可能就是40%?-[阿里云_云淘科技]
如果Flink能知道配置一个slot的cpu使用率,比如20%。那么配置2个slot可能就是40% 可以这么想吗? 以下为热心网友提供的参考意见 是的,你的理解是正确的。在Flin…