issues  

Messages by Thread

• [jira] [Commented] (FLINK-39750) Drop FailsOnJava11 Sergey Nuyanzin (Jira)
• [jira] [Resolved] (FLINK-39750) Drop FailsOnJava11 Sergey Nuyanzin (Jira)
• [jira] [Resolved] (FLINK-39755) RuntimeOpenRestAPIDocsCompletenessITCase fails for jdk 21+ Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-39755) RuntimeOpenRestAPIDocsCompletenessITCase fails for jdk 21+ Sergey Nuyanzin (Jira)
• [PR] [FLINK-39756] Fix unable to coerce complex types to STRING [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39756] Fix unable to coerce complex types to STRING [flink-cdc] via GitHub
• [jira] [Closed] (FLINK-39760) Fix unable to coerce complex types (ARRAY/MAP/ROW) to STRING Mao Jiayi (Jira)
• [jira] [Closed] (FLINK-39759) Fix unable to coerce complex types (ARRAY/MAP/ROW) to STRING Mao Jiayi (Jira)
• [jira] [Closed] (FLINK-39758) Fix unable to coerce complex types (ARRAY/MAP/ROW) to STRING Mao Jiayi (Jira)
• [jira] [Closed] (FLINK-39757) Fix unable to coerce complex types (ARRAY/MAP/ROW) to STRING Mao Jiayi (Jira)
• [jira] [Commented] (FLINK-39760) Fix unable to coerce complex types (ARRAY/MAP/ROW) to STRING Mao Jiayi (Jira)
• [jira] [Created] (FLINK-39760) Fix unable to coerce complex types (ARRAY/MAP/ROW) to STRING Mao Jiayi (Jira)
• [jira] [Created] (FLINK-39759) Fix unable to coerce complex types (ARRAY/MAP/ROW) to STRING Mao Jiayi (Jira)
• [jira] [Created] (FLINK-39758) Fix unable to coerce complex types (ARRAY/MAP/ROW) to STRING Mao Jiayi (Jira)
• [jira] [Created] (FLINK-39757) Fix unable to coerce complex types (ARRAY/MAP/ROW) to STRING Mao Jiayi (Jira)
• [jira] [Created] (FLINK-39756) Fix unable to coerce complex types (ARRAY/MAP/ROW) to STRING Mao Jiayi (Jira)
• [jira] [Updated] (FLINK-39755) RuntimeOpenRestAPIDocsCompletenessITCase fails for jdk 21+ ASF GitHub Bot (Jira)
• [PR] [FLINK-39755][tests] `RuntimeOpenRestAPIDocsCompletenessITCase` fails for jdk 21+ [flink] via GitHub
  • Re: [PR] [FLINK-39755][tests] `RuntimeOpenRestAPIDocsCompletenessITCase` fails for jdk 21+ [flink] via GitHub
  • Re: [PR] [FLINK-39755][tests] `RuntimeOpenRestAPIDocsCompletenessITCase` fails for jdk 21+ [flink] via GitHub
  • Re: [PR] [FLINK-39755][tests] `RuntimeOpenRestAPIDocsCompletenessITCase` fails for jdk 21+ [flink] via GitHub
  • Re: [PR] [FLINK-39755][tests] `RuntimeOpenRestAPIDocsCompletenessITCase` fails for jdk 21+ [flink] via GitHub
• [jira] [Created] (FLINK-39755) RuntimeOpenRestAPIDocsCompletenessITCase fails for jdk 21+ Sergey Nuyanzin (Jira)
• Re: [PR] [Feature][Java] Move MCP resource discovery to runtime [flink-agents] via GitHub
• [jira] [Comment Edited] (FLINK-39145) UnalignedCheckpointITCase.execute fails Rui Fan (Jira)
• [jira] [Commented] (FLINK-39145) UnalignedCheckpointITCase.execute fails Rui Fan (Jira)
• [jira] [Updated] (FLINK-39754) DataOutputSerializer.resize() int overflow causes O(n²) growth near 2 GB ASF GitHub Bot (Jira)
• [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
• [jira] [Created] (FLINK-39754) DataOutputSerializer.resize() int overflow causes O(n²) growth near 2 GB Saulius Valatka (Jira)
• [jira] [Commented] (FLINK-39753) RocksDB ColumnFamilyOptions and LRUCache leak in Compactor Keith Lee (Jira)
• [PR] [FLINK-39753][state/rocksdb] Close ColumnFamilyOptions from getDescriptor() in Compactor [flink] via GitHub
  • Re: [PR] [FLINK-39753][state/rocksdb] Close ColumnFamilyOptions from getDescriptor() in Compactor [flink] via GitHub
• [jira] [Updated] (FLINK-39753) RocksDB ColumnFamilyOptions and LRUCache leak in Compactor Keith Lee (Jira)
  • [jira] [Updated] (FLINK-39753) RocksDB ColumnFamilyOptions and LRUCache leak in Compactor Keith Lee (Jira)
  • [jira] [Updated] (FLINK-39753) RocksDB ColumnFamilyOptions and LRUCache leak in Compactor Keith Lee (Jira)
  • [jira] [Updated] (FLINK-39753) RocksDB ColumnFamilyOptions and LRUCache leak in Compactor Keith Lee (Jira)
  • [jira] [Updated] (FLINK-39753) RocksDB ColumnFamilyOptions and LRUCache leak in Compactor Keith Lee (Jira)
  • [jira] [Updated] (FLINK-39753) RocksDB ColumnFamilyOptions and LRUCache leak in Compactor Keith Lee (Jira)
  • [jira] [Updated] (FLINK-39753) RocksDB ColumnFamilyOptions and LRUCache leak in Compactor ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-39753) RocksDB ColumnFamilyOptions and LRUCache leak in Compactor Keith Lee (Jira)
  • [jira] [Updated] (FLINK-39753) RocksDB ColumnFamilyOptions and LRUCache leak in Compactor Keith Lee (Jira)
• [jira] [Created] (FLINK-39753) RocksDB ColumnFamilyOptions and LRUCache leak in Compactor Keith Lee (Jira)
• [jira] [Closed] (FLINK-39156) Document the changes Gustavo de Morais (Jira)
• [jira] [Updated] (FLINK-35761) FLIP-547: Support checkpoint during recovery Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-35761) FLIP-547: Support checkpoint during recovery Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-39443) Prepare Flink 2.3 release Yuepeng Pan (Jira)
• [jira] [Resolved] (FLINK-39449) [release-2.3] Cross-team testing Yuepeng Pan (Jira)
• [jira] [Resolved] (FLINK-39454) [Umbrella] Test Flink Release 2.3 Yuepeng Pan (Jira)
• [jira] [Closed] (FLINK-39710) Release Testing: Verify FLIP-565: Improve ProcessTableFunctions for late data handling and state access Yuepeng Pan (Jira)
• [PR] [doc] Add YAML API documentation and quickstart example. [flink-agents] via GitHub
  • Re: [PR] [doc] Add YAML API documentation and quickstart example. [flink-agents] via GitHub
  • Re: [PR] [doc] Add YAML API documentation and quickstart example. [flink-agents] via GitHub
• [PR] [hotfix] Reuse FlinkConfigManager#isSnapshotCrdInstalled in controllers [flink-kubernetes-operator] via GitHub
• Re: [PR] Bump JOSDK to 5.3 [flink-kubernetes-operator] via GitHub
• [jira] [Comment Edited] (FLINK-39710) Release Testing: Verify FLIP-565: Improve ProcessTableFunctions for late data handling and state access Mukul Gupta (Jira)
• [PR] [hotfix] Clean up FlinkBlueGreenDeploymentController [flink-kubernetes-operator] via GitHub
• [PR] [FLINK-39752] Thread EventRecorder through FlinkResourceContext instead of holding it on the factory [flink-kubernetes-operator] via GitHub
• [jira] [Created] (FLINK-39752) Thread EventRecorder through FlinkResourceContext instead of holding it on the factory Dennis-Mircea Ciupitu (Jira)
• [PR] [FLINK-38503] Adapt `DefaultClusterClientServiceLoader` to java 25 [flink] via GitHub
  • Re: [PR] [FLINK-38503] Adapt `DefaultClusterClientServiceLoader` to java 25 [flink] via GitHub
• [jira] [Commented] (FLINK-38503) ServiceLoader#hasNext fails with ClassNotFoundException Sergey Nuyanzin (Jira)
• [jira] [Assigned] (FLINK-38503) ServiceLoader#hasNext fails with ClassNotFoundException Sergey Nuyanzin (Jira)
• [jira] [Updated] (FLINK-38503) ServiceLoader#hasNext fails with ClassNotFoundException Sergey Nuyanzin (Jira)
  • [jira] [Updated] (FLINK-38503) ServiceLoader#hasNext fails with ClassNotFoundException ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-39751) Introduce FailsOnJava25 ASF GitHub Bot (Jira)
• [PR] [FLINK-39751][tests] Add `FailsOnJava25` [flink] via GitHub
  • Re: [PR] [FLINK-39751][tests] Add `FailsOnJava25` [flink] via GitHub
  • Re: [PR] [FLINK-39751][tests] Add `FailsOnJava25` [flink] via GitHub
• [PR] [hotfix][test] Replace JUnit 4 TemporaryFolder with JUnit 5 @TempDir [flink-kubernetes-operator] via GitHub
  • Re: [PR] [hotfix][test] Finalize JUnit 5 migration and prune unused test dependencies [flink-kubernetes-operator] via GitHub
• [jira] [Created] (FLINK-39751) Introduce FailsOnJava25 Sergey Nuyanzin (Jira)
• [jira] [Updated] (FLINK-39750) Drop FailsOnJava11 ASF GitHub Bot (Jira)
• [jira] [Closed] (FLINK-35905) Flink physical operator replacement support Qilong Wang (Jira)
• [PR] [FLINK-39750][tests] Drop `FailsOnJava11` [flink] via GitHub
  • Re: [PR] [FLINK-39750][tests] Drop `FailsOnJava11` [flink] via GitHub
  • Re: [PR] [FLINK-39750][tests] Drop `FailsOnJava11` [flink] via GitHub
  • Re: [PR] [FLINK-39750][tests] Drop `FailsOnJava11` [flink] via GitHub
  • Re: [PR] [FLINK-39750][tests] Drop `FailsOnJava11` [flink] via GitHub
  • Re: [PR] [FLINK-39750][tests] Drop `FailsOnJava11` [flink] via GitHub
  • Re: [PR] [FLINK-39750][tests] Drop `FailsOnJava11` [flink] via GitHub
  • Re: [PR] [FLINK-39750][tests] Drop `FailsOnJava11` [flink] via GitHub
• [jira] [Created] (FLINK-39750) Drop FailsOnJava11 Sergey Nuyanzin (Jira)
• [jira] [Updated] (FLINK-39216) [Kubernetes Operator] Add PKCS12 profile option for webhook certificate to support FIPS environments ASF GitHub Bot (Jira)
• [PR] [FLINK-39216] - Add PKCS12 profile option for webhook certificate [flink-kubernetes-operator] via GitHub
• [jira] [Updated] (FLINK-39749) [mysql-cdc] Introduce scan.incremental.snapshot.string-key.compare-mode to align Java and MySQL ordering for string chunk keys ASF GitHub Bot (Jira)
• [PR] [FLINK-39749][mysql-cdc] Add scan.incremental.snapshot.string-key.compare-mode option [flink-cdc] via GitHub
• [jira] [Created] (FLINK-39749) [mysql-cdc] Introduce scan.incremental.snapshot.string-key.compare-mode to align Java and MySQL ordering for string chunk keys Ziyan Lee (Jira)
• [jira] [Commented] (FLINK-39746) Add jdk25 profile in in common_docker.sh Sergey Nuyanzin (Jira)
• [jira] [Resolved] (FLINK-39746) Add jdk25 profile in in common_docker.sh Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-39216) [Kubernetes Operator] Add PKCS12 profile option for webhook certificate to support FIPS environments Breno Caetano (Jira)
• [jira] [Updated] (FLINK-39748) Postgres CDC snapshot produces wrong values for TIMESTAMP / TIMESTAMPTZ / DATE columns with historical dates ASF GitHub Bot (Jira)
• [PR] [FLINK-39748][postgres] Fix snapshot timestamp drift for historical TIMESTAMP/DATE columns [flink-cdc] via GitHub
• [jira] [Created] (FLINK-39748) Postgres CDC snapshot produces wrong values for TIMESTAMP / TIMESTAMPTZ / DATE columns with historical dates Di Wu (Jira)
• Re: [PR] [FLINK-37351][runtime] Ensure Writer/Committer Colocation for Non-Pre-Commit Topologies [flink] via GitHub
• Re: [PR] Allow content to expire [flink-web] via GitHub
• [jira] [Commented] (FLINK-39042) [webui] Make watermark timestamps timezone-aware and configurable Yuepeng Pan (Jira)
• Re: [PR] [FLINK-39042][webui] Port timezone-aware watermark timestamps to release-2.1 [flink] via GitHub
• [jira] [Commented] (FLINK-39401) Extend raw format to support line-delimiter option Yuepeng Pan (Jira)
• Re: [PR] [FLINK-39401][formats] Port raw line-delimiter option to release-2.1 [flink] via GitHub
• [jira] [Commented] (FLINK-33994) Use Datadog api key from environment variables if not set in conf Thierno BARRY (Jira)
• [jira] [Updated] (FLINK-33994) Use Datadog api key from environment variables if not set in conf Thierno BARRY (Jira)
• [jira] [Commented] (FLINK-36456) Improve Security in DatadogHttpReporterFactory by providing ENV alternative to retrieve API key Thierno BARRY (Jira)
• [PR] [release-0.1][ci] Cherry-pick #584 #585: fix CI by removing astral-sh/setup-uv and pinning uv version [flink-agents] via GitHub
  • Re: [PR] [hotfix] Cherry-pick #584 #585: fix CI by removing astral-sh/setup-uv and pinning uv version [flink-agents] via GitHub
  • Re: [PR] [hotfix] Cherry-pick #584 #585: fix CI by removing astral-sh/setup-uv and pinning uv version [flink-agents] via GitHub
• [jira] [Commented] (FLINK-39720) SubQueryDecorrelator produces incorrect plans for correlated EXISTS with HAVING on aggregate outputs lincoln lee (Jira)
• Re: [I] [Tech Debt] Add e2e test for submitting example to flink standalone cluster. [flink-agents] via GitHub
• [jira] [Updated] (FLINK-36298) NullPointerException in Calcite causes a PyFlink test failure ASF GitHub Bot (Jira)
• [PR] [FLINK-36298][table] Fix NullPointerException in metadata query supplier on fresh threads [flink] via GitHub
  • Re: [PR] [FLINK-36298][table] Fix NullPointerException in metadata query supplier on fresh threads [flink] via GitHub
• [PR] Fix CdcAsFlussRow.java file location to match package declaration [flink-cdc] via GitHub
  • Re: [PR] Fix CdcAsFlussRow.java file location to match package declaration [flink-cdc] via GitHub
• [PR] [FLINK-39747] Upgrade test to junit 5 [flink-connector-elasticsearch] via GitHub
  • Re: [PR] [FLINK-39747] Upgrade test to junit 5 [flink-connector-elasticsearch] via GitHub
• [jira] [Updated] (FLINK-39747) Upgrade test to junit 5 Fan Deng (Jira)
• [jira] [Created] (FLINK-39747) Upgrade test to junit 5 Fan Deng (Jira)
• [PR] [ci] Replace burnett01/rsync-deployments with local composite action [flink-agents] via GitHub
  • Re: [PR] [ci] Replace burnett01/rsync-deployments with local composite action [flink-agents] via GitHub
  • Re: [PR] [ci] Replace burnett01/rsync-deployments with local composite action [flink-agents] via GitHub
  • Re: [PR] [ci] Replace burnett01/rsync-deployments with local composite action [flink-agents] via GitHub
• [jira] [Updated] (FLINK-36472) Correlates with UDTF don't handle right-side projections or empty conditions ASF GitHub Bot (Jira)
• [PR] [FLINK-36472][table] Preserve right-side projections when converting Correlate to physical [flink] via GitHub
  • Re: [PR] [FLINK-36472][table] Preserve right-side projections when converting Correlate to physical [flink] via GitHub
• Re: [I] [Feature] Support making use of the native capabilities of models for structure output. [flink-agents] via GitHub
• [PR] [ci] Refactor CI of test cases in integration module [flink-agents] via GitHub
• [I] [Tech Debt] Remove Python-3.10-only Ollama auto-pull block in integration tests (follow-up to #161) [flink-agents] via GitHub
• [jira] [Updated] (FLINK-39746) Add jdk25 profile in in common_docker.sh ASF GitHub Bot (Jira)
• [PR] [FLINK-39746][build] Add jdk25 profile in `common_docker.sh` [flink] via GitHub
  • Re: [PR] [FLINK-39746][build] Add jdk25 profile in `common_docker.sh` [flink] via GitHub
  • Re: [PR] [FLINK-39746][build] Add jdk25 profile in `common_docker.sh` [flink] via GitHub
• [jira] [Created] (FLINK-39746) Add jdk25 profile in in common_docker.sh Sergey Nuyanzin (Jira)
• Re: [PR] [FLINK-39009] Support PostgreSQL unnest insert in dynamic table. [flink-connector-jdbc] via GitHub
• [jira] [Created] (FLINK-39745) Web dashboard: surface watermark lag as a per-job timeline Purushottam Sinha (Jira)
• [PR] [hotfix][docs] Fix duplicate word typos in documentation [flink] via GitHub
  • Re: [PR] [hotfix][docs] Fix duplicate word typos in documentation [flink] via GitHub
  • Re: [PR] [hotfix][docs] Fix duplicate word typos in documentation [flink] via GitHub
• Re: [PR] [FLINK-38742][cdc-pipeline/postgres] Fix timestamp with time zone [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-39692) Include caught exceptions in warn/error log statements Pavel Zeger (Jira)
  • [jira] [Updated] (FLINK-39692) Include caught exceptions in warn/error log statements Pavel Zeger (Jira)
  • [jira] [Updated] (FLINK-39692) Include caught exceptions in warn/error log statements Pavel Zeger (Jira)
• [jira] [Resolved] (FLINK-38944) Introduce a benchmark on adaptive partition selection for RescalePartitioner and RebalancePartitioner Yuepeng Pan (Jira)
• [jira] [Resolved] (FLINK-31655) Umbrella: FLIP-339: Support Adaptive Partition Selection for StreamPartitioner Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-38944) Introduce a benchmark on adaptive partition selection for RescalePartitioner and RebalancePartitioner Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-38944) Introduce a benchmark on adaptive partition selection for RescalePartitioner and RebalancePartitioner Yuepeng Pan (Jira)
• [jira] [Comment Edited] (FLINK-39478) Newly-added tables become ghost tables after job restart during initial snapshot phase Jubin Soni (Jira)
• [jira] [Updated] (FLINK-39478) Newly-added tables become ghost tables after job restart during initial snapshot phase ASF GitHub Bot (Jira)
• [PR] [FLINK-39478][mysql] Persist checkpointIdToFinish and expose enumerat or metrics [flink-cdc] via GitHub
• [jira] [Commented] (FLINK-39478) Newly-added tables become ghost tables after job restart during initial snapshot phase Jubin Soni (Jira)
  • [jira] [Commented] (FLINK-39478) Newly-added tables become ghost tables after job restart during initial snapshot phase Jubin Soni (Jira)
• [jira] [Closed] (FLINK-39461) Release Testing Instructions: FLIP-558: Improvements to SinkUpsertMaterializer and changelog disorder Yuepeng Pan (Jira)
• [jira] [Closed] (FLINK-39744) Release Testing: Verify FLIP-558: Improvements to SinkUpsertMaterializer and changelog disorder Yuepeng Pan (Jira)
• [jira] [Assigned] (FLINK-39744) Release Testing: Verify FLIP-558: Improvements to SinkUpsertMaterializer and changelog disorder Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-39744) Release Testing: Verify FLIP-558: Improvements to SinkUpsertMaterializer and changelog disorder Yuepeng Pan (Jira)
• [jira] [Assigned] (FLINK-39710) Release Testing: Verify FLIP-565: Improve ProcessTableFunctions for late data handling and state access Yuepeng Pan (Jira)
• [PR] [doc] Refactor the installation documentation based on install.sh [flink-agents] via GitHub
  • Re: [PR] [doc] Refactor the installation documentation based on install.sh [flink-agents] via GitHub
  • Re: [PR] [doc] Refactor the installation documentation based on install.sh [flink-agents] via GitHub
  • Re: [PR] [doc] Refactor the installation documentation based on install.sh [flink-agents] via GitHub
  • Re: [PR] [doc] Refactor the installation documentation based on install.sh [flink-agents] via GitHub
  • Re: [PR] [doc] Refactor the installation documentation based on install.sh [flink-agents] via GitHub
• [jira] [Commented] (FLINK-39742) FlinkImageBuilder checks for Java 25 Sergey Nuyanzin (Jira)
• [jira] [Resolved] (FLINK-39742) FlinkImageBuilder checks for Java 25 Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-39743) Incorrect Expected Processing Rate Computation Devika Sudheer (Jira)
• [jira] [Updated] (FLINK-39743) Incorrect Expected Processing Rate Computation Devika Sudheer (Jira)
  • [jira] [Updated] (FLINK-39743) Incorrect Expected Processing Rate Computation Devika Sudheer (Jira)
• [jira] [Resolved] (FLINK-39407) CreateTableEvent failed in MySQL to Paimon pipeline Xiqian Yu (Jira)
• [jira] [Updated] (FLINK-39742) FlinkImageBuilder checks for Java 25 Sergey Nuyanzin (Jira)
  • [jira] [Updated] (FLINK-39742) FlinkImageBuilder checks for Java 25 ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-39742) FlinkImageBuilder checks for Java 25 Sergey Nuyanzin (Jira)
• [PR] [FLINK-39742][tests] FlinkImageBuilder checks for Java 25 [flink] via GitHub
  • Re: [PR] [FLINK-39742][tests] FlinkImageBuilder checks for Java 25 [flink] via GitHub
  • Re: [PR] [FLINK-39742][tests] FlinkImageBuilder checks for Java 25 [flink] via GitHub
• [jira] [Closed] (FLINK-38793) Reuse result of functions if ther are used multiple times as input for other functions Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-38793) Reuse result of functions if ther are used multiple times as input for other functions Sergey Nuyanzin (Jira)
• Re: [PR] [FLINK-30975][filesystems] Upgrade to Hadoop to 3.4.3 and support AWS SDK v2 in flink-filesystem [flink] via GitHub
• [jira] [Commented] (FLINK-39643) [docs] Fix and improve MongoDB connector documentation Aleksandr Savonin (Jira)
• [jira] [Updated] (FLINK-35661) MiniBatchGroupAggFunction can silently drop records under certain conditions Rui Fan (Jira)
• [jira] [Commented] (FLINK-35661) MiniBatchGroupAggFunction can silently drop records under certain conditions Rui Fan (Jira)
• Re: [PR] [FLINK-35661][table] Fix MiniBatchGroupAggFunction silently dropping records (backport 2.0) [flink] via GitHub
• Re: [PR] [FLINK-35661][table] Fix MiniBatchGroupAggFunction silently dropping records (backport 2.1) [flink] via GitHub
• Re: [PR] [FLINK-35661][table] Fix MiniBatchGroupAggFunction silently dropping records (backport 2.2) [flink] via GitHub
• [PR] [FLINK-39740][table/runtime] Fix highSqn update in LinkedMultiSetState.add [flink] via GitHub
  • Re: [PR] [FLINK-39740][table/runtime] Fix highSqn update in LinkedMultiSetState.add [flink] via GitHub
  • Re: [PR] [FLINK-39740][table/runtime] Fix highSqn update in LinkedMultiSetState.add [flink] via GitHub
  • Re: [PR] [FLINK-39740][table/runtime] Fix highSqn update in LinkedMultiSetState.add [flink] via GitHub
  • Re: [PR] [FLINK-39740][table/runtime] Fix highSqn update in LinkedMultiSetState.add [flink] via GitHub
• [jira] [Commented] (FLINK-39735) Expose input upsert key on TableSemantics for ProcessTableFunctions Jubin Soni (Jira)
• [PR] [FLINK-39735][table] Expose input upsert key on TableSemantics for PTFs [flink] via GitHub
  • Re: [PR] [FLINK-39735][table] Expose input upsert key on TableSemantics for PTFs [flink] via GitHub
• [jira] (FLINK-39407) CreateTableEvent failed in MySQL to Paimon pipeline Melih Aycicek (Jira)
• [jira] [Updated] (FLINK-39741) Add generic type hints to DataStream functions in functions.py ASF GitHub Bot (Jira)
• [jira] [Commented] (FLINK-39741) Add generic type hints to DataStream functions in functions.py Vaibhav S Gowda (Jira)
• [jira] [Created] (FLINK-39741) Add generic type hints to DataStream functions in functions.py Vaibhav S Gowda (Jira)
• [jira] [Commented] (FLINK-37912) Typing the DataStream interfaces Vaibhav S Gowda (Jira)
• [jira] [Commented] (FLINK-39740) LinkedMultiSetState updates highestSqnAndSizeState unconditionally Jubin Soni (Jira)
  • [jira] [Commented] (FLINK-39740) LinkedMultiSetState updates highestSqnAndSizeState unconditionally Roman Khachatryan (Jira)
  • [jira] [Commented] (FLINK-39740) LinkedMultiSetState updates highestSqnAndSizeState unconditionally Roman Khachatryan (Jira)
• [PR] [FLINK-39740][table-runtime] Do not regress highestSqnAndSizeState on row replace in LinkedMultiSetState [flink] via GitHub
  • Re: [PR] [FLINK-39740][table-runtime] Do not regress highestSqnAndSizeState on row replace in LinkedMultiSetState [flink] via GitHub

• Earlier messages