issues
Thread
Date
Earlier messages
Later messages
Messages by Thread
Re: [PR] [FLINK-38450][iceberg] Fix duplicate records when schema change splits writes within a checkpoint [flink-cdc]
via GitHub
Re: [PR] [FLINK-38450][iceberg] Fix duplicate records when schema change splits writes within a checkpoint [flink-cdc]
via GitHub
Re: [PR] [FLINK-38450][iceberg] Fix duplicate records when schema change splits writes within a checkpoint [flink-cdc]
via GitHub
Re: [PR] [FLINK-38450][iceberg] Fix duplicate records when schema change splits writes within a checkpoint [flink-cdc]
via GitHub
Re: [PR] [FLINK-38450][iceberg] Fix duplicate records when schema change splits writes within a checkpoint [flink-cdc]
via GitHub
Re: [PR] [FLINK-38450][iceberg] Fix duplicate records when schema change splits writes within a checkpoint [flink-cdc]
via GitHub
Re: [PR] [FLINK-38450][iceberg] Fix duplicate records when schema change splits writes within a checkpoint [flink-cdc]
via GitHub
Re: [PR] [FLINK-38450][iceberg] Fix duplicate records when schema change splits writes within a checkpoint [flink-cdc]
via GitHub
Re: [PR] [FLINK-38450][iceberg] Fix duplicate records when schema change splits writes within a checkpoint [flink-cdc]
via GitHub
Re: [PR] [FLINK-38450][iceberg] Fix duplicate records when schema change splits writes within a checkpoint [flink-cdc]
via GitHub
Re: [PR] [FLINK-38450][iceberg] Fix duplicate records when schema change splits writes within a checkpoint [flink-cdc]
via GitHub
Re: [PR] [FLINK-38450][iceberg] Fix duplicate records when schema change splits writes within a checkpoint [flink-cdc]
via GitHub
[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)
Re: [PR] [FLINK-39582][postgres] Allow logical messages [flink-cdc]
via GitHub
Re: [PR] [FLINK-39582][postgres] Allow logical messages [flink-cdc]
via GitHub
Re: [PR] [FLINK-39582][postgres] Allow logical messages [flink-cdc]
via GitHub
Re: [PR] [FLINK-39582][postgres] Allow logical messages [flink-cdc]
via GitHub
Re: [PR] [FLINK-39582][postgres] Allow logical messages [flink-cdc]
via GitHub
Re: [PR] [FLINK-39582][postgres] Allow logical messages [flink-cdc]
via GitHub
Re: [PR] [FLINK-39582][postgres] Allow logical messages [flink-cdc]
via GitHub
Re: [PR] [FLINK-39582][postgres] Allow logical messages [flink-cdc]
via GitHub
Re: [PR] [FLINK-39582][postgres] Allow logical messages [flink-cdc]
via GitHub
Re: [PR] [FLINK-39582][postgres] Allow logical messages [flink-cdc]
via GitHub
Re: [PR] [FLINK-39582][postgres] Allow logical messages [flink-cdc]
via GitHub
Re: [PR] [FLINK-39582][postgres] Allow logical messages [flink-cdc]
via GitHub
Re: [PR] [FLINK-39582][postgres] Allow logical messages [flink-cdc]
via GitHub
Re: [PR] [FLINK-39582][postgres] Allow logical messages [flink-cdc]
via GitHub
Re: [PR] [FLINK-39582][postgres] Allow logical messages [flink-cdc]
via GitHub
Re: [PR] [FLINK-39582][postgres] Allow logical messages [flink-cdc]
via GitHub
Re: [PR] [FLINK-39582][postgres] Allow logical messages [flink-cdc]
via GitHub
[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)
Re: [PR] [FLINK-37834] Flink JDBC support ClickHouse Dialect [flink-connector-jdbc]
via GitHub
[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
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] [hotfix] Reuse FlinkConfigManager#isSnapshotCrdInstalled in controllers [flink-kubernetes-operator]
via GitHub
Re: [PR] Bump JOSDK to 5.3 [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)
Re: [I] [Tech Debt] Documentation for AWS integrations (Bedrock, OpenSearch, S3 Vectors) [flink-agents]
via GitHub
[jira] [Updated] (FLINK-39710) Release Testing: Verify FLIP-565: Improve ProcessTableFunctions for late data handling and state access
Mukul Gupta (Jira)
[jira] [Updated] (FLINK-39710) Release Testing: Verify FLIP-565: Improve ProcessTableFunctions for late data handling and state access
Mukul Gupta (Jira)
[jira] [Updated] (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
Re: [PR] [hotfix] Clean up FlinkBlueGreenDeploymentController [flink-kubernetes-operator]
via GitHub
Re: [PR] [hotfix] Clean up FlinkBlueGreenDeploymentController [flink-kubernetes-operator]
via GitHub
Re: [PR] [hotfix] Clean up FlinkBlueGreenDeploymentController [flink-kubernetes-operator]
via GitHub
Re: [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
Re: [PR] [FLINK-39752] Thread EventRecorder through FlinkResourceContext instead of holding it on the factory [flink-kubernetes-operator]
via GitHub
Re: [PR] [FLINK-39752] Thread EventRecorder through FlinkResourceContext instead of holding it on the factory [flink-kubernetes-operator]
via GitHub
Re: [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
Re: [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] [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)
Re: [PR] [Doc] Add documentation for Amazon Bedrock, Amazon OpenSearch, and Amazon S3 Vectors integrations [flink-agents]
via GitHub
Re: [PR] [Doc] Add documentation for Amazon Bedrock, Amazon OpenSearch, and Amazon S3 Vectors integrations [flink-agents]
via GitHub
Re: [PR] [Doc] Add documentation for Amazon Bedrock, Amazon OpenSearch, and Amazon S3 Vectors integrations [flink-agents]
via GitHub
[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
Re: [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
Re: [PR] [hotfix][test] Finalize JUnit 5 migration and prune unused test dependencies [flink-kubernetes-operator]
via GitHub
Re: [PR] [hotfix][test] Finalize JUnit 5 migration and prune unused test dependencies [flink-kubernetes-operator]
via GitHub
Re: [PR] [hotfix][test] Finalize JUnit 5 migration and prune unused test dependencies [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
Re: [PR] [FLINK-39216][Kubernetes-Operator] - Add PKCS12 profile option for webhook certificate [flink-kubernetes-operator]
via GitHub
Re: [PR] [FLINK-39216][helm] Add PKCS12 profile option for webhook certificate [flink-kubernetes-operator]
via GitHub
Re: [PR] [FLINK-39216][helm] Add PKCS12 profile option for webhook certificate [flink-kubernetes-operator]
via GitHub
Re: [PR] [FLINK-39216][helm] Add PKCS12 profile option for webhook certificate [flink-kubernetes-operator]
via GitHub
Re: [PR] [FLINK-39216][helm] Add PKCS12 profile option for webhook certificate [flink-kubernetes-operator]
via GitHub
Re: [PR] [FLINK-39216][helm] Add PKCS12 profile option for webhook certificate [flink-kubernetes-operator]
via GitHub
Re: [PR] [FLINK-39216][helm] 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
Re: [PR] [FLINK-39749][mysql-cdc] Support configurable string chunk key comparison mode to align with MySQL collation [flink-cdc]
via GitHub
Re: [PR] [FLINK-39749][mysql-cdc] Support configurable string chunk key comparison mode to align with MySQL collation [flink-cdc]
via GitHub
Re: [PR] [FLINK-39749][mysql-cdc] Support configurable string chunk key comparison mode to align with MySQL collation [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)
Re: [PR] [INFRA] Set up default rulesets for default and release branches [flink-agents]
via GitHub
[jira] [Commented] (FLINK-39216) [Kubernetes Operator] Add PKCS12 profile option for webhook certificate to support FIPS environments
Breno Caetano (Jira)
[jira] [Commented] (FLINK-39216) [Kubernetes Operator] Add PKCS12 profile option for webhook certificate to support FIPS environments
Pavel Zeger (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-39034][streaming] Fix timestamp loss in SortPartitionOperator [flink]
via GitHub
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: [PR] [FLINK-39720][table] SubQueryDecorrelator produces incorrect plans for correlated EXISTS with HAVING on aggregate outputs [flink]
via GitHub
[PR] [FLINK-39720][table] SubQueryDecorrelator produces incorrect plans for correlated EXISTS with HAVING on aggregate outputs [flink]
via GitHub
Re: [PR] [FLINK-39720][table] SubQueryDecorrelator produces incorrect plans for correlated EXISTS with HAVING on aggregate outputs [flink]
via GitHub
Re: [PR] [FLINK-39720][table] SubQueryDecorrelator produces incorrect plans for correlated EXISTS with HAVING on aggregate outputs [flink]
via GitHub
Re: [PR] [FLINK-39720][table] SubQueryDecorrelator produces incorrect plans for correlated EXISTS with HAVING on aggregate outputs [flink]
via GitHub
[PR] [FLINK-39720][table] SubQueryDecorrelator produces incorrect plans for correlated EXISTS with HAVING on aggregate outputs [flink]
via GitHub
Re: [PR] [FLINK-39720][table] SubQueryDecorrelator produces incorrect plans for correlated EXISTS with HAVING on aggregate outputs [flink]
via GitHub
Re: [I] [Tech Debt] Add e2e test for submitting example to flink standalone cluster. [flink-agents]
via GitHub
Re: [PR] [Feature][Python] Implement EventListener in python sdk [flink-agents]
via GitHub
Re: [PR] [Feature][Python] Implement EventListener in python sdk [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
Re: [PR] [FLINK-39697] Bump Flink version to 2.2.1 [flink-connector-pulsar]
via GitHub
Re: [PR] [FLINK-39697] Bump Flink version to 2.2.1 [flink-connector-pulsar]
via GitHub
Re: [PR] [FLINK-39697] Bump Flink version to 2.2.1 [flink-connector-pulsar]
via GitHub
Re: [PR] [FLINK-39697] Bump Flink version to 2.2.1 [flink-connector-pulsar]
via GitHub
Re: [PR] [FLINK-39697] Bump Flink version to 2.2.1 [flink-connector-pulsar]
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
Re: [PR] [FLINK-39747] Upgrade test to junit 5 [flink-connector-elasticsearch]
via GitHub
Re: [PR] [FLINK-39747] Upgrade test to junit 5 and remove junit4 dependency [flink-connector-elasticsearch]
via GitHub
Re: [PR] [FLINK-39747] Upgrade test to junit 5 and remove junit4 dependency [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
Re: [PR] [FLINK-38742][cdc-pipeline/postgres] Fix timestamp with time zone [flink-cdc]
via GitHub
Re: [PR] [FLINK-38742][cdc-pipeline/postgres] Fix timestamp with time zone [flink-cdc]
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)
Re: [PR] [FLINK-39619][docs] Add release notes for Flink 2.3 [flink]
via GitHub
Re: [PR] [FLINK-39619][docs] Add release notes for Flink 2.3 [flink]
via GitHub
[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)
Re: [PR] [FLINK-38944][benchmark] Introduce a benchmark on adaptive partition selection for RescalePartitioner and RebalancePartitioner [flink-benchmarks]
via GitHub
[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
Re: [PR] [FLINK-39478][mysql] Persist checkpointIdToFinish and expose enumerat or metrics [flink-cdc]
via GitHub
Earlier messages
Later messages