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

Hi Ron, I found that the manylinux package names are duplicated and what we need are manylinux1 packages. Best, Xingbo Ron Liu 于2025年7月21日周一 21:41写道： > Hi everyone, > > Please review and vote on the release candidate #1 for the version 2.1.0, > > as follows: > > [ ] +1, Approve the release >

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

+1 (binding) - verified signatures & checksums - pip install apache-flink-libraries && apache-flink with Python 3.12/3.10 in M2 - run pyflink job with UDF/Pandas in jdk11 && python 3.10 Best, Xingbo Xuyang 于2025年7月24日周四 17:28写道： > +1 > > > > > - built from sources (mac) > > - ran simple jobs b

[jira] [Created] (FLINK-30366) Python Group Agg failed in cleaning the idle state

Xingbo Huang created FLINK-30366: Summary: Python Group Agg failed in cleaning the idle state Key: FLINK-30366 URL: https://issues.apache.org/jira/browse/FLINK-30366 Project: Flink Issue

[jira] [Created] (FLINK-28788) Support SideOutput in Thread Mode

Xingbo Huang created FLINK-28788: Summary: Support SideOutput in Thread Mode Key: FLINK-28788 URL: https://issues.apache.org/jira/browse/FLINK-28788 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-28898) ChangelogRecoverySwitchStateBackendITCase.testSwitchFromEnablingToDisablingWithRescalingOut failed

Xingbo Huang created FLINK-28898: Summary: ChangelogRecoverySwitchStateBackendITCase.testSwitchFromEnablingToDisablingWithRescalingOut failed Key: FLINK-28898 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Created] (FLINK-28900) RecreateOnResetOperatorCoordinatorTest compile failed in jdk11

Xingbo Huang created FLINK-28900: Summary: RecreateOnResetOperatorCoordinatorTest compile failed in jdk11 Key: FLINK-28900 URL: https://issues.apache.org/jira/browse/FLINK-28900 Project: Flink

[jira] [Created] (FLINK-28901) CassandraSinkBaseTest.testTimeoutExceptionOnInvoke failed with TestTimedOutException

Xingbo Huang created FLINK-28901: Summary: CassandraSinkBaseTest.testTimeoutExceptionOnInvoke failed with TestTimedOutException Key: FLINK-28901 URL: https://issues.apache.org/jira/browse/FLINK-28901

[jira] [Created] (FLINK-29092) HadoopPathBasedPartFileWriterTest.testWriteFile failed with AssertionError

Xingbo Huang created FLINK-29092: Summary: HadoopPathBasedPartFileWriterTest.testWriteFile failed with AssertionError Key: FLINK-29092 URL: https://issues.apache.org/jira/browse/FLINK-29092 Project

[jira] [Created] (FLINK-29093) LookupJoinITCase failed with InternalCompilerException

Xingbo Huang created FLINK-29093: Summary: LookupJoinITCase failed with InternalCompilerException Key: FLINK-29093 URL: https://issues.apache.org/jira/browse/FLINK-29093 Project: Flink Issue

[jira] [Created] (FLINK-29102) ChangelogLocalRecoveryITCase.testRestartTM failed with AssertionFailedError

Xingbo Huang created FLINK-29102: Summary: ChangelogLocalRecoveryITCase.testRestartTM failed with AssertionFailedError Key: FLINK-29102 URL: https://issues.apache.org/jira/browse/FLINK-29102 Project

[jira] [Created] (FLINK-29105) KubernetesStateHandleStoreTest.testAddAndLockShouldNotThrowAlreadyExistExceptionWithSameContents failed with AssertionFailedError

Xingbo Huang created FLINK-29105: Summary: KubernetesStateHandleStoreTest.testAddAndLockShouldNotThrowAlreadyExistExceptionWithSameContents failed with AssertionFailedError Key: FLINK-29105 URL: https

[jira] [Created] (FLINK-29147) ChangelogLocalRecoveryITCase.testRestartTM failed with CheckpointException

Xingbo Huang created FLINK-29147: Summary: ChangelogLocalRecoveryITCase.testRestartTM failed with CheckpointException Key: FLINK-29147 URL: https://issues.apache.org/jira/browse/FLINK-29147 Project

[jira] [Created] (FLINK-29155) Improve default config of grpcServer in Process Mode

Xingbo Huang created FLINK-29155: Summary: Improve default config of grpcServer in Process Mode Key: FLINK-29155 URL: https://issues.apache.org/jira/browse/FLINK-29155 Project: Flink Issue

[jira] [Created] (FLINK-29161) Run kubernetes application HA test failed with unable to prepare context: path "dev/test_kubernetes_application_ha-debian" not found

Xingbo Huang created FLINK-29161: Summary: Run kubernetes application HA test failed with unable to prepare context: path "dev/test_kubernetes_application_ha-debian" not found Key: FLINK-29161

[jira] [Created] (FLINK-29196) Check 1.16 licensing

Xingbo Huang created FLINK-29196: Summary: Check 1.16 licensing Key: FLINK-29196 URL: https://issues.apache.org/jira/browse/FLINK-29196 Project: Flink Issue Type: Technical Debt

[jira] [Created] (FLINK-29217) CoordinatorEventsToStreamOperatorRecipientExactlyOnceITCase.testConcurrentCheckpoint failed with AssertionFailedError

Xingbo Huang created FLINK-29217: Summary: CoordinatorEventsToStreamOperatorRecipientExactlyOnceITCase.testConcurrentCheckpoint failed with AssertionFailedError Key: FLINK-29217 URL: https://issues.apache.org

[jira] [Created] (FLINK-29220) Skip ci tests on docs-only-PRs

Xingbo Huang created FLINK-29220: Summary: Skip ci tests on docs-only-PRs Key: FLINK-29220 URL: https://issues.apache.org/jira/browse/FLINK-29220 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-29274) HiveServer2EndpointITCase.testGetFunctionWithPattern failed with Persistence Manager has been closed

Xingbo Huang created FLINK-29274: Summary: HiveServer2EndpointITCase.testGetFunctionWithPattern failed with Persistence Manager has been closed Key: FLINK-29274 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Created] (FLINK-29296) OperatorCoordinatorHolder.create throws NPE

Xingbo Huang created FLINK-29296: Summary: OperatorCoordinatorHolder.create throws NPE Key: FLINK-29296 URL: https://issues.apache.org/jira/browse/FLINK-29296 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-29495) PulsarSinkE2ECase hang

Xingbo Huang created FLINK-29495: Summary: PulsarSinkE2ECase hang Key: FLINK-29495 URL: https://issues.apache.org/jira/browse/FLINK-29495 Project: Flink Issue Type: Bug Components

[jira] [Created] (FLINK-30169) Adds version switcher in PyFlink API doc

Xingbo Huang created FLINK-30169: Summary: Adds version switcher in PyFlink API doc Key: FLINK-30169 URL: https://issues.apache.org/jira/browse/FLINK-30169 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-37991) Upgrade pemja to 0.6.x

Xingbo Huang created FLINK-37991: Summary: Upgrade pemja to 0.6.x Key: FLINK-37991 URL: https://issues.apache.org/jira/browse/FLINK-37991 Project: Flink Issue Type: Bug Components

<    1   2   3