回复：打印不同流怎么进行区分

Hi Print 方法是可以传入一个参数的，用来标识某个流，比如 print(“a”); print(“b"); Best JasonLee 回复的原邮件 | 发件人 | 小昌同学 | | 发送日期 | 2023年04月14日 09:46 | | 收件人 | user-zh | | 主题 | 打印不同流怎么进行区分 | 你好，请问一下再一个程序中，有流与流之间的转换，比如说流A转换为流B，那我想看看流A，也想看看流B，请问我该怎么实现，直接print的话，再控制面板会乱掉 | | 小昌同学 | | ccc0606fight...@163.com |

打印不同流怎么进行区分

你好，请问一下再一个程序中，有流与流之间的转换，比如说流A转换为流B，那我想看看流A，也想看看流B，请问我该怎么实现，直接print的话，再控制面板会乱掉 | | 小昌同学 | | ccc0606fight...@163.com |

Re: 退订

退订请发送任意邮件到 user-zh-unsubscr...@flink.apache.org ，可以参考[1] [1] https://flink.apache.org/community.html#how-to-subscribe-to-a-mailing-list On Thu, Apr 13, 2023 at 9:53 PM lei-tian wrote: > 退订 > > > > | | > totorobabyf...@163.com > | > | > 邮箱：totorobabyf...@163.com > |

Re: Elasticsearch Connector 1.17 not on maven central.

Hi Ruibin I checked the maven central repository and found that there are no versions 3.0.0-1.17 of flink-connector-elasticsearch6 and flink-connector- elasticsearch7 available in https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/connectors/datastream/elasticsearch/. I have created

Re: Queries/Help regarding limitations on File source

Hi Kirti For the watermark problem, I think the description in the document mainly refers to the out-of-order data between multiple files. This will result in a large number of late events [1], which will generate a large number of retract events, and late events out of time will be discarded.

退订

退订 | | totorobabyf...@163.com | | 邮箱：totorobabyf...@163.com |

[Discussion] - Take findify/flink-scala-api under Flink umbrella

Hello Flink PMCs and Flink Scala Users, I would like to propose an idea to take the 3rd party Scala API findify/flink-scala-api project into the Apache Flink organization. *Motivation * The Scala-free Flink idea was finally implemented by the 1.15

Queries/Help regarding limitations on File source

Hi, I am using Data stream file source connector in one of my use case. I was going through the documentation where I found below limitations: https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/datastream/filesystem/#current-limitations 1. Watermarking does not work very

Elasticsearch Connector 1.17 not on maven central.

Hi community, When following the instructions for importing es connector into my project on https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/connectors/datastream/elasticsearch/, maven can't find the required version: > > org.apache.flink > flink-connector-elasticsearch7 >

ogg json格式不支持database include和table include参数

多张oracle表变更同步到同一个kafka topic，现在实时flinlk作业需要消费其中一张oracle表，查了一下没看到类似canal json格式中 canal-json.database.include 和 canal-json.table.include 参数，只在available metadata中看到 table 字段，这意味着我需要在select语句中按table字段进行过滤吗？ [1]

Re: Flink Job across Data Centers

Hi, Chirag, I am not sure whether this FLIP-268[1] is what you want. Best, Hang [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-268%3A+Kafka+Rack+Awareness Andrew Otto 于2023年4月12日周三 22:12写道： > Hi, I asked a similar question in this thread >

Re: Flink job manager conditional start of flink jobs

Hi, nage, I agree to the Shammon's suggestion after reading the context. Maybe you need a 'Job Management Service' to manage all jobs among different namespaces. I think the job management is not suitable for implementation in the Flink engine. Best, Hang Shammon FY 于2023年4月13日周四 11:34写道： >

Certificate renewal for Flink Kafka connectors

Hi, I am using Flink Kafka connectors to communicate with Kafka broker over mutual TLS. Is there any way or recommendation to handle certificate renewal for these Kafka clients. I am monitoring the pem files and recreating the keystore/truststore(jks) on renewal, but how can I reload these to

转发:

发件人: Henry meng (孟令平) 发送时间: 2023年4月13日 15:27 收件人: 'user-zh-i...@flink.apache.org' 主题: public static void main(String[] args) throws Exception { StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); //env.enableCheckpointing(6);