[jira] [Created] (FLINK-22198) org.apache.flink.streaming.connectors.kafka.table.KafkaTableITCase hang.

Guowei Ma created FLINK-22198: - Summary: org.apache.flink.streaming.connectors.kafka.table.KafkaTableITCase hang. Key: FLINK-22198 URL: https://issues.apache.org/jira/browse/FLINK-22198 Project: Flink

[jira] [Created] (FLINK-22197) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fail due to NoSuchFileException

Guowei Ma created FLINK-22197: - Summary: UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fail due to NoSuchFileException Key: FLINK-22197 URL: https://issues.apache.org/jira/browse/FLINK-22197

[jira] [Created] (FLINK-22196) FlinkRelMdUniqueKeys#getTableUniqueKeys should filter out the column indices which the does not exist

Lsw_aka_laplace created FLINK-22196: --- Summary: FlinkRelMdUniqueKeys#getTableUniqueKeys should filter out the column indices which the does not exist Key: FLINK-22196 URL: https://issues.apache.org/jira/browse/F

[jira] [Created] (FLINK-22195) YARNHighAvailabilityITCase.testClusterClientRetrieval because of TestTimedOutException

Guowei Ma created FLINK-22195: - Summary: YARNHighAvailabilityITCase.testClusterClientRetrieval because of TestTimedOutException Key: FLINK-22195 URL: https://issues.apache.org/jira/browse/FLINK-22195 Proj

[jira] [Created] (FLINK-22194) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers fail due to commit timeout

Guowei Ma created FLINK-22194: - Summary: KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers fail due to commit timeout Key: FLINK-22194 URL: https://issues.apache.org/jira/browse/FLINK-22194 Pro

[jira] [Created] (FLINK-22193) HiveTableSinkITCase.testNonPartStreamingMrWrite fail

Guowei Ma created FLINK-22193: - Summary: HiveTableSinkITCase.testNonPartStreamingMrWrite fail Key: FLINK-22193 URL: https://issues.apache.org/jira/browse/FLINK-22193 Project: Flink Issue Type: Bu

[jira] [Created] (FLINK-22192) HiveTableSinkITCase.testDefaultSerPartStreamingWrite fail

Guowei Ma created FLINK-22192: - Summary: HiveTableSinkITCase.testDefaultSerPartStreamingWrite fail Key: FLINK-22192 URL: https://issues.apache.org/jira/browse/FLINK-22192 Project: Flink Issue Typ

[jira] [Created] (FLINK-22191) PyFlinkStreamUserDefinedFunctionTests.test_udf_in_join_condition_2 fail due to NPE

Guowei Ma created FLINK-22191: - Summary: PyFlinkStreamUserDefinedFunctionTests.test_udf_in_join_condition_2 fail due to NPE Key: FLINK-22191 URL: https://issues.apache.org/jira/browse/FLINK-22191 Project

Using FileSystem SQL Connector to Commit Hive Partition Exception

https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/connectors/filesystem.html Here is my code: my datastream source: ``` public static class MySource implements SourceFunction{ String

[jira] [Created] (FLINK-22190) no guarantee on Flink exactly_once sink to Kafka

Spongebob created FLINK-22190: - Summary: no guarantee on Flink exactly_once sink to Kafka Key: FLINK-22190 URL: https://issues.apache.org/jira/browse/FLINK-22190 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-22189) Flink SQL Client Hudi batch write crashes JobManager

Phil Chen created FLINK-22189: - Summary: Flink SQL Client Hudi batch write crashes JobManager Key: FLINK-22189 URL: https://issues.apache.org/jira/browse/FLINK-22189 Project: Flink Issue Type: Bu

[jira] [Created] (FLINK-22188) Flink SQL Client Error running SQL job

Phil Chen created FLINK-22188: - Summary: Flink SQL Client Error running SQL job Key: FLINK-22188 URL: https://issues.apache.org/jira/browse/FLINK-22188 Project: Flink Issue Type: Bug Co

[jira] [Created] (FLINK-22187) Remove description of sync checkpoint mode of HashMapStateBackend

Yun Tang created FLINK-22187: Summary: Remove description of sync checkpoint mode of HashMapStateBackend Key: FLINK-22187 URL: https://issues.apache.org/jira/browse/FLINK-22187 Project: Flink Is

Re: [DISCUSS] Support registering custom JobStatusListeners when scheduling a job

Hi Till, Thanks for taking time out of your busy schedule. I have created a POC for this feature. The code change for the Flink source code will be like this commit: https://github.com/predatorray/flink/commit/2cab8bb1119162213632db984d2eb7529b8140e7 Generally, the idea is that custom `JobStatusL

[jira] [Created] (FLINK-22186) Standalone webUI Internal server error flink.client.program.PackagedProgram.close()V

刘虎 created FLINK-22186: -- Summary: Standalone webUI Internal server error flink.client.program.PackagedProgram.close()V Key: FLINK-22186 URL: https://issues.apache.org/jira/browse/FLINK-22186 Project: Flink