[jira] [Created] (FLINK-34141) Bash exited with code '143'

xuyang created FLINK-34141: -- Summary: Bash exited with code '143' Key: FLINK-34141 URL: https://issues.apache.org/jira/browse/FLINK-34141 Project: Flink Issue Type: Bug Components: Build

[jira] [Created] (FLINK-34140) Rename WindowContext in window

xuyang created FLINK-34140: -- Summary: Rename WindowContext in window Key: FLINK-34140 URL: https://issues.apache.org/jira/browse/FLINK-34140 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-34139) The window assigner should not reveal its event time or process time at the interface level.

xuyang created FLINK-34139: -- Summary: The window assigner should not reveal its event time or process time at the interface level. Key: FLINK-34139 URL: https://issues.apache.org/jira/browse/FLINK-34139

Re: [DISCUSS] FLIP-415: Introduce a new join operator to support minibatch

Hi all, Thank you for the valuable input. Based on the current discussion, the minibatch join is prepared to follow the existing three options of 'table.exec.mini-batch.enabled’, 'table.exec.mini-batch.allow-latency' and 'table.exec.mini-batch.size’. As for the compaction within the

[jira] [Created] (FLINK-34138) Improve the interface about MergeCallback in window

xuyang created FLINK-34138: -- Summary: Improve the interface about MergeCallback in window Key: FLINK-34138 URL: https://issues.apache.org/jira/browse/FLINK-34138 Project: Flink Issue Type:

Re: [DISCUSS] FLIP-415: Introduce a new join operator to support minibatch

Hi Benchao, I think your suggestion is very reasonable. For most users, having compaction enabled by default if mini-batch enabled is a more beneficial approach. However, I think this is an another thing we could discuss in the future about compaction within minibatch, which is an orthogonal

Re: [DISCUSS] FLIP-419: Optimize multi-sink query plan generation

Hi Jim, Thanks for your comments. Please find my answers below: 1. StreamOptimizeContext may still be needed to pass the fact that we >are optimizing a streaming query. I don't think this class will go away >completely. (I agree it may become more simple if the kind or >

Re: [DISCUSS] FLIP-417: Expose JobManagerOperatorMetrics via REST API

Hi Mason, Thanks for driving the discussion. +1 for the proposal. How about we return all operator metrics in a vertex? (the response is a map of operatorId/operatorName -> operator-metrics). Correspondingly, the url may be changed to /jobs//vertices//operator-metrics In this way, users can

[jira] [Created] (FLINK-34137) Update CI to test archunit configuration

Etienne Chauchot created FLINK-34137: Summary: Update CI to test archunit configuration Key: FLINK-34137 URL: https://issues.apache.org/jira/browse/FLINK-34137 Project: Flink Issue Type:

[jira] [Created] (FLINK-34136) Execute archunit tests only with Flink version that connectors were built against

Etienne Chauchot created FLINK-34136: Summary: Execute archunit tests only with Flink version that connectors were built against Key: FLINK-34136 URL: https://issues.apache.org/jira/browse/FLINK-34136

[jira] [Created] (FLINK-34135) A number of ci failures with Access to the path '.../_work/_temp/containerHandlerInvoker.js' is denied.

Sergey Nuyanzin created FLINK-34135: --- Summary: A number of ci failures with Access to the path '.../_work/_temp/containerHandlerInvoker.js' is denied. Key: FLINK-34135 URL:

Re: [DISCUSS] FLIP-395: Deprecate Global Aggregator Manager

Hi, Sorry for the late response. +1 for deprecating it. It would be even better to just remove it from the code base, but would require a little bit of investigation in the kinesis connector [1], if this feature can be safely removed from the kinesis connector in favour of the generic watermark

[jira] [Created] (FLINK-34134) Add tracing for restored state size and locations

Stefan Richter created FLINK-34134: -- Summary: Add tracing for restored state size and locations Key: FLINK-34134 URL: https://issues.apache.org/jira/browse/FLINK-34134 Project: Flink Issue

[jira] [Created] (FLINK-34133) Merge MiniBatchInterval when propagate traits to child block

zhouli created FLINK-34133: -- Summary: Merge MiniBatchInterval when propagate traits to child block Key: FLINK-34133 URL: https://issues.apache.org/jira/browse/FLINK-34133 Project: Flink Issue

[jira] [Created] (FLINK-34132) Batch WordCount job fails when run with AdaptiveBatch scheduler

Prabhu Joseph created FLINK-34132: - Summary: Batch WordCount job fails when run with AdaptiveBatch scheduler Key: FLINK-34132 URL: https://issues.apache.org/jira/browse/FLINK-34132 Project: Flink

[jira] [Created] (FLINK-34131) Checkpoint check window should take in account checkpoint job configuration

Nicolas Fraison created FLINK-34131: --- Summary: Checkpoint check window should take in account checkpoint job configuration Key: FLINK-34131 URL: https://issues.apache.org/jira/browse/FLINK-34131

Re: [VOTE] Accept Flink CDC into Apache Flink

+1 (non-binding) Best, Swapnal On Wed, Jan 17, 2024 at 1:57 AM Gunnar Morling wrote: > +1 (non-binding) > > Best, > > --Gunnar > > > Am Mo., 15. Jan. 2024 um 18:24 Uhr schrieb Fabian Hueske < > fhue...@apache.org > >: > > > +1 (binding) > > > > Cheers, Fabian > > > > > > Timo Walther schrieb

[jira] [Created] (FLINK-34130) Mark setBytes and getBytes of Configuration as @Internal

Rui Fan created FLINK-34130: --- Summary: Mark setBytes and getBytes of Configuration as @Internal Key: FLINK-34130 URL: https://issues.apache.org/jira/browse/FLINK-34130 Project: Flink Issue Type:

[jira] [Created] (FLINK-34129) correct writing: MiniBatchGlobalGroupAggFunction will make -D as +I then make +I as -U when state expired

Hongshun Wang created FLINK-34129: - Summary: correct writing: MiniBatchGlobalGroupAggFunction will make -D as +I then make +I as -U when state expired Key: FLINK-34129 URL: