[jira] [Created] (FLINK-31099) Chained WindowOperator throws NPE in PyFlink ThreadMode

Huang Xingbo created FLINK-31099: Summary: Chained WindowOperator throws NPE in PyFlink ThreadMode Key: FLINK-31099 URL: https://issues.apache.org/jira/browse/FLINK-31099 Project: Flink Issue

[jira] [Created] (FLINK-30040) Add more PyFlink API examples

Huang Xingbo created FLINK-30040: Summary: Add more PyFlink API examples Key: FLINK-30040 URL: https://issues.apache.org/jira/browse/FLINK-30040 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-29966) Replace and redesign the Python api documentation base

Huang Xingbo created FLINK-29966: Summary: Replace and redesign the Python api documentation base Key: FLINK-29966 URL: https://issues.apache.org/jira/browse/FLINK-29966 Project: Flink Issue

[jira] [Created] (FLINK-29833) Improve PyFlink support in Windows

Huang Xingbo created FLINK-29833: Summary: Improve PyFlink support in Windows Key: FLINK-29833 URL: https://issues.apache.org/jira/browse/FLINK-29833 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-29788) StatefulJobWBroadcastStateMigrationITCase failed in native savepoints

Huang Xingbo created FLINK-29788: Summary: StatefulJobWBroadcastStateMigrationITCase failed in native savepoints Key: FLINK-29788 URL: https://issues.apache.org/jira/browse/FLINK-29788 Project: Flink

[jira] [Created] (FLINK-29463) InputFormatCacheLoaderTest.checkCounter failed with AssertionError

Huang Xingbo created FLINK-29463: Summary: InputFormatCacheLoaderTest.checkCounter failed with AssertionError Key: FLINK-29463 URL: https://issues.apache.org/jira/browse/FLINK-29463 Project: Flink

[jira] [Created] (FLINK-29461) ProcessDataStreamStreamingTests.test_process_function unstable

Huang Xingbo created FLINK-29461: Summary: ProcessDataStreamStreamingTests.test_process_function unstable Key: FLINK-29461 URL: https://issues.apache.org/jira/browse/FLINK-29461 Project: Flink

[jira] [Created] (FLINK-29460) HsResultPartitionTest.testRelease failed with AssertionFailedError

Huang Xingbo created FLINK-29460: Summary: HsResultPartitionTest.testRelease failed with AssertionFailedError Key: FLINK-29460 URL: https://issues.apache.org/jira/browse/FLINK-29460 Project: Flink

[jira] [Created] (FLINK-29427) LookupJoinITCase failed with classloader problem

Huang Xingbo created FLINK-29427: Summary: LookupJoinITCase failed with classloader problem Key: FLINK-29427 URL: https://issues.apache.org/jira/browse/FLINK-29427 Project: Flink Issue Type:

[jira] [Created] (FLINK-29419) HybridShuffle.testHybridFullExchangesRestart hangs

Huang Xingbo created FLINK-29419: Summary: HybridShuffle.testHybridFullExchangesRestart hangs Key: FLINK-29419 URL: https://issues.apache.org/jira/browse/FLINK-29419 Project: Flink Issue Type

[jira] [Created] (FLINK-29408) HiveCatalogITCase failed with NPE

Huang Xingbo created FLINK-29408: Summary: HiveCatalogITCase failed with NPE Key: FLINK-29408 URL: https://issues.apache.org/jira/browse/FLINK-29408 Project: Flink Issue Type: Bug C

[jira] [Created] (FLINK-29407) HiveCatalogITCase.testCsvTableViaSQL failed with FileNotFoundException

Huang Xingbo created FLINK-29407: Summary: HiveCatalogITCase.testCsvTableViaSQL failed with FileNotFoundException Key: FLINK-29407 URL: https://issues.apache.org/jira/browse/FLINK-29407 Project: Flink

[jira] [Created] (FLINK-29387) IntervalJoinITCase.testIntervalJoinSideOutputRightLateData failed with AssertionError

Huang Xingbo created FLINK-29387: Summary: IntervalJoinITCase.testIntervalJoinSideOutputRightLateData failed with AssertionError Key: FLINK-29387 URL: https://issues.apache.org/jira/browse/FLINK-29387

[jira] [Created] (FLINK-29054) Azure tests failed with Temporary failure resolving 'archive.ubuntu.com'

Huang Xingbo created FLINK-29054: Summary: Azure tests failed with Temporary failure resolving 'archive.ubuntu.com' Key: FLINK-29054 URL: https://issues.apache.org/jira/browse/FLINK-29054 Project: Fli

[jira] [Created] (FLINK-29038) AsyncWaitOperatorTest.testProcessingTimeRepeatedCompleteOrderedWithRetry failed with AssertionError

Huang Xingbo created FLINK-29038: Summary: AsyncWaitOperatorTest.testProcessingTimeRepeatedCompleteOrderedWithRetry failed with AssertionError Key: FLINK-29038 URL: https://issues.apache.org/jira/browse/FLINK-290

[jira] [Created] (FLINK-29031) FlinkKinesisConsumerTest.testSourceSynchronization failed with AssertionFailedError

Huang Xingbo created FLINK-29031: Summary: FlinkKinesisConsumerTest.testSourceSynchronization failed with AssertionFailedError Key: FLINK-29031 URL: https://issues.apache.org/jira/browse/FLINK-29031 P

[jira] [Created] (FLINK-29029) Fix the bug of CSV format doesn't work in Thread Mode

Huang Xingbo created FLINK-29029: Summary: Fix the bug of CSV format doesn't work in Thread Mode Key: FLINK-29029 URL: https://issues.apache.org/jira/browse/FLINK-29029 Project: Flink Issue T

[jira] [Created] (FLINK-29028) Add the missing cache api in Python DataStream API

Huang Xingbo created FLINK-29028: Summary: Add the missing cache api in Python DataStream API Key: FLINK-29028 URL: https://issues.apache.org/jira/browse/FLINK-29028 Project: Flink Issue Type

[jira] [Created] (FLINK-29018) KafkaITCase.testMultipleSourcesOnePartition failed with TopicExistsException

Huang Xingbo created FLINK-29018: Summary: KafkaITCase.testMultipleSourcesOnePartition failed with TopicExistsException Key: FLINK-29018 URL: https://issues.apache.org/jira/browse/FLINK-29018 Project:

[jira] [Created] (FLINK-29009) flink-end-to-end-tests-sql compile failed in hadoop3

Huang Xingbo created FLINK-29009: Summary: flink-end-to-end-tests-sql compile failed in hadoop3 Key: FLINK-29009 URL: https://issues.apache.org/jira/browse/FLINK-29009 Project: Flink Issue Ty

[jira] [Created] (FLINK-29008) SortMergeResultPartitionTest.testRelease failed with TestTimedOutException

Huang Xingbo created FLINK-29008: Summary: SortMergeResultPartitionTest.testRelease failed with TestTimedOutException Key: FLINK-29008 URL: https://issues.apache.org/jira/browse/FLINK-29008 Project: F

[jira] [Created] (FLINK-29007) UsingRemoteJarITCase failed with NPE in hadoop3

Huang Xingbo created FLINK-29007: Summary: UsingRemoteJarITCase failed with NPE in hadoop3 Key: FLINK-29007 URL: https://issues.apache.org/jira/browse/FLINK-29007 Project: Flink Issue Type: B

[jira] [Created] (FLINK-29006) PulsarSourceITCase failed with Could not acquire the minimum required resources.

Huang Xingbo created FLINK-29006: Summary: PulsarSourceITCase failed with Could not acquire the minimum required resources. Key: FLINK-29006 URL: https://issues.apache.org/jira/browse/FLINK-29006 Proj

[jira] [Created] (FLINK-28999) OperatorCoordinatorHolder.checkpointCoordinatorInternal Cannot mark for checkpoint

Huang Xingbo created FLINK-28999: Summary: OperatorCoordinatorHolder.checkpointCoordinatorInternal Cannot mark for checkpoint Key: FLINK-28999 URL: https://issues.apache.org/jira/browse/FLINK-28999 P

[jira] [Created] (FLINK-28970) Add the doc how to use Cython to optimize Python function

Huang Xingbo created FLINK-28970: Summary: Add the doc how to use Cython to optimize Python function Key: FLINK-28970 URL: https://issues.apache.org/jira/browse/FLINK-28970 Project: Flink Iss

[jira] [Created] (FLINK-28961) Add the doc how to support third party connector in Python DataStream API

Huang Xingbo created FLINK-28961: Summary: Add the doc how to support third party connector in Python DataStream API Key: FLINK-28961 URL: https://issues.apache.org/jira/browse/FLINK-28961 Project: Fl

[jira] [Created] (FLINK-28957) Optimize Python API doc

Huang Xingbo created FLINK-28957: Summary: Optimize Python API doc Key: FLINK-28957 URL: https://issues.apache.org/jira/browse/FLINK-28957 Project: Flink Issue Type: Improvement Com

[jira] [Created] (FLINK-28955) YARNHighAvailabilityITCase compile failed in hadoop3

Huang Xingbo created FLINK-28955: Summary: YARNHighAvailabilityITCase compile failed in hadoop3 Key: FLINK-28955 URL: https://issues.apache.org/jira/browse/FLINK-28955 Project: Flink Issue Ty

[jira] [Created] (FLINK-28944) Optimize the Python Execution Mode Documentation

Huang Xingbo created FLINK-28944: Summary: Optimize the Python Execution Mode Documentation Key: FLINK-28944 URL: https://issues.apache.org/jira/browse/FLINK-28944 Project: Flink Issue Type:

[jira] [Created] (FLINK-28921) Optimize the Python DataStream Window Documentation

Huang Xingbo created FLINK-28921: Summary: Optimize the Python DataStream Window Documentation Key: FLINK-28921 URL: https://issues.apache.org/jira/browse/FLINK-28921 Project: Flink Issue Typ

[jira] [Created] (FLINK-28920) Release Testing: Running Python DataStream Window Job

Huang Xingbo created FLINK-28920: Summary: Release Testing: Running Python DataStream Window Job Key: FLINK-28920 URL: https://issues.apache.org/jira/browse/FLINK-28920 Project: Flink Issue T

[jira] [Created] (FLINK-28918) Release Testing: Running Python DataStream jobs in Thread Mode

Huang Xingbo created FLINK-28918: Summary: Release Testing: Running Python DataStream jobs in Thread Mode Key: FLINK-28918 URL: https://issues.apache.org/jira/browse/FLINK-28918 Project: Flink

[jira] [Created] (FLINK-28896) Test Flink Release 1.16

Huang Xingbo created FLINK-28896: Summary: Test Flink Release 1.16 Key: FLINK-28896 URL: https://issues.apache.org/jira/browse/FLINK-28896 Project: Flink Issue Type: Improvement Com

[jira] [Created] (FLINK-28887) Fix the bug of custom metrics in Thread Mode

Huang Xingbo created FLINK-28887: Summary: Fix the bug of custom metrics in Thread Mode Key: FLINK-28887 URL: https://issues.apache.org/jira/browse/FLINK-28887 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-28879) New File Sink s3 end-to-end test failed with Output hash mismatch

Huang Xingbo created FLINK-28879: Summary: New File Sink s3 end-to-end test failed with Output hash mismatch Key: FLINK-28879 URL: https://issues.apache.org/jira/browse/FLINK-28879 Project: Flink

[jira] [Created] (FLINK-28878) PipelinedRegionSchedulingITCase.testRecoverFromPartitionException failed with AssertionError

Huang Xingbo created FLINK-28878: Summary: PipelinedRegionSchedulingITCase.testRecoverFromPartitionException failed with AssertionError Key: FLINK-28878 URL: https://issues.apache.org/jira/browse/FLINK-28878

[jira] [Created] (FLINK-28860) CacheITCase.testBatchProduceCacheStreamConsume failed

Huang Xingbo created FLINK-28860: Summary: CacheITCase.testBatchProduceCacheStreamConsume failed Key: FLINK-28860 URL: https://issues.apache.org/jira/browse/FLINK-28860 Project: Flink Issue T

[jira] [Created] (FLINK-28856) YARNHighAvailabilityITCase tests failed with NoSuchMethodError

Huang Xingbo created FLINK-28856: Summary: YARNHighAvailabilityITCase tests failed with NoSuchMethodError Key: FLINK-28856 URL: https://issues.apache.org/jira/browse/FLINK-28856 Project: Flink

[jira] [Created] (FLINK-28855) ThriftObjectConversions compile failed

Huang Xingbo created FLINK-28855: Summary: ThriftObjectConversions compile failed Key: FLINK-28855 URL: https://issues.apache.org/jira/browse/FLINK-28855 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-28836) Support broadcast in Thread Mode

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

[jira] [Created] (FLINK-28818) KafkaSinkITCase.testWriteRecordsToKafkaWithExactlyOnceGuarantee failed with AssertionFailedError

Huang Xingbo created FLINK-28818: Summary: KafkaSinkITCase.testWriteRecordsToKafkaWithExactlyOnceGuarantee failed with AssertionFailedError Key: FLINK-28818 URL: https://issues.apache.org/jira/browse/FLINK-28818

[jira] [Created] (FLINK-28767) SqlGatewayServiceITCase.testCancelOperation failed with AssertionFailedError

Huang Xingbo created FLINK-28767: Summary: SqlGatewayServiceITCase.testCancelOperation failed with AssertionFailedError Key: FLINK-28767 URL: https://issues.apache.org/jira/browse/FLINK-28767 Project:

[jira] [Created] (FLINK-28766) UnalignedCheckpointStressITCase.runStressTest failed with NoSuchFileException

Huang Xingbo created FLINK-28766: Summary: UnalignedCheckpointStressITCase.runStressTest failed with NoSuchFileException Key: FLINK-28766 URL: https://issues.apache.org/jira/browse/FLINK-28766 Project

[jira] [Created] (FLINK-28752) Add the json plan support in Python UDFs

Huang Xingbo created FLINK-28752: Summary: Add the json plan support in Python UDFs Key: FLINK-28752 URL: https://issues.apache.org/jira/browse/FLINK-28752 Project: Flink Issue Type: New Feat

[jira] [Created] (FLINK-28745) Support DataStream PythonCoProcessOperator and PythonKeyedCoProcessOperator in Thread Mode

Huang Xingbo created FLINK-28745: Summary: Support DataStream PythonCoProcessOperator and PythonKeyedCoProcessOperator in Thread Mode Key: FLINK-28745 URL: https://issues.apache.org/jira/browse/FLINK-28745

[jira] [Created] (FLINK-28688) Support DataStream PythonWindowOperator in Thread Mode

Huang Xingbo created FLINK-28688: Summary: Support DataStream PythonWindowOperator in Thread Mode Key: FLINK-28688 URL: https://issues.apache.org/jira/browse/FLINK-28688 Project: Flink Issue

[jira] [Created] (FLINK-28680) No space left on device on Azure e2e_2_ci tests

Huang Xingbo created FLINK-28680: Summary: No space left on device on Azure e2e_2_ci tests Key: FLINK-28680 URL: https://issues.apache.org/jira/browse/FLINK-28680 Project: Flink Issue Type: B

[jira] [Created] (FLINK-28679) HiveServer2Endpoint compile failed

Huang Xingbo created FLINK-28679: Summary: HiveServer2Endpoint compile failed Key: FLINK-28679 URL: https://issues.apache.org/jira/browse/FLINK-28679 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-28627) KafkaITCase.testBrokerFailure failed with TestTimedOutException: test timed out after 60000 milliseconds

Huang Xingbo created FLINK-28627: Summary: KafkaITCase.testBrokerFailure failed with TestTimedOutException: test timed out after 6 milliseconds Key: FLINK-28627 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Created] (FLINK-28626) RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState failed with FileNotFoundException

Huang Xingbo created FLINK-28626: Summary: RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState failed with FileNotFoundException Key: FLINK-28626 URL: https://issues.apache.org/jira/browse/FLINK-2

[jira] [Created] (FLINK-28559) Support DataStream PythonKeyedProcessOperator in Thread Mode

Huang Xingbo created FLINK-28559: Summary: Support DataStream PythonKeyedProcessOperator in Thread Mode Key: FLINK-28559 URL: https://issues.apache.org/jira/browse/FLINK-28559 Project: Flink

[jira] [Created] (FLINK-28557) CheckpointCoordinatorTriggeringTest.discardingTriggeringCheckpointWillExecuteNextCheckpointRequest Process produced no output for 900 seconds

Huang Xingbo created FLINK-28557: Summary: CheckpointCoordinatorTriggeringTest.discardingTriggeringCheckpointWillExecuteNextCheckpointRequest Process produced no output for 900 seconds Key: FLINK-28557 URL: https

[jira] [Created] (FLINK-28549) Support DataStream PythonProcessOperator in Thread Mode

Huang Xingbo created FLINK-28549: Summary: Support DataStream PythonProcessOperator in Thread Mode Key: FLINK-28549 URL: https://issues.apache.org/jira/browse/FLINK-28549 Project: Flink Issue

[jira] [Created] (FLINK-28546) Add the release logic for py39 and m1 wheel package

Huang Xingbo created FLINK-28546: Summary: Add the release logic for py39 and m1 wheel package Key: FLINK-28546 URL: https://issues.apache.org/jira/browse/FLINK-28546 Project: Flink Issue Typ

[jira] [Created] (FLINK-28545) FlinkKafkaProducerITCase.testRestoreToCheckpointAfterExceedingProducersPool failed with TimeoutException: Topic flink-kafka-producer-fail-before-notify not present in m

Huang Xingbo created FLINK-28545: Summary: FlinkKafkaProducerITCase.testRestoreToCheckpointAfterExceedingProducersPool failed with TimeoutException: Topic flink-kafka-producer-fail-before-notify not present in metadata after 6 ms

[jira] [Created] (FLINK-28544) Elasticsearch6SinkE2ECase failed with no space left on device

Huang Xingbo created FLINK-28544: Summary: Elasticsearch6SinkE2ECase failed with no space left on device Key: FLINK-28544 URL: https://issues.apache.org/jira/browse/FLINK-28544 Project: Flink

[jira] [Created] (FLINK-28529) ChangelogPeriodicMaterializationSwitchStateBackendITCase.testSwitchFromDisablingToEnablingInClaimMode failed with CheckpointException: Checkpoint expired before completi

Huang Xingbo created FLINK-28529: Summary: ChangelogPeriodicMaterializationSwitchStateBackendITCase.testSwitchFromDisablingToEnablingInClaimMode failed with CheckpointException: Checkpoint expired before completing Key: FLINK-285

[jira] [Created] (FLINK-28525) HiveDialectITCase.testTableWithSubDirsInPartitionDir failed with AssertJMultipleFailuresError

Huang Xingbo created FLINK-28525: Summary: HiveDialectITCase.testTableWithSubDirsInPartitionDir failed with AssertJMultipleFailuresError Key: FLINK-28525 URL: https://issues.apache.org/jira/browse/FLINK-28525

[jira] [Created] (FLINK-28523) LocalRecoveryITCase failed with AssertionError

Huang Xingbo created FLINK-28523: Summary: LocalRecoveryITCase failed with AssertionError Key: FLINK-28523 URL: https://issues.apache.org/jira/browse/FLINK-28523 Project: Flink Issue Type: Bu

[jira] [Created] (FLINK-28453) KafkaSourceLegacyITCase.testBrokerFailure hang on azure

Huang Xingbo created FLINK-28453: Summary: KafkaSourceLegacyITCase.testBrokerFailure hang on azure Key: FLINK-28453 URL: https://issues.apache.org/jira/browse/FLINK-28453 Project: Flink Issue

[jira] [Created] (FLINK-28440) EventTimeWindowCheckpointingITCase.testSlidingTimeWindow failed with restore

Huang Xingbo created FLINK-28440: Summary: EventTimeWindowCheckpointingITCase.testSlidingTimeWindow failed with restore Key: FLINK-28440 URL: https://issues.apache.org/jira/browse/FLINK-28440 Project:

[jira] [Created] (FLINK-28429) Reduce pyflink tests time

Huang Xingbo created FLINK-28429: Summary: Reduce pyflink tests time Key: FLINK-28429 URL: https://issues.apache.org/jira/browse/FLINK-28429 Project: Flink Issue Type: Improvement C

[jira] [Created] (FLINK-28426) PyFlink provides M1 wheel package

Huang Xingbo created FLINK-28426: Summary: PyFlink provides M1 wheel package Key: FLINK-28426 URL: https://issues.apache.org/jira/browse/FLINK-28426 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-28328) RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState failed with IllegalStateException

Huang Xingbo created FLINK-28328: Summary: RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState failed with IllegalStateException Key: FLINK-28328 URL: https://issues.apache.org/jira/browse/FLINK-2

[jira] [Created] (FLINK-28326) ResultPartitionTest.testIdleAndBackPressuredTime failed with AssertError

Huang Xingbo created FLINK-28326: Summary: ResultPartitionTest.testIdleAndBackPressuredTime failed with AssertError Key: FLINK-28326 URL: https://issues.apache.org/jira/browse/FLINK-28326 Project: Fli

[jira] [Created] (FLINK-28305) SQL Client end-to-end test failed with ElasticsearchException

Huang Xingbo created FLINK-28305: Summary: SQL Client end-to-end test failed with ElasticsearchException Key: FLINK-28305 URL: https://issues.apache.org/jira/browse/FLINK-28305 Project: Flink

[jira] [Created] (FLINK-28237) Improve the flink-ml python examples in doc

Huang Xingbo created FLINK-28237: Summary: Improve the flink-ml python examples in doc Key: FLINK-28237 URL: https://issues.apache.org/jira/browse/FLINK-28237 Project: Flink Issue Type: Impro

[jira] [Created] (FLINK-28195) Annotate Python3.6 as deprecated in PyFlink 1.16

Huang Xingbo created FLINK-28195: Summary: Annotate Python3.6 as deprecated in PyFlink 1.16 Key: FLINK-28195 URL: https://issues.apache.org/jira/browse/FLINK-28195 Project: Flink Issue Type:

[jira] [Created] (FLINK-28177) Elasticsearch6DynamicSinkITCase.testWritingDocumentsNoPrimaryKey failed with 503 Service Unavailable

Huang Xingbo created FLINK-28177: Summary: Elasticsearch6DynamicSinkITCase.testWritingDocumentsNoPrimaryKey failed with 503 Service Unavailable Key: FLINK-28177 URL: https://issues.apache.org/jira/browse/FLINK-28

[jira] [Created] (FLINK-28176) test_es_sink_dynamic failed in jdk11

Huang Xingbo created FLINK-28176: Summary: test_es_sink_dynamic failed in jdk11 Key: FLINK-28176 URL: https://issues.apache.org/jira/browse/FLINK-28176 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-28002) test_connectors.py failed with "object is not an instance of declaring class" in JDK11

Huang Xingbo created FLINK-28002: Summary: test_connectors.py failed with "object is not an instance of declaring class" in JDK11 Key: FLINK-28002 URL: https://issues.apache.org/jira/browse/FLINK-28002

[jira] [Created] (FLINK-28001) PlannerScalaFreeITCase.testImperativeUdaf failed with Permission denied

Huang Xingbo created FLINK-28001: Summary: PlannerScalaFreeITCase.testImperativeUdaf failed with Permission denied Key: FLINK-28001 URL: https://issues.apache.org/jira/browse/FLINK-28001 Project: Flin

[jira] [Created] (FLINK-27955) Fix the problem of windows installation failure in PyFlink

Huang Xingbo created FLINK-27955: Summary: Fix the problem of windows installation failure in PyFlink Key: FLINK-27955 URL: https://issues.apache.org/jira/browse/FLINK-27955 Project: Flink Is

[jira] [Created] (FLINK-27918) SavepointITCase.testStopWithSavepointFailingAfterSnapshotCreation failed with Expected RuntimeException after snapshot creation

Huang Xingbo created FLINK-27918: Summary: SavepointITCase.testStopWithSavepointFailingAfterSnapshotCreation failed with Expected RuntimeException after snapshot creation Key: FLINK-27918 URL: https://issues.apac

[jira] [Created] (FLINK-27917) PulsarUnorderedPartitionSplitReaderTest.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition failed with AssertionError

Huang Xingbo created FLINK-27917: Summary: PulsarUnorderedPartitionSplitReaderTest.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition failed with AssertionError Key: FLINK-27917 URL: https:/

[jira] [Created] (FLINK-27916) HybridSourceReaderTest.testReader failed with AssertionError

Huang Xingbo created FLINK-27916: Summary: HybridSourceReaderTest.testReader failed with AssertionError Key: FLINK-27916 URL: https://issues.apache.org/jira/browse/FLINK-27916 Project: Flink

[jira] [Created] (FLINK-27915) WindowJoinITCase.testInnerJoinOnWTFWithOffset failed with InterruptedException

Huang Xingbo created FLINK-27915: Summary: WindowJoinITCase.testInnerJoinOnWTFWithOffset failed with InterruptedException Key: FLINK-27915 URL: https://issues.apache.org/jira/browse/FLINK-27915 Projec

[jira] [Created] (FLINK-27883) KafkaSubscriberTest failed with NPC

Huang Xingbo created FLINK-27883: Summary: KafkaSubscriberTest failed with NPC Key: FLINK-27883 URL: https://issues.apache.org/jira/browse/FLINK-27883 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-27870) SemiAntiJoinStreamITCase. testAntiJoinWithTwoSidesRetraction failed with InterruptedException

Huang Xingbo created FLINK-27870: Summary: SemiAntiJoinStreamITCase. testAntiJoinWithTwoSidesRetraction failed with InterruptedException Key: FLINK-27870 URL: https://issues.apache.org/jira/browse/FLINK-27870

[jira] [Created] (FLINK-27869) AdaptiveSchedulerITCase. testStopWithSavepointFailOnStop failed with FAIL_ON_CHECKPOINT_COMPLETE

Huang Xingbo created FLINK-27869: Summary: AdaptiveSchedulerITCase. testStopWithSavepointFailOnStop failed with FAIL_ON_CHECKPOINT_COMPLETE Key: FLINK-27869 URL: https://issues.apache.org/jira/browse/FLINK-27869

[jira] [Created] (FLINK-27833) PulsarSourceITCase.testTaskManagerFailure failed with AssertionError

Huang Xingbo created FLINK-27833: Summary: PulsarSourceITCase.testTaskManagerFailure failed with AssertionError Key: FLINK-27833 URL: https://issues.apache.org/jira/browse/FLINK-27833 Project: Flink

[jira] [Created] (FLINK-27832) SplitAggregateITCase tests failed with Could not acquire the minimum required resources

Huang Xingbo created FLINK-27832: Summary: SplitAggregateITCase tests failed with Could not acquire the minimum required resources Key: FLINK-27832 URL: https://issues.apache.org/jira/browse/FLINK-27832

[jira] [Created] (FLINK-27792) WindowDistinctAggregateITCase. testTumbleWindow_Rollup failed with InterruptedException

Huang Xingbo created FLINK-27792: Summary: WindowDistinctAggregateITCase. testTumbleWindow_Rollup failed with InterruptedException Key: FLINK-27792 URL: https://issues.apache.org/jira/browse/FLINK-27792

[jira] [Created] (FLINK-27791) SlotCountExceedingParallelismTest tests failed with NoResourceAvailableException

Huang Xingbo created FLINK-27791: Summary: SlotCountExceedingParallelismTest tests failed with NoResourceAvailableException Key: FLINK-27791 URL: https://issues.apache.org/jira/browse/FLINK-27791 Proj

[jira] [Created] (FLINK-27776) Throws exception when udaf used in sliding window does not implement merge method in PyFlink

Huang Xingbo created FLINK-27776: Summary: Throws exception when udaf used in sliding window does not implement merge method in PyFlink Key: FLINK-27776 URL: https://issues.apache.org/jira/browse/FLINK-27776

[jira] [Created] (FLINK-27774) Window Agg doesn't work when used in Batch Table API

Huang Xingbo created FLINK-27774: Summary: Window Agg doesn't work when used in Batch Table API Key: FLINK-27774 URL: https://issues.apache.org/jira/browse/FLINK-27774 Project: Flink Issue Ty

[jira] [Created] (FLINK-27765) TaskManagerProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure failed with FlinkJobNotFoundException

Huang Xingbo created FLINK-27765: Summary: TaskManagerProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure failed with FlinkJobNotFoundException Key: FLINK-27765 URL: https://issues.apache.org/jira/bro

[jira] [Created] (FLINK-27764) SetOperatorsITCase tests failed

Huang Xingbo created FLINK-27764: Summary: SetOperatorsITCase tests failed Key: FLINK-27764 URL: https://issues.apache.org/jira/browse/FLINK-27764 Project: Flink Issue Type: Bug Com

[jira] [Created] (FLINK-27751) Scala suffix check failed

Huang Xingbo created FLINK-27751: Summary: Scala suffix check failed Key: FLINK-27751 URL: https://issues.apache.org/jira/browse/FLINK-27751 Project: Flink Issue Type: Bug Component

[jira] [Created] (FLINK-27745) ClientUtilsTest.uploadAndSetUserArtifacts failed with NoClassDefFoundError

Huang Xingbo created FLINK-27745: Summary: ClientUtilsTest.uploadAndSetUserArtifacts failed with NoClassDefFoundError Key: FLINK-27745 URL: https://issues.apache.org/jira/browse/FLINK-27745 Project: F

[jira] [Created] (FLINK-27744) CheckPubSubEmulatorTest.testPull failed with AssertionError

Huang Xingbo created FLINK-27744: Summary: CheckPubSubEmulatorTest.testPull failed with AssertionError Key: FLINK-27744 URL: https://issues.apache.org/jira/browse/FLINK-27744 Project: Flink

[jira] [Created] (FLINK-27716) Add Python API docs in ML

Huang Xingbo created FLINK-27716: Summary: Add Python API docs in ML Key: FLINK-27716 URL: https://issues.apache.org/jira/browse/FLINK-27716 Project: Flink Issue Type: Sub-task Comp

[jira] [Created] (FLINK-27715) Add more Python ML examples

Huang Xingbo created FLINK-27715: Summary: Add more Python ML examples Key: FLINK-27715 URL: https://issues.apache.org/jira/browse/FLINK-27715 Project: Flink Issue Type: Sub-task Co

[jira] [Created] (FLINK-27703) FileChannelManagerImplTest.testDirectoriesCleanupOnKillWithoutCallerHook failed with The marker file was not found within 10000 msecs

Huang Xingbo created FLINK-27703: Summary: FileChannelManagerImplTest.testDirectoriesCleanupOnKillWithoutCallerHook failed with The marker file was not found within 1 msecs Key: FLINK-27703 URL: https://issue

[jira] [Created] (FLINK-27701) HashMapStateBackendWindowITCase. testAggregateWindowStateReader failed with Not all required tasks are currently running

Huang Xingbo created FLINK-27701: Summary: HashMapStateBackendWindowITCase. testAggregateWindowStateReader failed with Not all required tasks are currently running Key: FLINK-27701 URL: https://issues.apache.org

[jira] [Created] (FLINK-27695) KafkaTransactionLogITCase failed on azure due to Could not find a valid Docker environment

Huang Xingbo created FLINK-27695: Summary: KafkaTransactionLogITCase failed on azure due to Could not find a valid Docker environment Key: FLINK-27695 URL: https://issues.apache.org/jira/browse/FLINK-27695

[jira] [Created] (FLINK-27691) RankHarnessTest. testUpdateRankWithRowNumberSortKeyDropsToNotLast test failed with result mismatch

Huang Xingbo created FLINK-27691: Summary: RankHarnessTest. testUpdateRankWithRowNumberSortKeyDropsToNotLast test failed with result mismatch Key: FLINK-27691 URL: https://issues.apache.org/jira/browse/FLINK-2769

[jira] [Created] (FLINK-27674) Elasticsearch6SinkE2ECase test hangs

Huang Xingbo created FLINK-27674: Summary: Elasticsearch6SinkE2ECase test hangs Key: FLINK-27674 URL: https://issues.apache.org/jira/browse/FLINK-27674 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-27602) Add docs in Python ML

Huang Xingbo created FLINK-27602: Summary: Add docs in Python ML Key: FLINK-27602 URL: https://issues.apache.org/jira/browse/FLINK-27602 Project: Flink Issue Type: Sub-task Componen

[jira] [Created] (FLINK-27575) Support PyFlink in Python3.9

Huang Xingbo created FLINK-27575: Summary: Support PyFlink in Python3.9 Key: FLINK-27575 URL: https://issues.apache.org/jira/browse/FLINK-27575 Project: Flink Issue Type: New Feature

  1   2   3   4   >