commits  

Messages by Thread

• (flink) branch release-2.4 updated: [hotfix][docs] Fix temporal table function examples (#29717) martijnvisser.apache.org via commits
• (flink) branch release-2.3 updated: [hotfix][docs] Fix temporal table function examples (#29717) martijnvisser.apache.org via commits
• (flink) branch release-1.20 updated: [hotfix][docs] Fix temporal table function examples (#29717) martijnvisser.apache.org via commits
• (flink) branch release-2.3 updated: [FLINK-40886][runtime] Do not create the blob directories in the file count checks panyuepeng.apache.org via commits
• (flink) branch release-2.2 updated: [FLINK-41331][ci] Move python header installation to flink-ci-docker snuyanzin.apache.org via commits
• (flink) branch master updated: [FLINK-37381][docs] Fix typo in `joins.md` document snuyanzin.apache.org via commits
• (flink) branch master updated (2e89b879f1e -> 4fb928ed93f) martijnvisser.apache.org via commits
• (flink) branch release-2.4 updated: [BP-2.4][FLINK-41086][table] Return NULL from `JSON_LENGTH` and `JSON_TYPE` when a JSON path function fails (#29805) ramin.apache.org via commits
• (flink-agents) branch main updated: [python][plan] Split chat model action into per-model attempts (#1357) wenjin.apache.org via commits
• (flink) branch release-2.2 updated: [FLINK-40088][tests] Tolerate HTTP-level responses in RestClientITCase TLS check (#29736) fanrui.apache.org via commits
• (flink) branch release-2.4 updated: [BP-2.4][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native dbsamrat.apache.org via commits
• (flink) branch master updated: [FLINK-41330][table] Return NULL for a VARIANT array index outside the INT range (#29785) ramin.apache.org via commits
• (flink-connector-pulsar) branch main updated: [FLINK-41113] Bump jackson, log4j and assertj fcsaky.apache.org via commits
• (flink) branch master updated: [FLINK-41308][runtime-web] Use nettyShuffleMemorySegments fields for the Netty Shuffle Buffers table (#29761) rmetzger.apache.org via commits
• (flink) branch release-2.4 updated: [FLINK-40799][table] FlinkMarkChangeLogNormalizeProgram should cast to `RexCall` only in case of `AND` snuyanzin.apache.org via commits
• (flink) branch master updated: [FLINK-39566][runtime-web] Add checkpoint duration Gantt view fcsaky.apache.org via commits
• (flink) branch master updated: [FLINK-40494][docs] Document the UUID type panyuepeng.apache.org via commits
• (flink) branch release-2.4 updated (4ca6fb1c99c -> d545d196f74) panyuepeng.apache.org via commits
  • (flink) 01/02: [FLINK-40319][table] Allow CAST from a VARIANT string value to BINARY and VARBINARY panyuepeng.apache.org via commits
  • (flink) 02/02: [FLINK-41301][table] Throw TableRuntimeException for every failed cast from VARIANT panyuepeng.apache.org via commits
• [I] [Bug][PostgreSQL Pipeline] PostGIS geometry serialization flattens nested coordinates and loses geometry structure [flink-cdc] a1099259097 (via GitHub) via commits
  • Re: [I] [Bug][PostgreSQL Pipeline] PostGIS geometry serialization flattens nested coordinates and loses geometry structure [flink-cdc] github-actions[bot] (via GitHub) via commits
  • Re: [I] [Bug][PostgreSQL Pipeline] PostGIS geometry serialization flattens nested coordinates and loses geometry structure [flink-cdc] github-actions[bot] (via GitHub) via commits
  • Re: [I] [Bug][PostgreSQL Pipeline] PostGIS geometry serialization flattens nested coordinates and loses geometry structure [flink-cdc] github-actions[bot] (via GitHub) via commits
• (flink-connector-pulsar) branch dependabot/maven/org.xerial.snappy-snappy-java-1.1.10.9 updated (a13b8fc -> b176de6) github-bot.apache.org via commits
• (flink) branch master updated (12c944d5def -> de2cb88cb0c) ramin.apache.org via commits
  • (flink) 02/02: [FLINK-41301][table] Throw TableRuntimeException for every failed cast from VARIANT ramin.apache.org via commits
  • (flink) 01/02: [FLINK-40319][table] Allow CAST from a VARIANT string value to BINARY and VARBINARY ramin.apache.org via commits
• (flink-cdc) branch release-3.7 updated: [BP-3.7][docs][examples] Add MySQL to Fluss ingestion example (#4612) (#4615) yux.apache.org via commits
• (flink) branch master updated: [hotfix][ci] Do not run disk clean up if e2e is skipped snuyanzin.apache.org via commits
• (flink) branch master updated: [FLINK-41282][table-planner] Use each multi-join step's own join columns for upsert keys snuyanzin.apache.org via commits
• (flink) branch master updated: [FLINK-41086][table] Return NULL from `JSON_LENGTH` and `JSON_TYPE` when a JSON path function fails (#29628) ramin.apache.org via commits
• (flink) branch master updated: [FLINK-41263][table-planner] Add CompiledPlan support for BatchExecAdaptiveJoin snuyanzin.apache.org via commits
• (flink-agents) branch main updated: [hotfix][ci] Cancel superseded CI runs for the same PR (#1359) wenjin.apache.org via commits
• (flink) branch release-2.4 updated: [BP-2.4][FLINK-41362][table] Reject VARIANT in primary key columns (#29803) ramin.apache.org via commits
• (flink) branch master updated: [FLINK-41362][table] Reject VARIANT in primary key columns (#29801) ramin.apache.org via commits
• (flink) branch master updated: [hotfix][ci] Build flink-shaded for e2e only once snuyanzin.apache.org via commits
• (flink) branch master updated (75f86b6c4ae -> 4938de931bc) snuyanzin.apache.org via commits
  • (flink) 02/02: [hotfix][table] Treat missing predicates in FilterPushDownSpec as empty snuyanzin.apache.org via commits
  • (flink) 01/02: [hotfix][table] Treat missing predicates in MetadataFilterPushDownSpec as empty snuyanzin.apache.org via commits
• (flink) branch release-2.2 updated (3e73d669b76 -> ee47d538cab) dianfu.apache.org via commits
  • (flink) 06/14: [FLINK-40986][python] Make named Row hashing consistent with equality (#29472) dianfu.apache.org via commits
  • (flink) 02/14: [FLINK-40529][python] Warn on use of deprecated APIs not at import time (#29061) dianfu.apache.org via commits
  • (flink) 04/14: [FLINK-39572][python] Do not log the Beam environment payload (#29225) dianfu.apache.org via commits
  • (flink) 07/14: [FLINK-34625][python] Fix state TTL read cache disabling (#29576) dianfu.apache.org via commits
  • (flink) 01/14: [FLINK-23758][python] Fix semantics of Expression.__invert__ (#29148) dianfu.apache.org via commits
  • (flink) 09/14: [FLINK-41199][python] Decode NULL values in nested collected results (#29605) dianfu.apache.org via commits
  • (flink) 14/14: [FLINK-41102][python] Flush pending keyed state operations on key switch without state cache (#29600) dianfu.apache.org via commits
  • (flink) 10/14: [FLINK-41245][python] Fix missing allow_nested support (#29641) dianfu.apache.org via commits
  • (flink) 13/14: [FLINK-41106][python] Iterate key-value pairs in MapState.put_all (#29597) dianfu.apache.org via commits
  • (flink) 08/14: [FLINK-41196][python] Preserve TIMESTAMP_LTZ instants in Python conversions (#29603) dianfu.apache.org via commits
  • (flink) 12/14: [FLINK-41228][python] Fix thread-mode conversion of arrays, lists and maps (#29630) dianfu.apache.org via commits
  • (flink) 03/14: [FLINK-40628][python] Avoid gateway launch during embedded TTL initialization dianfu.apache.org via commits
• (flink) branch master updated: [hotfix][docs] Fix typos in Hive dialect docs snuyanzin.apache.org via commits
• (flink) branch release-2.3 updated: [FLINK-40799][table] FlinkMarkChangeLogNormalizeProgram should cast to `RexCall` only in case of `AND` snuyanzin.apache.org via commits
• (flink) branch release-2.3 updated: [FLINK-41331][ci] Move python header installation to flink-ci-docker snuyanzin.apache.org via commits
• (flink) branch release-2.4 updated: [FLINK-41331][ci] Move python header installation to flink-ci-docker snuyanzin.apache.org via commits
• (flink-cdc) branch release-3.7 updated: [BP-3.7][docs][paimon] Add MySQL CDC Action migration guide (#4616) kunni.apache.org via commits
• (flink-cdc) branch master updated: [docs][paimon] Add MySQL CDC Action migration guide (#4614) kunni.apache.org via commits
• (flink) branch release-2.4 updated: [FLINK-41330][table] Return NULL for a VARIANT array index outside the INT range (#29785) ramin.apache.org via commits
• (flink) branch master updated: [FLINK-41281][table] Allow CAST from a VARIANT timestamp to the other temporal types ramin.apache.org via commits
• (flink) branch master updated (4cdc6d83a9d -> c59810c04f8) ramin.apache.org via commits
  • (flink) 02/03: [FLINK-41305][table-runtime] Support the raw line delimiter only for a string column and split UTF-8 on its bytes ramin.apache.org via commits
  • (flink) 03/03: [FLINK-41323][table-runtime] Add a binary encoding for a VARIANT column in the raw format ramin.apache.org via commits
  • (flink) 01/03: [FLINK-41305][table-runtime] Require UTF-8 for a VARIANT column in the raw format and parse it from bytes ramin.apache.org via commits
• (flink) branch release-2.2 updated: [FLINK-41280][table] Fix CAST of a TIMESTAMP before 1970 to DATE, TIME and a lower precision (#29774) ramin.apache.org via commits
• (flink) 02/02: [FLINK-41275][e2e] Start SQL e2e test clusters once per class instead of per test snuyanzin.apache.org via commits
• (flink-cdc) branch master updated: [FLINK-41317][pipeline-connector/kafka] Fix NPE when serializing REPLACE events without before image (#4610) kunni.apache.org via commits
• (flink) branch release-2.4 updated: [FLINK-41014][s3] Add an adaptive retry mode to the native S3 connector dbsamrat.apache.org via commits
• (flink-kubernetes-operator) branch main updated: [FLINK-40954] Force delete pods stuck Terminating on cluster resourcecleanup timeout (#1232) gyfora.apache.org via commits
• (flink) branch release-2.2 updated: [FLINK-40011][table-planner] Fix NoMoreSplitsEvent race in CommonExecSinkITCase (#29734) fanrui.apache.org via commits
• (flink-connector-cassandra) branch dependabot/maven/org.xerial.snappy-snappy-java-1.1.10.9 created (now 24d5ae5) github-bot.apache.org via commits
• (flink) branch release-2.2 updated: [FLINK-41104][python] Return true from MapState.contains for keys mapped to None (#29776) dianfu.apache.org via commits
• (flink-agents) branch main updated: [runtime][java] Fall back to legacy flink-conf.yaml when loading agent configuration (#1337) wenjin.apache.org via commits
• (flink) branch master updated: [FLINK-41014][s3] Add an adaptive retry mode to the native S3 connector dbsamrat.apache.org via commits
• (flink) branch master updated: [FLINK-41331][ci] Move python header installation to flink-ci-docker snuyanzin.apache.org via commits
• (flink) branch release-2.4 updated: [FLINK-40002][table-planner] Keep metadata column references out of physical filter push-down snuyanzin.apache.org via commits
• (flink) branch release-2.4 updated: [FLINK-40886][runtime] Do not create the blob directories in the file count checks panyuepeng.apache.org via commits
• (flink) branch release-1.20 updated: [FLINK-41291] Bump snappy-java from 1.1.10.4 to 1.1.10.12 snuyanzin.apache.org via commits
• (flink) branch release-2.2 updated: [FLINK-39146] Update log4j to 2.25.3 fanrui.apache.org via commits
• (flink) branch release-2.4 updated (6427ac6dea2 -> ace2e6cedcf) panyuepeng.apache.org via commits
  • (flink) 01/03: [FLINK-41305][table-runtime] Require UTF-8 for a VARIANT column in the raw format and parse it from bytes panyuepeng.apache.org via commits
  • (flink) 02/03: [FLINK-41305][table-runtime] Support the raw line delimiter only for a string column and split UTF-8 on its bytes panyuepeng.apache.org via commits
  • (flink) 03/03: [FLINK-41323][table-runtime] Add a binary encoding for a VARIANT column in the raw format panyuepeng.apache.org via commits
• (flink) branch release-2.4 updated: [FLINK-41281][table] Allow CAST from a VARIANT timestamp to the other temporal types panyuepeng.apache.org via commits
• (flink) branch release-2.3 updated: [FLINK-40088][tests] Tolerate HTTP-level responses in RestClientITCase TLS check (#29735) fanrui.apache.org via commits
• (flink) branch release-2.3 updated: [FLINK-40011][table-planner] Fix NoMoreSplitsEvent race in CommonExecSinkITCase (#29733) fanrui.apache.org via commits
• (flink) branch release-1.20 updated: [FLINK-35661][table] Fix MiniBatchGroupAggFunction silently dropping records (backport #27505) (#28262) fanrui.apache.org via commits
• (flink) branch release-1.20 updated: [FLINK-40088][tests] Tolerate HTTP-level responses in RestClientITCase TLS check (#29737) fanrui.apache.org via commits
• (flink-ci-docker) branch main updated (79ca5d2 -> fbd7003) snuyanzin.apache.org via commits
  • (flink-ci-docker) 01/02: [hotfix] Add python3-dev snuyanzin.apache.org via commits
  • (flink-ci-docker) 02/02: [hotfix] Reduce size of image snuyanzin.apache.org via commits
• (flink-agents) branch main updated: [runtime] Fix action-state key collisions between event occurrences with identical attributes (#1342) wenjin.apache.org via commits
• (flink) branch release-2.4 updated: [hotfix][ci] Run python doc checks in parallel snuyanzin.apache.org via commits
• (flink-connector-pulsar) branch dependabot/maven/io.opentelemetry-opentelemetry-api-1.67.0 created (now 15c1e30) github-bot.apache.org via commits
• (flink) branch master updated: [hotfix][ci] Remove obsolete libssl download for e2e netty-tcnative on Ubuntu 26.04 snuyanzin.apache.org via commits
• (flink) branch release-1.20 updated: [FLINK-38558] Require copy when use heap timer fanrui.apache.org via commits
• (flink) branch release-2.2 updated: [FLINK-40644][state/forst] Close the remote stream when a CachedDataInputStream is closed (#29753) fanrui.apache.org via commits
• (flink) branch release-2.3 updated: [FLINK-39984][runtime] Dispatch thread dump to ioExecutor (#29738) fanrui.apache.org via commits
• (flink) branch release-2.2 updated: [FLINK-38534][runtime/tests] Fix flaky LocalRecoveryTest by waiting for tasks to reach RUNNING state (#29751) fanrui.apache.org via commits
• (flink) branch release-1.20 updated: [FLINK-38442][test] Make ProfilingServiceTest.testRollingDeletion more stable (#29756) fanrui.apache.org via commits
• (flink) branch master updated: [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native dbsamrat.apache.org via commits
• (flink) 01/02: [FLINK-41275][e2e] Start `FlinkContainers` once per class in `SqlClientITCase` snuyanzin.apache.org via commits
• (flink) branch release-2.2 updated: [FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join gustavodemorais.apache.org via commits
• (flink) branch release-2.3 updated: [FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join gustavodemorais.apache.org via commits
• (flink) branch master updated (c48b1f1746d -> 18674692463) ramin.apache.org via commits
• (flink-cdc) branch master updated: [FLINK-41107][pipeline-connector] Honor accepted schema evolution types in Hudi and MaxCompute sinks (#4599) kunni.apache.org via commits
• (flink-cdc) branch release-3.7 updated: [FLINK-41057][iceberg] Fix append-only update and delete handling (#4588) (#4606) yux.apache.org via commits
• (flink) branch master updated: [FLINK-41291] Bump snappy-java from 1.1.10.7 to 1.1.10.12 snuyanzin.apache.org via commits
• (flink-connector-pulsar) branch dependabot/maven/org.xerial.snappy-snappy-java-1.1.10.9 created (now a13b8fc) github-bot.apache.org via commits
• (flink) branch master updated: [hotfix][e2e] Submit all TPC-H queries in one SQL Client session in test_tpch.sh snuyanzin.apache.org via commits
• (flink) branch master updated (8b445a18f8e -> 891bd525d3f) snuyanzin.apache.org via commits
  • (flink) 02/02: [hotfix][ci] Do not invoke lint or test for npm in compile_ci snuyanzin.apache.org via commits
• (flink) branch release-2.4 updated: [FLINK-41277][tests] `test_file_sink.sh` hangs in the second OpenSSL linkage run snuyanzin.apache.org via commits
• (flink) branch release-2.4 updated: [FLINK-41102][python] Flush pending keyed state operations on key switch without state cache (#29600) dianfu.apache.org via commits
• (flink) branch release-2.1 updated: [FLINK-41244][table-runtime] Scope clearing of unnamed PTF timers to the current key twalthr.apache.org via commits
• (flink) branch release-2.2 updated: [FLINK-41291] Bump snappy-java from 1.1.10.7 to 1.1.10.12 snuyanzin.apache.org via commits
• (flink) branch release-1.20 updated: [FLINK-39388][tests] Fix flaky DataGeneratorSourceITCase#testGatedRateLimiter (#29732) fanrui.apache.org via commits
• (flink) branch release-1.20 updated: [FLINK-39984][runtime] Dispatch thread dump to ioExecutor (#29740) fanrui.apache.org via commits
• (flink-connector-mongodb) branch dependabot/maven/org.xerial.snappy-snappy-java-1.1.10.9 created (now ad51cc4) github-bot.apache.org via commits
• (flink-connector-opensearch) branch dependabot/maven/org.xerial.snappy-snappy-java-1.1.10.9 created (now 9408bf2) github-bot.apache.org via commits
• (flink-connector-kafka) branch dependabot/maven/org.xerial.snappy-snappy-java-1.1.10.9 created (now 80a00b39) github-bot.apache.org via commits
• (flink) branch release-2.4 updated: [FLINK-41280][table] Fix CAST of a TIMESTAMP before 1970 to DATE, TIME and a lower precision ramin.apache.org via commits
• (flink) branch release-2.3 updated: [FLINK-41291] Bump snappy-java from 1.1.10.7 to 1.1.10.12 snuyanzin.apache.org via commits
• (flink) branch release-2.2 updated: [FLINK-39388][tests] Fix flaky DataGeneratorSourceITCase#testGatedRateLimiter (#29731) fanrui.apache.org via commits
• (flink) branch release-2.4 updated: [FLINK-41291] Bump snappy-java from 1.1.10.7 to 1.1.10.12 snuyanzin.apache.org via commits
• (flink) branch release-2.4 updated: [FLINK-41244][table-runtime] Scope clearing of unnamed PTF timers to the current key twalthr.apache.org via commits
• (flink) branch release-2.3 updated: [BP-2.3][FLINK-41247][queryable-state] Close server channels before shutting down the Netty event loops (#29700) fanrui.apache.org via commits
• (flink) branch release-2.2 updated: [FLINK-41244][table-runtime] Scope clearing of unnamed PTF timers to the current key twalthr.apache.org via commits
• (flink) branch master updated: [FLINK-41277][tests] `test_file_sink.sh` hangs in the second OpenSSL linkage run snuyanzin.apache.org via commits
• (flink) branch release-2.2 updated: [FLINK-38967] Fix flaky UnalignedCheckpointFailureHandlingITCase (#29744) fanrui.apache.org via commits
• (flink) branch release-2.2 updated: [FLINK-38970] Fix flaky AdaptiveBatchSchedulerTest by using synchrono… (#29746) fanrui.apache.org via commits
• (flink) branch release-1.20 updated: [FLINK-38967] Fix flaky UnalignedCheckpointFailureHandlingITCase (#29745) fanrui.apache.org via commits
• (flink) branch release-2.4 updated: [BP-2.4][FLINK-41247][queryable-state] Close server channels before shutting down the Netty event loops (#29699) fanrui.apache.org via commits
• (flink) branch release-2.3 updated: [FLINK-39388][tests] Fix flaky DataGeneratorSourceITCase#testGatedRateLimiter (#29730) fanrui.apache.org via commits
• (flink) branch release-2.3 updated: [FLINK-41244][table-runtime] Scope clearing of unnamed PTF timers to the current key twalthr.apache.org via commits
• (flink) branch dependabot/maven/org.xerial.snappy-snappy-java-1.1.10.9 deleted (was fed41e402e3) github-bot.apache.org via commits
• (flink-agents) branch main updated: [runtime] Add cross-release state migration test for ActionExecutionOperator (#1341) wenjin.apache.org via commits
• (flink) branch master updated (ac917e901a7 -> a4c3507d491) snuyanzin.apache.org via commits
  • (flink) 01/02: [hotfix][ci] Skip maven source in compile_ci and test jobs snuyanzin.apache.org via commits
  • (flink) 02/02: [hotfix][ci] Make scala byte code generation multithreaded snuyanzin.apache.org via commits
• (flink) branch release-1.20 updated: [FLINK-41102][python] Flush pending keyed state operations on key switch without state cache (#29600) dianfu.apache.org via commits
• (flink-agents) branch release-0.4 updated: [docs] Standardize Alibaba Cloud Model Studio naming (#1329) (#1345) wenjin.apache.org via commits
• (flink-agents) branch main updated: [hotfix][api][java] Move ResourceContext lookup factory to test utilities (#1349) wenjin.apache.org via commits
• (flink) branch release-2.3 updated: [FLINK-41102][python] Flush pending keyed state operations on key switch without state cache (#29600) dianfu.apache.org via commits
• (flink) branch master updated: [FLINK-41102][python] Flush pending keyed state operations on key switch without state cache (#29600) dianfu.apache.org via commits
• (flink-cdc) branch master updated: [FLINK-41057][iceberg] Fix append-only update and delete handling (#4588) kunni.apache.org via commits
• (flink-connector-prometheus) branch dependabot/maven/org.xerial.snappy-snappy-java-1.1.10.9 created (now 578e3f6) github-bot.apache.org via commits
• (flink) branch master updated (01966740401 -> b9d1ab93768) snuyanzin.apache.org via commits
• (flink) branch release-1.20 updated (33b4010725f -> 1dce10347e9) fanrui.apache.org via commits
  • (flink) 03/06: [FLINK-40904][runtime] Pass consumer parallelism to tasks via ResultPartitionDeploymentDescriptor fanrui.apache.org via commits
  • (flink) 02/06: [FLINK-39912][runtime] Change the annotation from 'RepeatTest' to 'Test' in ForwardEdgesAdapterTest to reduce the time cost (#28393) fanrui.apache.org via commits
  • (flink) 01/06: [FLINK-33123][runtime] Fix the wrong dynamic replacement of partitioner from FORWARD to REBALANCE for autoscaler and adaptive scheduler fanrui.apache.org via commits
  • (flink) 05/06: [FLINK-40780][runtime] Make FORWARD-to-REBALANCE downgrade on parallelism mismatch configurable fanrui.apache.org via commits
  • (flink) 06/06: [FLINK-40780][tests] Add ITCases for forward edge parallelism mismatch modes fanrui.apache.org via commits
  • (flink) 04/06: [FLINK-40904][runtime] Detect FORWARD parallelism mismatch with the actual consumer parallelism fanrui.apache.org via commits
• (flink) branch release-2.2 updated (e497f5d6d95 -> f292243a52f) fanrui.apache.org via commits
  • (flink) 03/06: [FLINK-40904][runtime] Pass consumer parallelism to tasks via ResultPartitionDeploymentDescriptor fanrui.apache.org via commits
  • (flink) 05/06: [FLINK-40780][runtime] Make FORWARD-to-REBALANCE downgrade on parallelism mismatch configurable fanrui.apache.org via commits
  • (flink) 04/06: [FLINK-40904][runtime] Detect FORWARD parallelism mismatch with the actual consumer parallelism fanrui.apache.org via commits
  • (flink) 02/06: [FLINK-39912][runtime] Change the annotation from 'RepeatTest' to 'Test' in ForwardEdgesAdapterTest to reduce the time cost (#28393) fanrui.apache.org via commits
  • (flink) 01/06: [FLINK-33123][runtime] Fix the wrong dynamic replacement of partitioner from FORWARD to REBALANCE for autoscaler and adaptive scheduler fanrui.apache.org via commits
  • (flink) 06/06: [FLINK-40780][tests] Add ITCases for forward edge parallelism mismatch modes fanrui.apache.org via commits
• (flink) branch release-2.3 updated (6034766bbbc -> b120aa85a54) fanrui.apache.org via commits
  • (flink) 02/04: [FLINK-40904][runtime] Detect FORWARD parallelism mismatch with the actual consumer parallelism fanrui.apache.org via commits
  • (flink) 04/04: [FLINK-40780][tests] Add ITCases for forward edge parallelism mismatch modes fanrui.apache.org via commits
  • (flink) 03/04: [FLINK-40780][runtime] Make FORWARD-to-REBALANCE downgrade on parallelism mismatch configurable fanrui.apache.org via commits
  • (flink) 01/04: [FLINK-40904][runtime] Pass consumer parallelism to tasks via ResultPartitionDeploymentDescriptor fanrui.apache.org via commits
• (flink) branch master updated (cd4c2ab77b7 -> 01966740401) ramin.apache.org via commits
• (flink) branch release-2.3 updated: [hotfix][ci] Use `includeOnlyProperties` only for JGit snuyanzin.apache.org via commits
• (flink) branch release-2.2 updated: [hotfix][ci] Use more threads for download during ci, also download dep POMs in parallel snuyanzin.apache.org via commits
• (flink) branch release-2.3 updated: [hotfix][ci] Use more threads for download during ci, also download dep POMs in parallel snuyanzin.apache.org via commits
• (flink) branch release-1.20 updated: [hotfix][ci] Use `includeOnlyProperties` only for JGit snuyanzin.apache.org via commits
• (flink) branch master updated (29a37c6e043 -> cd4c2ab77b7) martijnvisser.apache.org via commits
• (flink) branch release-2.4 updated: [hotfix][ci] Use `includeOnlyProperties` only for JGit snuyanzin.apache.org via commits
• (flink) branch release-2.2 updated: [FLINK-41117][ci] Bump ubuntu to 26 in Azure and GHA snuyanzin.apache.org via commits
• (flink) branch release-2.3 updated: [hotfix][ci] Run pyflink tests in parallel snuyanzin.apache.org via commits
• (flink) branch release-1.20 updated: [hotfix][ci] Use more threads for download during ci, also download dep POMs in parallel snuyanzin.apache.org via commits
• (flink) branch release-2.4 updated: [hotfix][ci] Use more threads for download during ci, also download dep POMs in parallel snuyanzin.apache.org via commits
• (flink) branch release-2.4 updated: [hotfix][ci] Run pyflink tests in parallel snuyanzin.apache.org via commits
• (flink) branch master updated (a7f4db7326a -> 29a37c6e043) snuyanzin.apache.org via commits
• (flink) branch release-2.3 updated: [FLINK-41117][ci] Bump ubuntu to 26 in Azure and GHA snuyanzin.apache.org via commits
• (flink) branch master updated: [FLINK-39330][runtime] Make CollectSinkFunction teardown null-safe (#28474) rmetzger
• (flink) branch release-2.2 updated: [FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper snuyanzin
• (flink) branch release-2.4 updated: [FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join snuyanzin.apache.org via commits
• (flink) branch master updated: [FLINK-41211][table] Add listMaterializedTables for a given catalog and database gustavodemorais
• (flink) branch master updated: [FLINK-41276][ci] Run the License task in parallel and regroup its log so the license checks still work snuyanzin
• (flink) branch master updated: [FLINK-34224][state] Fix mailbox handling in changelog storage metrics tests (#29560) martijnvisser.apache.org via commits
• (flink) branch release-2.3 updated: [FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper snuyanzin
• (flink) branch master updated: [hotfix][ci] Run python doc checks in parallel snuyanzin
• (flink) branch master updated: [FLINK-36725] Add CompiledPlan suppport for BatchExecRuntimeFilter martijnvisser
• (flink) branch release-2.4 updated: [FLINK-40958][core] `BinaryVariantInternalBuilder.appendVariantImpl` might lead to `StackOverflow` snuyanzin
• (flink) branch master updated: [hotfix][ci] Use more threads for download during ci, also download dep POMs in parallel snuyanzin
• (flink) branch release-2.4 updated: [FLINK-41117][ci] Bump ubuntu to 26 in Azure and GHA snuyanzin
• (flink) branch master updated: [FLINK-41247][queryable-state] Close server channels before shutting down the Netty event loops martijnvisser
• (flink-kubernetes-operator) branch main updated: [FLINK-40365][docs] Correct savepoint config requirements (#1173) gyfora
• (flink) branch release-1.20 updated: [hotfix][python] Fix Java 8 compilation of PythonTypeUtils martijnvisser
• (flink) branch master updated: [FLINK-40886][runtime] Do not create the blob directories in the file count checks martijnvisser
• (flink) branch release-1.20 updated: [FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper snuyanzin
• (flink) branch release-2.2 updated: [FLINK-40499][runtime] Emit ACTIVE before final MAX_WATERMARK at drain martijnvisser

• Earlier messages