commits  

Messages by Date

• 2025/01/23 (flink) 02/02: [FLINK-37100][tests] Fix `test_netty_shuffle_memory_control.sh` with Netty4 RPC fcsaky
• 2025/01/23 (flink) branch release-1.19 updated: [FLINK-37099][docs] Document memory/performance considerations and config possibilities for Netty4 fcsaky
• 2025/01/23 (flink) branch release-1.20 updated: [FLINK-37099][docs] Document memory/performance considerations and config possibilities for Netty4 fcsaky
• 2025/01/23 (flink) branch release-2.0 updated: [FLINK-37099][docs] Document memory/performance considerations and config possibilities for Netty4 fcsaky
• 2025/01/23 (flink) branch master updated: [FLINK-37099][docs] Document memory/performance considerations and config possibilities for Netty4 fcsaky
• 2025/01/23 (flink-benchmarks) branch master updated: [hotfix] Remove flink-java dependency guoweijie
• 2025/01/23 (flink-benchmarks) branch master updated: [hotfix] Add profile to apply `--add-opens` for java17 CI (#103) zakelly
• 2025/01/22 (flink-cdc) branch master updated: [hotfix][docs] Change docs in master to 3.4-SNAPSHOT (#3886) ruanhang1993
• 2025/01/22 (flink-cdc) branch release-3.2 updated: [hotfix][docs] Fix dead links in Doris (#3878) (#3885) ruanhang1993
• 2025/01/22 (flink-cdc) branch master updated: [hotfix][cdc][docs] Build 3.3 docs and mark it as stable (#3882) ruanhang1993
• 2025/01/22 (flink) branch release-2.0 updated: [BP-2.0][FLINK-36838][state/forst] Fix the deadlock when quit forst state backend (#26054) zakelly
• 2025/01/22 (flink) branch master updated: [FLINK-36868][state/forst] Fix the deadlock when quit forst state backend (#26053) zakelly
• 2025/01/22 (flink) branch release-2.0 updated (2dfac963567 -> 95450ed676f) fcsaky
• 2025/01/22 (flink-cdc) branch release-3.3 updated: [hotfix][docs] Fix dead links in Doris (#3878) ruanhang1993
• 2025/01/22 (flink-cdc) branch master updated: [hotfix][docs][pipeline-connector/maxcompute] Fix maxcompute connector typo in examples section leonard
• 2025/01/22 (flink-cdc) branch master updated: [build] Update version to 3.4-SNAPSHOT and add release-3.3 docs leonard
• 2025/01/22 Error while running notifications feature from refs/heads/master:.asf.yaml in flink-cdc! Apache Infrastructure
• 2025/01/22 (flink) branch release-1.20 updated: [FLINK-37098] Fix UnresolvedSchema of QueryOperationCatalogView dwysakowicz
• 2025/01/21 (flink-benchmarks) branch master updated: [hotfix] Bump CI to jdk17 (#102) zakelly
• 2025/01/21 (flink) branch master updated: [FLINK-37183][clients] Fix symbolic links not being followed in "usrlib" fcsaky
• 2025/01/21 (flink) branch release-1.19 updated: [FLINK-37183][clients] Fix symbolic links not being followed in "usrlib" fcsaky
• 2025/01/21 (flink) branch release-1.20 updated: [FLINK-37183][clients] Fix symbolic links not being followed in "usrlib" fcsaky
• 2025/01/21 (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-0dbc78daaa created (now 73608a77e3f) github-bot
• 2025/01/21 (flink) branch master updated: [FLINK-37035][release] Build doc for release-2.0 branch guoweijie
• 2025/01/21 (flink) branch master updated: [FLINK-37035][release] Add new version 2.1 and update GHA nightly build versions guoweijie
• 2025/01/21 (flink-benchmarks) branch master updated: [hotfix] Bump flink version to 2.1-SNAPSHOT zakelly
• 2025/01/21 svn commit: r74352 - /release/flink/KEYS leonard
• 2025/01/21 svn commit: r74350 - in /dev/flink/flink-2.0.0-rc0: ./ python/ guoweijie
• 2025/01/21 (flink-connector-mongodb) branch main updated: [FLINK-36074][Connectors/mongodb] Support insert overwrite semantics for mongodb table sink (#43) jiabaosun
• 2025/01/21 (flink) branch master updated (5749a07b072 -> abbfc66c905) junrui
• 2025/01/21 svn commit: r74336 - /release/flink/KEYS gyfora
• 2025/01/21 (flink) branch master updated: [FLINK-37076][table-planner] Support PTFs until ExecNode level twalthr
• 2025/01/21 (flink) branch release-1.19 updated: [FLINK-36348][test] Fix the Netty shuffle direct memory test by increase the direct memory of TM afedulov
• 2025/01/21 (flink) branch release-1.20 updated: [FLINK-36348][test] Fix the Netty shuffle direct memory test by increase the direct memory of TM afedulov
• 2025/01/21 (flink-connector-kudu) branch main updated: [FLINK-37190] Make Kudu `FlushMode` configurable in Flink SQL fcsaky
• 2025/01/21 (flink-web) branch asf-site updated (f95c24752 -> 83e0ab92b) ruanhang1993
• 2025/01/21 (flink-web) 01/02: Add release announcement for Flink CDC 3.3.0 ruanhang1993
• 2025/01/21 (flink) annotated tag release-2.0.0-rc0 updated (03bcb11290d -> 14e9144db7c) guoweijie
• 2025/01/21 svn commit: r74327 - /dev/flink/flink-cdc-3.3.0-rc1/ /release/flink/flink-cdc-3.3.0/ leonard
• 2025/01/21 (flink) branch master updated (e000678091b -> 9ba5afc2605) martijnvisser
• 2025/01/21 (flink-cdc) annotated tag release-3.3.0 updated (6b53136c8 -> acd02ca78) ruanhang1993
• 2025/01/21 (flink) branch master updated (632f3fe88d6 -> e000678091b) dwysakowicz
• 2025/01/21 (flink) 02/02: [FLINK-37173][build] Fix license check issue in JDK11 build guoweijie
• 2025/01/21 (flink) 01/02: [FLINK-37189][build] Correct version string of maven-enforcer-plugin requireJavaVersion in release profile guoweijie
• 2025/01/21 (flink) branch release-2.0 updated (12596c72bf9 -> 2dfac963567) guoweijie
• 2025/01/21 (flink) branch master updated (cf6ba7aad53 -> 632f3fe88d6) guoweijie
• 2025/01/20 (flink-benchmarks) branch dev-2.0 created (now 481ff96) guoweijie
• 2025/01/20 (flink) branch master updated: [FLINK-37173][build] Fix license check issue in JDK11 build guoweijie
• 2025/01/20 (flink) branch master updated: [FLINK-37170][ci] Removes 1.18 version from GHA nightly builds mapohl
• 2025/01/20 (flink) branch master updated: [FLINK-36652][Formats/ORC] Upgrade Apache ORC Version to 1.9.4 (#25711) martijnvisser
• 2025/01/20 (flink) branch master updated: [FLINK-37176][docs] Support mac binary for setup_hugo dwysakowicz
• 2025/01/20 (flink) branch master updated (dccb782134b4 -> c065920c1c99) guoweijie
• 2025/01/20 (flink) branch release-2.0 updated: Update for 2.0.0 guoweijie
• 2025/01/20 (flink) branch release-2.0 created (now dccb782134b4) guoweijie
• 2025/01/20 (flink) branch master updated (4a2535cb8ab9 -> dccb782134b4) zakelly
• 2025/01/20 (flink) 02/02: [FLINK-37021][state/forst] Leverage fast-copying of FileSystems for snapshots zakelly
• 2025/01/20 (flink) 03/04: [FLINK-37133][table] Fix NullPointerException in EmbeddedWorkflowScheduler when closing without open ron
• 2025/01/20 (flink) 04/04: [FLINK-37133][table] Support Submitting Refresh Job of Materialized Table to Yarn/K8s ron
• 2025/01/20 (flink) 01/04: [FLINK-37133][table] Fix ScriptExecutor to properly split scripts without trailing semicolon ron
• 2025/01/20 (flink) branch master updated (1afe645f59fc -> 4a2535cb8ab9) ron
• 2025/01/20 (flink) 02/04: [FLINK-37133][table] Fix TestFileSystemCatalog losing scheme information when constructing table paths ron
• 2025/01/20 (flink) branch master updated: [FLINK-37174][sql-client] Fix failed tests about SqlClientTest#testPrintAllModeHelp and #testPrintEmbeddedModeHelp (#26018) dianfu
• 2025/01/19 (flink-cdc) branch master updated: [hotfix][build] Miscellaneous fixes on GHA workflows leonard
• 2025/01/19 (flink) branch master updated: [FLINK-37172][table-runtime] Add logs in all existing async state ops to check if they are under async state when running lincoln
• 2025/01/19 (flink-kubernetes-operator) branch main updated: [FLINK-37166] Use concurrenthashmap in flink config manager gyfora
• 2025/01/19 (flink) branch release-1.19 updated: [FLINK-37168][python] Clean up TimerRegistrationAction in unregisteredTimers list after timers are registered (#26011) dianfu
• 2025/01/19 (flink) branch release-1.20 updated: [FLINK-37168][python] Clean up TimerRegistrationAction in unregisteredTimers list after timers are registered (#26011) dianfu
• 2025/01/19 (flink) branch master updated: [FLINK-37168][python] Clean up TimerRegistrationAction in unregisteredTimers list after timers are registered (#26011) dianfu
• 2025/01/19 (flink) branch master updated: [FLINK-35282][python] Upgrade Apache Beam >=2.54 (#25541) dianfu
• 2025/01/19 (flink) 02/04: [FLINK-37028][State] Introduce namespace wrapped state for window operator. zakelly
• 2025/01/19 (flink) branch master updated (7964466016da -> 65705096e164) zakelly
• 2025/01/19 (flink) 01/04: [FLINK-37028][State] Hotfix the callback of asyncAdd() in Reducing/AggregatingState zakelly
• 2025/01/19 (flink) 04/04: [FLINK-37028][Runtime] Integrate async window operator to DataStream API zakelly
• 2025/01/19 (flink) branch master updated: [FLINK-37045] Remove useless StateDescriptor of state v2 (#26009) zakelly
• 2025/01/19 (flink-connector-hive) branch dependabot/maven/io.netty-netty-common-4.1.115.Final updated (26e4c192 -> 7ba09e35) snuyanzin
• 2025/01/19 (flink-connector-hive) branch dependabot/maven/io.netty-netty-common-4.1.115.Final updated (1679efaf -> 26e4c192) snuyanzin
• 2025/01/19 (flink-connector-hive) branch dependabot/maven/io.netty-netty-common-4.1.115.Final updated (7b498df4 -> 1679efaf) github-bot
• 2025/01/19 (flink-connector-hive) branch dependabot/maven/flink-sql-connector-hive-3.1.3/org.apache.zookeeper-zookeeper-3.8.4 updated (03923afe -> a202487f) github-bot
• 2025/01/19 (flink-connector-hive) branch main updated: [hotfix] Enable tests for java 11 with hive2 snuyanzin
• 2025/01/19 (flink) branch master updated: [FLINK-37021][state/forst] Forst remote dir share checkpoint dir (#26006) leiyanfei
• 2025/01/19 (flink) branch master updated: [FLINK-35405][runtime] Add metrics for AsyncExecutionController (#25998) leiyanfei
• 2025/01/18 (flink) branch master updated (180d587717b -> f2460c889dd) guoweijie
• 2025/01/18 (flink) 01/02: [FLINK-37136][API] Introduce Window extension components for DataStream V2 guoweijie
• 2025/01/17 (flink-cdc) annotated tag release-3.3.0-rc1 updated (6b53136c8 -> 5e4909a6a) ruanhang1993
• 2025/01/17 svn commit: r74277 - in /dev/flink/flink-cdc-3.3.0-rc1: ./ flink-cdc-3.3.0-bin.tar.gz flink-cdc-3.3.0-bin.tar.gz.asc flink-cdc-3.3.0-bin.tar.gz.sha512 flink-cdc-3.3.0-src.tgz flink-cdc-3.3.0-src.tgz.asc flink-cdc-3.3.0-src.tgz.sha512 ruanhang1993
• 2025/01/17 (flink) branch master updated: [FLINK-37164][Runtime] Speed up state v2 synchronous methods execution (#26005) zakelly
• 2025/01/17 (flink) branch release-1.19 updated: [FLINK-37084][python] Fix TimerRegistration concurrency issue in PyFlink (#26004) dianfu
• 2025/01/17 (flink) branch release-1.20 updated: [FLINK-37084][python] Fix TimerRegistration concurrency issue in PyFlink (#26004) dianfu
• 2025/01/17 (flink) branch master updated: [FLINK-37084][python] Fix TimerRegistration concurrency issue in PyFlink (#26004) dianfu
• 2025/01/17 (flink) branch master updated: [FLINK-36695][Formats] Bump Parquet dependency to 1.14.4 snuyanzin
• 2025/01/17 (flink) branch master updated: [hotfix] Fix compile error in EventTimeWatermarkHandlerTest (#26007) leiyanfei
• 2025/01/17 (flink) branch release-1.20 updated: [FLINK-37098] Fix selecting time attribute from a view dwysakowicz
• 2025/01/17 (flink) branch release-1.20 updated: Update overview.md fhueske
• 2025/01/17 (flink) branch master updated: [FLINK-36837][table] Introduce RowTimeDeduplicateFunction with Async State API lincoln
• 2025/01/17 (flink) branch master updated: [FLINK-37140][runtime] Create async timer service when restore async operator (#25993) leiyanfei
• 2025/01/16 (flink) branch master updated: [FLINK-37098] Fix selecting time attribute from a view dwysakowicz
• 2025/01/16 (flink-cdc) branch master updated: [FLINK-34865][pipeline-connector/mysql] Support sync newly added table's comment leonard
• 2025/01/16 (flink) branch master updated: [FLINK-36293][state] make sure register is closed before verification (#25373) zakelly
• 2025/01/16 (flink) 02/03: [FLINK-37112][runtime] Process event time extension related watermarks in operator for DataStream V2 guoweijie
• 2025/01/16 (flink) 01/03: [FLINK-37112][API] Introduce EventTimeWatermark definition and EventTimeWatermarkGeneratorBuilder for DataStream V2 guoweijie
• 2025/01/16 (flink) 03/03: [FLINK-37112][API] Process event time extension related watermarks in EventTimeProcessFunction for DataStream V2 guoweijie
• 2025/01/16 (flink) branch master updated (9a4f2895b7a -> 69e67fa8ca7) guoweijie
• 2025/01/16 (flink) branch master updated (c4bea91284b -> 9a4f2895b7a) hxb
• 2025/01/16 (flink) branch tisonkun-patch-1 deleted (was eafa803ce45) tison
• 2025/01/16 (flink) branch master updated (55de8d683cc -> c4bea91284b) xtsong
• 2025/01/16 (flink-cdc) 02/02: [minor][ci] Set proper timeout for compile_and_test step of CI job leonard
• 2025/01/16 (flink-cdc) branch master updated (947dffca3 -> e81df946b) leonard
• 2025/01/16 (flink-cdc) 01/02: [FLINK-36578][pipeline-connector/mysql] Introduce option to unify json type output between snapshot phase and binlog phase leonard
• 2025/01/16 (flink) branch master updated (ed6de585481 -> 55de8d683cc) twalthr
• 2025/01/16 (flink-cdc) branch master updated: [FLINK-37122][build] Try to be compatible with old flink version 1.18.x leonard
• 2025/01/16 (flink-cdc) branch master updated: [FLINK-35067][cdc-connector][postgres] Adding metadata 'row_kind' for Postgres CDC Connector. leonard
• 2025/01/16 (flink-cdc) branch master updated: [FLINK-36913][pipeline-connector][kafka] Introduce option to define custom mapping from upstream table id to downstream topic name leonard
• 2025/01/16 (flink-cdc) branch master updated: [hotfix[cdc-runtime] Close MetadataApplier in SchemaRegistry when the job stops leonard
• 2025/01/16 (flink-cdc) branch master updated (2fa215e5c -> cf95dcab6) leonard
• 2025/01/16 (flink-cdc) branch master updated: [FLINK-35600][pipeline-connector/mysql] Add timestamp for low and high watermark leonard
• 2025/01/16 (flink-cdc) branch master updated: [FLINK-35802][pipeline-connectors/mysql] Clean ChangeEventQueue to avoid deadlock when calling BinaryLogClient#disconnect method leonard
• 2025/01/16 (flink) branch master updated: [FLINK-37092][e2e] Add adaptive skewed join optimization to e2e tpc-ds tests junrui
• 2025/01/16 (flink-cdc) branch master updated: [FLINK-36351][pipeline-connector/doris] Support the conversion of Flink TIME type to Doris String type leonard
• 2025/01/16 (flink-cdc) branch master updated: [FLINK-36620][cdc-cli] Add support for specifying the --flink-home parameter via an '=' character leonard
• 2025/01/16 (flink-cdc) branch master updated (5691b7bf9 -> 087195a3a) leonard
• 2025/01/16 (flink-cdc) branch master updated (47e5cd6d8 -> 9ad071c1f) gongzhongqiang
• 2025/01/16 (flink-cdc) branch master updated (9ad071c1f -> 5691b7bf9) leonard
• 2025/01/16 (flink-cdc) branch master updated: [hotfix][pipeline-connector][maxcompute] Fix MaxCompute Pipeline Connector tests by upgrading maxcompute-emulator leonard
• 2025/01/15 (flink-cdc) branch master updated: [FLINK-36754][transform] Projection should treated as an asterisk when projection expression is empty or null leonard
• 2025/01/15 (flink) branch master updated (d774cf1bdea -> b3e7f9bd972) guoweijie
• 2025/01/15 (flink) 03/03: [FLINK-37135][runtime] Implement Join extension for DataStream V2 guoweijie
• 2025/01/15 (flink) 02/03: [FLINK-37135][API] Introduce JoinFunction, JoinType and BuiltinFuncs for Join extension in DataStream V2 guoweijie
• 2025/01/15 (flink) 01/03: [hotfix] Add missing generic type param for the use of PartitionedContext guoweijie
• 2025/01/15 (flink) branch master updated: [FLINK-37139][table-planner] Improve AdaptiveSkewedJoinOptimizationStrategy to make it effective in more scenarios (#25989) junrui
• 2025/01/15 (flink) 01/01: [hotfix] Add homepage link to .asf.yaml tison
• 2025/01/15 (flink) branch tisonkun-patch-1 created (now eafa803ce45) tison
• 2025/01/15 (flink) branch master updated: [FLINK-37090][e2e] add adaptive broadcast join to e2e tpc-ds tests. (#25954) junrui
• 2025/01/15 (flink) 02/04: [FLINK-37017][Runtime] Allow buffer overdraft in async state processing zakelly
• 2025/01/15 (flink) 03/04: [FLINK-37017][Runtime] Drain in best efforts when allowing overdraft zakelly
• 2025/01/15 (flink) 04/04: [FLINK-37017][Runtime] Prevent stack overflow when draining in-flight records zakelly
• 2025/01/15 (flink) 01/04: [FLINK-35412][Runtime] Remove `BatchCallbackRunner` zakelly
• 2025/01/15 (flink) branch master updated (07ea97cd1ae -> 9da368d6cb1) zakelly
• 2025/01/15 (flink-cdc) branch master updated: [FLINK-37124][build] Simplify logs in test cases to avoid flooding GHA outputs leonard
• 2025/01/15 (flink-cdc) branch master updated: [FLINK-34865][pipeline-connector/mysql] Support sync table and column comment leonard
• 2025/01/15 (flink-cdc) 02/02: [build][minor] Upgrade the max file length from 3k to 4k leonard
• 2025/01/15 (flink-cdc) 01/02: [FLINK-36647][transform] Support Timestampdiff and Timestampadd function in cdc pipeline transform leonard
• 2025/01/15 (flink-cdc) branch master updated (79e868b86 -> 50e6c8287) leonard
• 2025/01/15 (flink) branch master updated: [FLINK-37137][runtime] Fix unstable test testGenerateStreamGraphJson (#25990) junrui
• 2025/01/15 (flink) branch master updated: [FLINK-37026] Fix the stale pr message formatting (#25992) fanrui
• 2025/01/15 (flink) branch master updated: [hotfix][javadoc] Use correct syntax for `TRIM` in `SqlCallSyntax` javadoc snuyanzin
• 2025/01/15 (flink) 02/02: [FLINK-37130][table] Minor optimization of async state api usage in window join operator zakelly
• 2025/01/15 (flink) 01/02: [FLINK-37130][State] An util converting future of StateIterator to Iterable zakelly
• 2025/01/15 (flink) branch master updated (997b48340d2 -> d0165dee9e0) zakelly
• 2025/01/15 (flink) branch master updated: [FLINK-36181] Use Java 17 by default (#25898) martijnvisser
• 2025/01/15 (flink-connector-hive) branch dependabot/maven/commons-net-commons-net-3.9.0 deleted (was 407d2a40) github-bot
• 2025/01/15 (flink-connector-hive) branch main updated: [hotfix] Bump commons-net:commons-net from 3.6 to 3.9.0 snuyanzin
• 2025/01/15 (flink-connector-hive) branch dependabot/maven/flink-sql-connector-hive-3.1.3/com.nimbusds-nimbus-jose-jwt-9.37.2 created (now 9a57b2db) github-bot
• 2025/01/15 (flink-connector-hive) branch dependabot/maven/io.netty-netty-common-4.1.115.Final created (now 7b498df4) github-bot
• 2025/01/15 (flink-connector-hive) branch dependabot/maven/flink-connector-hive/org.apache.hadoop-hadoop-common-3.4.0 created (now bf73a4b1) github-bot
• 2025/01/15 (flink-connector-hive) branch dependabot/maven/commons-net-commons-net-3.9.0 updated (7f0fdb93 -> 407d2a40) snuyanzin
• 2025/01/14 (flink-connector-hive) branch dependabot/maven/flink-sql-connector-hive-3.1.3/org.eclipse.jetty-jetty-server-9.4.55.v20240627 created (now 65d1a4c0) github-bot
• 2025/01/14 (flink-connector-hive) branch dependabot/maven/flink-sql-connector-hive-3.1.3/org.eclipse.jetty-jetty-server-9.4.51.v20230217 deleted (was 8b59eb0f) github-bot
• 2025/01/14 (flink-connector-hive) branch dependabot/maven/flink-sql-connector-hive-3.1.3/org.apache.zookeeper-zookeeper-3.7.2 deleted (was b3f30eb1) github-bot
• 2025/01/14 (flink-connector-hive) branch dependabot/maven/flink-sql-connector-hive-3.1.3/org.apache.zookeeper-zookeeper-3.8.4 created (now 03923afe) github-bot
• 2025/01/14 (flink-connector-hive) branch dependabot/maven/org.apache.commons-commons-compress-1.26.0 deleted (was 1e7b3a1e) github-bot
• 2025/01/14 (flink-connector-hive) branch dependabot/maven/flink-sql-connector-hive-3.1.3/org.apache.avro-avro-1.11.3 deleted (was 725b7e36) github-bot
• 2025/01/14 (flink-connector-hive) branch dependabot/maven/org.apache.avro-avro-1.11.3 deleted (was 9f902af9) github-bot
• 2025/01/14 (flink-connector-hive) branch dependabot/maven/commons-net-commons-net-3.9.0 updated (c6b8b4e5 -> 7f0fdb93) github-bot
• 2025/01/14 (flink-connector-hive) branch main updated: [hotfix] Update dependencies snuyanzin
• 2025/01/14 (flink) branch master updated: [FLINK-36504][table-common]Remove all deprecated methods ModuleFactory (#25963) ron
• 2025/01/14 (flink) branch master updated: [FLINK-36499][table-common] Remove deprecated method `SupportsProjectionPushDown#applyProjection` (#25967) ron
• 2025/01/14 (flink) branch master updated: [FLINK-36503][table-common] Remove deprecated method FunctionDefinitionFactory#createFunctionDefinition (#25979) ron
• 2025/01/14 (flink) branch master updated: [FLINK-36492][table-common] Remove all deprecated methods in ListView (#25565) ron
• 2025/01/14 (flink-cdc) branch master updated: [FLINK-36741][transform] Fix the decimal precision and length lost during transform leonard
• 2025/01/14 (flink) branch master updated: [FLINK-36496][table-common] Remove deprecated method CatalogFunction#isGeneric (#25981) ron
• 2025/01/14 (flink) branch master updated: [FLINK-36493][table-common] Remove all deprecated methods in MapView (#25566) ron
• 2025/01/14 (flink) branch master updated: [FLINK-37015][doc] Remove Scala contents in serialization doc guoweijie
• 2025/01/14 (flink) branch release-1.19 updated: [FLINK-37108] Use-non terminal savepoint in source/sink suite arvid
• 2025/01/14 (flink-cdc) branch master updated: [FLINK-36977][pipeline-connector/paimon] Apply default value when process add_column schema change envent leonard
• 2025/01/14 (flink) branch master updated: [FLINK-36926][table] Introduce window join operator with async state api lincoln
• 2025/01/14 (flink-cdc) branch master updated: [FLINK-36636][transform] Supports timestamp comparison in cdc pipeline transform leonard
• 2025/01/14 (flink-cdc) branch master updated: [FLINK-35387][cdc-connector][postgres] PG CDC source support heart beat leonard
• 2025/01/14 (flink-cdc) branch master updated: [FLINK-36974][cdc-cli] Support overwrite flink configuration via command line leonard
• 2025/01/14 (flink) branch master updated: [FLINK-36831][table] Introduce AppendOnlyTopNFunction in Rank with Async State API lincoln
• 2025/01/14 (flink) branch master updated: [FLINK-36707][table] Add output strategy to SystemTypeInference twalthr
• 2025/01/14 (flink-cdc) branch master updated: [FLINK-35634][build] Add CdcUp playground CLI scripts leonard
• 2025/01/14 (flink-cdc) branch master updated: [FLINK-37011][cdc-transform] Improve get source field value by column name in PreTransformProcessor leonard
• 2025/01/14 (flink) 01/04: [FLINK-36629][table-planner] Introduce configuration options for adaptive skewed join optimization. zhuzh
• 2025/01/14 (flink) 04/04: [FLINK-36629][table-planner] Introduce the AdaptiveSkewedJoinOptimizationStrategy zhuzh
• 2025/01/14 (flink) 02/04: [FLINK-36629][table-planner] Modify StreamGraphContext to provide more necessary interfaces zhuzh
• 2025/01/14 (flink) branch master updated (fd0222041b1 -> df021354008) zhuzh
• 2025/01/14 (flink) 03/04: [FLINK-36629][table-planner] Modify AdaptiveJoinProcessor to support adaptive skewed join optimization zhuzh
• 2025/01/14 (flink-benchmarks) branch master updated: [FLINK-37115] Fix compile error related with SerializerConfig (#99) zakelly
• 2025/01/14 (flink) branch master updated: [FLINK-37026] Add Stale PR GitHub Action workflow fanrui
• 2025/01/14 (flink) branch release-1.19 updated: [FLINK-36739] Update the NodeJS to v22.11.0 (LTS) afedulov
• 2025/01/14 (flink-cdc) branch master updated: [FLINK-36700][pipeline-connector][elasticsearch] Elasticsearch pipeline sink supports authentication leonard
• 2025/01/14 (flink-cdc) branch master updated: [FLINK-36193][pipeline-connectors][paimon/doris/starrocks] Supports applying TRUNCATE & DROP Table Event to Paimon, StarRocks and Doris leonard
• 2025/01/14 (flink-kubernetes-operator) 01/03: [hotfix] Refactor autoscaler related `setClock` to optimize testing fanrui
• 2025/01/14 (flink-kubernetes-operator) 03/03: [FLINK-36863][autoscaler] Add the end-to-end test for delayed scale down fanrui
• 2025/01/14 (flink-kubernetes-operator) branch main updated (66f7b42f -> cd55bdc7) fanrui
• 2025/01/14 (flink-kubernetes-operator) 02/03: [FLINK-36863][autoscaler] Use the maximum parallelism in the past scale-down.interval window when scaling down fanrui
• 2025/01/13 (flink-cdc) branch master updated: [FLINK-37042][pipeline-connector/maxcompute] Rename maxcompute pipieline connector options to follow flink style leonard
• 2025/01/13 (flink) branch release-1.20 updated: [FLINK-37108] Use-non terminal savepoint in source/sink suite arvid
• 2025/01/13 (flink) branch master updated: [FLINK-37108] Use-non terminal savepoint in source/sink suite arvid
• 2025/01/13 (flink) branch master updated (1f6a6af327d -> 60497e7dfdd) ron

• Earlier messages
• Later messages