issues
Thread
Date
Earlier messages
Later messages
Messages by Thread
[jira] [Updated] (FLINK-39162) The data of the custom partitioner is corrupted when unaligned checkpoint is enabled
Rui Fan (Jira)
[jira] [Updated] (FLINK-39162) The data of the custom partitioner is corrupted when unaligned checkpoint is enabled
Rui Fan (Jira)
[jira] [Updated] (FLINK-39162) The data of the custom partitioner is corrupted when unaligned checkpoint is enabled
ASF GitHub Bot (Jira)
[jira] [Updated] (FLINK-39162) The data of the custom partitioner is corrupted when unaligned checkpoint is enabled
Roman Khachatryan (Jira)
[jira] [Updated] (FLINK-39162) The data of the custom partitioner is corrupted when unaligned checkpoint is enabled
Roman Khachatryan (Jira)
[jira] [Updated] (FLINK-39162) The data of the custom partitioner is corrupted when unaligned checkpoint is enabled
Roman Khachatryan (Jira)
[jira] [Created] (FLINK-39162) The data of the custom partitioner is corrupted during unaligned checkpoint
Rui Fan (Jira)
[jira] [Updated] (FLINK-39161) INTERVAL WEEK, QUARTER has wron math
Sergey Nuyanzin (Jira)
[jira] [Created] (FLINK-39161) INTERVAL WEEK, QUARTER has wron math
Sergey Nuyanzin (Jira)
[jira] [Commented] (FLINK-39160) [Runtime][Rpc][Metrics] Expose RPC response frame size and oversized-response rejection metrics
Arun Lakshman (Jira)
[jira] [Updated] (FLINK-39160) [runtime][rpc][metrics] Expose RPC response frame size and oversized-response rejection metrics
Arun Lakshman (Jira)
[jira] [Updated] (FLINK-39160) [runtime][rpc][metrics] Expose RPC response frame size and oversized-response rejection metrics
Arun Lakshman (Jira)
[jira] [Updated] (FLINK-39160) [Runtime][Rpc][Metrics] Expose RPC response frame size and oversized-response rejection metrics
Arun Lakshman (Jira)
[jira] [Created] (FLINK-39160) [runtime][rpc][metrics] Expose RPC response frame size and oversized-response rejection metrics
Arun Lakshman (Jira)
[PR] FLINK-39098 fixing test-case failure due to build server not supporting docker 1.33 api [flink-connector-mongodb]
via GitHub
Re: [PR] FLINK-39098 fixing test-case failure [flink-connector-mongodb]
via GitHub
Re: [PR] [FLINK-39098] Bump testcontainers version to fix CI [flink-connector-mongodb]
via GitHub
Re: [PR] [FLINK-39098] Bump testcontainers version to fix CI [flink-connector-mongodb]
via GitHub
Re: [PR] [FLINK-39098] Bump testcontainers version to fix CI [flink-connector-mongodb]
via GitHub
[jira] [Created] (FLINK-39159) Using KeyedProcessFunction in batch mode reads events out of order
Grzegorz Liter (Jira)
[PR] [FLINK-33634] Add Conditions to Flink CRD's Status field [flink-kubernetes-operator]
via GitHub
Re: [PR] [FLINK-33634] Add Conditions to Flink CRD's Status field [flink-kubernetes-operator]
via GitHub
Re: [PR] [FLINK-33634] Add Conditions to Flink CRD's Status field [flink-kubernetes-operator]
via GitHub
Re: [PR] [FLINK-33634] Add Conditions to Flink CRD's Status field [flink-kubernetes-operator]
via GitHub
Re: [PR] [FLINK-33634] Add Conditions to Flink CRD's Status field [flink-kubernetes-operator]
via GitHub
Re: [PR] [FLINK-33634] Add Conditions to Flink CRD's Status field [flink-kubernetes-operator]
via GitHub
Re: [PR] [FLINK-33634] Add Conditions to Flink CRD's Status field [flink-kubernetes-operator]
via GitHub
[PR] Bump io.airlift:aircompressor from 0.27 to 2.0.3 in /flink-runtime [flink]
via GitHub
Re: [PR] Bump io.airlift:aircompressor from 0.27 to 2.0.3 in /flink-runtime [flink]
via GitHub
Re: [PR] [FLINK-25538][Connectors/Kafka] Migration flink-connector-kafka from Junit4 to Junit5 [flink-connector-kafka]
via GitHub
Re: [PR] [FLINK-25538][Connectors/Kafka] Migration flink-connector-kafka from Junit4 to Junit5 [flink-connector-kafka]
via GitHub
[jira] [Updated] (FLINK-37951) Enable VariantSerializerUpgradeTest in Flink 2.2
ASF GitHub Bot (Jira)
[PR] [FLINK-37951] Enable VariantSerializerUpgradeTest [flink]
via GitHub
Re: [PR] [FLINK-37951] Enable VariantSerializerUpgradeTest [flink]
via GitHub
Re: [D] Community Sync - 2026 [flink-agents]
via GitHub
Re: [D] Community Sync - 2026 [flink-agents]
via GitHub
Re: [D] Community Sync - 2026 [flink-agents]
via GitHub
Re: [D] Community Sync - 2026 [flink-agents]
via GitHub
Re: [D] Community Sync - 2026 [flink-agents]
via GitHub
Re: [D] Community Sync - 2026 [flink-agents]
via GitHub
Re: [D] Community Sync - 2026 [flink-agents]
via GitHub
Re: [D] Planning Flink Agents 0.3 [flink-agents]
via GitHub
Re: [D] Planning Flink Agents 0.3 [flink-agents]
via GitHub
Re: [D] Planning Flink Agents 0.3 [flink-agents]
via GitHub
Re: [D] Planning Flink Agents 0.3 [flink-agents]
via GitHub
Re: [D] Planning Flink Agents 0.3 [flink-agents]
via GitHub
Re: [D] Planning Flink Agents 0.3 [flink-agents]
via GitHub
[jira] [Commented] (FLINK-39150) Join operator crashes jobs when using custom types or custom type serializers
Timo Walther (Jira)
[jira] [Commented] (FLINK-39150) Join operator crashes jobs when using custom types or custom type serializers
lincoln lee (Jira)
[jira] [Commented] (FLINK-39150) Join operator crashes jobs when using custom types or custom type serializers
Zhu Zhu (Jira)
[jira] [Commented] (FLINK-39150) Join operator crashes jobs when using custom types or custom type serializers
Lei Yang (Jira)
[jira] [Commented] (FLINK-39150) Join operator crashes jobs when using custom types or custom type serializers
Lei Yang (Jira)
[jira] [Commented] (FLINK-39150) Join operator crashes jobs when using custom types or custom type serializers
Piotr Przybylski (Jira)
[jira] [Commented] (FLINK-39150) Join operator crashes jobs when using custom types or custom type serializers
Lei Yang (Jira)
[jira] [Commented] (FLINK-39150) Join operator crashes jobs when using custom types or custom type serializers
Zhu Zhu (Jira)
[jira] [Commented] (FLINK-39150) Join operator crashes jobs when using custom types or custom type serializers
Lei Yang (Jira)
[jira] [Updated] (FLINK-39157) ColumnList has no hashCode/equals
ASF GitHub Bot (Jira)
[PR] [FLINK-39157][table-common] Add ColumnList.hashCode()/equals() [flink]
via GitHub
Re: [PR] [FLINK-39157][table-common] Add ColumnList.hashCode()/equals() [flink]
via GitHub
Re: [PR] [FLINK-39157][table-common] Add ColumnList.hashCode()/equals() [flink]
via GitHub
Re: [PR] [FLINK-39157][table-common] Add ColumnList.hashCode()/equals() [flink]
via GitHub
Re: [PR] [FLINK-39157][table-common] Add ColumnList.hashCode()/equals() [flink]
via GitHub
Re: [PR] [FLINK-39157][table-common] Add ColumnList.hashCode()/equals() [flink]
via GitHub
Re: [PR] [FLINK-39157][table-common] Add ColumnList.hashCode()/equals() [flink]
via GitHub
[jira] [Updated] (FLINK-39158) Minor polish for RestAPIStabilityTestUtils to reduce redundant lines
ASF GitHub Bot (Jira)
[PR] [FLINK-39158][runtime/test] Minor polish for RestAPIStabilityTestUtils to reduce redundant lines [flink]
via GitHub
Re: [PR] [FLINK-39158][runtime/test] Minor polish for RestAPIStabilityTestUtils to reduce redundant lines [flink]
via GitHub
[jira] [Created] (FLINK-39158) Minor polish for RestAPIStabilityTestUtils to reduce redundant lines
Yuepeng Pan (Jira)
[jira] [Created] (FLINK-39157) ColumnList has no hashCode/equals
Timo Walther (Jira)
[PR] Dynamodb client refresh [flink-connector-aws]
via GitHub
Re: [PR] Dynamodb client refresh [flink-connector-aws]
via GitHub
Re: [PR] Dynamodb client refresh [flink-connector-aws]
via GitHub
[PR] Dynamodb client refresh [flink-connector-aws]
via GitHub
Re: [PR] Dynamodb client refresh [flink-connector-aws]
via GitHub
[PR] Dynamodb client refresh [flink-connector-aws]
via GitHub
Re: [PR] Dynamodb client refresh [flink-connector-aws]
via GitHub
[jira] [Comment Edited] (FLINK-39139) Update lz4-java to 1.10.3
Rui Fan (Jira)
[jira] [Comment Edited] (FLINK-39139) Update lz4-java to 1.10.3
Rui Fan (Jira)
Re: [PR] [FLINK-39139] Update lz4-java to 1.10.3 [flink]
via GitHub
Re: [PR] [FLINK-39139] Update lz4-java to 1.10.3 [flink]
via GitHub
[jira] [Resolved] (FLINK-39139) Update lz4-java to 1.10.3
Rui Fan (Jira)
[PR] [hotfix][tests] Fix HistoryServerTest by adding delay to avoid identi… [flink]
via GitHub
Re: [PR] [hotfix][tests] Fix HistoryServerTest by adding delay to avoid identi… [flink]
via GitHub
Re: [PR] [FLINK-39164][history] Fix HistoryServerTest by adding delay to avoid identical archive timestamps [flink]
via GitHub
Re: [PR] [FLINK-38814][Connector/Kinesis] Kinesis Source in EFO - Fix idle consumer on subscription failure [flink-connector-aws]
via GitHub
Re: [PR] [FLINK-38814][Connector/Kinesis] Kinesis Source in EFO - Fix idle consumer on subscription failure [flink-connector-aws]
via GitHub
Re: [PR] [FLINK-38814][Connector/Kinesis] Kinesis Source in EFO - Fix idle consumer on subscription failure [flink-connector-aws]
via GitHub
Re: [PR] [FLINK-38814][Connector/Kinesis] Kinesis Source in EFO - Fix idle consumer on subscription failure [flink-connector-aws]
via GitHub
Re: [PR] [FLINK-38814][Connector/Kinesis] Kinesis Source in EFO - Fix idle consumer on subscription failure [flink-connector-aws]
via GitHub
Re: [PR] [FLINK-38814][Connector/Kinesis] Kinesis Source in EFO - Fix idle consumer on subscription failure [flink-connector-aws]
via GitHub
Re: [PR] [FLINK-38814][Connector/Kinesis] Kinesis Source in EFO - Fix idle consumer on subscription failure [flink-connector-aws]
via GitHub
Re: [PR] [FLINK-38814][Connector/Kinesis] Kinesis Source in EFO - Fix idle consumer on subscription failure [flink-connector-aws]
via GitHub
Re: [PR] [FLINK-38814][Connector/Kinesis] Kinesis Source in EFO - Fix idle consumer on subscription failure [flink-connector-aws]
via GitHub
[jira] [Reopened] (FLINK-39130) Allow native types to be used for MetricConfig
Rui Fan (Jira)
[jira] [Updated] (FLINK-39130) Allow native types to be used for MetricConfig
Rui Fan (Jira)
[jira] [Updated] (FLINK-39130) Allow native types to be used for MetricConfig
Rui Fan (Jira)
[jira] [Resolved] (FLINK-39130) Allow native types to be used for MetricConfig
Rui Fan (Jira)
[jira] [Assigned] (FLINK-39130) Allow native types to be used for MetricConfig
Rui Fan (Jira)
[jira] [Updated] (FLINK-38851) Support passing arbitrary database options to JDBC Catalog
Yuepeng Pan (Jira)
[jira] [Updated] (FLINK-38851) Support passing arbitrary database options to JDBC Catalog
Yuepeng Pan (Jira)
[jira] [Updated] (FLINK-38851) Support passing arbitrary database options to JDBC Catalog
Yuepeng Pan (Jira)
[jira] [Resolved] (FLINK-39001) [doc] Supplement the documentation with newlyaddedtable
Yanquan Lv (Jira)
[jira] [Updated] (FLINK-38850) Support PostgreSQL uuid type
Yuepeng Pan (Jira)
[jira] [Updated] (FLINK-38729) Bump Flink version of Flink CDC to 2.1 or 2.2
ASF GitHub Bot (Jira)
[PR] [FLINK-38729] Bump Flink version to 2.2.0 [flink-cdc]
via GitHub
Re: [PR] [FLINK-38729] Bump Flink version to 2.2.0 [flink-cdc]
via GitHub
[jira] [Created] (FLINK-39156) Document the changes
Dawid Wysakowicz (Jira)
[jira] [Created] (FLINK-39155) Add a check watermarks are defined in source for ERROR/NOTHING
Dawid Wysakowicz (Jira)
[jira] [Updated] (FLINK-39140) Enhance Unaligned Checkpoint ITCases to perform checkpointing during recovery
Rui Fan (Jira)
[jira] [Updated] (FLINK-39140) Enhance Unaligned Checkpoint ITCases to perform checkpointing during recovery
Rui Fan (Jira)
[jira] [Updated] (FLINK-39140) Enhance Unaligned Checkpoint ITCases to perform checkpointing during recovery
Rui Fan (Jira)
Re: [PR] [FLINK-34864][cdc-connector-mysql] Add the IgnoreNoPrimaryKeyTable parameter to skip tables without primary keys in multi-table synchronization [flink-cdc]
via GitHub
[jira] [Updated] (FLINK-39154) [Table/SQL] Support Async Batch Lookup Join (with Calc) for Temporal Table Join
featzhang (Jira)
[jira] [Updated] (FLINK-39154) [Table]Support Async Batch Lookup Join (with Calc) for Temporal Table Join
featzhang (Jira)
[jira] [Created] (FLINK-39154) [Table]Support Async Batch Lookup Join (with Calc) for Temporal Table Join
featzhang (Jira)
Re: [PR] [FLINK-39106] Support ROW and ARRAY<ROW> data types in DynamoDB API / SQL sink [flink-connector-aws]
via GitHub
Re: [PR] [FLINK-39106] Support ROW and ARRAY<ROW> data types in DynamoDB API / SQL sink [flink-connector-aws]
via GitHub
Re: [PR] [FLINK-39106] Support ROW and ARRAY<ROW> data types in DynamoDB API / SQL sink [flink-connector-aws]
via GitHub
Re: [PR] [FLINK-39001][doc][Flink-source]supple NewlyAddTable's doc with mongodb,postgres,oracle connectors [flink-cdc]
via GitHub
Re: [PR] [FLINK-39001][doc][Flink-source]supple NewlyAddTable's doc with mongodb,postgres,oracle connectors [flink-cdc]
via GitHub
Re: [PR] [FLINK-39001][doc][Flink-source]supple NewlyAddTable's doc with mongodb,postgres,oracle connectors [flink-cdc]
via GitHub
Re: [PR] [FLINK-39001][doc][Flink-source]supple NewlyAddTable's doc with mongodb,postgres,oracle connectors [flink-cdc]
via GitHub
[jira] [Closed] (FLINK-38978) Expose JM config for applications
Zhu Zhu (Jira)
[jira] [Closed] (FLINK-39133) DispatcherTest.testApplicationStatusChange_ThrowsIfDuplicateTerminalStatus fails on state exception
Zhu Zhu (Jira)
[jira] [Assigned] (FLINK-39133) DispatcherTest.testApplicationStatusChange_ThrowsIfDuplicateTerminalStatus fails on state exception
Zhu Zhu (Jira)
[PR] [FLINK-39124][test] Migrate remaining flink-tests to JUnit 5 [flink]
via GitHub
Re: [PR] [FLINK-39124][test] Migrate remaining flink-tests to JUnit 5 [flink]
via GitHub
Re: [PR] [FLINK-39124][test] Migrate remaining flink-tests to JUnit 5 [flink]
via GitHub
Re: [PR] [FLINK-39124][test] Migrate remaining flink-tests to JUnit 5 [flink]
via GitHub
Re: [PR] [FLINK-39124][test] Migrate remaining flink-tests to JUnit 5 [flink]
via GitHub
Re: [PR] [FLINK-39124][test] Migrate remaining flink-tests to JUnit 5 [flink]
via GitHub
Re: [PR] [FLINK-39124][test] Migrate remaining flink-tests to JUnit 5 [flink]
via GitHub
Re: [PR] [FLINK-39124][test] Migrate remaining flink-tests to JUnit 5 [flink]
via GitHub
Re: [PR] [FLINK-39124][test] Migrate remaining flink-tests to JUnit 5 [flink]
via GitHub
Re: [PR] [FLINK-39124][test] Migrate remaining flink-tests to JUnit 5 [flink]
via GitHub
[PR] [FLINK-39124][test] Migrate streaming and runtime ITCases to JUnit 5 [flink]
via GitHub
Re: [PR] [FLINK-39124][test] Migrate streaming and runtime ITCases to JUnit 5 [flink]
via GitHub
Re: [PR] [FLINK-39124][test] Migrate streaming and runtime ITCases to JUnit 5 [flink]
via GitHub
Re: [PR] [FLINK-39124][test] Migrate streaming and runtime ITCases to JUnit 5 [flink]
via GitHub
[PR] [FLINK-39124][test] Migrate checkpointing ITCases to JUnit 5 [flink]
via GitHub
Re: [PR] [FLINK-39124][test] Migrate checkpointing ITCases to JUnit 5 [flink]
via GitHub
Re: [PR] [FLINK-39124][test] Migrate checkpointing ITCases to JUnit 5 [flink]
via GitHub
Re: [PR] [FLINK-39124][test] Migrate checkpointing ITCases to JUnit 5 [flink]
via GitHub
Re: [PR] [FLINK-39124][test] Migrate checkpointing ITCases to JUnit 5 [flink]
via GitHub
[PR] [FLINK-39124][test] Migrate operator restore tests to JUnit 5 [flink]
via GitHub
Re: [PR] [FLINK-39124][test] Migrate operator restore tests to JUnit 5 [flink]
via GitHub
Re: [PR] [FLINK-39124][test] Migrate operator restore tests to JUnit 5 [flink]
via GitHub
[PR] [FLINK-39124][test] Migrate CancellingTestBase and StreamFaultToleranceTestBase to JUnit 5 [flink]
via GitHub
Re: [PR] [FLINK-39124][test] Migrate CancellingTestBase and StreamFaultToleranceTestBase to JUnit 5 [flink]
via GitHub
Re: [PR] [FLINK-39124][test] Migrate CancellingTestBase and StreamFaultToleranceTestBase to JUnit 5 [flink]
via GitHub
[jira] [Updated] (FLINK-39117) Flaky ChainUnionTest testMigrationAndRestore
ASF GitHub Bot (Jira)
[PR] [FLINK-39117] Fix flaky ChainUnionTest [flink]
via GitHub
Re: [PR] [FLINK-39117] Fix flaky ChainUnionTest [flink]
via GitHub
Re: [PR] [FLINK-39117] Fix flaky ChainUnionTest [flink]
via GitHub
Re: [PR] [FLINK-39117] Fix flaky ChainUnionTest [flink]
via GitHub
Re: [PR] [FLINK-39117] Fix flaky ChainUnionTest [flink]
via GitHub
Re: [PR] [FLINK-39117] Fix flaky ChainUnionTest [flink]
via GitHub
Re: [PR] [FLINK-39117] Fix flaky ChainUnionTest [flink]
via GitHub
[jira] [Resolved] (FLINK-39041) Rebuild REST API docs pages to supplement the missing content.
Yuepeng Pan (Jira)
[jira] [Created] (FLINK-39153) Add comprehensive performance metrics for PyFlink
Liu (Jira)
[D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
Re: [PR] [FLINK-39094][table-planner] Avoid creating duplicate function instances in code generation [flink]
via GitHub
Re: [PR] [FLINK-39094][table-planner] Avoid creating duplicate function instances in code generation [flink]
via GitHub
Re: [PR] [FLINK-39094][table-planner] Avoid creating duplicate function instances in code generation [flink]
via GitHub
[PR] [FLINK-39080][debug] test CI license behavior [flink-connector-kafka]
via GitHub
Re: [PR] [FLINK-39080] Introduce apache-rat check [flink-connector-kafka]
via GitHub
Re: [PR] Bump @angular/common from 20.1.3 to 20.3.14 in /flink-runtime-web/web-dashboard [flink]
via GitHub
Re: [PR] [FLINK-37932] Add UserAgent in GCS requests [flink]
via GitHub
Re: [PR] [FLINK-37932] Add UserAgent in GCS requests [flink]
via GitHub
[jira] [Assigned] (FLINK-39117) Flaky ChainUnionTest testMigrationAndRestore
Roman Khachatryan (Jira)
Earlier messages
Later messages