[jira] [Created] (FLINK-25375) Update Log4j to 2.17.0

Sergey Nuyanzin created FLINK-25375: --- Summary: Update Log4j to 2.17.0 Key: FLINK-25375 URL: https://issues.apache.org/jira/browse/FLINK-25375 Project: Flink Issue Type: Technical Debt A

Sending watermarks into Kafka

Hi, About a year ago I spoke at the Flink Forward conference ( https://www.youtube.com/watch?v=wqRDyrE3dwg ) about handling development problems regarding streaming applications and handling the lack of events in a stream. Something I spoke about towards the end of this talk was the idea to ship t

Re: [DISCUSS] FLIP-200: Support Multiple Rule and Dynamic Rule Changing (Flink CEP)

Hi Yue, Thanks a lot for your suggestions for this FLIP. 1. PatternProcessorDiscoverer is just an interface, which could have implementations that satisfy different expectations. The example implementation proposed in the FLIP would periodically check a database for updates, but another possible

Re: [DISCUSS] FLIP-200: Support Multiple Rule and Dynamic Rule Changing (Flink CEP)

Hi Yue, Thanks for your feedback of the FLIP. I have addressed your questions and made a corresponding explanation as follows: -- About Pattern Updating. If we use PatternProcessoerDiscoverer to update the rules, will it increase the load of JM? For example, if the user wants the updated rule

[jira] [Created] (FLINK-25376) Too many JM logs in flink session cluster for olap queries

Shammon created FLINK-25376: --- Summary: Too many JM logs in flink session cluster for olap queries Key: FLINK-25376 URL: https://issues.apache.org/jira/browse/FLINK-25376 Project: Flink Issue Type:

[jira] [Created] (FLINK-25378) kubernetes's request/limit resource can been seperated?

jeff-zou created FLINK-25378: Summary: kubernetes's request/limit resource can been seperated? Key: FLINK-25378 URL: https://issues.apache.org/jira/browse/FLINK-25378 Project: Flink Issue Type: N

[jira] [Created] (FLINK-25377) kubernetes's request/limit resource can been seperated?

jeff-zou created FLINK-25377: Summary: kubernetes's request/limit resource can been seperated? Key: FLINK-25377 URL: https://issues.apache.org/jira/browse/FLINK-25377 Project: Flink Issue Type: N

[jira] [Created] (FLINK-25379) Support limit push down in DATAGEN connector.

Moses created FLINK-25379: - Summary: Support limit push down in DATAGEN connector. Key: FLINK-25379 URL: https://issues.apache.org/jira/browse/FLINK-25379 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-25380) Introduce DynamicTableSink & DynamicTableSource for RabbitMQ

RocMarshal created FLINK-25380: -- Summary: Introduce DynamicTableSink & DynamicTableSource for RabbitMQ Key: FLINK-25380 URL: https://issues.apache.org/jira/browse/FLINK-25380 Project: Flink Iss