commits
Thread
Date
Earlier messages
Later messages
Messages by Date
2025/04/10
(flink-connector-elasticsearch) annotated tag v4.0.0-rc2 updated (0c181b0 -> 2f46e9f)
guoweijie
2025/04/10
Re: [I] [oracle-cdc]com.ververica.cdc.connectors.shaded.org.apache.kafka.connect.errors.DataException: file is not a valid field name [flink-cdc]
via GitHub
2025/04/10
(flink-connector-elasticsearch) branch v4.0 updated: [hotfix] Update NOTICE file to 2025
guoweijie
2025/04/10
(flink) branch master updated: [FLINK-37623][datastream] Async state support for process() in Datastream API (#26419)
leiyanfei
2025/04/10
svn commit: r76153 - /dev/flink/flink-connector-kafka-4.0.0-rc1/
arvid
2025/04/10
(flink-connector-kafka) branch main updated (45df794b -> 2b199b0c)
arvid
2025/04/10
(flink) branch master updated: [hotfix] Fix size of PyFlink INT(#25511)
rmetzger
2025/04/10
(flink) branch master updated: [FLINK-37601] Remove Unirest dependency in PrometheusReporterTest (#26387)
hong
2025/04/10
(flink-connector-kafka) 01/05: [FLINK-34554] Introduce transaction strategies
arvid
2025/04/10
svn commit: r76152 - in /dev/flink/flink-connector-kafka-4.0.0-rc2: ./ flink-connector-kafka-4.0.0-src.tgz flink-connector-kafka-4.0.0-src.tgz.asc flink-connector-kafka-4.0.0-src.tgz.sha512
arvid
2025/04/10
(flink-cdc) branch master updated: [FLINK-37484][cdc-connector] unevenly chunk split also enables unbounded-chunk-first.enabled. (#3954)
ruanhang1993
2025/04/10
Re: [I] oracle-connector实时读取只读备库的问题 [flink-cdc]
via GitHub
2025/04/10
(flink) branch release-2.0 updated: [FLINK-37620][state/forst] ForSt Sync mode support remote storage (#26422)
leiyanfei
2025/04/10
(flink-cdc) branch master updated: [minor][pipeline-connector/doris] Fix deprecated method usage in DorisSchemaChangeManager
leonard
2025/04/10
(flink-connector-kafka) annotated tag v4.0.0-rc1 updated (206255c9 -> 753641bd)
arvid
2025/04/10
(flink) branch master updated: [FLINK-37610] Check if `ORDER BY` keys exists before accessing
snuyanzin
2025/04/10
(flink) branch master updated (b37c98599b3 -> f7b5d00c453)
leiyanfei
2025/04/10
(flink) branch master updated: [hotfix] [docs] Typo fix in several docs (#26432)
rmetzger
2025/04/09
svn commit: r76172 - in /dev/flink/flink-connector-jdbc-3.3.0-rc1: ./ flink-connector-jdbc-3.3.0-src.tgz flink-connector-jdbc-3.3.0-src.tgz.asc flink-connector-jdbc-3.3.0-src.tgz.sha512
ruanhang1993
2025/04/09
(flink-web) branch jdbc3.3.0 created (now 5b4646c29)
ruanhang1993
2025/04/09
(flink-web) 01/01: Adding JDBC Connector v3.3.0
ruanhang1993
2025/04/09
(flink-connector-jdbc) annotated tag v3.3.0-rc1 deleted (was 81ade9f)
ruanhang1993
2025/04/09
(flink-connector-jdbc) annotated tag v3.3.0-rc1 updated (30e6360 -> 2b93364)
ruanhang1993
2025/04/09
(flink) branch master updated: [FLINK-37225] Remove remaining test resources of Gelly
junrui
2025/04/09
(flink-connector-jdbc) annotated tag v3.3.0-rc1 updated (544275c -> 81ade9f)
ruanhang1993
2025/04/09
(flink-cdc) branch master updated: [hotfix][test] Sleep to wait for the assign status to INITIAL_ASSIGNING_FINISHED so that newly added table won't be stuck
leonard
2025/04/09
(flink) branch master updated: [FLINK-37511] Use Jackson serialization in JobPlanInfo.Plan
roman
2025/04/09
(flink-connector-kudu) annotated tag v2.0.0 updated (ce1c85b -> 112ca81)
fcsaky
2025/04/09
(flink) branch release-2.0 updated: [FLINK-37628] Fix reference counting in ForSt file cache (#26421)
zakelly
2025/04/09
(flink-cdc) branch master updated (4baee8c63 -> 3460ba275)
leonard
2025/04/09
(flink-cdc) 01/02: [FLINK-36611][pipeline-connector/kafka] Rename sink.debezium-json.include-schema.enabled to debezium-json.include-schema.enabled
leonard
2025/04/09
(flink) branch master updated (c0dd8f0e7e7 -> 40ffc158755)
zakelly
2025/04/09
(flink-cdc) 02/02: [hotfix][minor] Fix CI failure due to code checkstyle
leonard
2025/04/09
(flink-connector-kafka) branch v4.0 updated (1fec86e7 -> 6940604b)
arvid
2025/04/09
(flink-connector-kafka) tag v4.0.0-rc2 created (now 6940604b)
arvid
2025/04/09
(flink-connector-jdbc) branch v3.3 created (now 544275c)
ruanhang1993
2025/04/09
(flink-connector-kafka) annotated tag v4.0.0-rc2 deleted (was bcffe174)
arvid
2025/04/09
svn commit: r76160 - in /dev/flink/flink-connector-kafka-4.0.0-rc2: ./ flink-connector-kafka-4.0.0-src.tgz flink-connector-kafka-4.0.0-src.tgz.asc flink-connector-kafka-4.0.0-src.tgz.sha512
arvid
2025/04/09
svn commit: r76159 - /dev/flink/flink-connector-kafka-4.0.0-rc2/
arvid
2025/04/09
(flink-kubernetes-operator) branch release-1.10 updated: [FLINK-36920] Bump quartz-scheduler from 2.3.2 to 2.4.0 (#924)
rmetzger
2025/04/09
(flink-connector-kafka) 01/01: [hotfix] Updated NOTICE to 2025
arvid
2025/04/09
(flink) branch master updated: [FLINK-37620][state/forst] ForSt Sync mode support remote storage (#26412)
leiyanfei
2025/04/09
(flink-connector-kafka) annotated tag v4.0.0-rc2 updated (206255c9 -> bcffe174)
arvid
2025/04/08
(flink) branch master updated (3bc96001656 -> 9cfd7ca5b3a)
zakelly
2025/04/08
(flink) branch release-2.0 updated: [FLINK-37458][datastream] Forbid enableAsyncState() for synchronous operators (#26395)
leiyanfei
2025/04/08
svn commit: r76135 - in /dev/flink/flink-connector-kafka-4.0.0-rc1: ./ flink-connector-kafka-4.0.0-src.tgz flink-connector-kafka-4.0.0-src.tgz.asc flink-connector-kafka-4.0.0-src.tgz.sha512
arvid
2025/04/08
(flink-connector-kafka) branch v4.0 created (now 1fec86e7)
arvid
2025/04/08
(flink) branch master updated: [FLINK-37596][metrics] Close metric group of a finished split
pnowojski
2025/04/08
(flink) branch master updated: [hotfix] Update copyright NOTICE year to 2025 (#26413)
zakelly
2025/04/08
(flink) branch master updated: [FLINK-37598][table] Support list and map state in PTFs
twalthr
2025/04/08
(flink-connector-kafka) branch main updated: [FLINK-37622] Fix KafkaSink in BATCH
arvid
2025/04/08
(flink-cdc) branch master updated: [FLINK-37000][pipeline-connector][mysql] Fix MySQL CDC could not handle datetime prior to 1970 properly (#3834)
ruanhang1993
2025/04/08
(flink) branch master updated (b2231dac38a -> ec810badf19)
snuyanzin
2025/04/08
(flink-connector-kafka) 04/05: [FLINK-34554] Adding strategies to table API
arvid
2025/04/08
(flink-connector-kafka) 03/05: [FLINK-34554] Adding pooling name strategy
arvid
2025/04/08
(flink-connector-kafka) 05/05: [hotfix] Harden KafkaWriterFaultToleranceITCase
arvid
2025/04/08
(flink-connector-kafka) 02/05: [FLINK-34554] Adding listing abort strategy
arvid
2025/04/07
(flink) branch master updated: [FLINK-37407][state] Add savepoint metadata SQL built-in process function
gaborgsomogyi
2025/04/07
(flink-cdc) branch master updated: [hotfix][cli] Fix duplicated option in CliFrontendOptions
leonard
2025/04/07
(flink-cdc) branch master updated: [FLINK-36611][pipeline-connector/kafka] Support output schema for Kafka debezium-json format
leonard
2025/04/07
(flink-cdc) branch master updated (2e4abdb68 -> f072bf1da)
leonard
2025/04/07
(flink) branch master updated (a80d71f638b -> 4db8c48d9e2)
twalthr
2025/04/07
(flink-cdc) branch master updated: [FLINK-36683][cdc-connector/mongo] Support metadata 'row_kind' virtual column
leonard
2025/04/07
(flink) branch master updated: [hotfix] Avoid copy set in PekkoRpcService (#26372)
fanrui
2025/04/07
(flink) branch master updated: [hotfix] Avoid duplicate get memory segment size (#26367)
fanrui
2025/04/06
(flink-connector-kafka) branch main updated: [hotfix] Remove unused method
fanrui
2025/04/06
(flink) branch master updated: [FLINK-37524][state/forst] Make ForStState Restore from previous StateMetaInfo (#26391)
leiyanfei
2025/04/06
(flink) branch release-2.0 updated: [FLINK-37597][state/forst] Use ResourceGuard to make sure snapshot quit before ForSt disposal
leiyanfei
2025/04/06
(flink) branch release-2.0 updated: [FLINK-37609][format] Bump parquet to 1.15.1
fcsaky
2025/04/06
(flink) branch release-1.20 updated (35e37312c1a -> 0a12d6b1fc8)
snuyanzin
2025/04/06
(flink) 01/03: [FLINK-20092] Bump maven-shade-plugin to 3.5.3 and maven-remote-resource-plugin to 3.2.0
snuyanzin
2025/04/06
(flink) 03/03: [FLINK-37609][format] Bump parquet to 1.15.1
snuyanzin
2025/04/06
(flink) 02/03: [FLINK-36695][Formats] Bump Parquet dependency to 1.14.4
snuyanzin
2025/04/06
(flink) 02/03: [FLINK-36695][Formats] Bump Parquet dependency to 1.14.4
snuyanzin
2025/04/06
(flink) 01/03: [FLINK-20092] Bump maven-shade-plugin to 3.5.3 and maven-remote-resource-plugin to 3.2.0
snuyanzin
2025/04/06
(flink) 03/03: [FLINK-37609][format] Bump parquet to 1.15.1
snuyanzin
2025/04/06
(flink) branch release-1.19 updated (233e77e8a1e -> 1c195b0471c)
snuyanzin
2025/04/05
(flink-connector-elasticsearch) annotated tag v4.0.0-rc1 deleted (was 50072c2)
guoweijie
2025/04/05
(flink) branch master updated: [hotfix][docs] update create table syntax pseudo code
sxnan
2025/04/05
(flink) branch master updated: [FLINK-37475] Drop ChangelogNormalize for piping from upsert source to sink
dwysakowicz
2025/04/05
(flink) branch master updated: [FLINK-37584][tests] Bump AssertJ version to 3.27.3
fcsaky
2025/04/05
(flink) branch master updated: [hotfix][doc] two modes instead of three
jingge
2025/04/05
(flink) branch dependabot/maven/flink-end-to-end-tests/flink-sql-client-test/org.apache.kafka-kafka-clients-2.6.3 deleted (was 62c67c387d6)
github-bot
2025/04/05
(flink-connector-kafka) branch main updated (33d00224 -> c2805458)
leonard
2025/04/05
(flink-cdc) branch master updated: [FLINK-37577][pipeline-connector/paimon] Enable waitCompaction feature in PaimonWriter only when deletion-vectors.enabled option enabled
leonard
2025/04/05
(flink-connector-elasticsearch) annotated tag v4.0.0-rc1 updated (658d26a -> 9ce06cd)
guoweijie
2025/04/05
(flink-web) branch asf-site updated (7cb72b7f1 -> 629d8326d)
fanrui
2025/04/05
(flink) branch master updated: [FLINK-37490][Docs] Add 2.0 to PreviousDocs list
guoweijie
2025/04/05
(flink) branch release-1.20 updated: [FLINK-35117][Table SQL/Planner] Add commons-text to allowed classloader list. This closes #26390 (#26402)
martijnvisser
2025/04/05
(flink) branch release-2.0 updated: [FLINK-35117][Table SQL/Planner] Add commons-text to allowed classloader list. This closes #26390 (#26401)
martijnvisser
2025/04/04
(flink) branch release-1.19 updated: [FLINK-37505][python] Add pyflink YAML based config support
fcsaky
2025/04/04
(flink) branch release-1.20 updated: [FLINK-37505][python] Add pyflink YAML based config support
fcsaky
2025/04/04
(flink-connector-kafka) 01/02: [FLINK-37611] Deflake ExactlyOnceKafkaWriterITCase#shouldAbortLingeringTransactions
arvid
2025/04/04
(flink-connector-elasticsearch) annotated tag v3.1.0-rc1 updated (c1d9d70 -> e389669)
guoweijie
2025/04/04
(flink) 01/02: [FLINK-37597][state/forst] Use ResourceGuard to make sure snapshot quit before ForSt disposal
leiyanfei
2025/04/04
(flink-connector-elasticsearch) annotated tag v3.1.0-rc1 deleted (was e0e89c3)
guoweijie
2025/04/04
(flink-connector-kudu) branch main updated: [FLINK-37527] Add `KuduSource` documentation
fcsaky
2025/04/04
(flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-bae04bd671 created (now 9199a541362)
github-bot
2025/04/04
(flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/word-wrap-1.2.4 deleted (was 5b103efc21c)
github-bot
2025/04/04
(flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-1ed37b8fa7 created (now 8cca20654b9)
github-bot
2025/04/04
(flink) 02/02: [FLINK-37158][tests] Introduce ForSt to existing ITCases
leiyanfei
2025/04/04
(flink-connector-elasticsearch) branch test-3.1 created (now b7ccbad)
guoweijie
2025/04/04
(flink-connector-kafka) branch main updated: [FLINK-37304][connector/kafka] Downgrade the log level of metadataUpdateEvent in DynamicKafkaSourceEnumerator to avoid displaying connection information
leonard
2025/04/04
(flink) branch master updated: [FLINK-37609][format] Bump parquet to 1.15.1
snuyanzin
2025/04/04
(flink-connector-kafka) branch main updated: [FLINK-37613] Fix resource leak during abortion
arvid
2025/04/04
(flink) branch dependabot/maven/flink-metrics/flink-metrics-influxdb/com.github.tomakehurst-wiremock-jre8-2.35.1 deleted (was 00f414ac5fd)
github-bot
2025/04/04
(flink) branch master updated: [FLINK-35117][Table SQL/Planner] Add commons-text to allowed classloader list. This closes #26390
martijnvisser
2025/04/04
(flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-0dbc78daaa deleted (was 73608a77e3f)
github-bot
2025/04/04
(flink-connector-kafka) 02/02: [FLINK-37611] Deflake KafkaWriterFaultToleranceITCase.testWriteExceptionWhenKafkaUnavailable
arvid
2025/04/04
(flink-connector-kafka) branch main updated (1b9b1aa3 -> d74a7bd8)
arvid
2025/04/03
(flink) branch dependabot/maven/flink-connectors/flink-connector-hive/org.apache.avro-avro-1.11.3 deleted (was 0343dc8fc1b)
github-bot
2025/04/03
(flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/babel/traverse-7.23.2 deleted (was f2cd3c85614)
github-bot
2025/04/03
(flink) branch dependabot/maven/flink-connectors/flink-sql-connector-hive-3.1.3/org.apache.avro-avro-1.11.3 deleted (was 1b6d55827c7)
github-bot
2025/04/03
(flink) branch master updated (4a0c2e40506 -> 076fa80e314)
leiyanfei
2025/04/03
(flink-connector-jdbc) branch main updated: [FLINK-36659][connector/jdbc] Update version to 4.0-SNAPSHOT
leonard
2025/04/03
(flink-cdc) branch master updated: [FLINK-37572][pipeline-connector/paimon] Shuffle Event by bucket and tableid to avoid data skew
leonard
2025/04/03
(flink-connector-jdbc) 02/02: [FLINK-36659] Bump version of flink to 2.0.0.
leonard
2025/04/03
(flink-connector-jdbc) branch main updated (544275c -> f9167c3)
leonard
2025/04/02
(flink) branch dependabot/maven/flink-end-to-end-tests/flink-end-to-end-tests-sql/com.squareup.okio-okio-3.4.0 deleted (was c1ebb259b21)
github-bot
2025/04/02
(flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/stylelint-15.10.1 deleted (was c74b8f0c2c6)
github-bot
2025/04/02
(flink) branch master updated: [FLINK-37521][runtime] Implement async state version of KeyedCoProcessOperator (#26328)
leiyanfei
2025/04/02
(flink-connector-elasticsearch) branch v4.0 created (now a2173f6)
guoweijie
2025/04/02
(flink-connector-elasticsearch) 01/01: [hotfix] v4.0 branch run ci for 2.0-SNAPSHOT
guoweijie
2025/04/02
svn commit: r75989 - in /dev/flink/flink-connector-elasticsearch-4.0.0-rc1: ./ flink-connector-elasticsearch-4.0.0-src.tgz flink-connector-elasticsearch-4.0.0-src.tgz.asc flink-connector-elasticsearch-4.0.0-src.tgz.sha512
guoweijie
2025/04/02
(flink) branch master updated: [FLINK-37569] Add userKeySerializer in RegisteredKeyValueStateBackend V2 (#26364)
zakelly
2025/04/02
(flink-connector-elasticsearch) annotated tag v4.0.0-rc1 updated (7778b76 -> 50072c2)
guoweijie
2025/04/01
(flink-connector-kafka) branch main updated: [FLINK-36821] Update to Kafka 3.9.0
arvid
2025/04/01
svn commit: r75978 - in /dev/flink/flink-connector-elasticsearch-3.1.0-rc1: ./ flink-connector-elasticsearch-3.1.0-src.tgz flink-connector-elasticsearch-3.1.0-src.tgz.asc flink-connector-elasticsearch-3.1.0-src.tgz.sha512
guoweijie
2025/04/01
(flink-cdc) branch master updated: [FLINK-37529][cdc-connector] Add flink-cdc-common module to all sql jars (#3962)
ruanhang1993
2025/04/01
(flink-connector-elasticsearch) branch test-3.1 updated: [hotfix] Fix compatible issue with 1.20
guoweijie
2025/04/01
svn commit: r75976 - /dev/flink/flink-connector-elasticsearch-3.1.0-rc1/
guoweijie
2025/04/01
(flink-connector-elasticsearch) 01/01: Update version to 3.1.0
guoweijie
2025/04/01
(flink-connector-elasticsearch) annotated tag v3.1.0-rc1 updated (228ebd0 -> e0e89c3)
guoweijie
2025/04/01
svn commit: r75975 - in /dev/flink/flink-connector-elasticsearch-3.1.0-rc1: ./ flink-connector-elasticsearch-3.1.0-src.tgz flink-connector-elasticsearch-3.1.0-src.tgz.asc flink-connector-elasticsearch-3.1.0-src.tgz.sha512
guoweijie
2025/04/01
(flink-connector-kafka) 01/02: [FLINK-37590][build] Add CI of python and add jdk11 to ensure compatibility.
arvid
2025/04/01
(flink) branch release-1.20 updated (7bd8ba4913a -> e1e6527d9f7)
sxnan
2025/04/01
(flink-connector-kafka) 02/02: Fix compatibility with 2.1-SNAPSHOT.
arvid
2025/04/01
(flink-connector-kafka) branch main updated (6f251eca -> 11c22645)
arvid
2025/04/01
(flink) branch master updated (60041948a63 -> e06fddc9554)
twalthr
2025/03/31
(flink) branch master updated: [FLINK-37570][metrics] Export default watermark if split doesn't have any
pnowojski
2025/03/31
(flink) branch master updated (0e7b44c6009 -> 7052c3bd875)
klion26
2025/03/31
(flink) branch master updated: [FLINK-37582] Apply PushCalcPastChangelogNormalizeRule before FlinkChangelogModeInferenceProgram
dwysakowicz
2025/03/30
(flink-cdc) branch master updated: [hotfix][ci] Prevent Nightly actions from being triggered by forks (#3969)
jiabaosun
2025/03/30
(flink) branch master updated: [FLINK-37576][runtime] Fix the incorrect status of the isBroadcast field in AllToAllBlockingResultInfo when submitting a job graph.
junrui
2025/03/30
(flink) branch release-2.0 updated: [FLINK-37576][runtime] Fix the incorrect status of the isBroadcast field in AllToAllBlockingResultInfo when submitting a job graph.
junrui
2025/03/28
(flink) branch master updated: [hotfix] Replacing manual comparison logic with `Long#compare`
fcsaky
2025/03/28
(flink) branch master updated: [FLINK-37408] Update all `docker-compose` references to `docker compose`
fcsaky
2025/03/28
(flink-kubernetes-operator) branch main updated: [FLINK-37530] Record upgrade savepoint correctly in savepointInfo as well
gyfora
2025/03/28
svn commit: r75858 - in /dev/flink/flink-connector-kudu-2.0.0-rc1: ./ flink-connector-kudu-2.0.0-src.tgz flink-connector-kudu-2.0.0-src.tgz.asc flink-connector-kudu-2.0.0-src.tgz.sha512
fcsaky
2025/03/28
(flink-connector-kudu) annotated tag v2.0.0-rc1 updated (ce1c85b -> ab6fda6)
fcsaky
2025/03/28
(flink-kubernetes-operator) branch main updated: [FLINK-37470] Improve JobManager Deployment / Pod error handling
gyfora
2025/03/28
(flink-connector-kudu) branch v2.0 created (now a79daca)
fcsaky
2025/03/28
(flink-connector-kudu) branch main updated: [hotfix] Add shared release utils
fcsaky
2025/03/28
(flink-kubernetes-operator) branch main updated: [FLINK-37455] Create error Event when job goes into FAILED state
gyfora
2025/03/27
(flink) branch release-2.0 updated: [FLINK-37556][metrics][otel] Add missing dependencies for OpenTelemetry
fcsaky
2025/03/27
(flink) branch master updated (56e1e76a776 -> b506661a9d0)
fcsaky
2025/03/27
(flink-connector-kafka) 02/03: [FLINK-36648][Connectors/Kafka] Bump Flink version to 2.0.0
leonard
2025/03/27
(flink-connector-kafka) branch main updated: [FLINK-37144][Connectors/Kafka] Update version to 4.0-SNAPSHOT
leonard
2025/03/27
(flink-connector-kafka) 03/03: [hotfix][build] Add stable version to weekly CI
leonard
2025/03/27
(flink-kubernetes-operator) branch main updated: [hotfix] Do not leak autoscaler configs to jobs
gyfora
2025/03/27
(flink-kubernetes-operator) branch main updated: [FLINK-37562] Do not check all JM replicas in observer
gyfora
2025/03/27
(flink-kubernetes-operator) branch main updated: [FLINK-37571] Fix JobGraph removal for 2.0 last-state upgrades
gyfora
2025/03/27
(flink-cdc) branch master updated: [FLINK-37506][transform] Print more descriptive error messages when TransformOperator throws an exception
leonard
2025/03/27
(flink-cdc) branch master updated: [FLINK-37371][cdc-connector/postgresql] Postgres CDC incremental source fails to handle upper-case table and column names
leonard
2025/03/27
(flink-cdc) branch master updated: [FLINK-37358][kafka] Support to pass format options
leonard
2025/03/27
(flink-kubernetes-operator) branch main updated: [FLINK-37430] Operator hides the actual error on deployment issues
gyfora
2025/03/27
(flink) branch master updated: [FLINK-37533][CI] Add action: write permission to stale PR github action (#26360)
rmetzger
2025/03/27
(flink-cdc) branch master updated: [FLINK-35360][cli] Support Yarn application mode for yaml job
leonard
2025/03/27
(flink) branch master updated (8c9d4ee5ab0 -> d5ecb07dab4)
junrui
2025/03/27
(flink-kubernetes-operator) branch main updated: [ci] PRs should not cancel each others or traget branches CI runs
gyfora
2025/03/26
(flink) branch master updated: [FLINK-37493][release] Update japicmp configuration for 2.0.0
guoweijie
2025/03/26
(flink-kubernetes-operator) branch main updated: [FLINK-37405] Validate config prefixes for Flink 2.0
gyfora
2025/03/26
(flink-connector-aws) branch main updated: [FLINK-37416][BugFix][Connectors/DynamoDB] Fix state inconsistency issue in DDB connector when sending split finished event from reader -> enumerator
hong
2025/03/26
(flink) branch master updated: [FLINK-37533][CI] Reduce the stale PR github action timouts to match typical apache values (90 days inactive with 30 to respond) (#26336)
rmetzger
2025/03/26
(flink) branch master updated (df9db31010f -> 0091f39b4a7)
pnowojski
2025/03/26
(flink-web) branch asf-site updated: [hotfix] Update Slack invite link
martijnvisser
2025/03/26
(flink) branch master updated: [FLINK-37410][runtime/metrics] Split level Watermark metrics (#26276)
pnowojski
2025/03/26
(flink) branch release-1.20 updated: [FLINK-37557] Fix ResolvedSchema#getPrimaryKeyIndexes
dwysakowicz
2025/03/25
(flink-cdc) branch master updated: [FLINK-37539][pipeline-connector/paimon] Replace stream with parallelStream to optimize the performance
leonard
2025/03/25
(flink) branch master updated: [FLINK-36443][table][test] Improve flaky tests related to partition specs (#26335)
xuyangzhong
2025/03/25
(flink) branch master updated: [hotfix][clients] Refactor PackagedProgram#getJobJarAndDependencies to reduce some redundant lines. (#26238)
fanrui
2025/03/25
(flink) branch master updated (d39b8a61df3 -> a5d419427d7)
fanrui
2025/03/25
(flink) branch master updated (36111caf994 -> d39b8a61df3)
fanrui
2025/03/25
(flink) branch master updated: [hotfix] Rename JobRestEndpointFactory to ApplicationRestEndpointFactory (#26347)
fanrui
2025/03/25
(flink) branch master updated: [hotfix] Remove redundant config operation for ADDRESS and PORT (#26342)
fanrui
2025/03/25
Re: [I] How to define a slotSharingGroup on pipeline? when using flink-cdc.sh [flink-cdc]
via GitHub
2025/03/25
Re: [I] How to define a slotSharingGroup on pipeline? when using flink-cdc.sh [flink-cdc]
via GitHub
2025/03/25
Re: [I] How to define a slotSharingGroup on pipeline? when using flink-cdc.sh [flink-cdc]
via GitHub
2025/03/25
(flink) branch master updated: [FLINK-37557] Fix ResolvedSchema#getPrimaryKeyIndexes
dwysakowicz
2025/03/25
(flink) branch master updated (34edc0322d4 -> 960a253e8bd)
mxm
2025/03/24
(flink-cdc) branch master updated: [FLINK-36573][cdc-connector][mysql] Print table names of binlog split when checkpointing
leonard
2025/03/24
(flink-web) branch asf-site updated: Add LTS documentation link
guoweijie
2025/03/24
[I] How to define a slotSharingGroup on pipeline? when using flink-cdc.sh [flink-cdc]
via GitHub
2025/03/24
(flink) branch master updated: [hotfix] The checkState should follows the Flink code style
xtsong
2025/03/24
(flink-web) 01/03: corrected released version in the release doc.
fanrui
2025/03/24
(flink-web) 02/03: corrected released version in the release doc of 1.10 and 1.9
fanrui
2025/03/24
(flink-web) branch asf-site updated (f90b883a7 -> 7cb72b7f1)
zakelly
2025/03/24
(flink-web) 01/02: [hotfix] Fix the broken TOC
zakelly
2025/03/24
(flink) branch master updated (df058589aff -> c151909d5a0)
guoweijie
2025/03/24
(flink-web) 01/02: Add Flink 2.0.0 release
xtsong
Earlier messages
Later messages