Re: [EXTERNAL] - Re: Discussion on Vertica-Flink Connector

2024-08-22 Thread Vikas Garg
Hello Ahmed, I have already addressed his concern, attaching the screenshot. We are using all the functionalities of Vertica in the named connector which are not available in generic connector. [cid:f8115540-bfc2-4932-b1f0-fd4e95235524] Vikas Garg General Engineering | General Engineering

[jira] [Created] (FLINK-36142) Remove TestTableSourceWithTime and its subclasses to prepare to remove TableEnvironmentInternal#registerTableSourceInternal

2024-08-22 Thread xuyang (Jira)
xuyang created FLINK-36142: -- Summary: Remove TestTableSourceWithTime and its subclasses to prepare to remove TableEnvironmentInternal#registerTableSourceInternal Key: FLINK-36142 URL: https://issues.apache.org/jira/brows

[jira] [Created] (FLINK-36141) Set the scanNewlyAddedTableEnabled is true, but does not support automatic identification new table

2024-08-22 Thread zhongyuandong (Jira)
zhongyuandong created FLINK-36141: - Summary: Set the scanNewlyAddedTableEnabled is true, but does not support automatic identification new table Key: FLINK-36141 URL: https://issues.apache.org/jira/browse/FLINK-36

[jira] [Created] (FLINK-36140) Log a warning when pods are terminated by kubernetes

2024-08-22 Thread Clara Xiong (Jira)
Clara Xiong created FLINK-36140: --- Summary: Log a warning when pods are terminated by kubernetes Key: FLINK-36140 URL: https://issues.apache.org/jira/browse/FLINK-36140 Project: Flink Issue Type

[jira] [Created] (FLINK-36139) ClassCastException when checkpointing AggregateFunction

2024-08-22 Thread Vladislav Keda (Jira)
Vladislav Keda created FLINK-36139: -- Summary: ClassCastException when checkpointing AggregateFunction Key: FLINK-36139 URL: https://issues.apache.org/jira/browse/FLINK-36139 Project: Flink I

Re: Flink CDC insert-only changelog mode

2024-08-22 Thread Daniel Henneberger
Unfortunately no, this would not be helpful. The changelog type needs to be insert-only to invoke the correct streaming planner rules. On Wed, Aug 21, 2024 at 9:01 PM Hongshun Wang wrote: > Hi Daniel, > > > > There's no way to convert a different changelog stream to an insertonly > > stream so

[jira] [Created] (FLINK-36138) KinesisStreamsSource.buil() should have helpful null errors

2024-08-22 Thread Jira
Jörn Kottmann created FLINK-36138: - Summary: KinesisStreamsSource.buil() should have helpful null errors Key: FLINK-36138 URL: https://issues.apache.org/jira/browse/FLINK-36138 Project: Flink

[jira] [Created] (FLINK-36137) Missing JarURI leads to null pointer in reconciler

2024-08-22 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-36137: -- Summary: Missing JarURI leads to null pointer in reconciler Key: FLINK-36137 URL: https://issues.apache.org/jira/browse/FLINK-36137 Project: Flink Issue Type: Bu

Re: [jira](FLINK-36127) Apply for a jira account and repair bug

2024-08-22 Thread Leonard Xu
Welcome Yuming to join the Flink Community! Your Jira account has been created and I’ve assigned ticket FLINK-36127 to you. Best, Leonard > 2024年8月22日 下午8:14,Yu Chen 写道: > > Hi Yunming, > > Thanks for help to resolve the ticket FLINK-36127, and welcome to join flink > community. > > I notic

Re: [jira](FLINK-36127) Apply for a jira account and repair bug

2024-08-22 Thread Yu Chen
Hi Yunming, Thanks for help to resolve the ticket FLINK-36127, and welcome to join flink community. I noticed that Leonard was processing request recently, and cc’ed. Best, Yu Chen. > 2024年8月22日 20:01,Yunming Tang 写道: > > Dear committers, > I'm willing to repair the bug of FLINK-36127 and

[jira](FLINK-36127) Apply for a jira account and repair bug

2024-08-22 Thread Yunming Tang
Dear committers, I'm willing to repair the bug of FLINK-36127 and I've requested a jira account while it's under processing. My email is yunming.e...@gmail.com, could you please help approve the request? Best regards, Yunming

Re: [jira](FLINK-35444) Apply for a jira account and repair bug

2024-08-22 Thread Kaiyuan Zheng
Copy that! I've logged into jira and left a comment for FLINK-35444, please assign this issue to me. Many thanks! Leonard Xu 于2024年8月22日周四 17:43写道: > Welcome @kyzheng for joining Flink Community, I just processed jira > account pending requests these days, hope your jira account have been > cre

[jira] [Created] (FLINK-36136) Remove TableSource & TableSink impl and utils, docs and etc.

2024-08-22 Thread xuyang (Jira)
xuyang created FLINK-36136: -- Summary: Remove TableSource & TableSink impl and utils, docs and etc. Key: FLINK-36136 URL: https://issues.apache.org/jira/browse/FLINK-36136 Project: Flink Issue Type:

[jira] [Created] (FLINK-36135) Remove the TableSource and TableSink ecosystem APIs like TableFactory, DefinedFieldMapping, FilterableTableSource, etc.

2024-08-22 Thread xuyang (Jira)
xuyang created FLINK-36135: -- Summary: Remove the TableSource and TableSink ecosystem APIs like TableFactory, DefinedFieldMapping, FilterableTableSource, etc. Key: FLINK-36135 URL: https://issues.apache.org/jira/browse/FL

[jira] [Created] (FLINK-36133) Remove subclass implementations of TableSource and TableSink, along with their corresponding Factory classes.

2024-08-22 Thread xuyang (Jira)
xuyang created FLINK-36133: -- Summary: Remove subclass implementations of TableSource and TableSink, along with their corresponding Factory classes. Key: FLINK-36133 URL: https://issues.apache.org/jira/browse/FLINK-36133

[jira] [Created] (FLINK-36134) Remove the classes associated with TableSource and TableSink as part of the optimization process.

2024-08-22 Thread xuyang (Jira)
xuyang created FLINK-36134: -- Summary: Remove the classes associated with TableSource and TableSink as part of the optimization process. Key: FLINK-36134 URL: https://issues.apache.org/jira/browse/FLINK-36134

[jira] [Created] (FLINK-36132) Remove codes that references TableSource and TableSink directly at the API level.

2024-08-22 Thread xuyang (Jira)
xuyang created FLINK-36132: -- Summary: Remove codes that references TableSource and TableSink directly at the API level. Key: FLINK-36132 URL: https://issues.apache.org/jira/browse/FLINK-36132 Project: Flink

Re: [jira](FLINK-35444) Apply for a jira account and repair bug

2024-08-22 Thread Leonard Xu
Welcome @kyzheng for joining Flink Community, I just processed jira account pending requests these days, hope your jira account have been created. I’m not sure the result because the jira account request doesn’t contains applier’s email address, feel free to ping me if your account still not rea

[jira] [Created] (FLINK-36131) FlinkSQL upgraded from 1.13.1 to 1.18.1 metrics does not display data

2024-08-22 Thread mumu (Jira)
mumu created FLINK-36131: Summary: FlinkSQL upgraded from 1.13.1 to 1.18.1 metrics does not display data Key: FLINK-36131 URL: https://issues.apache.org/jira/browse/FLINK-36131 Project: Flink Issue

[jira] [Created] (FLINK-36130) flink cdc submit yaml task

2024-08-22 Thread zzm (Jira)
zzm created FLINK-36130: --- Summary: flink cdc submit yaml task Key: FLINK-36130 URL: https://issues.apache.org/jira/browse/FLINK-36130 Project: Flink Issue Type: Improvement Reporter: zzm

Re: [jira](FLINK-35444) Apply for a jira account and repair bug

2024-08-22 Thread Gabor Somogyi
Hi, I think you can file PR wihout jira access. Once the PR is there we can handle the rest. Please read through the contribution guide [1], which can give you good corner points. [1] https://flink.apache.org/how-to-contribute/contribute-code/ BR, G On Thu, Aug 22, 2024 at 10:06 AM 郑恺原 wrote:

[jira](FLINK-35444) Apply for a jira account and repair bug

2024-08-22 Thread 郑恺原
Dear committers, I'm willing to repair the bug of FLINK-35444 and I've requested a jira account several days ago, while it's still under processing. My email is kyzheng...@163.com, could you help to approve this request? Many thanks!

Issue with table.optimizer.join-reorder-enabled and lookup join

2024-08-22 Thread Tamas Sule
Hello, I ran into an issue where if `table.optimizer.join-reorder-enabled` is set to true and I execute a lookup join query the following error is shown: ``` Exception in thread "main" org.apache.flink.table.api.TableException: Cannot generate a valid execution plan for the given query: FlinkLog