[jira] [Created] (FLINK-32906) Release Testing: Verify FLINK-30025

2023-08-21 Thread Jing Ge (Jira)
Jing Ge created FLINK-32906: --- Summary: Release Testing: Verify FLINK-30025 Key: FLINK-32906 URL: https://issues.apache.org/jira/browse/FLINK-32906 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-32905) Fix the bug of broadcast hash join doesn't support spill to disk when enable operator fusion codegn

2023-08-21 Thread dalongliu (Jira)
dalongliu created FLINK-32905: - Summary: Fix the bug of broadcast hash join doesn't support spill to disk when enable operator fusion codegn Key: FLINK-32905 URL: https://issues.apache.org/jira/browse/FLINK-32905

Re: [DISCUSS][2.0] Evaluation of imperative API related TBD work items

2023-08-21 Thread Xintong Song
As no concerns are raised, I'll update the wiki page. Best, Xintong On Thu, Aug 17, 2023 at 5:31 PM Xintong Song wrote: > Hi devs, > > We have been evaluating the 3 TBD items from the Imperative API section of > the release 2.0 work items [1]. > 1. Refactor the API modules > 2. Refactor

Re: [DISCUSS] FLIP-356: Support Nested Fields Filter Pushdown

2023-08-21 Thread Venkatakrishnan Sowrirajan
Sounds like a great suggestion, Becket. +1. Agree with cleaning up the APIs and making it consistent in all the pushdown APIs. Your suggested approach seems fine to me, unless anyone else has any other concerns. Just have couple of clarifying questions: 1. Do you think we should standardize the

Re: [DISCUSS] FLIP-334 : Decoupling autoscaler and kubernetes

2023-08-21 Thread Gyula Fóra
I would still prefer to polish the interfaces before we move forward. To me the AutoscalerEventHandler is a bit of a weird interface. There are some random methods in it and I am not sure how they are going to be implemented. This seems to be really specific for sending Kubernetes events. Also

[jira] [Created] (FLINK-32904) Support cron expressions for periodic snapshots triggering

2023-08-21 Thread Alexander Fedulov (Jira)
Alexander Fedulov created FLINK-32904: - Summary: Support cron expressions for periodic snapshots triggering Key: FLINK-32904 URL: https://issues.apache.org/jira/browse/FLINK-32904 Project: Flink

Re: [DISCUSS] FLIP-229: Prometheus Sink Connector

2023-08-21 Thread Ahmed Hamdy
Hello Karthi Is this FLIP still in progress? I see the FLIP not updated & couldn't find open JIRAs. I am happy to take over if you are no longer working on this. Best Regards Ahmed Hamdy On Mon, 22 May 2023 at 14:49, Martijn Visser wrote: > Hi all, > > > For example, a user might want to read

[jira] [Created] (FLINK-32903) Add a load simulation example pipeline for canary testing

2023-08-21 Thread Maximilian Michels (Jira)
Maximilian Michels created FLINK-32903: -- Summary: Add a load simulation example pipeline for canary testing Key: FLINK-32903 URL: https://issues.apache.org/jira/browse/FLINK-32903 Project: Flink

log4j2 integration with flink 1.10

2023-08-21 Thread Y SREEKARA BHARGAVA REDDY
Hi Team, Does any one did integration flink 1.10 with log4j2 instead of log4j1. If yes, please share the reference for that. Any suggestion, greatly appreciated. Regards, Nagireddy Y.

Re: Heartbeat of TaskManager with id container

2023-08-21 Thread Y SREEKARA BHARGAVA REDDY
Thanks Xiangyu, I have one issue, while running flink with kafka connector. its a working fine for couple of days. But suddenly kafka lag went to "Negative value" I am trying to find the root cause for that. Any suggestions? On Sat, Aug 5, 2023 at 5:57 PM xiangyu feng wrote: > Hi

[jira] [Created] (FLINK-32902) Docs creation and checks in multiple locations

2023-08-21 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-32902: - Summary: Docs creation and checks in multiple locations Key: FLINK-32902 URL: https://issues.apache.org/jira/browse/FLINK-32902 Project: Flink Issue Type:

[jira] [Created] (FLINK-32901) Should set initial

2023-08-21 Thread Feifan Wang (Jira)
Feifan Wang created FLINK-32901: --- Summary: Should set initial Key: FLINK-32901 URL: https://issues.apache.org/jira/browse/FLINK-32901 Project: Flink Issue Type: Bug Reporter:

Re: [DISCUSS] FLIP-334 : Decoupling autoscaler and kubernetes

2023-08-21 Thread Rui Fan
Hi Max, Gyula and Matt, Do you have any other comments? The flink-kubernetes-operator 1.6 has been released recently, it's a good time to kick off this FLIP. Please let me know if you have any questions or concerns, looking forward to your feedback, thanks! Best, Rui On Wed, Aug 9, 2023 at

Re: [DISCUSS] FLIP-328: Allow source operators to determine isProcessingBacklog based on watermark lag

2023-08-21 Thread Xuannan Su
Hi Jark, Thanks for the comments. I agree that the current solution cannot support jobs that cannot define watermarks. However, after considering the pending-record-based solution, I believe the current solution is superior for the target use case as it is more intuitive for users. The

[jira] [Created] (FLINK-32900) Flink SQL doesn't find any built-in SQL functions

2023-08-21 Thread Tan Kim (Jira)
Tan Kim created FLINK-32900: --- Summary: Flink SQL doesn't find any built-in SQL functions Key: FLINK-32900 URL: https://issues.apache.org/jira/browse/FLINK-32900 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-32899) Can not access inner/nested objects in MATCH_RECOGNIZE DFINE clause and in Aggregate function

2023-08-21 Thread Krutik (Jira)
Krutik created FLINK-32899: -- Summary: Can not access inner/nested objects in MATCH_RECOGNIZE DFINE clause and in Aggregate function Key: FLINK-32899 URL: https://issues.apache.org/jira/browse/FLINK-32899