Re:Elasticsearch source

Hi, Tauseef. Currently flink community only supports sink and look up source for ES, but you can follow this JIRA[1] that supports ES source. [1] https://issues.apache.org/jira/browse/FLINK-25568 -- Best！ Xuyang At 2023-11-15 14:33:53, "Tauseef Janvekar" wrote: Dear

Re: Elasticsearch source

Hi Tauseef, AFAIK, Flink does not support ElasticSearch as a source connector. It only supports ElasticSearch as a sink connector. Best regards, Junrui Tauseef Janvekar 于2023年11月15日周三 14:36写道： > Dear Team, > > We were looking for some elasticsearch source connector for flink and I > could not

Java 17 as default

Dear Team, I saw the documentation for 1.18 and Java 17 is not supported and the image is created from Java11. I guess there is separate docker image for java_17. When do we plan to release main image with Java 17. Thanks, Tauseef

Elasticsearch source

Dear Team, We were looking for some elasticsearch source connector for flink and I could not get any example though. Is it possible to read from elasticsearch, technically it is not streaming but somehow it should be supported as we want some transformation logic based on elastic entries. Any

Re:Flink sql 1.17.1 字段类型 DECIMAL(10, 0) 无法执行sql

Hi, 你的图挂了，可以贴一下图床链接或者直接贴一下代码。 -- Best！ Xuyang 在 2023-11-15 09:39:22，"刘聪聪" 写道： Flink 1.17.1 遇到 DECIMAL(10, 0)类型字段，直接无法运行，我用强转都不行，还是报数组越界，去除 DECIMAL(10, 0)类型字段，sql运行都正常。

Re: 关于Apache Flink源码贡献流程

hi， 你可以发给dev那个邮件列表咨询，这个邮件列表是用户交流用的开发者没那个多 Best regards, k...@jiayeli.cn tanjialiang 于 4月24日 下午4:06写道： Hello，everyone. 我想向apache flink贡献源码，由于修复这个issue需要新增一些API，按照流程需要发起邮件讨论，但这个topic只得到一名开发者关注，这样的情况下我应该如何进行后面的流程？期待有熟悉flink源码贡献的开发者可以提供帮助 issue:

Re: unsubscribe

Hi, Ralph, Please send an email to user-unsubscr...@flink.apache.org to unsubscribe the user mailing list. [1] [1] https://flink.apache.org/what-is-flink/community/ Best, Yuxin Ralph Matthias Debusmann 于2023年11月15日周三 06:18写道： > >

Re: unsubscribe

Hi, Please send email to user-unsubscr...@flink.apache.org if you want to unsubscribe the mail from user@flink.apache.org. Ralph Matthias Debusmann 于2023年11月15日周三 07:29写道： > >

Flink sql 1.17.1 字段类型 DECIMAL(10, 0) 无法执行sql

Flink 1.17.1 遇到 DECIMAL(10, 0)类型字段，直接无法运行，我用强转都不行，还是报数组越界，去除 DECIMAL(10, 0)类型字段，sql运行都正常。

unsubscribe

Re: Kafka Topic Permissions Failure

Hey Hang, We may have encountered a bug. It seems like deleting the job and redeploying "fixed" the issue. We will work on recreating this scenario and will follow-up at some point. On Mon, Nov 13, 2023 at 3:35 AM Hang Ruan wrote: > Hi, Razin. > > It seems like the issue you shared is a

Re: Apache Flink + Java 17 error module

Hi Patricia, Try to use this: --add-opens=java.base/java.util=ALL-UNNAMED --add-opens=java.base/java.lang=ALL-UNNAMED Regards, Xiangyu patricia lee 于2023年11月14日周二 15:43写道： > Hi, > > > I upgraded the project to Flink 1.18.0 and Java 17. I am also using > flink-kafka-connector 3.0.1-1.18 from

Re: dependency error with latest Kafka connector

Isn't it expected that it points to 1.17? That version of the Kafka connector is meant to be compatible with both Flink 1.17 and 1.18, right? So the older version should be specified so that the consumer can decide which Flink version to compile against, otherwise the build tool could silently

The generated schema is not correct when using filesystem connector and avro format

Hi! I'm facing an issue with the output schema for FileSystemTableSink. In FileSystemTableSink#createWriter (FileSystemTableSink.java#L29

Re: dependency error with latest Kafka connector

Hi Günterh, It looks like a problem with the Kafka connector release. https://mvnrepository.com/artifact/org.apache.flink/flink-connector-kafka/3.0.1-1.18 Compile dependencies are still pointing to Flink 1.17. Release person is already contacted about this or will be contacted soon. Best