流计算

flink有没得重启flink 的时候提交的任务也一起重启了，现在是里面有好几个人任务，停电服务器停止了，然后自动启动flink,但是提交的任务每的了？ 以下为热心网友提供的参考意…

flink 1.15.4 /tmp目录，看每天都会生成10多个flink-table-planner_xxx.jar，这个是什么情况呢？ 以下为热心网友提供的参考意见 这个现象可能…

spark和flink sql取hash的函数是什么啊？需要取完的值是一样的，这个自带的函数有吗，哪位大佬知道啊？ 以下为热心网友提供的参考意见 在Spark和Flink SQL中…

flink sink websocket 需要哪个依赖？ 以下为热心网友提供的参考意见 要在Flink中使用WebSocket Sink，你需要依赖flink-streaming-…

Flink在 https://mvnrepository.com/ 上没有搜到， 有测试过 sink 到 websocket 的吗？ 以下为热心网友提供的参考意见 是的，Flink…

Flink中kafka总共有16266条数据, 但是消费到6144就停止并报这两条日志了？ 以下为热心网友提供的参考意见 从你给出的日志来看，问题是关于Kafka消费者未能获取足够…

Flink重新发任务，怎么从上一个checkpoint点位启动？ 以下为热心网友提供的参考意见 在Flink中，如果需要从上一个checkpoint点位重新启动任务，可以使用fli…

Flink中appliction 模式怎么从 checkpoint 保存的地方 启动？ 以下为热心网友提供的参考意见 在Flink中，应用程序模式（Application Mode…

经测试，相同连接配置和依赖的情况下，读取mongodb同一库下面不同集合，集合命名是’abc’,’abc_def’这种的读取没有问题…

机器学习PAI flink运行一段时间后jobManager里经常会报Connection reset by peer这个错是什么原因？ 以下为热心网友提供的参考意见 由于您没有提…

Flink 集群重启后，所有的Jobs任务全都没有了。大家有没有好的办法快速恢复。 因为我配置了几十个任务，如果重启后任务没有了，我得输入命令【建表语句，同步语句】操作几十次，工作…

Flink SQL中有没有行转列的函数？ 以下为热心网友提供的参考意见 在Flink SQL中，你可以使用内置的聚合函数GROUP_CONCAT来实现行转列的功能。这个函数会将输入…