commits  

Messages by Thread

• (flink-connector-jdbc) branch dependabot/maven/org.apache.commons-commons-lang3-3.18.0 deleted (was 0c36072d) github-bot
• (flink) branch master updated: [FLINK-40109] Verify Kerberos keytab logs after the YARN application is killed martijnvisser
• (flink) branch master updated: [hotfix] Use `systemPropertyVariables` instead of `systemProperties` snuyanzin
• (flink) branch master updated (4732a5210a8 -> c2f0c123409) fanrui
  • (flink) 08/08: [FLINK-39521][network] CheckpointedInputGate: consume EndOfFetchedChannelStateEvent fanrui
  • (flink) 01/08: [FLINK-39521][test] Temporarily remove during-recovery flag from ITCase randomization fanrui
  • (flink) 03/08: [FLINK-39521][network] Add RecoverableInputChannel contract and recovery sentinels fanrui
  • (flink) 07/08: [FLINK-39521][network] Propagate needsRecovery in PartitionRequest; start view reader with zero credit fanrui
  • (flink) 05/08: [FLINK-39521][network] RemoteInputChannel: push-based recovery state fanrui
  • (flink) 04/08: [FLINK-39521][network] LocalInputChannel: push-based recovery state fanrui
  • (flink) 06/08: [FLINK-39521][network] Convert recovered channels via the push interface; thread needsRecovery through gates fanrui
  • (flink) 02/08: [FLINK-39521][network] BufferManager: gate credit notification behind notifyInitiallyEnabled fanrui
• (flink-kubernetes-operator) branch main updated: [FLINK-38795] Support Flink 2.0+ HA in standalone mode fcsaky
• (flink-kubernetes-operator) branch main updated: [hotfix] Fix typos in operator documentation, comments and scripts (#1148) fanrui
• (flink-agents) branch main updated: [docs] Clarify review policy (#890) wenjin
• (flink-agents) branch main updated: [python] Backfill remote test coverage ahead of local execution path removal (#881) wenjin
• (flink-cdc) branch master updated: [FLINK-39760][postgres] Fix missing JTS core dependency of PostgreSQL YAML connector (#4467) kunni
• (flink) branch master updated: [FLINK-40111][table-planner] Fall back to retract for a keyless sink without an upsert key twalthr
• (flink) branch master updated: [FLINK-40112][table-planner] Report changelog mode mismatch instead of a generic planning error twalthr
• (flink) branch release-2.2 updated: [hotfix] Fix misprint in upload artifact condition snuyanzin
• (flink-cdc) branch master updated: [hotfix] Bump Mockito for JDK 17 tests (#4463) kunni
• (flink-connector-elasticsearch) branch v4.0 updated: [FLINK-38054] Fix OperationSerializer issue for es8 sink guoweijie
• (flink) branch release-1.20 updated: [hotfix] Fix misprint in upload artifact condition snuyanzin
• (flink) branch release-2.1 updated: [hotfix] Fix misprint in upload artifact condition snuyanzin
• (flink) branch release-2.3 updated: [hotfix] Fix misprint in upload artifact condition snuyanzin
• (flink) branch release-2.1 updated: [hotfix][ci] Do not run GHA nightly if there is no newer commits since the last run snuyanzin
• (flink) branch release-2.2 updated: [hotfix][ci] Do not run GHA nightly if there is no newer commits since the last run snuyanzin
• (flink) branch release-2.3 updated: [hotfix][ci] Do not run GHA nightly if there is no newer commits since the last run snuyanzin
• (flink) branch release-1.20 updated: [hotfix][ci] Do not run GHA nightly if there is no newer commits since the last run snuyanzin
• (flink) branch master updated: [FLINK-39191][runtime-web] Upgrade monaco-editor to 0.55.1 (#27745) martijnvisser
• svn commit: r85798 - dev/flink/flink-connector-jdbc-4.1.0-rc4 panyuepeng
• (flink-connector-jdbc) annotated tag v4.1.0-rc4 updated (a528bf5c -> 079d1baa) panyuepeng
• svn commit: r85797 - dev/flink/flink-connector-jdbc-3.4.0-rc4 panyuepeng
• (flink-connector-jdbc) annotated tag v3.4.0-rc4 updated (72282c57 -> beab454c) panyuepeng
• (flink) branch release-2.2 updated (1c7d62e404d -> 82c1e4eb6d1) martijnvisser
  • (flink) 03/05: [FLINK-39922][runtime/test] Fix the flaky test case AbstractAsyncRunnableStreamOperatorTest#testCheckpointDrain (#28425) martijnvisser
  • (flink) 04/05: [FLINK-39921][runtime/tests] Fix the flaky test case ExecutionVertexCancelTest.testSendCancelAndReceiveFail (#28449) martijnvisser
  • (flink) 05/05: [FLINK-39929][runtime/tests] Fix the flaky test case ExecutionTimeBasedSlowTaskDetectorTest due to unexepected ComponentMainThreadExecutor setting. (#28434) martijnvisser
  • (flink) 02/05: [FLINK-39914][runtime] Fix flaky TaskDeploymentDescriptorFactoryTest#testHybridVertexFinish caused by async TDD creation (#28398) martijnvisser
  • (flink) 01/05: [FLINK-39387][Test] Fix flaky scheduler benchmark tests caused by thread assertion failure in async TDD creation martijnvisser
• (flink) branch master updated: [FLINK-39583][table-planner] Normalize Calcite correl variables for more effective sub-plan digest reuse (#27959) fcsaky
• (flink-connector-aws) branch main updated: [FLINK-40065] Update `flink-connector-parent` to 2.0.0 and Flink to 2.1.2 fcsaky
• (flink-kubernetes-operator) branch main updated: [FLINK-40104] Logging framework JARs are placed under /log instead of the operator lib directory gyfora
• (flink-kubernetes-operator) branch main updated: [FLINK-40106] Move FlinkResourceValidator and FlinkResourceMutator to the api module gyfora
• (flink-kubernetes-operator) branch main updated: [FLINK-40107] Group example modules under an examples aggregator pom gyfora
• (flink-kubernetes-operator) branch main updated: [hotfix] Cleanup api compatibility test execution gyfora
• (flink) branch master updated: [FLINK-40099] Fix flaky YARNSessionFIFOSecuredITCase by verifying Kerberos keytab logs before the application is killed martijnvisser
• (flink) branch master updated: [FLINK-40084][build] maven-shade-plugin does not respect multi release jars snuyanzin
• (flink) branch master updated (7f770b87178 -> 8cd1c0ec657) fanrui
  • (flink) 01/05: [hotfix] Report END_OF_INPUT from multiple-input processor when all inputs finished fanrui
  • (flink) 04/05: [FLINK-39520][network] Add InputGate#getChannel(InputChannelInfo) fanrui
  • (flink) 02/05: [FLINK-39520][network] Decouple LocalInputChannel recovery wiring from toBeConsumedBuffers fanrui
  • (flink) 03/05: [FLINK-39520][checkpoint] Extract AbstractInputChannelRecoveredStateHandler with concrete no-filtering/filtering handlers fanrui
  • (flink) 05/05: [FLINK-39520][network] Additive logging overload; widen releaseAllResources visibility fanrui
• (flink) branch master updated: [FLINK-40076][tests] Fix race in RescaleTimelineITCase.testRecordNonTerminatedRescaleMergingWithNewRecoverableFailureTriggerCause mapohl
• (flink) branch master updated: [FLINK-40096][table] Migrate `EXPLAIN` `CTAS`/`RTAS` Explain tests to Java snuyanzin
• (flink-connector-elasticsearch) branch main updated: [FLINK-38429] Improve perf for Elasticsearch 8 connector guoweijie
• (flink-connector-jdbc) branch dependabot/maven/flink-connector-jdbc-sqlserver/com.microsoft.sqlserver-mssql-jdbc-11.2.0.jre8 created (now 1ae7aa9f) github-bot
• (flink-connector-jdbc) branch main updated: [hotfix] Add missing ASF license headers in backward-compatibility module (#205) panyuepeng
• (flink-connector-jdbc) branch v3.4 updated: [hotfix] Add missing ASF license headers in backward-compatibility module (#207) panyuepeng
• (flink-connector-jdbc) branch v4.1 updated: [hotfix] Add missing ASF license headers in backward-compatibility module (#206) panyuepeng
• (flink) branch master updated (3e3e270c98d -> a1dcc9d5bec) martijnvisser
• (flink-shaded) branch master updated: [FLINK-40090][docs] Add cryptography export notice to README martijnvisser
• (flink-connector-elasticsearch) branch main updated: [FLINK-38054] Fix OperationSerializer issue for es8 sink guoweijie
• (flink) branch release-2.3 updated: [hotfix] Bump download-artifact action to v8 as GHA requires snuyanzin
• (flink-cdc) branch master updated: [FLINK-40091][connect/paimon] Upgrade Paimon SDK to 1.4.2 (#4465) yux
• (flink-agents) branch main updated: [runtime] Binary serde for MemoryUpdate values via versioned Kryo envelope (#874) wenjin
• (flink-connector-http) branch dependabot/maven/org.apache.flink-flink-table-planner_2.12-2.2.1 deleted (was b57f2ec) github-bot
• (flink-connector-http) branch dependabot/maven/org.apache.flink-flink-table-runtime-2.2.1 deleted (was ac3e465) github-bot
• (flink-connector-http) branch dependabot/maven/org.apache.flink-flink-table-api-java-2.2.1 deleted (was 7e3e326) github-bot
• (flink-connector-http) branch main updated: [FLINK-40030][connector-http] Add architecture tests (#50) davidrad
• (flink-agents) branch main updated: [hotfix] Propagate action task Errors from mailbox (#880) wenjin
• (flink) branch release-2.3 updated: [FLINK-40082][table] Watermark generated method `extractTimestamp` might invoke code throwing exceptions snuyanzin
• (flink-agents) branch release-0.3 updated: [python] Remove PyFlink gateway fallback from AgentConfigOptions (#867) wenjin
• (flink-agents) branch main updated: [python] Remove PyFlink gateway fallback from AgentConfigOptions (#867) wenjin
• (flink-agents) branch main updated: [infra] Add AGENTS.md (#878) wenjin
• (flink-connector-jdbc) branch dependabot/maven/flink-connector-jdbc-core/org.apache.derby-derby-10.17.1.0 created (now 0a233f6d) github-bot
• (flink-docker) branch dev-master updated: [FLINK-39924] Size jemalloc narenas from container CPU allowance roman
• (flink) branch master updated: [FLINK-39923][state] Fix RocksDB Statistics native memory leak (#28489) roman
• (flink) branch master updated: [FLINK-40039][table] Fix `CTAS`/`RTAS` when used with set-semantic PTFs snuyanzin
• (flink) branch master updated: [FLINK-36334][tests] Enable TraversableSerializerUpgradeTest snuyanzin
• (flink) branch master updated: [FLINK-39715][table] Sync SQL and table api behavior for queries with sort snuyanzin
• (flink) branch release-2.2 updated: [FLINK-40082][table] Watermark generated method `extractTimestamp` might invoke code throwing exceptions snuyanzin
• svn commit: r85728 - dev/flink/flink-connector-jdbc-3.4.0-rc3 panyuepeng
• (flink-connector-jdbc) annotated tag v3.4.0-rc3 updated (5616f5eb -> dca63b3a) panyuepeng
• (flink) branch release-1.20 updated: [hotfix][ci] Use correct property `steps.docker-cache.outputs.cache-hit` snuyanzin
• (flink) branch master updated: [FLINK-40032][runtime-web] Migrate web-dashboard eslint to v9 (flat config) martijnvisser
• (flink) branch master updated: [FLINK-40045][runtime-web] Upgrade d3-flame-graph to v5 (#28601) martijnvisser
• (flink-cdc) branch master updated: [FLINK-39477][infra] Add AGENTS.md for AI-assisted contributions (#4380) yux
• (flink-agents) branch main updated: [ci] Use maintained 'temurin' distribution for setup-java (#873) wenjin
• (flink) branch release-2.2 updated: [hotfix][ci] Use correct property `steps.docker-cache.outputs.cache-hit` snuyanzin
• (flink) branch master updated: [FLINK-40082][table] Watermark generated method `extractTimestamp` might invoke code throwing exceptions snuyanzin
• (flink) branch master updated: [FLINK-32695][e2e] Migrate SqlToolbox watermark push-down source to Source V2 martijnvisser
• (flink) branch master updated: [FLINK-40068][tests] Do not assert apply() was called when cancelling KeyedJob window martijnvisser
• (flink) branch release-2.2 updated (65428744ebe -> 387edaa04ab) martijnvisser
  • (flink) 01/02: [FLINK-38441][runtime] Fix ExecutionGraphCoLocationRestartTest failures (#27060) martijnvisser
  • (flink) 02/02: [FLINK-39182][runtime/test] Fix the flaky test class ExecutionGraphRestartTest martijnvisser
• (flink) branch release-2.3 updated (8321c1b666d -> 0fc5a00df34) martijnvisser
  • (flink) 02/02: [FLINK-39929][runtime/tests] Fix the flaky test case ExecutionTimeBasedSlowTaskDetectorTest due to unexepected ComponentMainThreadExecutor setting. (#28434) martijnvisser
  • (flink) 01/02: [FLINK-39921][runtime/tests] Fix the flaky test case ExecutionVertexCancelTest.testSendCancelAndReceiveFail (#28449) martijnvisser
• (flink) branch release-2.1 updated: [hotfix][ci] Use correct property `steps.docker-cache.outputs.cache-hit` snuyanzin
• (flink) branch release-2.3 updated: [hotfix][ci] Use correct property `steps.docker-cache.outputs.cache-hit` snuyanzin
• (flink-connector-jdbc) branch v3.4 updated: [hotfix][Connectors/JDBC] Bump Flink test version to 1.20.5 to fix CI binary download (#203) panyuepeng
• (flink-connector-kafka) branch main updated: [FLINK-38919][docs] Document PyFlink per-cluster offsets (#280) bli
• (flink) branch release-1.20 updated: [FLINK-40074][tests] Avoid @TempDir cleanup race in SinkV2ITCase scaling test martijnvisser
• (flink) branch release-2.2 updated: [FLINK-40074][tests] Avoid @TempDir cleanup race in SinkV2ITCase scaling test martijnvisser
• (flink-connector-kafka) branch main updated (eb8ff700 -> ccb316cb) bli
• (flink) branch master updated: [FLINK-40074][tests] Avoid @TempDir cleanup race in SinkV2ITCase scaling test martijnvisser
• (flink) branch release-2.3 updated: [FLINK-40074][tests] Avoid @TempDir cleanup race in SinkV2ITCase scaling test martijnvisser
• (flink) branch release-1.20 updated (6e98363a802 -> 2a38d6b3366) martijnvisser
  • (flink) 01/02: [FLINK-36242][test] Fix inconsistent logic between listTable and getTable in TestFileSystemCatalog martijnvisser
  • (flink) 02/02: [FLINK-36242][table] Drop all materialized tables manually instead of automatically dropping them in the after method. martijnvisser
• (flink) branch master updated (9661ab549bc -> c73b956225a) snuyanzin
  • (flink) 03/08: [FLINK-39859][table] Remove deprecated `JavaConversions` from `Sink` and its children snuyanzin
  • (flink) 04/08: [FLINK-39859][table] Remove deprecated `JavaConversions` from `FlinkRelDistribution` snuyanzin
  • (flink) 06/08: [FLINK-39859][table] Remove usage of deprecated `getIndicatorCount` snuyanzin
  • (flink) 02/08: [FLINK-39859][table] Remove deprecated `JavaConversions` from `FlinkStatistic` snuyanzin
  • (flink) 05/08: [FLINK-39859][table] Remove deprecated `JavaConversions` from `FlinkRelMdUtil` snuyanzin
  • (flink) 07/08: [FLINK-39859][table] Replace deprecated usage of `SqlLiteral#createTimestamp` snuyanzin
  • (flink) 01/08: [FLINK-39859][table] Replace `Javaconverions` with `JavaConverters` in `RemoteCalcSplitRule` and `RemoteCalcSpliRule` snuyanzin
• svn commit: r85712 - dev/flink/flink-connector-jdbc-4.1.0-rc3 panyuepeng
• (flink-connector-jdbc) annotated tag v4.1.0-rc3 updated (3b7d5fe6 -> c8ea61a7) panyuepeng
• svn commit: r85710 - dev/flink/flink-connector-jdbc-4.1.0-rc2 panyuepeng
• (flink-connector-jdbc) branch v4.1 updated: [hotfix][tests] Introduce TestingStreamingRuntimeContext to assure the test cases run compatibility in JdbcDynamicTableSinkITCase panyuepeng
• (flink-connector-jdbc) annotated tag v4.1.0-rc2 updated (3b7d5fe6 -> 5843d8f2) panyuepeng
• (flink) branch release-2.3 updated (f73dec412d7 -> fcd20f29b87) martijnvisser
  • (flink) 02/02: [FLINK-39481][table] Add stress ITCase for watermarks deferred at end of input martijnvisser
  • (flink) 01/02: [FLINK-39481][task] Execute deferrable mails when finishing an operator martijnvisser
• svn commit: r85708 - dev/flink/flink-connector-jdbc-4.1.0-rc1 panyuepeng
• (flink-connector-jdbc) annotated tag v4.1.0-rc1 updated (9853ba1c -> f8727500) panyuepeng
• (flink) branch release-2.3 updated: [FLINK-40062][table] Allow `BridgingSqlAggFunction` being instantiated from `BuiltInFunctionDefinitions`, fix `$WELFORD_M2$1` function deserialization (#28647) snuyanzin
• (flink) branch release-1.20 updated (069ddfe5179 -> 6e98363a802) martijnvisser
  • (flink) 02/02: [FLINK-39481][table] Add stress ITCase for watermarks deferred at end of input martijnvisser
  • (flink) 01/02: [FLINK-39481][task] Execute deferrable mails when finishing an operator martijnvisser
• (flink) branch release-2.2 updated (7244dc10ea4 -> 30bec17c2bf) martijnvisser
  • (flink) 02/02: [FLINK-39481][table] Add stress ITCase for watermarks deferred at end of input martijnvisser
  • (flink) 01/02: [FLINK-39481][task] Execute deferrable mails when finishing an operator martijnvisser
• svn commit: r85706 - dev/flink/flink-connector-jdbc-3.4.0-rc2 panyuepeng
• (flink-connector-jdbc) annotated tag v3.4.0-rc2 updated (3f91a2db -> 3929d482) panyuepeng
• (flink) branch master updated: [FLINK-36753][runtime]Adaptive Scheduler actively triggers a Checkpoint after all resources are ready pnowojski
• (flink) branch master updated (2d14af307fb -> bbc688cef98) pnowojski
  • (flink) 01/02: [FLINK-39481][task] Execute deferrable mails when finishing an operator pnowojski
  • (flink) 02/02: [FLINK-39481][table] Add stress ITCase for watermarks deferred at end of input pnowojski
• (flink) branch master updated (a6669809b9f -> 2d14af307fb) snuyanzin
  • (flink) 02/02: [FLINK-40062][table] Allow `BridgingSqlAggFunction` being instantiated from `BuiltInFunctionDefinitions`, fix `$WELFORD_M2$1` function deserialization snuyanzin
  • (flink) 01/02: [FLINK-40062][table] Replace deprecated `JavaConversions` with `JavaConverters` snuyanzin
• (flink-agents) branch main updated: [dist] Add Flink 2.3 distribution and make it the default (#856) wenjin
• (flink-cdc) branch master updated (279278af6 -> e1e9c939c) kunni
• (flink-cdc) branch master updated: [FLINK-39934][postgres] Fix invalid tables format error message (#4442) kunni
• (flink-cdc) branch master updated (6914d7028 -> accee6552) leonard
  • (flink-cdc) 03/24: [test][connector/mysql] Stabilize NewlyAddedTableITCase failover waits leonard
  • (flink-cdc) 06/24: [test][connector/postgres] Stabilize PostgresSourceReaderTest schema polling leonard
  • (flink-cdc) 02/24: [test][ci] Keep E2E timezone selection on hour boundaries leonard
  • (flink-cdc) 04/24: [test][connector/mysql] Stabilize MySqlConnectorITCase waits leonard
  • (flink-cdc) 10/24: [test][source-e2e][mongodb] Wait for MongoE2eITCase snapshot before changes leonard
  • (flink-cdc) 08/24: [test][connector/sqlserver] Stabilize full types and timezone waits leonard
  • (flink-cdc) 22/24: [test] Keep stabilization changes semantically strict leonard
  • (flink-cdc) 19/24: [test][pipeline-e2e] Stabilize UdfE2eITCase event waits leonard
  • (flink-cdc) 11/24: [test][connector/oceanbase] Stabilize failover and startup waits leonard
  • (flink-cdc) 13/24: [test][pipeline-e2e] Add shared wait and checkpoint helpers leonard
  • (flink-cdc) 14/24: [test][pipeline-e2e] Stabilize MySqlToHudiE2eITCase visibility waits leonard
  • (flink-cdc) 15/24: [test][pipeline-e2e] Stabilize MySqlToIcebergE2eITCase commits leonard
  • (flink-cdc) 18/24: [test][pipeline-e2e] Stabilize TransformE2eITCase handoff waits leonard
  • (flink-cdc) 23/24: [test][pipeline-e2e] Skip checkpointing non-streaming Iceberg job leonard
  • (flink-cdc) 24/24: [test][pipeline-e2e] Share stream split readiness wait leonard
  • (flink-cdc) 20/24: [test][pipeline-e2e] Stabilize RouteE2eITCase batch wait leonard
  • (flink-cdc) 01/24: [fix][mysql-source] Compare varbinary split keys by byte value leonard
  • (flink-cdc) 12/24: [test][connector/tidb] Retry TiDB JDBC startup connections leonard
  • (flink-cdc) 05/24: [test][connector/postgres] Stabilize NewlyAddedTableITCase failover waits leonard
  • (flink-cdc) 07/24: [test][pipeline-postgres] Avoid canceling stopped savepoint jobs leonard
  • (flink-cdc) 09/24: [test][connector/mongodb] Tolerate newly-added table replay pair leonard
  • (flink-cdc) 17/24: [test][pipeline-e2e] Stabilize SqlServerE2eITCase split handoff leonard
  • (flink-cdc) 16/24: [test][pipeline-e2e] Wait for MysqlToKafkaE2eITCase stream handoff leonard
  • (flink-cdc) 21/24: [test][pipeline-e2e] Stabilize Hudi schema evolution waits leonard
• (flink-connector-jdbc) branch v4.1 created (now 9853ba1c) panyuepeng
  • (flink-connector-jdbc) 02/02: [hotfix][docs] Add flink-connector-jdbc-${database} dependency in docs (#166) panyuepeng
  • (flink-connector-jdbc) 01/02: Update version to 4.1.0 panyuepeng
• (flink-connector-jdbc) branch v3.4 created (now 3f91a2db) panyuepeng
• svn commit: r85681 - dev/flink/flink-connector-jdbc-3.4.0-rc1 panyuepeng
• svn commit: r85680 - in dev/flink: flink-connector-jdbc-3.4.0-rc0 flink-connector-jdbc-3.4.0-rc1 panyuepeng
• (flink-connector-jdbc) annotated tag v3.4.0-rc1 updated (3f91a2db -> c8ba7f66) panyuepeng
• (flink-connector-jdbc) annotated tag v3.4.0-rc1 deleted (was e5b938a6) panyuepeng
• svn commit: r85678 - dev/flink/flink-connector-jdbc-3.4.0-rc1 panyuepeng
• svn commit: r85677 - dev/flink/flink-connector-jdbc-3.4.0-rc1 panyuepeng
• (flink-connector-jdbc) annotated tag v3.4.0-rc1 updated (1eb0a2be -> e5b938a6) panyuepeng
• (flink-connector-jdbc) annotated tag v3.4.0-rc1 deleted (was 4202340a) panyuepeng
• svn commit: r85676 - dev/flink/flink-connector-jdbc-3.4.0-rc1 panyuepeng
• (flink-connector-jdbc) annotated tag v3.4.0-rc1 updated (135c2194 -> 4202340a) panyuepeng
• (flink) branch master updated: [FLINK-39957][table] Support `EXPLAIN` of `CREATE [OR ALTER] MATERIALIZED TABLE` snuyanzin
• (flink-connector-jdbc) annotated tag v3.4.0-rc0 deleted (was 24cee6e2) panyuepeng
• (flink) branch master updated: [FLINK-30166][tests] Refactor tests that use the deprecated StreamingFileSink to FileSink (#28565) martijnvisser
• (flink) branch master updated: [FLINK-40053] Update Log4j to 2.26.1 (#28615) martijnvisser
• (flink) branch master updated (5ac1750fdcb -> 8cc44d14cd3) martijnvisser
  • (flink) 02/02: [FLINK-40064][python][e2e] Use no_watermarks() instead of disabling periodic watermarks martijnvisser
  • (flink) 01/02: [FLINK-40064][python][e2e] Migrate PyFlink DataStream e2e test from Kafka to FileSource/FileSink martijnvisser
• (flink) branch release-2.3 updated: [FLINK-40003][runtime] Fix IOMetrics not visible to state transition listeners mapohl
• (flink) branch release-1.20 updated: [FLINK-40003][runtime] Fix IOMetrics not visible to state transition listeners mapohl
• (flink) branch release-2.2 updated: [FLINK-40003][runtime] Fix IOMetrics not visible to state transition listeners mapohl
• (flink) branch release-2.3 updated: [FLINK-40058][ci] Free up disk space in nightly dist deployment jobs martijnvisser
• (flink) branch release-2.2 updated: [FLINK-40058][ci] Free up disk space in nightly dist deployment jobs martijnvisser

• Earlier messages