Re:flink sink web ui显示为Sink: Unnamed

可以在算子后面调用.name()方法指定名称，方法参数就是算子名称。 比如需sink的流为stream stream.sinkTo(Sink算子).name("sink-name") -- Best， Hjw 在 2023-04-14 16:26:35，"小昌同学" 写道： >我将流式数据输出到mysql，查看flink 自带的web ui界面，有一个sink节点显示为Sink: Unnamed ，这个针对sink节点可以命名嘛 > > >| | >小昌同学 >| >| >ccc0606fight...@163.com >|

Re:Re:如何查看Flink on Native K8s模式下失败作业的日志

Hi, 不好意思，忘记补充背景了。我目前使用的都是Application模式部署。 的确如你说的Flink session模式下作业失败JM和TM是不会消失的。 -- Best， Hjw 在 2022-12-26 11:25:50，"RS" 写道： >Hi， > > >我的也是on K8S，是session模式的，得看你的模式是什么 >我的流作业失败了，配置了checkpoint，会自动重试，jm和tm都还在，可以直接看到作业异常信息。 > > >Thanks > > > >

如何查看Flink on Native K8s模式下失败作业的日志

Flink On Native K8s 模式下，如果流作业因异常失败了，作业的JobManager和TaskManager所在Pod都会消失，就无法查看作业日志。 请问在K8s模式下，在查看日志方面有没有相关解决方案。 目前我只想到将作业Jm和Tm打印的日志通过pv-pvc方式挂载NFS做持久化。这样做日志就可以保存下来方便查看。 -- Best， Hjw

Flink Kubernetes Operator何时会保留JobManager

pod。 2、直接执行kubectl delete flinkdeployment my-deployment。作业的所有关联资源全被删除，包括HA资源，状态存储信息，Deployment等。 -- Best， Hjw

Flink Kubernetes Operator何时会保留JobManager Pod

在pod。 2、直接执行kubectl delete flinkdeployment my-deployment。作业的所有关联资源全被删除，包括HA资源，状态存储信息，Deployment等。 -- Best， Hjw

Re:Re: Flink Kubernetes Operator何时会保留JobManager Pod

hi.如果是流作业呢？其实我是想在作业失败的时候能保留日志方便查看排查。 -- Best， Hjw 在 2022-11-28 15:33:37，"Biao Geng" 写道： >hi，主要就是针对作业FINISHED或者FAILED时也能保留作业。你可以跑一个批作业试试。 >Best， >Biao Geng > >获取 Outlook for iOS<https://aka.ms/o0ukef> >____ >发件人: hjw

Flink Kubernetes Operator何时会保留JobManager Pod

在pod。 2、直接执行kubectl delete flinkdeployment my-deployment。作业的所有关联资源全被删除，包括HA资源，状态存储信息，Deployment等。 -- Best， Hjw

??????k8s??????application????flink????HA??????????????

/flink-docs-release-1.15/docs/deployment/ha/kubernetes_ha/#high-availability-data-clean-up Best, Hjw   --  -- ??: "user-zh"

?????? Re: flink1.15.1 stop ????????

Kafka Connector??Api??IDEAJira https://issues.apache.org/jira/browse/FLINK-28758 --  -- ??:

Flink ????????????????Tag??????

Flink docker ??Tag?? ??1.15.1??Tag??scala_2.12-java8??scala_2.12-java11??java8?? scala??JavaFlink??java?? ??jdk11FlinkTag??java8?? thx  

Flink ????????????????Tag??????

Flink docker ??Tag?? ??1.15.1??Tag??scala_2.12-java8??scala_2.12-java11??java8?? scala??JavaFlink??java?? ??jdk11FlinkTag??java8?? thx  

Flink k8s ????????????

Flink version:1.15.0 ??1.15.0Flink??native k8s?Flink on Native k8s ??:)  

?????? Flink????????????

er-zh" https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/fault-tolerance/state/ hjw <1010445...@qq.com.invalid> ??2022??3??9?? 01:32?? > sql??SELECT color, sum(

Flink????????????

sql??SELECT color, sum(id) FROM T GROUP BY colorFlinkTgroup by key??color)??Flink???

Flink On K8s ???????? SSL????????

K8sk8s~/.kube/config.SSL??kubectl??k8s (kubectl get pod -n namespace ??)?? Flink: 1.13.6 ~/.kube/config apiVersion:v1 kind:config cluster: -name: "yf-dev-cluster1" cluster: server: "https://in-acp

Flink on Native K8s ??????????Tm??Jm????????Hosts????

Flink:1.13FlinkNative K8s jobmanager??taskmanager??hostspod-Template??jm??tm??K8spod-Template?? ??jm??tm??Hosts???