commits  

Messages by Thread

• (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
• (flink) branch release-1.20 updated: [FLINK-40058][ci] Free up disk space in nightly dist deployment jobs martijnvisser
• (flink) branch master updated: [FLINK-40058][ci] Free up disk space in nightly dist deployment jobs martijnvisser
• (flink-cdc) branch master updated: [FLINK-39916][mysql] Fix MySQL batch startup option validation error (#4441) kunni
• (flink) branch master updated: [hotfix] Mark Hadoop 3.4.3 runs correctly martijnvisser
• (flink) branch dependabot/maven/flink-end-to-end-tests/flink-sql-client-test/org.apache.kafka-kafka-clients-3.9.2 deleted (was e58649963b1) github-bot
• (flink) branch dependabot/maven/flink-models/flink-model-triton/com.fasterxml.jackson.core-jackson-core-2.18.6 deleted (was 3ffd8cf368e) github-bot
• (flink) branch master updated: [FLINK-40048][e2e] Replace Kafka with filesystem connector in SqlClientITCase (#28606) martijnvisser
• (flink) branch master updated: [FLINK-40054] Update aircompressor to 2.0.3 martijnvisser
• (flink) branch release-2.3 updated (4753030c886 -> ad50a307283) fanrui
  • (flink) 02/02: [FLINK-40016][checkpoint] Prevent recovered buffers from being persisted twice in LocalInputChannel fanrui
  • (flink) 01/02: [FLINK-40016][checkpoint] Refactor getBufferAndAvailability to return BufferAndAvailability directly fanrui
• (flink) branch dependabot/maven/flink-runtime/io.airlift-aircompressor-2.0.3 deleted (was e9c229d8df5) github-bot
• (flink) branch dependabot/maven/org.apache.logging.log4j-log4j-layout-template-json-2.25.4 deleted (was fb1e1e97a04) github-bot
• (flink) branch dependabot/maven/org.apache.logging.log4j-log4j-1.2-api-2.25.4 deleted (was 42e46c4b120) github-bot
• (flink) branch dependabot/maven/org.apache.logging.log4j-log4j-core-2.25.4 deleted (was 21db0a811d8) github-bot
• (flink) branch master updated: [FLINK-40031][runtime-web] Fix Exceptions view crash navigating to an unassigned TaskManager (#28599) martijnvisser
• (flink) branch master updated: [FLINK-40044][runtime-web] Replace unmaintained dagre with @dagrejs/dagre 3.x (#28600) martijnvisser
• (flink) branch master updated (4998d25a811 -> e42dbd5eb23) gaborgsomogyi
• (flink) branch release-2.1 updated: [FLINK-39384][python] Fix Java errors when trying to load or compile a CompiledPlan gustavodemorais
• (flink) branch release-2.2 updated: [FLINK-39384][python] Fix Java errors when trying to load or compile a CompiledPlan gustavodemorais
• (flink) branch release-2.3 updated: [FLINK-39384][python] Fix Java errors when trying to load or compile a CompiledPlan gustavodemorais
• (flink-kubernetes-operator) branch main updated: [hotfix][ci] Replace disallowed azure/setup-helm action with a direct Helm download (#1151) gyfora
• (flink) branch master updated (c0f774fdcef -> 4998d25a811) lincoln
  • (flink) 02/03: [FLINK-39839][docs-zh] Translate AsyncTableFunction section to Chinese lincoln
  • (flink) 03/03: [FLINK-39839][docs] Document custom timeout convention for AsyncTableFunction lincoln
• (flink) branch master updated: [FLINK-40003][runtime] Fix IOMetrics not visible to state transition listeners mapohl
• (flink-agents) branch main updated: [python] Admit bytes in the Python memory value contract (#846) wenjin
• (flink) branch master updated (8cc54fb6ba5 -> 54707707f72) fanrui
  • (flink) 01/02: [FLINK-40016][checkpoint] Refactor getBufferAndAvailability to return BufferAndAvailability directly fanrui
  • (flink) 02/02: [FLINK-40016][checkpoint] Prevent recovered buffers from being persisted twice in LocalInputChannel fanrui
• (flink) branch master updated: [FLINK-40018][table] Throw a clear error when a PTF table argument input cannot satisfy the required changelog mode gustavodemorais
• (flink-cdc) branch master updated: [minor][pipeline-connector/sqlserver] Align MySQL's schema restore process instead of per-record JDBC leonard
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-8b8c83898a deleted (was 642228331b4) github-bot
• (flink) branch dependabot/uv/flink-python/docs/urllib3-2.7.0 updated (8c15883f31d -> e95fccc2ada) github-bot
• (flink) branch dependabot/uv/flink-python/docs/idna-3.15 updated (da75b22852b -> 51941fc88aa) github-bot
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/fast-uri-3.1.2 deleted (was 313c81f8bb9) github-bot
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/babel/plugin-transform-modules-systemjs-7.29.4 deleted (was 421bd642842) github-bot
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/follow-redirects-1.16.0 deleted (was 8b03b951acc) github-bot
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/node-forge-1.4.0 deleted (was 948d7d16541) github-bot
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-8df8ad9d12 deleted (was de77272d26e) github-bot
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/flatted-3.4.2 deleted (was b14721d8250) github-bot
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/immutable-5.1.5 deleted (was c4d1f048acc) github-bot
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/angular/core-20.3.18 deleted (was 3b97f3e5e6e) github-bot
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/angular/compiler-20.3.18 deleted (was 9220cd847f0) github-bot
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/angular/compiler-20.3.25 deleted (was fa9b66bc2af) github-bot
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/launch-editor-2.14.1 deleted (was 7c485b127fa) github-bot
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/angular/common-20.3.25 deleted (was 62a18fd04ec) github-bot
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/js-yaml-4.3.0 deleted (was 38ca3ecaa0a) github-bot
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-f5678199fe deleted (was a195ef3c010) github-bot
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-f7295d6b11 deleted (was b65bb0fd95d) github-bot
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/shell-quote-1.8.4 deleted (was 4842196251f) github-bot
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-7415bac7bc created (now 5d85125412d) github-bot
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-64e7abbcba created (now f298dd40181) github-bot
• (flink) branch master updated: [FLINK-38536][tests] Deploy synchronously to avoid deployment-callback race martijnvisser
• svn commit: r85575 - dev/flink/flink-connector-jdbc-3.4.0-rc0 panyuepeng
• (flink-connector-jdbc) annotated tag v3.4.0-rc0 updated (52de513a -> 24cee6e2) panyuepeng
• (flink) branch master updated: [FLINK-39956][metrics] Add heap memory pool metrics (Used/Max/CollectionUsed/CollectionMax) (#28582) peterhuang
• (flink) branch master updated: [FLINK-39384][python] Fix Java errors when trying to load or compile a CompiledPlan twalthr
• (flink-connector-http) branch pomupdate deleted (was 5d1359a) fcsaky
• (flink-connector-http) branch main updated: [hotfix] Update project version to `1.1-SNAPSHOT` fcsaky
• (flink-connector-http) branch pomupdate created (now 5d1359a) davidrad
  • (flink-connector-http) 01/01: [hotfix] Update poms to 1.1-SNAPSHOT davidrad
• (flink) branch master updated: [FLINK-39776][runtime][core] Expose JobInfo on SourceOperators fanrui
• [I] Oracle CDC pipeline connector (introduced in 3.6.0) fails with `Cannot find any table by the option 'tables'` when connecting to Oracle 19c CDB+PDB architecture. [flink-cdc] via GitHub
  • Re: [I] Oracle CDC pipeline connector (introduced in 3.6.0) fails with `Cannot find any table by the option 'tables'` when connecting to Oracle 19c CDB+PDB architecture. [flink-cdc] via GitHub
  • Re: [I] Oracle CDC pipeline connector (introduced in 3.6.0) fails with `Cannot find any table by the option 'tables'` when connecting to Oracle 19c CDB+PDB architecture. [flink-cdc] via GitHub
  • Re: [I] Oracle CDC pipeline connector (introduced in 3.6.0) fails with `Cannot find any table by the option 'tables'` when connecting to Oracle 19c CDB+PDB architecture. [flink-cdc] via GitHub
• (flink-agents) branch main updated: [feature][integration][java] Add built-in Google Gemini chat model integration (#718) wenjin
• (flink) branch master updated: [FLINK-38233][table] Adds support to StreamNonDeterministicUpdatePlanVisitor for PTFs gustavodemorais
• (flink) branch master updated: [FLINK-40029][tests] Use Hadoop 3.4.3 in nightly snuyanzin
• (flink-connector-jdbc) branch main updated: [FLINK-39960][docs] Remove broken JavaDoc shortcode usage from JDBC docs (#193) panyuepeng
• (flink-connector-elasticsearch) branch main updated: [FLINK-40006] ElasticsearchRowDataLookupFunction leaks REST client / HTTP connections on task close guoweijie
• (flink) branch NKnBm5RsWzmiuvLk created (now ce4cec57bc6) danderson
• (flink) branch master updated: [FLINK-40012][table] Correctly inject Context into scalar-only PTFs in ProcessTableFunctionTestHarness (#28579) fhueske
• (flink) branch master updated (9e663f3e3ad -> ad2dee480a6) martijnvisser
  • (flink) 01/02: [FLINK-40009][tests] Enforce timeout in RescaleTimelineITCase wait helper martijnvisser
  • (flink) 02/02: [FLINK-40010][tests] Fix race in RescaleTimelineITCase.testRescaleTerminatedByNoResourcesOrNoParallelismsChange martijnvisser
• (flink) branch master updated: [hotfix][docs] Fix broken link in PyFlink documentation martijnvisser
• (flink) branch master updated: [FLINK-39987][state] update State Processor API doc to include filter pushdown examples gaborgsomogyi
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/js-yaml-4.2.0 deleted (was 220be056ce1) github-bot
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/js-yaml-4.3.0 created (now 38ca3ecaa0a) github-bot
• (flink) branch master updated: [FLINK-40008][security] Replace fixed delegation token renewal retry backoff with exponential backoff gaborgsomogyi
• (flink-cdc) branch master updated: [FLINK-39832] Fix Oracle NUMBER(p,0) with p>=19 incorrectly mapped to BIGINT (#4424) kunni
• (flink) branch master updated: [FLINK-40021][table] `AND` for pushdown filters should be in uppercase snuyanzin
• (flink) branch master updated: [FLINK-40013][table] Correctly clear state in ctx.clearState in ProcessTableFunctionTestHarness (#28574) fhueske
• (flink) branch release-1.20 updated: [FLINK-38406][runtime] Fix DefaultSchedulerCheckpointCoordinatorTest failures (#27061) martijnvisser
• (flink) branch release-2.2 updated: [FLINK-38406][runtime] Fix DefaultSchedulerCheckpointCoordinatorTest failures (#27061) martijnvisser
• (flink) branch master updated: [FLINK-21995][yarn-tests] Whitelist netty-wrapped Pekko connection-refused WARN martijnvisser
• (flink) branch master updated: [FLINK-40011][table-planner] Fix NoMoreSplitsEvent race in CommonExecSinkITCase martijnvisser
• (flink) branch master updated: [FLINK-38536][tests] Fix data race in FinalizeOnMasterTest and ExecutionGraphFinishTest (#28350) martijnvisser
• (flink) branch master updated: [hotfix][docs] Document how to run the S3 end-to-end tests martijnvisser
• (flink-web) branch asf-site updated: [hotfix] Fix typos in documentation source and templates fcsaky
• (flink) branch master updated: [FLINK-39998][state] Surface root cause exception when parallel RocksDB state download fails gyfora
• (flink-connector-kafka) branch main updated: [FLINK-39728] Fix pauseOrResumeSplits race with unassigned partitions arvid
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-f5678199fe created (now a195ef3c010) github-bot
• (flink) branch master updated: [hotfix][build] Bump netty to 4.2.15.Final snuyanzin
• (flink) branch master updated: Revert "Refactor RexNodeExtractor to use Scala collections" snuyanzin
• (flink) branch master updated: Refactor RexNodeExtractor to use Scala collections snuyanzin
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-f5f34deeac deleted (was cec1ce0ddcf) github-bot
• [I] [Bug][cdc-cli] CliExecutor in application mode parses the pipeline definition file *path* as YAML content → "Missing required field 'source'" [flink-cdc] via GitHub
  • Re: [I] [Bug][cdc-cli] CliExecutor in application mode parses the pipeline definition file *path* as YAML content → "Missing required field 'source'" [flink-cdc] via GitHub
  • Re: [I] [Bug][cdc-cli] CliExecutor in application mode parses the pipeline definition file *path* as YAML content → "Missing required field 'source'" [flink-cdc] via GitHub
  • Re: [I] [Bug][cdc-cli] CliExecutor in application mode parses the pipeline definition file *path* as YAML content → "Missing required field 'source'" [flink-cdc] via GitHub
• (flink) branch master updated: [FLINK-39772][tests][JUnit5 migration] Module: flink-fs-tests snuyanzin
• (flink) branch master updated (5b60aba2ecb -> 1c17615d998) snuyanzin
  • (flink) 02/02: [FLINK-39999][table] Add temporary DeepCopyUnparsingTesterImpl before Calcite 1.42.0 upgrade snuyanzin
• (flink) branch master updated (cb17c87788a -> 5b60aba2ecb) panyuepeng
• (flink-connector-kafka) branch main updated: [hotfix] update reader idleness test output (#281) bli
• (flink-connector-kafka) branch main updated: [FLINK-39979] DynamicKafkaSource should mark reader idle when metadata removal leaves a subtask with no active subreaders (#276) bli
• (flink) branch release-2.3 updated: [FLINK-39061][example] Roll back StateMachineExample to v1 State API gaborgsomogyi
• (flink) branch release-2.2 updated: [FLINK-39061][example] Roll back StateMachineExample to v1 State API gaborgsomogyi
• (flink) branch release-2.1 updated: [FLINK-39061][example] Roll back StateMachineExample to v1 State API gaborgsomogyi
• (flink) branch release-2.0 updated: [FLINK-39061][example] Roll back StateMachineExample to v1 State API gaborgsomogyi
• (flink-web) branch asf-site updated (beac33687c -> 97e7f0f6ff) gaborgsomogyi
  • (flink-web) 01/02: Native s3 Filesystem Blog gaborgsomogyi
• (flink-connector-http) branch main updated: [FLINK-39361][connector-http] Improve README with SQL examples (#30) davidrad
• (flink-connector-elasticsearch) branch main updated: [FLINK-39816] Ship parsson into es8 uber jar guoweijie
• (flink) branch master updated: [FLINK-39994][table] Allow the use of primitive scalar arguments in ProcessTableFunctionTestHarness (#28545) fhueske
• (flink) branch master updated: [hotfix] [docs] Fix java.util.Collection reference in DataStream overview guoweijie
• (flink) branch master updated (c5d3273ffdd -> 0fbd749cacc) guoweijie
  • (flink) 01/04: [FLINK-39911][historyserver] Introduce ArchiveStorage abstraction and FileArchiveStorage implementation guoweijie

• Earlier messages
• Later messages