issues  

Messages by Thread

• • Re: [PR] [FLINK-39026][runtime] Remove misleading TODO about getPartitionedState overhead [flink] via GitHub
• Re: [PR] [hotfix] [docs] Rework 'Name and Description' section of operators overview to improve grammar and clarity [flink] via GitHub
  • Re: [PR] [hotfix] [docs] Rework 'Name and Description' section of operators overview to improve grammar and clarity [flink] via GitHub
• Re: [PR] [FLINK-38566] Support CEP DSL [flink] via GitHub
  • Re: [PR] [FLINK-38566] Support CEP DSL [flink] via GitHub
• Re: [PR] Fix the conversion to relational algebra issue in Batch Mode [flink] via GitHub
  • Re: [PR] Fix the conversion to relational algebra issue in Batch Mode [flink] via GitHub
• Re: [PR] [FLINK-38584][metrics] Support checkpoint path as Prometheus info-style metric [flink] via GitHub
  • Re: [PR] [FLINK-38584][metrics] Support checkpoint path as Prometheus info-style metric [flink] via GitHub
• Re: [PR] [FLINK-37730][rest] Add client method for getting JM exception history [flink] via GitHub
  • Re: [PR] [FLINK-37730][rest] Add client method for getting JM exception history [flink] via GitHub
• Re: [PR] [hotfix] Tracks the number of pending manual compactions. [flink] via GitHub
  • Re: [PR] [hotfix] Tracks the number of pending manual compactions. [flink] via GitHub
• Re: [PR] [FLINK-38444][table] Join unique keys should not contain null values [flink] via GitHub
  • Re: [PR] [FLINK-38444][table] Join unique keys should not contain null values [flink] via GitHub
• Re: [PR] [hotfix] Adds Override annotation [flink] via GitHub
  • Re: [PR] [hotfix] Adds Override annotation [flink] via GitHub
• Re: [PR] [FLINK-38057][runtime] Fix the error value between getting and using idleStartTime in source reader metric group [flink] via GitHub
  • Re: [PR] [FLINK-38057][runtime] Fix the error value between getting and using idleStartTime in source reader metric group [flink] via GitHub
• Re: [PR] [hotfix]Adds Override annotation [flink] via GitHub
  • Re: [PR] [hotfix]Adds Override annotation [flink] via GitHub
• Re: [PR] [FLINK-37771] Simplify getPartitionedState of AbstractKeyedStateBackend [flink] via GitHub
  • Re: [PR] [FLINK-37771] Simplify getPartitionedState of AbstractKeyedStateBackend [flink] via GitHub
• Re: [PR] [FLINK-37746] Added serialVersionUID in MapTypeInfo class [flink] via GitHub
  • Re: [PR] [FLINK-37746] Added serialVersionUID in MapTypeInfo class [flink] via GitHub
• Re: [PR] [FLINK-36808][table-planner] Fix LookupJoin bug when used with filterable table source [flink] via GitHub
  • Re: [PR] [FLINK-36808][table-planner] Fix LookupJoin bug when used with filterable table source [flink] via GitHub
• Re: [PR] [FLINK-37716] Simplify YarnClusterDescriptor by removing parameter JobGraph [flink] via GitHub
  • Re: [PR] [FLINK-37716] Simplify YarnClusterDescriptor by removing parameter JobGraph [flink] via GitHub
• Re: [PR] [FLINK-37608][fs-connector] File sink supports to close buckets in parallel when snapshot [flink] via GitHub
  • Re: [PR] [FLINK-37608][fs-connector] File sink supports to close buckets in parallel when snapshot [flink] via GitHub
• Re: [PR] [hotfix] Avoid invalid thread for state reader [flink] via GitHub
  • Re: [PR] [hotfix] Avoid invalid thread for state reader [flink] via GitHub
• Re: [PR] [FLINK-37666]: Address CWE-378: Creation of Temporary File With Insec… [flink] via GitHub
  • Re: [PR] [FLINK-37666]: Address CWE-378: Creation of Temporary File With Insec… [flink] via GitHub
• Re: [PR] [FLINK-37521][table] Implement Proc/RowTimeIntervalJoin with async state [flink] via GitHub
  • Re: [PR] [FLINK-37521][table] Implement Proc/RowTimeIntervalJoin with async state [flink] via GitHub
• Re: [PR] [FLINK-37661] Remove Kryo serializer reference data from version 1.x [flink] via GitHub
  • Re: [PR] [FLINK-37661] Remove Kryo serializer reference data from version 1.x [flink] via GitHub
• Re: [PR] [FLINK-35571][test] Can pass global test [flink] via GitHub
  • Re: [PR] [FLINK-35571][test] Can pass global test [flink] via GitHub
• Re: [PR] [FLINK-37655][runtime] Convert WindowStagger into an interface [flink] via GitHub
  • Re: [PR] [FLINK-37655][runtime] Convert WindowStagger into an interface [flink] via GitHub
• Re: [PR] [hotfix] Rename loadJarFile to checkJarFile [flink] via GitHub
  • Re: [PR] [hotfix] Rename loadJarFile to checkJarFile [flink] via GitHub
• Re: [PR] [FLINK-37637] Avoid dead lock for Configuration's addAll [flink] via GitHub
  • Re: [PR] [FLINK-37637] Avoid dead lock for Configuration's addAll [flink] via GitHub
• Re: [PR] [hotfix] Remove the redundant config for execution target [flink] via GitHub
  • Re: [PR] [hotfix] Remove the redundant config for execution target [flink] via GitHub
• [PR] [integrations][mcp] Read MCP server timeout from the "timeout" descriptor argument [flink-agents] via GitHub
  • Re: [PR] [integrations][mcp] Read MCP server timeout from the "timeout" descriptor argument [flink-agents] via GitHub
  • Re: [PR] [integrations][mcp] Read MCP server timeout from the "timeout" descriptor argument [flink-agents] via GitHub
  • Re: [PR] [integrations][mcp] Read MCP server timeout from the "timeout" descriptor argument [flink-agents] via GitHub
• [I] [Bug] Java MCPServer ignores the "timeout" ResourceDescriptor argument, always uses 30s default [flink-agents] via GitHub
  • Re: [I] [Bug] Java MCPServer ignores the "timeout" ResourceDescriptor argument, always uses 30s default [flink-agents] via GitHub
  • Re: [I] [Bug] Java MCPServer ignores the "timeout" ResourceDescriptor argument, always uses 30s default [flink-agents] via GitHub
  • Re: [I] [Bug] Java MCPServer ignores the "timeout" ResourceDescriptor argument, always uses 30s default [flink-agents] via GitHub
• [I] [Release] Manual verification workflow agent section of user documentation [flink-agents] via GitHub
  • Re: [I] [Release] Manual verification quickstart workflow agent section of user documentation [flink-agents] via GitHub
• [I] [Release] Manual verification quickstart yaml agent section of user documentation [flink-agents] via GitHub
  • Re: [I] [Release] Manual verification quickstart yaml agent section of user documentation [flink-agents] via GitHub
• [I] [Release] Manual verification installation section of user documentation [flink-agents] via GitHub
  • Re: [I] [Release] Manual verification installation section of user documentation [flink-agents] via GitHub
• [I] [Release] Manual verification overview section of user documentation [flink-agents] via GitHub
  • Re: [I] [Release] Manual verification overview section of user documentation [flink-agents] via GitHub
• [I] [Release] Manual verification quickstart skills section of user documentation [flink-agents] via GitHub
  • Re: [I] [Release] Manual verification quickstart skills section of user documentation [flink-agents] via GitHub
• [I] [Release] Manual verification quickstart react agent section of user documentation [flink-agents] via GitHub
  • Re: [I] [Release] Manual verification quickstart react agent section of user documentation [flink-agents] via GitHub
  • Re: [I] [Release] Manual verification quickstart react agent section of user documentation [flink-agents] via GitHub
  • Re: [I] [Release] Manual verification quickstart react agent section of user documentation [flink-agents] via GitHub
• Re: [PR] [FLINK-39265][postgres] PostgreSQL CDC intermittently drops INSERT records after checkpoint recovery due to WalPositionLocator filtering [flink-cdc] via GitHub
• [PR] # [FLINK-39837][connectors/kafka] Add tombstone-based retention for removed splits in dynamic Kafka source [flink-connector-kafka] via GitHub
  • Re: [PR] # [FLINK-39837][connectors/kafka] Add tombstone-based retention for removed splits in dynamic Kafka source [flink-connector-kafka] via GitHub
• [PR] [FLINK-39837] Retain removed dynamic Kafka cluster offsets [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-39837] Retain removed dynamic Kafka cluster offsets [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-39837] Retain removed dynamic Kafka cluster offsets [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-39837] Retain removed dynamic Kafka cluster offsets [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-39837] Retain removed dynamic Kafka cluster offsets [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-39837] Retain removed dynamic Kafka cluster offsets [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-39837] Retain removed dynamic Kafka cluster offsets [flink-connector-kafka] via GitHub
• Re: [PR] [FLINK-38907][postgres] Debezium publication filtering data lost [flink-cdc] via GitHub
• [jira] [Commented] (FLINK-39837) Make dynamic Kafka source resilient for Kafka topology instability Jubin Soni (Jira)
  • [jira] [Commented] (FLINK-39837) Make dynamic Kafka source resilient for Kafka topology instability Jubin Soni (Jira)
  • [jira] [Commented] (FLINK-39837) Make dynamic Kafka source resilient for Kafka topology instability Xin Gao (Jira)
  • [jira] [Commented] (FLINK-39837) Make dynamic Kafka source resilient for Kafka topology instability Jubin Soni (Jira)
  • [jira] [Commented] (FLINK-39837) Make dynamic Kafka source resilient for Kafka topology instability Xin Gao (Jira)
• [jira] (FLINK-39687) URI used as URL in SessionContext causes ArrayStoreException Jubin Soni (Jira)
• [jira] [Comment Edited] (FLINK-39687) URI used as URL in SessionContext causes ArrayStoreException Jubin Soni (Jira)
• [jira] [Commented] (FLINK-39687) URI used as URL in SessionContext causes ArrayStoreException Jubin Soni (Jira)
• [PR] [BP-2.3][FLINK-39761][runtime] Set 'Connection: close' header when sending '304 Not Modified' responses [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-39761][runtime] Set 'Connection: close' header when sending '304 Not Modified' responses [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-39761][runtime] Set 'Connection: close' header when sending '304 Not Modified' responses [flink] via GitHub
• [PR] [BP-2.2][FLINK-39761][runtime] Set 'Connection: close' header when sending '304 Not Modified' responses [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-39761][runtime] Set 'Connection: close' header when sending '304 Not Modified' responses [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-39761][runtime] Set 'Connection: close' header when sending '304 Not Modified' responses [flink] via GitHub
• [PR] [BP-2.1][FLINK-39761][runtime] Set 'Connection: close' header when sending '304 Not Modified' responses [flink] via GitHub
  • Re: [PR] [BP-2.1][FLINK-39761][runtime] Set 'Connection: close' header when sending '304 Not Modified' responses [flink] via GitHub
  • Re: [PR] [BP-2.1][FLINK-39761][runtime] Set 'Connection: close' header when sending '304 Not Modified' responses [flink] via GitHub
• [PR] [BP-2.0][FLINK-39761][runtime] Set 'Connection: close' header when sending '304 Not Modified' responses [flink] via GitHub
  • Re: [PR] [BP-2.0][FLINK-39761][runtime] Set 'Connection: close' header when sending '304 Not Modified' responses [flink] via GitHub
  • Re: [PR] [BP-2.0][FLINK-39761][runtime] Set 'Connection: close' header when sending '304 Not Modified' responses [flink] via GitHub
• [PR] [BP-1.20][FLINK-39761][runtime] Set 'Connection: close' header when sending '304 Not Modified' responses [flink] via GitHub
  • Re: [PR] [BP-1.20][FLINK-39761][runtime] Set 'Connection: close' header when sending '304 Not Modified' responses [flink] via GitHub
  • Re: [PR] [BP-1.20][FLINK-39761][runtime] Set 'Connection: close' header when sending '304 Not Modified' responses [flink] via GitHub
• [jira] [Updated] (FLINK-39837) Make dynamic Kafka source resilient for Kafka topology instability ASF GitHub Bot (Jira)
• [PR] [FLINK-39837][connectors] Add tombstone-based retention for removed s… [flink] via GitHub
  • Re: [PR] [FLINK-39837][connectors] Add tombstone-based retention for removed splits in dynamic sources [flink] via GitHub
• [jira] [Updated] (FLINK-39859) Upgrade Calcite version to 1.41.0 ASF GitHub Bot (Jira)
• [PR] [FLINK-39859][table] Upgrade Calcite to 1.41.0 [flink] via GitHub
  • Re: [PR] [FLINK-39859][table] Upgrade Calcite to 1.41.0 [flink] via GitHub
• [jira] [Created] (FLINK-39859) Upgrade Calcite version to 1.41.0 Sergey Nuyanzin (Jira)
• [jira] [Updated] (FLINK-39858) RestClient.close() can leave in-flight request futures uncompleted, hanging the caller ASF GitHub Bot (Jira)
• [PR] [FLINK-39858][rest] Fail orphaned in-flight request futures on RestClient close [flink] via GitHub
  • Re: [PR] [FLINK-39858][rest] Fail orphaned in-flight request futures on RestClient close [flink] via GitHub
  • Re: [PR] [FLINK-39858][rest] Fail orphaned in-flight request futures on RestClient close [flink] via GitHub
  • Re: [PR] [FLINK-39858][rest] Fail orphaned in-flight request futures on RestClient close [flink] via GitHub
• [jira] [Updated] (FLINK-39857) Upgrade Pekko to 1.6.0 ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-39858) RestClient.close() can leave in-flight request futures uncompleted, hanging the caller Martijn Visser (Jira)
• [PR] [FLINK-39857] Upgrade Pekko to 1.6.0 [flink] via GitHub
  • Re: [PR] [FLINK-39857] Upgrade Pekko to 1.6.0 [flink] via GitHub
  • Re: [PR] [FLINK-39857] Upgrade Pekko to 1.6.0 [flink] via GitHub
  • Re: [PR] [FLINK-39857] Upgrade Pekko to 1.6.0 [flink] via GitHub
  • Re: [PR] [FLINK-39857] Upgrade Pekko to 1.6.0 [flink] via GitHub
  • Re: [PR] [FLINK-39857] Upgrade Pekko to 1.6.0 [flink] via GitHub
• [jira] [Created] (FLINK-39857) Upgrade Pekko to 1.6.0 Sergey Nuyanzin (Jira)
• [jira] [Updated] (FLINK-39121) kafka connector CI test timeout due to "/tmp/testcontainers_start.sh: Text file busy" Martijn Visser (Jira)
• [jira] [Resolved] (FLINK-39845) SavepointITCase.testStopWithSavepointFailsOverToSavepoint fails on AdaptiveScheduler after JUnit5 migration Martijn Visser (Jira)
• [PR] [hotfix][tests] Bump MinIO test image to RELEASE.2022-02-12T00-51-25Z [flink] via GitHub
  • Re: [PR] [hotfix][tests] Bump MinIO test image to RELEASE.2022-02-12T00-51-25Z [flink] via GitHub
  • Re: [PR] [hotfix][tests] Bump MinIO test image to RELEASE.2022-02-12T00-51-25Z [flink] via GitHub
  • Re: [PR] [hotfix][tests] Bump MinIO test image to RELEASE.2022-02-12T00-51-25Z [flink] via GitHub
  • Re: [PR] [hotfix][tests] Pin MinIO test image by digest [flink] via GitHub
  • Re: [PR] [hotfix][tests] Pin MinIO test image by digest [flink] via GitHub
• [PR] [FLINK-39421][table] Fix metadata filter contract and add coverage [flink] via GitHub
  • Re: [PR] [FLINK-39421][table] Fix metadata filter contract and add coverage [flink] via GitHub
  • Re: [PR] [FLINK-39421][table] Fix metadata filter contract and add coverage [flink] via GitHub
  • Re: [PR] [FLINK-39421][table] Fix metadata filter contract and add coverage [flink] via GitHub
  • Re: [PR] [FLINK-39421][table] Fix metadata filter contract and add coverage [flink] via GitHub
  • Re: [PR] [FLINK-39421][table] Fix metadata filter contract and add coverage [flink] via GitHub
  • Re: [PR] [FLINK-39421][table] Fix metadata filter contract and add coverage [flink] via GitHub
  • Re: [PR] [FLINK-39421][table] Fix metadata filter contract and add coverage [flink] via GitHub
  • Re: [PR] [FLINK-39421][table] Fix metadata filter contract and add coverage [flink] via GitHub
  • Re: [PR] [FLINK-39421][table] Fix metadata filter contract and add coverage [flink] via GitHub
  • Re: [PR] [FLINK-39421][table] Fix metadata filter contract and add coverage [flink] via GitHub
  • Re: [PR] [FLINK-39421][table] Fix metadata filter contract and add coverage [flink] via GitHub
  • Re: [PR] [FLINK-39421][table] Fix metadata filter contract and add coverage [flink] via GitHub
  • Re: [PR] [FLINK-39421][table] Fix metadata filter contract and add coverage [flink] via GitHub
  • Re: [PR] [FLINK-39421][table] Fix metadata filter contract and add coverage [flink] via GitHub
  • Re: [PR] [FLINK-39421][table] Fix metadata filter contract and add coverage [flink] via GitHub
  • Re: [PR] [FLINK-39421][table] Fix metadata filter contract and add coverage [flink] via GitHub
  • Re: [PR] [FLINK-39421][table] Fix metadata filter contract and add coverage [flink] via GitHub
  • Re: [PR] [FLINK-39421][table] Fix metadata filter contract and add coverage [flink] via GitHub
  • Re: [PR] [FLINK-39421][table] Fix metadata filter contract and add coverage [flink] via GitHub
  • Re: [PR] [FLINK-39421][table] Fix metadata filter contract and add coverage [flink] via GitHub
  • Re: [PR] [FLINK-39421][table] Fix metadata filter contract and add coverage [flink] via GitHub
  • Re: [PR] [FLINK-39421][table] Fix metadata filter contract and add coverage [flink] via GitHub
• [jira] [Commented] (FLINK-39776) Expose JobInfo on Source contexts Aleksandr Savonin (Jira)
• [PR] [FLINK-39121][tests] Retry kafka containers startup [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-39121][tests] Retry kafka containers startup [flink-connector-kafka] via GitHub
• [jira] [Assigned] (FLINK-39856) Auto-derive a default transactionalIdPrefix for EXACTLY_ONCE from JobID when unset Roman Khachatryan (Jira)
• [jira] [Assigned] (FLINK-39854) Log JobID in KafkaCommitter Roman Khachatryan (Jira)
• [jira] [Assigned] (FLINK-39855) Include JobID in the backchannel key (cross-job robustness) Roman Khachatryan (Jira)
• Re: [PR] [hotfix] Fix typo in upload artifact condition [flink] via GitHub
• Re: [PR] [hotfix] warning for conditional [flink] via GitHub
  • Re: [PR] [hotfix] warning for conditional [flink] via GitHub
• [jira] [Created] (FLINK-39856) Auto-derive a default transactionalIdPrefix for EXACTLY_ONCE from JobID when unset Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-39855) Include JobID in the backchannel key (cross-job robustness) Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-39854) Log JobID in KafkaCommitter Aleksandr Savonin (Jira)
• [jira] [Updated] (FLINK-39827) [umbrella] Adopt JobInfo on source contexts Aleksandr Savonin (Jira)
• Re: [PR] [FLINK-39754][core] Fix int overflow in DataOutputSerializer.resize [flink] via GitHub
  • Re: [PR] [FLINK-39754][core] Fix int overflow in DataOutputSerializer.resize [flink] via GitHub
  • Re: [PR] [FLINK-39754][core] Fix int overflow in DataOutputSerializer.resize [flink] via GitHub
  • Re: [PR] [FLINK-39754][core] Fix int overflow in DataOutputSerializer.resize [flink] via GitHub
  • Re: [PR] [FLINK-39754][core] Fix int overflow in DataOutputSerializer.resize [flink] via GitHub
  • Re: [PR] [FLINK-39754][core] Fix int overflow in DataOutputSerializer.resize [flink] via GitHub
• [PR] [FLINK-39853][test] Upgrade Testcontainers to 2.0.5 and remove JUnit 4 dependency [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39853][test] Upgrade Testcontainers to 2.0.5 and remove JUnit 4 dependency [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39853][test] Upgrade Testcontainers to 2.0.5 and remove JUnit 4 dependency [flink-kubernetes-operator] via GitHub
• [jira] [Updated] (FLINK-39853) [JUnit5 Migration] Upgrade Testcontainers to 2.0.5 - flink-autoscaler-plugin-jdbc Purushottam Sinha (Jira)
  • [jira] [Updated] (FLINK-39853) [JUnit5 Migration] Upgrade Testcontainers to 2.0.5 - flink-autoscaler-plugin-jdbc ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-39853) Upgrade Testcontainers to 2.0.5 and remove the JUnit 4 dependency from flink-autoscaler-plugin-jdbc Purushottam Sinha (Jira)
• Re: [PR] [FLINK-39306][flink-autoscaler] Non-source vertices do not use per-second rate metrics, producing inaccurate scaling decisions [flink-kubernetes-operator] via GitHub
• [PR] [FLINK-38647] Support changelog-mode=upsert + null-tolerancy [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-38647) NullPointerException in Postgres CDC pipeline when update data in table ASF GitHub Bot (Jira)
• Re: [PR] [FLINK-39565] Eliminate maven build warnings across all modules [flink-kubernetes-operator] via GitHub
• [jira] [Updated] (FLINK-39847) FLIP-578: Support in-place conversion of a table to a materialized table ASF GitHub Bot (Jira)
• [jira] [Closed] (FLINK-39688) Share a single PluginManager across operator and webhook startup Gyula Fora (Jira)
• Re: [PR] [FLINK-39688] Share a single PluginManager across operator and webhook startup [flink-kubernetes-operator] via GitHub
• [jira] [Closed] (FLINK-39838) Bump Flink version to 1.20.4 in flink-kubernetes-operator Gyula Fora (Jira)
• Re: [PR] [FLINK-36753][runtime]Adaptive Scheduler actively triggers a Checkpoint after all resources are ready [flink] via GitHub
  • Re: [PR] [FLINK-36753][runtime]Adaptive Scheduler actively triggers a Checkpoint after all resources are ready [flink] via GitHub
  • Re: [PR] [FLINK-36753][runtime]Adaptive Scheduler actively triggers a Checkpoint after all resources are ready [flink] via GitHub
  • Re: [PR] [FLINK-36753][runtime]Adaptive Scheduler actively triggers a Checkpoint after all resources are ready [flink] via GitHub
  • Re: [PR] [FLINK-36753][runtime]Adaptive Scheduler actively triggers a Checkpoint after all resources are ready [flink] via GitHub
  • Re: [PR] [FLINK-36753][runtime]Adaptive Scheduler actively triggers a Checkpoint after all resources are ready [flink] via GitHub
  • Re: [PR] [FLINK-36753][runtime]Adaptive Scheduler actively triggers a Checkpoint after all resources are ready [flink] via GitHub
  • Re: [PR] [FLINK-36753][runtime]Adaptive Scheduler actively triggers a Checkpoint after all resources are ready [flink] via GitHub
• [jira] [Updated] (FLINK-34806) [Feature][Postgres] Support automatically identify newly added tables ASF GitHub Bot (Jira)
• [PR] [FLINK-34806][postgres] Expose scan.newly-added-table.enabled option [flink-cdc] via GitHub

• Earlier messages
• Later messages