流计算
-
提交 flink 任务给 k8s 可以在本地推送到服务器吗 ?-[阿里云_云淘科技]
提交 flink 任务给 k8s 可以在本地推送到服务器吗 ?还是一定要在服务器操作 以下为热心网友提供的参考意见 k8s server flink-kubernetes-oper…
-
请问下大家有用过flink on k8s吗?-[阿里云_云淘科技]
请问下大家有用过flink on k8s吗?我在kubernetes application模式下运行,运行一段时间后就会出现这个报错,然后jobmanager就重启了Except…
-
flink sql执行的时候,如果不用实体对象去封装有什么解决办法吗?-[阿里云_云淘科技]
flink sql执行的时候,接收到上游的datastream数据对象是用map封装的,然后执行时报错:Column ‘o7’ not found in a…
-
为什么flink提供的demo代码都执行不了?-[阿里云_云淘科技]
为什么flink提供的demo代码都执行不了?Caused by: org.apache.flink.table.api.TableException: Failed to exe…
-
在一个flink任务中需要近1小时和近6小时的特征,这种在生产上一般用事件时间还是处理时间?-[阿里云_云淘科技]
在一个flink任务中需要近1小时和近6小时的特征,这种在生产上一般用事件时间还是处理时间?如果用事件事件窗口可能不关闭怎么办? 以下为热心网友提供的参考意见 楼主你好,在一个阿里…
-
请问Flink这个AI 说的 每个key状态 和每个并行度的状态 怎么测试区分?-[阿里云_云淘科技]
请问Flink这个AI 说的 每个key状态 和每个并行度的状态 怎么测试区分? 以下为热心网友提供的参考意见 楼主你好,在阿里云Flink中,”每个key状态R…
-
问一下,我保存了savepoint并关掉了任务,现在想启动任务,应该如何做呀?-[阿里云_云淘科技]
问一下,我保存了savepoint并关掉了任务,现在想启动任务,应该如何做呀?使用背景是将pyflink的任务提交到k8s上运行。保存savepoint并关闭任务的语句如下:bin…
-
Flink这个状态是全局的还是 每个并行度一份呀?-[阿里云_云淘科技]
Flink这个状态是全局的还是 每个并行度一份呀? 以下为热心网友提供的参考意见 楼主你好,据我所知,在阿里云Flink中,存储在状态中的数据可以是全局的或者每个并行度一份,这取决…
-
Flink有没有就是用sqlclient提交到yarnperjob模式后。有没有人遇到这个问题?-[阿里云_云淘科技]
Flink有没有就是用sqlclient提交到yarnperjob模式后。web界面上拿不到日志,有没有人遇到这个问题,求大佬解决? 以下为热心网友提供的参考意见 是这样的,Fli…
-
Flink 1.18 sql客户端启动异常,大家知道怎么处理吗?-[阿里云_云淘科技]
Flink 1.18 sql客户端启动异常,大家知道怎么处理? 以下为热心网友提供的参考意见 Flink SQL 客户端启动异常,可能有以下几个原因: JDK 版本不兼容。Flin…
-
想对Flink提交到k8s上的任务进行savepoint保存。报超时的错误,如下图。请问如何解决呀?-[阿里云_云淘科技]
想对Flink提交到k8s上的任务进行savepoint保存。报超时的错误,如下图。请问如何解决呀?运行语句是: ./bin/flink stop –savepoint…
-
有遇到flink 1.18清空表数据遇到异常的嘛?-[阿里云_云淘科技]
有遇到flink 1.18清空表数据遇到异常的嘛,官网这段没看明白,执行truncate前需要执行什么操作嘛? 以下为热心网友提供的参考意见 Flink 1.18 清空表数据遇到异…