[jira] [Created] (FLINK-25687) DropDelete is incorrect in CompactManager when outputLevel is zero

Jingsong Lee created FLINK-25687: Summary: DropDelete is incorrect in CompactManager when outputLevel is zero Key: FLINK-25687 URL: https://issues.apache.org/jira/browse/FLINK-25687 Project: Flink

[jira] [Created] (FLINK-25686) Support Pulsar Schema evolution in Pulsar Connector

Yufei Zhang created FLINK-25686: --- Summary: Support Pulsar Schema evolution in Pulsar Connector Key: FLINK-25686 URL: https://issues.apache.org/jira/browse/FLINK-25686 Project: Flink Issue

[jira] [Created] (FLINK-25685) RestClusterClient gets stuck on submitting job with local user artifact

Xuannan Su created FLINK-25685: -- Summary: RestClusterClient gets stuck on submitting job with local user artifact Key: FLINK-25685 URL: https://issues.apache.org/jira/browse/FLINK-25685 Project: Flink

[jira] [Created] (FLINK-25684) Support enhanced show databases syntax

Moses created FLINK-25684: - Summary: Support enhanced show databases syntax Key: FLINK-25684 URL: https://issues.apache.org/jira/browse/FLINK-25684 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-25683) wrong result if table transfrom to DataStream then window process grouped to mini batch in batch mode

zhangzh created FLINK-25683: --- Summary: wrong result if table transfrom to DataStream then window process grouped to mini batch in batch mode Key: FLINK-25683 URL: https://issues.apache.org/jira/browse/FLINK-25683

Re:Re: I want to contribute to Apache Flink

Thank you At 2022-01-18 01:28:49, "Zhilong Hong" wrote: >Hi, Chengyun: > >Thanks for your passion for contributing to the Flink community. You don't >need a contributor permission to contribute your code to Flink. Find an >open issue you are interested in at

Re: [VOTE] Release 1.14.3, release candidate #1

Release finalization steps have been completed, except for the Docker images. Can someone please approve/merge: https://github.com/apache/flink-docker/pull/97 https://github.com/apache/flink-docker/pull/98 I don't have access to publishing to DockerHub: apache/flink yet. I'm going to request

Re: I want to contribute to Apache Flink

Hi, Chengyun: Thanks for your passion for contributing to the Flink community. You don't need a contributor permission to contribute your code to Flink. Find an open issue you are interested in at http://issues.apache.org/jira/browse/FLINK and comment with your ideas. It would be a good start for

[jira] [Created] (FLINK-25682) Check in script to verify cheksums and signatures for Apache Flink Releases

Konstantin Knauf created FLINK-25682: Summary: Check in script to verify cheksums and signatures for Apache Flink Releases Key: FLINK-25682 URL: https://issues.apache.org/jira/browse/FLINK-25682

I want to contribute to Apache Flink

Hi, I want to contribute to Apache Flink. Would you please give me the contributor permission? My JIRA full name is Chengyun Zhang.

Re: [VOTE] Release 1.14.3, release candidate #1

Hi everyone, The vote duration has passed and we have approved the release. Binding votes: * Till * Timo * Chesnay I would like to ask Thomas to finalise the release and make the announcement. Best regards, Martijn On Mon, 17 Jan 2022 at 11:29, Chesnay Schepler wrote: > +1 (binding) > >

[jira] [Created] (FLINK-25681) CodeSplitITCase produces large stacktraces and potentially out of memory errors

Martijn Visser created FLINK-25681: -- Summary: CodeSplitITCase produces large stacktraces and potentially out of memory errors Key: FLINK-25681 URL: https://issues.apache.org/jira/browse/FLINK-25681

[jira] [Created] (FLINK-25680) Introduce Table Store Flink Sink

Jingsong Lee created FLINK-25680: Summary: Introduce Table Store Flink Sink Key: FLINK-25680 URL: https://issues.apache.org/jira/browse/FLINK-25680 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-25679) Build arm64 Linux images for Apache Flink

Robert Metzger created FLINK-25679: -- Summary: Build arm64 Linux images for Apache Flink Key: FLINK-25679 URL: https://issues.apache.org/jira/browse/FLINK-25679 Project: Flink Issue Type:

Re: Flink native k8s integration vs. operator

Hi Yang! Thanks for the input! I agree with you on both points that you made. Even if we might support both standalone and native modes in the long run, we should probably build the first version on top of the native integration. This I feel will result in a much simpler, minimalistic first

[jira] [Created] (FLINK-25678) TaskExecutorStateChangelogStoragesManager.shutdown is not thread-safe

Roman Khachatryan created FLINK-25678: - Summary: TaskExecutorStateChangelogStoragesManager.shutdown is not thread-safe Key: FLINK-25678 URL: https://issues.apache.org/jira/browse/FLINK-25678

[jira] [Created] (FLINK-25677) Update ReplicateRows to the new type system

Timo Walther created FLINK-25677: Summary: Update ReplicateRows to the new type system Key: FLINK-25677 URL: https://issues.apache.org/jira/browse/FLINK-25677 Project: Flink Issue Type:

Re: [VOTE] Release 1.14.3, release candidate #1

+1 (binding) Went over the pom changes and double-checked licensing. On 17/01/2022 10:44, Timo Walther wrote: +1 (binding) I had an offline chat with Fabian Paul about the mentioned changes. The serializer changes should be acceptable as the migration would have failed/stuck otherwise. At

Re: [DISCUSS] FLIP-203: Incremental savepoints

Hi everyone, Thanks for Piotr to drive this topic. I have several questions on this FLIP. 1. From my understanding, native savepoint appears much closer to current alignment checkpoint. What's their difference? 2. If self-contained and relocatable are the most important difference, why

[jira] [Created] (FLINK-25676) Add set_description in Python API

Dian Fu created FLINK-25676: --- Summary: Add set_description in Python API Key: FLINK-25676 URL: https://issues.apache.org/jira/browse/FLINK-25676 Project: Flink Issue Type: Improvement

[RESULT][VOTE] FLIP-206: Support PyFlink Runtime Execution in Thread Mode

Hi everyone, The voting time for FLIP-206: Support PyFlink Runtime Execution in Thread Mode[1] has passed. I'm closing the vote now. There were 4 +1 votes, 4 of which are binding: - Wei Zhong (binding) - Till Rohrmann (binding) - Thomas Weise (binding) - Dian Fu (binding) There were no -1

Re: [VOTE] Release 1.14.3, release candidate #1

+1 (binding) I had an offline chat with Fabian Paul about the mentioned changes. The serializer changes should be acceptable as the migration would have failed/stuck otherwise. At no point in time we end up with a corrupt serializer snapshot. We will update older 1.14 release notes to point

Re: [DISCUSS] FLIP-210: Change logging level dynamically at runtime

Thanks Wenhao for referring the JMX solution. I believe it is a good alternative for who they do not have the ssh permission of the production machines. Best, Yang Wenhao Ji 于2022年1月16日周日 20:20写道： > The FLIP has been marked as rejected. > > Anyone landing here looking for a solution to change

Re: Flink native k8s integration vs. operator

Glad to see that the interest of this thread keeps going. And thanks Thomas, Gyula, and Marton for driving this effort. I want to share my two cents about the Flink K8s operator. > Standalone deployment VS native K8s integration There is already some feature requirement issue[1] for the

Re: How to use TableEnvironment in multiple thread environments

Hi Chang, Yes, I think this would make most sense to do. Cheers, Till On Mon, Jan 17, 2022 at 9:13 AM Chang Chen wrote: > IIUC, TableEnvironment isn't thread-safe, since it contains some internal > states, for example, PlannerContext that has RelOptCluster used to optimize > SQL. > > So do I

[jira] [Created] (FLINK-25675) UnalignedCheckpointCompatibilityITCase.test hangs on AZP

Till Rohrmann created FLINK-25675: - Summary: UnalignedCheckpointCompatibilityITCase.test hangs on AZP Key: FLINK-25675 URL: https://issues.apache.org/jira/browse/FLINK-25675 Project: Flink

[jira] [Created] (FLINK-25674) CassandraConnectorITCase.testCassandraPojoNoAnnotatedKeyspaceAtLeastOnceSink fails on AZP

Till Rohrmann created FLINK-25674: - Summary: CassandraConnectorITCase.testCassandraPojoNoAnnotatedKeyspaceAtLeastOnceSink fails on AZP Key: FLINK-25674 URL: https://issues.apache.org/jira/browse/FLINK-25674

[jira] [Created] (FLINK-25673) AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSavepointSucceedOnSecond hangs on AZP

Till Rohrmann created FLINK-25673: - Summary: AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSavepointSucceedOnSecond hangs on AZP Key: FLINK-25673 URL: https://issues.apache.org/jira/browse/FLINK-25673

[jira] [Created] (FLINK-25672) FileSource enumerator remembers paths of all already processed files which can result in large state

Martijn Visser created FLINK-25672: -- Summary: FileSource enumerator remembers paths of all already processed files which can result in large state Key: FLINK-25672 URL:

Re: [VOTE] Release 1.14.3, release candidate #1

I went through the commit diff and found the following changes that might cause issues in my opinion. Maybe it makes sense to take a second look before I will cast my vote: // change of transformations https://github.com/apache/flink/commit/b7cd97b02d7f39b5190d27fbaf6e6287f127b9a9 // change

Re: [DISCUSS] FLIP-205: Support cache in DataStream for Batch Processing

+1 Thanks Xuannan, no more objections from my side On Mon, Jan 17, 2022 at 7:14 AM Yun Gao wrote: > Hi Xuannan, > > Very thanks for the detailed explanation and sorry for the very > late response. > > For cached result partition v.s. managed table, I also agree with > the current conclusion

[jira] [Created] (FLINK-25671) npm ci failed with code EPROTO when downloading stylelint-config-prettier-8.0.2.tgz

Yun Gao created FLINK-25671: --- Summary: npm ci failed with code EPROTO when downloading stylelint-config-prettier-8.0.2.tgz Key: FLINK-25671 URL: https://issues.apache.org/jira/browse/FLINK-25671 Project:

[jira] [Created] (FLINK-25670) StateFun: Unable to handle oversize HTTP message if state size is large

Kyle created FLINK-25670: Summary: StateFun: Unable to handle oversize HTTP message if state size is large Key: FLINK-25670 URL: https://issues.apache.org/jira/browse/FLINK-25670 Project: Flink

How to use TableEnvironment in multiple thread environments

IIUC, TableEnvironment isn't thread-safe, since it contains some internal states, for example, PlannerContext that has RelOptCluster used to optimize SQL. So do I create a TableEnvironment per thread?

[jira] [Created] (FLINK-25669) Support register operator coordinators for newly initialized ExecutionJobVertex.

Lijie Wang created FLINK-25669: -- Summary: Support register operator coordinators for newly initialized ExecutionJobVertex. Key: FLINK-25669 URL: https://issues.apache.org/jira/browse/FLINK-25669

[jira] [Created] (FLINK-25668) Support calcuate network memory for dynamic graph.

Lijie Wang created FLINK-25668: -- Summary: Support calcuate network memory for dynamic graph. Key: FLINK-25668 URL: https://issues.apache.org/jira/browse/FLINK-25668 Project: Flink Issue Type: