issues
Thread
Date
Earlier messages
Messages by Thread
Re: [PR] [FLINK-38733] Add new SplitterEnumerator on JdbcSource [flink-connector-jdbc]
via GitHub
Re: [PR] [FLINK-38866][flink-table-planner] Passing timestamp precision from window strategy to window operators to support non-compact BinaryRowData timestamps [flink]
via GitHub
Re: [PR] [FLINK-38866][flink-table-planner] Passing timestamp precision from window strategy to window operators to support non-compact BinaryRowData timestamps [flink]
via GitHub
Re: [PR] [FLINK-38866][flink-table-planner] Passing timestamp precision from window strategy to window operators to support non-compact BinaryRowData timestamps [flink]
via GitHub
[jira] [Closed] (FLINK-38916) MultiJoin produces incorrect results for OR join conditions when parallelism is greater than 1
Timo Walther (Jira)
Re: [PR] [FLINK-38242] Improve upgrading documentation for SQL/Table API state compatibility and add Flink 2.x to compatibility table [flink]
via GitHub
[jira] [Updated] (FLINK-39080) Missing license undetected by connector CI
ASF GitHub Bot (Jira)
[PR] [FLINK-39080][debug] main CI license behavior [flink]
via GitHub
Re: [PR] [FLINK-39080][debug] main CI license behavior [flink]
via GitHub
Re: [PR] [FLINK-39080][debug] main CI license behavior [flink]
via GitHub
[jira] [Comment Edited] (FLINK-39131) Multi-Input Processors
Salva (Jira)
[jira] [Comment Edited] (FLINK-39131) Multi-Input Processors
Salva (Jira)
[jira] [Comment Edited] (FLINK-39131) Multi-Input Processors
Salva (Jira)
[jira] [Comment Edited] (FLINK-39131) Multi-Input Processors
Salva (Jira)
[jira] [Comment Edited] (FLINK-39131) Multi-Input Processors
Salva (Jira)
[jira] [Commented] (FLINK-39131) Multi-Input Processors
Salva (Jira)
[jira] [Resolved] (FLINK-39107) OpenTelemetryEventReporterITCase fails with ContainerLaunch Container startup failed for image
Martijn Visser (Jira)
[PR] [hotfix][mcp][python] Check whether mcp server supports prompts via server capabilities [flink-agents]
via GitHub
[PR] [hotfix][doc] Use version 0.2.0 rather than 0.2-SNAPSHOT in maven dependency doc. [flink-agents]
via GitHub
[jira] [Commented] (FLINK-39139) Update lz4-java to 1.10.3
Cameron (Jira)
[jira] [Updated] (FLINK-39149) `gtid.new.channel.position=LATEST` Incorrectly Replays Pre-Checkpoint Transactions for Old Channels in Multi-Source Replication
Jia Fan (Jira)
[jira] [Updated] (FLINK-39149) `gtid.new.channel.position=LATEST` Incorrectly Replays Pre-Checkpoint Transactions for Old Channels in Multi-Source Replication
Jia Fan (Jira)
[jira] [Updated] (FLINK-39149) `gtid.new.channel.position=LATEST` Incorrectly Replays Pre-Checkpoint Transactions for Old Channels in Multi-Source Replication
Jia Fan (Jira)
[jira] [Created] (FLINK-39149) `gtid.new.channel.position=LATEST` Incorrectly Replays Pre-Checkpoint Transactions for Old Channels in Multi-Source Replication
Jia Fan (Jira)
[jira] [Commented] (FLINK-39146) Update log4j to 2.25.3
Cameron (Jira)
[jira] [Commented] (FLINK-39148) Update flink-connector-kafka & flink-sql-connector-kafka to 4.0.1-2.0
Shekhar Prasad Rajak (Jira)
[jira] [Commented] (FLINK-39147) Update Guava to 32.0.1
Shekhar Prasad Rajak (Jira)
[jira] [Commented] (FLINK-39147) Update Guava to 32.0.1
Cameron (Jira)
[jira] [Created] (FLINK-39148) Update flink-connector-kafka & flink-sql-connector-kafka to 4.0.1-2.0
Cameron (Jira)
[jira] [Created] (FLINK-39147) Update Guava to 32.0.1
Cameron (Jira)
[jira] [Created] (FLINK-39146) Update log4j to 2.25.3
Cameron (Jira)
[PR] [FLINK-38970] Fix flaky AdaptiveBatchSchedulerTest by using synchrono… [flink]
via GitHub
Re: [PR] [FLINK-38970] Fix flaky AdaptiveBatchSchedulerTest by using synchrono… [flink]
via GitHub
[PR] [FLINK-38727] Fix flaky test by adding slot request timeout configura… [flink]
via GitHub
Re: [PR] [FLINK-38727] Fix flaky test by adding slot request timeout configura… [flink]
via GitHub
[jira] [Commented] (FLINK-38287) Kafka 4.1.0 Queue Semantics support in Flink Connector Kafka
Shekhar Prasad Rajak (Jira)
[PR] [FLINK-39145][checkpointing] Account for already closed classloader during async operation failure [flink]
via GitHub
Re: [PR] [FLINK-39145][checkpointing] Account for already closed classloader during async operation failure [flink]
via GitHub
Re: [PR] [FLINK-39145][checkpointing] Account for already closed classloader during async operation failure [flink]
via GitHub
[PR] [hotfix] fixup typos in docs [flink-connector-http]
via GitHub
Re: [PR] [hotfix] fixup typos in docs [flink-connector-http]
via GitHub
[jira] [Assigned] (FLINK-39124) [JUnit5 Migration] Migrate the JUnit5 for Module: flink-tests
Yuepeng Pan (Jira)
[jira] [Updated] (FLINK-39124) [JUnit5 Migration] Migrate the JUnit5 for Module: flink-tests
Yuepeng Pan (Jira)
[jira] [Updated] (FLINK-39124) [JUnit5 Migration] Migrate the JUnit5 for Module: flink-tests
Yuepeng Pan (Jira)
[jira] [Updated] (FLINK-39145) UnalignedCheckpointITCase.execute fails - IllegalStateException: Trying to access closed classloader
Efrat Levitan (Jira)
[jira] [Updated] (FLINK-39145) UnalignedCheckpointITCase.execute fails - IllegalStateException: Trying to access closed classloader
Efrat Levitan (Jira)
[jira] [Updated] (FLINK-39145) UnalignedCheckpointITCase.execute fails - IllegalStateException: Trying to access closed classloader
ASF GitHub Bot (Jira)
[jira] [Resolved] (FLINK-38601) MongoDB CDC silently stops consuming from unbounded streams when Throwable errors occur and never recovers
Yanquan Lv (Jira)
[jira] [Resolved] (FLINK-39066) Fix fluss's metric histogram always return null
Yanquan Lv (Jira)
[jira] [Resolved] (FLINK-38596) The comment of the created MaxCompute table is incorrect
Yanquan Lv (Jira)
[PR] [FLINK-38244][hotfix] Fix the full snapshot phase, the field case is adjusted based on isTableIdCaseInsensitive [flink-cdc]
via GitHub
Re: [PR] [FLINK-38244][hotfix] Fix the full snapshot phase, the field case is adjusted based on isTableIdCaseInsensitive [flink-cdc]
via GitHub
[PR] [FLINK-39144][paimon] Fix ioManager close. [flink-cdc]
via GitHub
Re: [PR] [FLINK-39144][paimon] Fix ioManager close. [flink-cdc]
via GitHub
[jira] [Created] (FLINK-39145) UnalignedCheckpointITCase.execute fails - Could not acquire the minimum required resources.
Efrat Levitan (Jira)
[jira] [Assigned] (FLINK-38851) Support passing arbitrary database options to JDBC Catalog
Yuepeng Pan (Jira)
[jira] [Assigned] (FLINK-38970) AdaptiveBatchSchedulerTest is unstable
Roman Khachatryan (Jira)
[jira] [Assigned] (FLINK-38850) Support PostgreSQL uuid type
Yuepeng Pan (Jira)
[jira] [Assigned] (FLINK-38727) Unstable test cases EventTimeWindowCheckpointingITCase.testPreAggregatedSlidingTimeWindow
Roman Khachatryan (Jira)
[PR] [FLINK-39143][pipeline-connecotr][fluss]Optimize the connection of fluss when use FlussMetaDataApplier [flink-cdc]
via GitHub
Re: [PR] [FLINK-39143][pipeline-connecotr][Fluss]Optimize the connection of fluss when use FlussMetaDataApplier [flink-cdc]
via GitHub
Re: [PR] [FLINK-39143][pipeline-connecotr][Fluss]Optimize the connection of fluss when use FlussMetaDataApplier [flink-cdc]
via GitHub
Re: [PR] [FLINK-39143][pipeline-connecotr][Fluss]Optimize the connection of fluss when use FlussMetaDataApplier [flink-cdc]
via GitHub
Re: [PR] [FLINK-39143][pipeline-connecotr][Fluss]Optimize the connection of fluss when use FlussMetaDataApplier [flink-cdc]
via GitHub
Re: [PR] [FLINK-39143][pipeline-connecotr][Fluss]Optimize the connection of fluss when use FlussMetaDataApplier [flink-cdc]
via GitHub
Re: [PR] [FLINK-39143][pipeline-connecotr][Fluss]Optimize the connection of fluss when use FlussMetaDataApplier [flink-cdc]
via GitHub
[jira] [Updated] (FLINK-39144) fix IOManager not close
peiyu (Jira)
[jira] [Updated] (FLINK-39144) fix IOManager not close
ASF GitHub Bot (Jira)
[jira] [Created] (FLINK-39144) fix IOManager not close
peiyu (Jira)
[jira] [Closed] (FLINK-39084) Variant Field accesor helper methods
Gyula Fora (Jira)
[jira] [Updated] (FLINK-39124) [JUnit5 Migration] Module: flink-tests
ASF GitHub Bot (Jira)
[PR] [FLINK-39124] Update flink-tests to JUnit5 [flink]
via GitHub
Re: [PR] [FLINK-39124] Update flink-tests to JUnit5 [flink]
via GitHub
Re: [PR] [FLINK-39124] Update flink-tests to JUnit5 [flink]
via GitHub
Re: [PR] [FLINK-39124] Update flink-tests to JUnit5 [flink]
via GitHub
[jira] [Updated] (FLINK-39143) It is better to use a transient connection for fluss's connection
Thorne (Jira)
[jira] [Updated] (FLINK-39143) It is better to use a transient connection for fluss's connection
ASF GitHub Bot (Jira)
[jira] [Commented] (FLINK-39137) Add configurable delay between non-empty GetRecords calls in Kinesis source
Andreas Bube (Jira)
Re: [PR] [FLINK-37247][FileSystems][Tests] Implement common Hadoop file system integration tests for GCS. [flink]
via GitHub
Re: [PR] [FLINK-37328][FileSystems] Upgrade GCS connector to 2.2.26. [flink]
via GitHub
[jira] [Commented] (FLINK-38970) AdaptiveBatchSchedulerTest is unstable
Shekhar Prasad Rajak (Jira)
[jira] [Commented] (FLINK-38970) AdaptiveBatchSchedulerTest is unstable
Roman Khachatryan (Jira)
[jira] [Updated] (FLINK-39143) It is better to use a connection pool for fluss's connections
Thorne (Jira)
[jira] [Updated] (FLINK-39143) It is better to use a connection pool for fluss's connections
Thorne (Jira)
[jira] (FLINK-39143) fluss‘s connection use connection pool be better
Thorne (Jira)
[jira] [Updated] (FLINK-39143) fluss‘s connection use connection pool be better
Thorne (Jira)
[jira] [Commented] (FLINK-39143) fluss‘s connection use connection pool be better
Thorne (Jira)
[jira] [Created] (FLINK-39143) fluss‘s connection use connection pool be better
Thorne (Jira)
[PR] [FLINK-38978][runtime] Expose JM config for applications [flink]
via GitHub
Re: [PR] [FLINK-38978][runtime] Expose JM config for applications [flink]
via GitHub
[jira] [Updated] (FLINK-38978) Expose JM config for applications
Yi Zhang (Jira)
[jira] [Updated] (FLINK-38978) Expose JM config for applications
ASF GitHub Bot (Jira)
[PR] Expose exceptions for applications [flink]
via GitHub
Re: [PR] [FLINK-38977][runtime] Expose exceptions for applications [flink]
via GitHub
[jira] [Updated] (FLINK-38977) Expose exceptions for applications
Yi Zhang (Jira)
[jira] [Updated] (FLINK-38977) Expose exceptions for applications
ASF GitHub Bot (Jira)
[jira] [Updated] (FLINK-38973) Job ID assignment and matching based on name
Yi Zhang (Jira)
[PR] [FLINK-39133][runtime] Fix DispatcherTest to properly handle async op… [flink]
via GitHub
Re: [PR] [FLINK-39133][runtime] Fix DispatcherTest to properly handle async op… [flink]
via GitHub
[PR] [FLINK-39066][pipeline-connector][Fluss] fix the metric histogram always return null [flink-cdc]
via GitHub
Re: [PR] [FLINK-39066][pipeline-connector][Fluss] fix the metric histogram always return null [flink-cdc]
via GitHub
[jira] [Commented] (FLINK-38828) PostTransformOperator needs to detect dynamic projection updates when restarting from checkpoint/savepoint
Vinay Sagar Gonabavi (Jira)
[jira] [Commented] (FLINK-38828) PostTransformOperator needs to detect dynamic projection updates when restarting from checkpoint/savepoint
Vinay Sagar Gonabavi (Jira)
[jira] [Updated] (FLINK-38828) PostTransformOperator needs to detect dynamic projection updates when restarting from checkpoint/savepoint
ASF GitHub Bot (Jira)
[PR] [FLINK-38828][cdc-runtime] Add state persistence to PostTransformOperator for projection schema evolution [flink-cdc]
via GitHub
[jira] [Updated] (FLINK-38830) PreTransformOperator needs to avoid crashing with "Field names must be unique" error and handle processing a duplicate AddColumnEvent better
ASF GitHub Bot (Jira)
[PR] [FLINK-38830][runtime] Handle duplicate AddColumnEvent gracefully to prevent pipeline crashes [flink-cdc]
via GitHub
[jira] [Commented] (FLINK-38830) PreTransformOperator needs to avoid crashing with "Field names must be unique" error and handle processing a duplicate AddColumnEvent better
Vinay Sagar Gonabavi (Jira)
[jira] [Commented] (FLINK-38830) PreTransformOperator needs to avoid crashing with "Field names must be unique" error and handle processing a duplicate AddColumnEvent better
Vinay Sagar Gonabavi (Jira)
[jira] [Created] (FLINK-39142) Support AWS Glue Schema Registry Protobuf for Table API
Francisco Morillo (Jira)
[PR] [BP-2.2][FLINK-38624][table] Type Mismatch Exception in StreamPhysicalOverAggregateRule [flink]
via GitHub
Re: [PR] [BP-2.2][FLINK-38624][table] Type Mismatch Exception in StreamPhysicalOverAggregateRule [flink]
via GitHub
[jira] [Created] (FLINK-39141) Support AWS Glue Schema Registry JSON for Table API
Francisco Morillo (Jira)
[PR] [BP-2.0][FLINK-38624][table] Type Mismatch Exception in StreamPhysicalOverAggregateRule [flink]
via GitHub
Re: [PR] [BP-2.0][FLINK-38624][table] Type Mismatch Exception in StreamPhysicalOverAggregateRule [flink]
via GitHub
[jira] [Commented] (FLINK-38162) Use of SQL functions with time attributes causes downstream temporal functions to fail
Sergey Nuyanzin (Jira)
[jira] [Commented] (FLINK-38807) Add state SQL metadata based type inference
Gabor Somogyi (Jira)
[jira] [Closed] (FLINK-38807) Add state SQL metadata based type inference
Gabor Somogyi (Jira)
[jira] [Resolved] (FLINK-38807) Add state SQL metadata based type inference
Gabor Somogyi (Jira)
[PR] [FLINK-24379] Add Glue Schema Registry Avro SQL format factory [flink-connector-aws]
via GitHub
[jira] [Commented] (FLINK-39123) ValueLiteralExpression.asSerializableString has problems with TIMESTAMP_LTZ(9)
Rion Williams (Jira)
[jira] [Comment Edited] (FLINK-39123) ValueLiteralExpression.asSerializableString has problems with TIMESTAMP_LTZ(9)
Rion Williams (Jira)
[PR] [FLINK-39123][table] [flink]
via GitHub
Re: [PR] [FLINK-39123][table] [flink]
via GitHub
Re: [PR] [FLINK-39123][table] Updated ValueLiteralExpression Support for Larger Precision TIMESTAMP_LTZ Instances [flink]
via GitHub
Re: [PR] [FLINK-39123][table] Updated ValueLiteralExpression Support for Larger Precision TIMESTAMP_LTZ Instances [flink]
via GitHub
Re: [PR] [FLINK-39123][table] Updated ValueLiteralExpression Support for Larger Precision TIMESTAMP_LTZ Instances [flink]
via GitHub
[jira] [Resolved] (FLINK-38624) Flink 2.1 Job Failure: Type Mismatch Exception in StreamPhysicalOverAggregateRule (TIMESTAMP(3) vs TIMESTAMP(3) ROWTIME)
Sergey Nuyanzin (Jira)
[jira] [Created] (FLINK-39140) Enhance Unaligned Checkpoint ITCases to perform checkpointing during recovery
Rui Fan (Jira)
[jira] [Updated] (FLINK-39139) Update lz4-java to 1.10.3
Cameron (Jira)
[jira] [Created] (FLINK-39139) Update lz4-java to 1.10.3
Cameron (Jira)
[PR] [wip] BYTES -> STRING's non-injectivity for invalid UTF-8 bytes input [flink]
via GitHub
Re: [PR] [wip] BYTES -> STRING's non-injectivity for invalid UTF-8 bytes input [flink]
via GitHub
Re: [PR] [wip] BYTES -> STRING's non-injectivity for invalid UTF-8 bytes input [flink]
via GitHub
Re: [PR] [wip] BYTES -> STRING's non-injectivity for invalid UTF-8 bytes input [flink]
via GitHub
Re: [PR] [FLINK-38742][cdc-pipeline/postgres] Fix timestamp with time zone [flink-cdc]
via GitHub
[PR] Update CI for Flink Connector Parent POM 2.0 compatibility [flink-connector-shared-utils]
via GitHub
[jira] [Resolved] (FLINK-38999) License lineage files
Arvid Heise (Jira)
[jira] [Commented] (FLINK-38999) License lineage files
Arvid Heise (Jira)
[jira] [Resolved] (FLINK-29245) [JUnit 5 Migration] Remove RetryRule
Rui Fan (Jira)
[jira] [Closed] (FLINK-39121) kafka connector CI test timeout due to "/tmp/testcontainers_start.sh: Text file busy"
Roman Khachatryan (Jira)
[jira] [Updated] (FLINK-39121) kafka connector CI test timeout due to "/tmp/testcontainers_start.sh: Text file busy"
ASF GitHub Bot (Jira)
[jira] [Updated] (FLINK-39121) kafka connector CI test timeout due to "/tmp/testcontainers_start.sh: Text file busy"
Roman Khachatryan (Jira)
[jira] [Updated] (FLINK-39138) Update Flink Connector Kafka to Flink Connector Parent POM 2.0
ASF GitHub Bot (Jira)
[PR] [FLINK-39138] Update to flink connector parent pom version 2.0 [flink-connector-kafka]
via GitHub
Re: [PR] [FLINK-39138] Update to flink connector parent pom version 2.0 [flink-connector-kafka]
via GitHub
Re: [PR] [FLINK-39138] Update to flink connector parent pom version 2.0 [flink-connector-kafka]
via GitHub
Re: [PR] [FLINK-39138] Update to flink connector parent pom version 2.0 [flink-connector-kafka]
via GitHub
Re: [PR] [FLINK-39138] Update to flink connector parent pom version 2.0 [flink-connector-kafka]
via GitHub
[jira] [Created] (FLINK-39138) Update Flink Connector Kafka to Flink Connector Parent POM 2.0
Thomas Cooper (Jira)
[jira] [Commented] (FLINK-39136) GS file system fails to retry on certain 503's due to old GCS lib dependency
Martijn Visser (Jira)
[jira] [Assigned] (FLINK-38624) Flink 2.1 Job Failure: Type Mismatch Exception in StreamPhysicalOverAggregateRule (TIMESTAMP(3) vs TIMESTAMP(3) ROWTIME)
Timo Walther (Jira)
[jira] [Commented] (FLINK-39088) Preserve upsert keys for explicit (injective) CAST calls to avoid unnecessary SinkUpsertMaterializer
Timo Walther (Jira)
[jira] [Updated] (FLINK-39137) Add configurable delay between non-empty GetRecords calls in Kinesis source
Andreas Bube (Jira)
[jira] [Created] (FLINK-39137) Add configurable delay between non-empty GetRecords calls in Kinesis source
Andreas Bube (Jira)
[jira] [Commented] (FLINK-38764) switch lz4-java to at.yawk.lz4 version due to CVE
Piotr Nowojski (Jira)
[jira] [Updated] (FLINK-38764) switch lz4-java to at.yawk.lz4 version due to CVE
Piotr Nowojski (Jira)
[jira] [Commented] (FLINK-39133) DispatcherTest.testApplicationStatusChange_ThrowsIfDuplicateTerminalStatus fails on state exception
Matthias Pohl (Jira)
[jira] [Commented] (FLINK-39133) DispatcherTest.testApplicationStatusChange_ThrowsIfDuplicateTerminalStatus fails on state exception
Yi Zhang (Jira)
[jira] [Commented] (FLINK-39133) DispatcherTest.testApplicationStatusChange_ThrowsIfDuplicateTerminalStatus fails on state exception
Martijn Visser (Jira)
[jira] [Updated] (FLINK-39133) DispatcherTest.testApplicationStatusChange_ThrowsIfDuplicateTerminalStatus fails on state exception
Matthias Pohl (Jira)
[jira] [Updated] (FLINK-39133) DispatcherTest.testApplicationStatusChange_ThrowsIfDuplicateTerminalStatus fails on state exception
ASF GitHub Bot (Jira)
Re: [PR] [FLINK-38276][cdc-common] PaimonWriter does not invalidate cache when… [flink-cdc]
via GitHub
Re: [PR] [FLINK-38276][cdc-common] PaimonWriter does not invalidate cache when… [flink-cdc]
via GitHub
[jira] [Updated] (FLINK-39136) GS file system fails to retry on certain 503's due to old GCS lib dependency
Jon Chase (Jira)
[jira] [Created] (FLINK-39136) GS file system fails to retry on certain 503's due to old GCS lib dependency
Jon Chase (Jira)
[jira] [Created] (FLINK-39135) Backport GSBlobStorageImpl precondition check to 1.20.4
Jon Chase (Jira)
[jira] [Assigned] (FLINK-39134) UnalignedCheckpointFailureHandlingITCase.testCheckpointSuccessAfterFailure is flaky
Roman Khachatryan (Jira)
[jira] [Commented] (FLINK-39134) UnalignedCheckpointFailureHandlingITCase.testCheckpointSuccessAfterFailure is flaky
Martijn Visser (Jira)
[jira] [Commented] (FLINK-39134) UnalignedCheckpointFailureHandlingITCase.testCheckpointSuccessAfterFailure is flaky
Efrat Levitan (Jira)
[jira] [Created] (FLINK-39134) UnalignedCheckpointFailureHandlingITCase.testCheckpointSuccessAfterFailure is flaky
Martijn Visser (Jira)
[jira] [Commented] (FLINK-39107) OpenTelemetryEventReporterITCase fails with ContainerLaunch Container startup failed for image
Martijn Visser (Jira)
[jira] [Updated] (FLINK-38971) Migrate ExpandWindowTableFunctionTransposeRule
ASF GitHub Bot (Jira)
[PR] [FLINK-38971][table] Migrate ExpandWindowTableFunctionTransposeRule t… [flink]
via GitHub
Re: [PR] [FLINK-38971][table] Migrate ExpandWindowTableFunctionTransposeRule t… [flink]
via GitHub
Re: [PR] [FLINK-38971][table] Migrate ExpandWindowTableFunctionTransposeRule t… [flink]
via GitHub
Re: [PR] [FLINK-38971][table] Migrate ExpandWindowTableFunctionTransposeRule t… [flink]
via GitHub
[PR] [FLINK-39073][tests] Retry kafka containers startup [flink-connector-kafka]
via GitHub
Re: [PR] [FLINK-39121][tests] Retry kafka containers startup [flink-connector-kafka]
via GitHub
Re: [PR] [FLINK-38525][python] Fix coder doesn't process TIMESTAMP_LTZ correctly [flink]
via GitHub
Re: [PR] [FLINK-38525][python] Fix coder doesn't process TIMESTAMP_LTZ correctly [flink]
via GitHub
Re: [PR] [FLINK-36753] Adaptive Scheduler actively triggers a Checkpoint [flink]
via GitHub
Re: [PR] [FLINK-36753] Adaptive Scheduler actively triggers a Checkpoint [flink]
via GitHub
[I] [Feature] Runtime reloading for MCP tools and prompts [flink-agents]
via GitHub
Re: [I] [Feature] Runtime reloading for MCP tools and prompts [flink-agents]
via GitHub
[PR] [plan] Extract ResourceCache and PythonResourceBridge from AgentPlan [flink-agents]
via GitHub
Re: [PR] [plan] Extract ResourceCache and PythonResourceBridge from AgentPlan [flink-agents]
via GitHub
[I] [Tech Debt] Refactor AgentPlan & ResourceCache [flink-agents]
via GitHub
[PR] [runtime] Refactor ActionExecutionOperator into focused manager classes [flink-agents]
via GitHub
[I] [Tech Debt] Refactor ActionExecutionOperator into focused manager classes [flink-agents]
via GitHub
[jira] [Updated] (FLINK-38403) UnalignedCheckpointITCase failed in test_cron_hadoop313 tests
Rui Fan (Jira)
Re: [PR] [FLINK-38807][state] Add state SQL metadata based type inference [flink]
via GitHub
Re: [PR] [FLINK-38807][state] Add state SQL metadata based type inference [flink]
via GitHub
Re: [PR] [FLINK-38807][state] Add state SQL metadata based type inference [flink]
via GitHub
Re: [PR] [FLINK-38807][state] Add state SQL metadata based type inference [flink]
via GitHub
Re: [PR] [FLINK-38807][state] Add state SQL metadata based type inference [flink]
via GitHub
Re: [PR] [FLINK-38807][state] Add state SQL metadata based type inference [flink]
via GitHub
Re: [PR] [FLINK-38807][state] Add state SQL metadata based type inference [flink]
via GitHub
Re: [PR] [FLINK-38807][state] Add state SQL metadata based type inference [flink]
via GitHub
Re: [PR] [FLINK-38807][state] Add state SQL metadata based type inference [flink]
via GitHub
Earlier messages