issues  

Messages by Thread

• [jira] [Updated] (FLINK-39959) Improve the autoscaler context structure and propagation Gyula Fora (Jira)
  • [jira] [Updated] (FLINK-39959) Improve the autoscaler context structure and propagation ASF GitHub Bot (Jira)
• [jira] [Closed] (FLINK-39555) FLIP-575: Scaling Executor Plugin SPI for Flink Autoscaler Gyula Fora (Jira)
• [jira] [Created] (FLINK-39959) Improve the autoscaler context structure and propagation Dennis-Mircea Ciupitu (Jira)
• [jira] [Updated] (FLINK-39923) RocksDB Statistics native memory leaks on state backend rebuild when ticker metrics are enabled ASF GitHub Bot (Jira)
• [PR] [FLINK-39923][state] Fix RocksDB Statistics native memory leak [flink] via GitHub
  • Re: [PR] [FLINK-39923][state] Fix RocksDB Statistics native memory leak [flink] via GitHub
  • Re: [PR] [FLINK-39923][state] Fix RocksDB Statistics native memory leak [flink] via GitHub
  • Re: [PR] [FLINK-39923][state] Fix RocksDB Statistics native memory leak [flink] via GitHub
  • Re: [PR] [FLINK-39923][state] Fix RocksDB Statistics native memory leak [flink] via GitHub
  • Re: [PR] [FLINK-39923][state] Fix RocksDB Statistics native memory leak [flink] via GitHub
  • Re: [PR] [FLINK-39923][state] Fix RocksDB Statistics native memory leak [flink] via GitHub
  • Re: [PR] [FLINK-39923][state] Fix RocksDB Statistics native memory leak [flink] via GitHub
  • Re: [PR] [FLINK-39923][state] Fix RocksDB Statistics native memory leak [flink] via GitHub
• [jira] [Commented] (FLINK-38961) Display process metrics (CPU, Memory, I/O) on TaskManager Web UI Purushottam Sinha (Jira)
• [jira] [Updated] (FLINK-33383) flink-quickstart-scala.sh is not supported anymore since 1.17 but is used in flink-web helper scripts ASF GitHub Bot (Jira)
• [PR] [FLINK-33383] [Project Website] Remove deprecated Scala quickstart scripts [flink-web] via GitHub
• [PR] [FLINK-24544][formats] Fix Avro enum deserialization failure with Confluent Schema Registry [flink] via GitHub
  • Re: [PR] [FLINK-24544][formats] Fix Avro enum deserialization failure with Confluent Schema Registry [flink] via GitHub
• Re: [PR] [FLINK-34022][core] Fix ArithmeticException in TimeUtils.formatWithHighestUnit for large Duration values [flink] via GitHub
• Re: [PR] [FLINK-39555] FLIP-575: Scaling Executor Plugin SPI for Flink Autoscaler [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39555] FLIP-575: Scaling Executor Plugin SPI for Flink Autoscaler [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39555] FLIP-575: Scaling Executor Plugin SPI for Flink Autoscaler [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39555] FLIP-575: Scaling Executor Plugin SPI for Flink Autoscaler [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39555] FLIP-575: Scaling Executor Plugin SPI for Flink Autoscaler [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39555] FLIP-575: Scaling Executor Plugin SPI for Flink Autoscaler [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39555] FLIP-575: Scaling Executor Plugin SPI for Flink Autoscaler [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39555] FLIP-575: Scaling Executor Plugin SPI for Flink Autoscaler [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39555] FLIP-575: Scaling Executor Plugin SPI for Flink Autoscaler [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39555] FLIP-575: Scaling Executor Plugin SPI for Flink Autoscaler [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39555] FLIP-575: Scaling Executor Plugin SPI for Flink Autoscaler [flink-kubernetes-operator] via GitHub
• [PR] [hotfix] Strip B/G scale subresource in process-classes so partial builds keep CRDs valid [flink-kubernetes-operator] via GitHub
  • Re: [PR] [hotfix] Strip B/G scale subresource in process-classes so partial builds keep CRDs valid [flink-kubernetes-operator] via GitHub
  • Re: [PR] [hotfix] Strip B/G scale subresource in process-classes so partial builds keep CRDs valid [flink-kubernetes-operator] via GitHub
• [jira] [Assigned] (FLINK-39730) ApplicationExceptionsHandler silently ignores maxExceptions parameter; ApplicationExceptionsMessageParameters is unreachable via typed REST client Sergey Nuyanzin (Jira)
• [jira] [Resolved] (FLINK-39730) ApplicationExceptionsHandler silently ignores maxExceptions parameter; ApplicationExceptionsMessageParameters is unreachable via typed REST client Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-39730) ApplicationExceptionsHandler silently ignores maxExceptions parameter; ApplicationExceptionsMessageParameters is unreachable via typed REST client Sergey Nuyanzin (Jira)
• [PR] [hotfix][api] Remove unused Diffable markers from spec/status types [flink-kubernetes-operator] via GitHub
  • Re: [PR] [hotfix][api] Remove unused Diffable markers from spec/status types [flink-kubernetes-operator] via GitHub
• [jira] [Closed] (FLINK-39887) Use validated query node as a fallback when parsing the raw asQuery fails Sergey Nuyanzin (Jira)
• [PR] [hotfix] Replace deprecated procedure syntax for scala [flink] via GitHub
  • Re: [PR] [hotfix] Replace deprecated procedure syntax for scala [flink] via GitHub
  • Re: [PR] [hotfix] Replace deprecated procedure syntax for scala [flink] via GitHub
• [jira] [Updated] (FLINK-39958) Autoscaler Flink REST client timeout is silently overridden by the operator client timeout ASF GitHub Bot (Jira)
• [PR] [FLINK-39958] Autoscaler Flink REST client timeout is silently overridden by the operator client timeout [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39958] Autoscaler Flink REST client timeout is silently overridden by the operator client timeout [flink-kubernetes-operator] via GitHub
• [jira] [Closed] (FLINK-30571) Compute scale parallelism based on observed scalability Gyula Fora (Jira)
• [jira] [Closed] (FLINK-39441) Table configuration inside Flink config is not applying at runtime Gyula Fora (Jira)
• [jira] [Closed] (FLINK-34728) operator does not need to upload and download the jar when deploying session job Gyula Fora (Jira)
• [jira] [Closed] (FLINK-35285) Autoscaler key group optimization can interfere with scale-down.max-factor Gyula Fora (Jira)
• [jira] [Closed] (FLINK-37682) Upgrade Jackson Lib to Address CVE-2023-35116 Gyula Fora (Jira)
• [jira] [Closed] (FLINK-38116) Flink kubernetes operator RequestWatchProgress Error Gyula Fora (Jira)
• [jira] [Closed] (FLINK-38710) operator properties in FlinkDeployment are not taking effect Gyula Fora (Jira)
• [jira] [Created] (FLINK-39958) Autoscaler Flink REST client timeout is silently overridden by the operator client timeout Dennis-Mircea Ciupitu (Jira)
• Re: [PR] Bump flatted from 3.3.2 to 3.4.2 in /flink-runtime-web/web-dashboard [flink] via GitHub
  • Re: [PR] Bump flatted from 3.3.2 to 3.4.2 in /flink-runtime-web/web-dashboard [flink] via GitHub
  • Re: [PR] Bump flatted from 3.3.2 to 3.4.2 in /flink-runtime-web/web-dashboard [flink] via GitHub
  • Re: [PR] Bump flatted from 3.3.2 to 3.4.2 in /flink-runtime-web/web-dashboard [flink] via GitHub
• Re: [PR] [hotfix][docs] Clarify Kryo behavior [flink] via GitHub
  • Re: [PR] [hotfix][docs] Clarify Kryo behavior [flink] via GitHub
• Re: [PR] Add AWS Connectors 6.0.1 [flink-web] via GitHub
• [jira] [Comment Edited] (FLINK-39725) from_source does not use timestamp assigner in pyflink Swati Gupta (Jira)
• [jira] [Created] (FLINK-39957) Support EXPLAIN CREATE [OR ALTER] MATERIALIZED TABLE statements Ramin Gharib (Jira)
• [jira] [Updated] (FLINK-39586) CombinedWatermarkStatus.updateCombinedWatermark() fails to mark idle when partialWatermarks is empty ASF GitHub Bot (Jira)
• [PR] FLINK-39586: Mark the combined watermark status idle when all partial watermarks are unregistered [flink] via GitHub
  • Re: [PR] [FLINK-39586][core] Mark the combined watermark status idle when all partial watermarks are unregistered [flink] via GitHub
  • Re: [PR] [FLINK-39586][core] Mark the combined watermark status idle when all partial watermarks are unregistered [flink] via GitHub
  • Re: [PR] [FLINK-39586][core] Mark the combined watermark status idle when all partial watermarks are unregistered [flink] via GitHub
• [jira] [Commented] (FLINK-39725) from_source does not use timestamp assigner in pyflink Swati Gupta (Jira)
  • [jira] [Commented] (FLINK-39725) from_source does not use timestamp assigner in pyflink Andrew Feng (Jira)
• Re: [PR] [hotfix] warning for conditional [flink] via GitHub
  • Re: [PR] [hotfix] warning for conditional [flink] via GitHub
• [PR] [hotfix][tests] Fix flaky `SessionRelatedITCase#testTouchSession` [flink] via GitHub
  • Re: [PR] [hotfix][tests] Fix flaky `SessionRelatedITCase#testTouchSession` [flink] via GitHub
  • Re: [PR] [hotfix][tests] Fix flaky `SessionRelatedITCase#testTouchSession` [flink] via GitHub
• [jira] [Commented] (FLINK-39956) Expose per-pool heap CollectionUsage gauges Swati Gupta (Jira)
  • [jira] [Commented] (FLINK-39956) Expose per-pool heap CollectionUsage gauges Peter Huang (Jira)
• Re: [PR] [FLINK-34415] Move away from Kafka-Zookeeper based tests in favor of Kafka-KRaft [flink] via GitHub
• [PR] [FLINK-39898][runtime] Fire processing-time timers between unaligned checkpoints when mini-batch is enabled [flink] via GitHub
  • Re: [PR] [FLINK-39898][runtime] Fire processing-time timers between unaligned checkpoints when mini-batch is enabled [flink] via GitHub
  • Re: [PR] [FLINK-39898][runtime] Fire processing-time timers between unaligned checkpoints when mini-batch is enabled [flink] via GitHub
  • Re: [PR] [FLINK-39898][runtime] Fire processing-time timers between unaligned checkpoints when mini-batch is enabled [flink] via GitHub
  • Re: [PR] [FLINK-39898][runtime] Fire processing-time timers between unaligned checkpoints when mini-batch is enabled [flink] via GitHub
  • Re: [PR] [FLINK-39898][runtime] Fire processing-time timers between unaligned checkpoints when mini-batch is enabled [flink] via GitHub
  • Re: [PR] [FLINK-39898][runtime] Fire processing-time timers between unaligned checkpoints when mini-batch is enabled [flink] via GitHub
• [jira] [Comment Edited] (FLINK-39949) [ForSt] State restore from savepoints/checkpoints not supported Jubin Soni (Jira)
  • [jira] [Comment Edited] (FLINK-39949) [ForSt] State restore from savepoints/checkpoints not supported Jubin Soni (Jira)
• [jira] [Updated] (FLINK-39898) ProcessingTimeService timer callbacks delayed until checkpoint when mini-batch and unaligned checkpoints are enabled ASF GitHub Bot (Jira)
• [PR] FLINK-39898: Fire processing-time timers between unaligned checkpoints when mini-batch is enabled [flink] via GitHub
  • Re: [PR] FLINK-39898: Fire processing-time timers between unaligned checkpoints when mini-batch is enabled [flink] via GitHub
  • Re: [PR] FLINK-39898: Fire processing-time timers between unaligned checkpoints when mini-batch is enabled [flink] via GitHub
• Re: [PR] [FLINK-39837][connectors] Add tombstone-based retention for removed splits in dynamic sources [flink] via GitHub
• [jira] [Updated] (FLINK-39193) SpecifiedOffsetsInitializer can fail if the caller passes a non-empty but incomplete specific-offset map. Bowen Li (Jira)
  • [jira] [Updated] (FLINK-39193) SpecifiedOffsetsInitializer can fail if the caller passes a non-empty but incomplete specific-offset map. ASF GitHub Bot (Jira)
• [jira] [Closed] (FLINK-39054) DynamicKafkaSourceEnumStateSerializer should preserve full per-cluster properties instead of only bootstrap.servers Bowen Li (Jira)
• [jira] [Updated] (FLINK-39054) DynamicKafkaSourceEnumStateSerializer should preserve full per-cluster properties instead of only bootstrap.servers Bowen Li (Jira)
• [jira] [Created] (FLINK-39956) Expose per-pool heap CollectionUsage gauges Zhenqiu Huang (Jira)
• Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc] via GitHub
• Re: [PR] [FLINK-39516][web dashboard] Address npm security advisories in flink-runtime-web web-dashboard [flink] via GitHub
• Re: [PR] [FLINK-32609] Support Projection Pushdown [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-32609] Support Projection Pushdown [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-32609] Support Projection Pushdown [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-32609] Support Projection Pushdown [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-32609] Support Projection Pushdown [flink-connector-kafka] via GitHub
• Re: [PR] [FLINK-38536][tests] Fix data race in FinalizeOnMasterTest and ExecutionGraphFinishTest [flink] via GitHub
  • Re: [PR] [FLINK-38536][tests] Fix data race in FinalizeOnMasterTest and ExecutionGraphFinishTest [flink] via GitHub
  • Re: [PR] [FLINK-38536][tests] Fix data race in FinalizeOnMasterTest and ExecutionGraphFinishTest [flink] via GitHub
• Re: [PR] [FLINK-37351][runtime] Ensure Writer/Committer Colocation for Non-Pre-Commit Topologies [flink] via GitHub
  • Re: [PR] [FLINK-37351][runtime] Ensure Writer/Committer Colocation for Non-Pre-Commit Topologies [flink] via GitHub
  • Re: [PR] [FLINK-37351][runtime] Ensure Writer/Committer Colocation for Non-Pre-Commit Topologies [flink] via GitHub
  • Re: [PR] [FLINK-37351][runtime] Ensure Writer/Committer Colocation for Non-Pre-Commit Topologies [flink] via GitHub
• Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
  • Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
• [jira] [Commented] (FLINK-39837) Make dynamic Kafka source resilient for Kafka topology instability Bowen Li (Jira)
• [jira] [Resolved] (FLINK-39837) Make dynamic Kafka source resilient for Kafka topology instability Bowen Li (Jira)
• [jira] [Assigned] (FLINK-39837) Make dynamic Kafka source resilient for Kafka topology instability Bowen Li (Jira)
• [jira] [Updated] (FLINK-39837) Make dynamic Kafka source resilient for Kafka topology instability Bowen Li (Jira)
• [PR] [drfat] [minor][pipeline-connector/sqlserver] Fix SQL Server schema restore without per-record JDBC [flink-cdc] via GitHub
  • Re: [PR] [drfat] [minor][pipeline-connector/sqlserver] Fix SQL Server schema restore without per-record JDBC [flink-cdc] via GitHub
  • Re: [PR] [minor][pipeline-connector/sqlserver] Fix SQL Server schema restore without per-record JDBC [flink-cdc] via GitHub
  • Re: [PR] [minor][pipeline-connector/sqlserver] Fix SQL Server schema restore without per-record JDBC [flink-cdc] via GitHub
• [jira] [Commented] (FLINK-39481) ⁠[tests] Fix flaky WindowDistinctAggregateITCase#testCumulateWindow_GroupingSets⁠ Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-39481) ⁠[tests] Fix flaky WindowDistinctAggregateITCase#testCumulateWindow_GroupingSets⁠ Rui Fan (Jira)
  • [jira] [Commented] (FLINK-39481) ⁠[tests] Fix flaky WindowDistinctAggregateITCase#testCumulateWindow_GroupingSets⁠ Rui Fan (Jira)
  • [jira] [Commented] (FLINK-39481) ⁠[tests] Fix flaky WindowDistinctAggregateITCase#testCumulateWindow_GroupingSets⁠ Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-39481) ⁠[tests] Fix flaky WindowDistinctAggregateITCase#testCumulateWindow_GroupingSets⁠ Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-39481) ⁠[tests] Fix flaky WindowDistinctAggregateITCase#testCumulateWindow_GroupingSets⁠ Piotr Nowojski (Jira)
• [jira] [Assigned] (FLINK-35562) WindowTableFunctionProcTimeRestoreTest produced no output for 900 seconds Martijn Visser (Jira)
• [jira] [Resolved] (FLINK-35562) WindowTableFunctionProcTimeRestoreTest produced no output for 900 seconds Martijn Visser (Jira)
• [jira] [Resolved] (FLINK-37663) Thread Synchronization Issue in FutureCompletingBlockingQueue <> Connector Split Fetching Martijn Visser (Jira)
• [PR] [hotfix][table] Fix view comment derived from QueryOperation summary string [flink] via GitHub
  • Re: [PR] [hotfix][table] Fix view comment derived from QueryOperation summary string [flink] via GitHub
  • Re: [PR] [hotfix][table] Fix view comment derived from QueryOperation summary string [flink] via GitHub
  • Re: [PR] [hotfix][table] Fix view comment derived from QueryOperation summary string [flink] via GitHub
  • Re: [PR] [hotfix][table] Fix view comment derived from QueryOperation summary string [flink] via GitHub
  • Re: [PR] [hotfix][table] Fix view comment derived from QueryOperation summary string [flink] via GitHub
• [jira] [Updated] (FLINK-39931) Fix flaky AdaptiveBatchSchedulerTest due to unexpected ComponentMainThreadExecutor behavior in async execution ASF GitHub Bot (Jira)
• [jira] [Resolved] (FLINK-39792) Add multi-headers metadata key to Kafka connector Arvid Heise (Jira)
• [jira] [Commented] (FLINK-39792) Add multi-headers metadata key to Kafka connector Arvid Heise (Jira)
  • [jira] [Commented] (FLINK-39792) Add multi-headers metadata key to Kafka connector Arvid Heise (Jira)
• [PR] [Flink 39931][runtime/tests] Verify stability of testVertexInitializationFailureIsLabeled and testUnbalancedInput with RepeatedTest [flink] via GitHub
  • Re: [PR] [Flink 39931][runtime/tests] Verify stability of testVertexInitializationFailureIsLabeled and testUnbalancedInput with RepeatedTest [flink] via GitHub

• Earlier messages
• Later messages