commits
Thread
Date
Later messages
Messages by Date
2024/02/07
(flink-kubernetes-operator) branch main updated: [FLINK-33771] Extract method to estimate task slots and add dedicated test (#773)
mxm
2024/02/07
(flink-connector-kafka) branch v3.1 updated: [hotfix] Update copyright year to 2024 (#82)
martijnvisser
2024/02/07
(flink-connector-kafka) branch v3.1 updated: [hotfix] Update shortcode in Kafka Datastream documentation so that the download links appear
martijnvisser
2024/02/07
(flink-connector-kafka) branch main updated: [hotfix] Update shortcode in Kafka Datastream documentation so that the download links appear
martijnvisser
2024/02/07
(flink-connector-kafka) branch v3.1 updated: [hotfix] Make the upsert-kafka artifacts point to the regular kafka artifacts in the documentation
martijnvisser
2024/02/07
(flink-connector-kafka) branch main updated: [hotfix] Make the upsert-kafka artifacts point to the regular kafka artifacts in the documentation
martijnvisser
2024/02/07
(flink) branch master updated (f1fba33d85a -> eb1f7c8f998)
martijnvisser
2024/02/07
(flink) branch release-1.17 updated: [release] Integrate Kafka v3.1 connector documentation
martijnvisser
2024/02/07
(flink) branch release-1.18 updated: [release] Integrate Kafka v3.1 connector documentation
martijnvisser
2024/02/07
(flink-connector-kafka) branch v3.1 updated: [release] Add Flink compatibility table for documentation purposes
martijnvisser
2024/02/06
(flink) branch master updated: [FLINK-34345][runtime] Remove TaskExecutorManager related logic
fanrui
2024/02/06
(flink-benchmarks) branch master updated: [FLINK-34282] Upgrade Flink version to 1.20-SNAPSHOT
lincoln
2024/02/06
(flink-benchmarks) branch dev-1.19 created (now fc87459)
lincoln
2024/02/06
(flink) branch master updated: [FLINK-33611][flink-protobuf] Split last segment only when size exceeds split threshold limit in deserializer
libenchao
2024/02/06
(flink-docker) 01/01: [FLINK-34282] Initialize dev-1.19 branch
lincoln
2024/02/06
(flink-docker) branch dev-1.19 created (now 59f0b72)
lincoln
2024/02/06
(flink) branch master updated (03b45844228 -> b8b2596a1e4)
lincoln
2024/02/06
(flink) branch release-1.19 created (now 3d67a2b9b20)
lincoln
2024/02/06
(flink) 01/01: Update for 1.19.0
lincoln
2024/02/06
(flink-web) branch asf-site updated: [FLINK-34365] Delete repeated pages in Chinese Flink website and correct the Paimon url (#713)
wanglijie
2024/02/06
(flink-kubernetes-operator) branch main updated: [FLINK-31220] Replace Pod with PodTemplateSpec for the pod template properties
gyfora
2024/02/06
(flink) branch master updated: [FLINK-34337][Core] Sink.InitContextWrapper should implement metadataConsumer method. This closes #24249
martijnvisser
2024/02/06
(flink) branch master updated: [FLINK-34095] Adds restore tests for StreamExecAsyncCalc (#24220)
twalthr
2024/02/06
(flink) branch release-1.18 updated: Revert "[FLINK-34324][test] Makes all s3 related operations being declared and called in a single location"
mapohl
2024/02/06
svn commit: r67207 - /dev/flink/flink-connector-kafka-3.1.0-rc1/ /release/flink/flink-connector-kafka-3.1.0/
martijnvisser
2024/02/06
(flink-connector-kafka) annotated tag v3.1.0 updated (e51adab0 -> 62b9ab6a)
martijnvisser
2024/02/06
(flink) branch master updated: [FLINK-33739][doc] Document FLIP-364: Improve the exponential-delay restart-strategy
fanrui
2024/02/06
(flink) branch master updated: [hotfix][web] Correct the hint of options name of rest.profiling.enabled
tangyun
2024/02/06
(flink) branch master updated: [FLINK-34256][docs] Add documentation for mini-batch regular join
ron
2024/02/05
(flink) branch release-1.18 updated: [FLINK-34324][test] Makes all s3 related operations being declared and called in a single location
mapohl
2024/02/05
(flink) 01/02: [hotfix][core] Makes ExecutorUtils#gracefulShutdown return any outstanding tasks
mapohl
2024/02/05
(flink) 02/02: [FLINK-34007][k8s] Adds graceful shutdown logic to KubernetesLeaderElector
mapohl
2024/02/05
(flink) branch master updated (3d0cddef418 -> 79cccd7103a)
mapohl
2024/02/05
(flink) branch master updated (839f298c383 -> 3d0cddef418)
dwysakowicz
2024/02/05
(flink) 01/02: [FLINK-33441] Move Union restore tests
dwysakowicz
2024/02/05
(flink) 02/02: [FLINK-33441] Remove unused json plan
dwysakowicz
2024/02/05
(flink) branch release-1.17 updated: [FLINK-34343][rpc] Use actor path when rejecting early messages
chesnay
2024/02/05
(flink) branch release-1.18 updated: [FLINK-34343][rpc] Use actor path when rejecting early messages
chesnay
2024/02/05
(flink) branch master updated: [FLINK-34343][rpc] Use actor path when rejecting early messages
chesnay
2024/02/05
(flink) branch master updated: [FLINK-34247][doc] Fix the wrong zh link for flink-configuration-file and repeated flink configuration file
fanrui
2024/02/04
(flink) branch release-1.17 updated: [FLINK-33981][runtime] Fix not closing DirectoryStream after listing local state files
fanrui
2024/02/04
(flink) branch master updated: [FLINK-33981][runtime] Fix not closing DirectoryStream after listing local state files
fanrui
2024/02/04
(flink) branch master updated: [FLINK-34353][table-planner] Fix unclear exception without setting minibatch size when enable minibatch optimization
ron
2024/02/04
(flink) 02/03: [FLINK-34247][doc] Update the usage of "env.java.home" in doc.
zhuzh
2024/02/04
(flink) 03/03: [FLINK-34247][doc] Update the usage of flink-conf.yaml in doc.
zhuzh
2024/02/04
(flink) 01/03: [FLINK-34247][doc] Add documentation of new Flink configuration file config.yaml.
zhuzh
2024/02/04
(flink) branch master updated (6be30b16799 -> e9bea09510e)
zhuzh
2024/02/04
(flink) branch master updated: [FLINK-34323][table-planner] Fix named params in session window tvf
jchan
2024/02/04
(flink) branch master updated: [FLINK-34229][table-runtime] Set CodeGeneratorContext of outer class as ancestor context when generate inner classes to avoid naming conflicts
ron
2024/02/04
(flink) branch master updated: [FLINK-34313][doc][table] Add document for session window tvf
jchan
2024/02/04
(flink) branch master updated (60795b78dce -> 433b025b057)
jchan
2024/02/04
(flink) branch master updated (5fe6f2024f7 -> 60795b78dce)
guoweijie
2024/02/03
(flink) branch release-1.18 updated: [FLINK-33981][runtime] Fix not closing DirectoryStream after listing local state files
fanrui
2024/02/02
(flink) branch master updated: [FLINK-26369][doc-zh] Translate the part zh-page mixed with not be translated.
fanrui
2024/02/01
(flink-kubernetes-operator) 01/02: [FLINK-34178][autoscaler][refactor] Get the jobRunningTs from JobStatus.RUNNING instead of max timestamp
fanrui
2024/02/01
(flink-kubernetes-operator) 02/02: [FLINK-34178][autoscaler] Fix the bug that observed scaling restart time is always great than `stabilization.interval`
fanrui
2024/02/01
(flink-kubernetes-operator) branch main updated (398a87c9 -> 2bd6b1b3)
fanrui
2024/02/01
(flink-kubernetes-operator) branch main updated: [FLINK-34329][autoscaler] Fix the bug that scaling report parser doesn't support Locale
fanrui
2024/02/01
(flink) branch master updated: [FLINK-34258][docs][table] Fix incorrect retract example for TableAggregateFunction
jchan
2024/02/01
(flink-kubernetes-operator) branch main updated: [FLINK-33089] Clean up 1.13 and 1.14 references from docs and code (#768)
mxm
2024/02/01
(flink-kubernetes-operator) branch main updated: [FLINK-34319] Bump okhttp version to 4.12.0
gyfora
2024/02/01
(flink-web) branch asf-site updated: Add Opensearch connector v1.1.0
dannycranmer
2024/02/01
svn commit: r67096 - /release/flink/flink-connector-opensearch-1.0.1/
dannycranmer
2024/02/01
svn commit: r67095 - /dev/flink/flink-connector-opensearch-1.1.0-rc1/ /release/flink/flink-connector-opensearch-1.1.0/
dannycranmer
2024/02/01
(flink-connector-opensearch) branch v1.1 updated: [hotfix] Update connector docs metadata for v1.1 branch
dannycranmer
2024/02/01
(flink) branch release-1.17 updated: [hotfix] Integrate opensearch v1.1 docs
dannycranmer
2024/02/01
(flink) branch release-1.18 updated: [hotfix] Integrate opensearch v1.1 docs
dannycranmer
2024/02/01
(flink) branch master updated: [hotfix] Integrate opensearch v1.1 docs
dannycranmer
2024/02/01
(flink-connector-opensearch) 01/01: [hotfix] Set version to 1.1-SNAPSHOT
dannycranmer
2024/02/01
(flink-connector-opensearch) branch v1.1 created (now 5d1918f)
dannycranmer
2024/02/01
(flink-connector-opensearch) annotated tag v1.1.0 updated (0f659cc -> 21ba9f7)
dannycranmer
2024/02/01
(flink-connector-opensearch) annotated tag v deleted (was 4f3008a)
dannycranmer
2024/02/01
(flink-connector-opensearch) annotated tag v updated (0f659cc -> 4f3008a)
dannycranmer
2024/02/01
svn commit: r67094 - in /dev/flink/flink-connector-jdbc-3.1.2-rc3: ./ flink-connector-jdbc-3.1.2-src.tgz flink-connector-jdbc-3.1.2-src.tgz.asc flink-connector-jdbc-3.1.2-src.tgz.sha512
snuyanzin
2024/02/01
(flink-connector-jdbc) annotated tag v3.1.2-rc3 updated (fb383ab9 -> bf6be327)
snuyanzin
2024/02/01
svn commit: r67092 - /dev/flink/flink-connector-jdbc-3.1.2-rc2/
snuyanzin
2024/02/01
(flink) 01/05: [hotfix][test] Moves ConfigMap lifecycle management into @BeforeEach/@AfterEach methods
mapohl
2024/02/01
(flink) 03/05: [hotfix][test] Refactors TestingLeaderCallbackHandler to allow async calls
mapohl
2024/02/01
(flink) 04/05: [FLINK-34007][k8s] fabric8io LeaderElector is created with every new #run() call
mapohl
2024/02/01
(flink) 02/05: [hotfix][test] Makes ManuallyTriggeredScheduledExecutorService#execute rely on a BlockingQueue
mapohl
2024/02/01
(flink) branch master updated (dd3e60a4b1e -> 95417a4857e)
mapohl
2024/02/01
(flink) 05/05: [FLINK-34007][k8s] Upgrade k8s client to v6.9.2 to cover client issue #5464
mapohl
2024/02/01
(flink) branch master updated (2be1ea801cf -> dd3e60a4b1e)
zhuzh
2024/01/31
(flink) branch master updated: [FLINK-34126][configuration] Correct the description of config option jobmanager.scheduler
zhuzh
2024/01/31
(flink) branch master updated: [FLINK-34206][runtime] Fix potential job failure due to concurrent global failure and source paralelism inference
zhuzh
2024/01/31
(flink) branch master updated: [FLINK-33358][sql-client] Fix Flink SQL Client fail to start in Flink on YARN (#23629)
shengkai
2024/01/31
(flink) branch master updated (8e11b6005c9 -> 98e1d079f6e)
libenchao
2024/01/31
(flink) branch master updated (cb9e220c229 -> 8e11b6005c9)
dmvk
2024/01/31
(flink-connector-jdbc) branch v3.1 updated: [hotfix] Use 1.16.x as minimum supported version in pom
snuyanzin
2024/01/31
(flink-kubernetes-operator) branch main updated: [FLINK-34311] Do not change min resource requirements when rescaling for adaptive scheduler
gyfora
2024/01/31
(flink) branch master updated: [FLINK-34271][table-planner] Fix unstable GroupAggregateRestoreTest#AGG_WITH_STATE_TTL_HINT
jchan
2024/01/31
(flink) branch master updated: [FLINK-34316] Reduce instantiation of ScanRuntimeProvider in streaming mode
twalthr
2024/01/31
(flink) branch master updated (697d328f6bb -> ff9a3c85f69)
mapohl
2024/01/31
(flink) branch release-1.18 updated: [FLINK-33915][ci] Adds workflow release-1.18 nightly CI workflow
mapohl
2024/01/31
(flink) branch master updated: [FLINK-33915][ci] Adds workflow for extended master CI workflow
mapohl
2024/01/31
(flink) 03/07: [hotfix][build] Adds Maven and Java version to Maven command
mapohl
2024/01/31
(flink) 07/07: [FLINK-33914][ci] Introduces a basic GitHub Actions workflow
mapohl
2024/01/31
(flink) 02/07: [hotfix][ci] Fixes condition for filtering NOTICE files
mapohl
2024/01/31
(flink) 05/07: [hotfix][ci] Adds proper log message at the end of a successful CI run
mapohl
2024/01/31
(flink) 04/07: [hotfix][ci] Replaces spaces with tabs
mapohl
2024/01/31
(flink) 01/07: [hotfix][ci] Fixes find commands where touch might cause a failure if no files were found
mapohl
2024/01/31
(flink) branch release-1.18 updated (d903990e1ed -> a64e1c98533)
mapohl
2024/01/31
(flink) 06/07: [FLINK-27082][ci] Updates github-actions profile.
mapohl
2024/01/31
(flink) 04/08: [hotfix][ci] Replaces spaces with tabs
mapohl
2024/01/31
(flink) 06/08: [FLINK-34062][build] Adds JDK 21 surefire configuration.
mapohl
2024/01/31
(flink) 07/08: [FLINK-27082][ci] Updates github-actions profile.
mapohl
2024/01/31
(flink) 05/08: [hotfix][ci] Adds proper log message at the end of a successful CI run
mapohl
2024/01/31
(flink) 02/08: [hotfix][ci] Fixes condition for filtering NOTICE files
mapohl
2024/01/31
(flink) 08/08: [FLINK-33914][ci] Introduces a basic GitHub Actions workflow
mapohl
2024/01/31
(flink) 01/08: [hotfix][ci] Fixes find commands where touch might cause a failure if no files were found
mapohl
2024/01/31
(flink) 03/08: [hotfix][build] Adds Maven and Java version to Maven command
mapohl
2024/01/31
(flink) branch master updated (b5a2ee4e988 -> 85edd784fc7)
mapohl
2024/01/31
(flink) branch master updated (0ba3e76b147 -> b5a2ee4e988)
chesnay
2024/01/31
(flink-connector-jdbc) branch main updated (5a90eb0a -> 611b45cf)
guoweijie
2024/01/31
(flink-connector-elasticsearch) branch dependabot/maven/org.yaml-snakeyaml-2.0 created (now 60c726d)
github-bot
2024/01/31
(flink-connector-elasticsearch) branch main updated (153b8fc -> 4914929)
leonard
2024/01/31
(flink-connector-gcp-pubsub) branch main updated: [hotfix][ci] Make CI against multiple Flink versions
leonard
2024/01/31
(flink-connector-hbase) branch main updated (42870d5 -> 91d166d)
leonard
2024/01/31
(flink-connector-pulsar) branch main updated: [hotfix] Update copyright year to 2024
leonard
2024/01/30
(flink) branch master updated: [docs] Fix typo in ide_setup.md (#20877)
mxm
2024/01/30
svn commit: r67002 - in /dev/flink/flink-connector-mongodb-1.1.0-rc2: ./ flink-connector-mongodb-1.1.0-src.tgz flink-connector-mongodb-1.1.0-src.tgz.asc flink-connector-mongodb-1.1.0-src.tgz.sha512
leonard
2024/01/30
(flink-connector-mongodb) annotated tag v1.1.0-rc2 updated (6c620cd -> d59567a)
leonard
2024/01/30
(flink) branch master updated: [FLINK-32684][rpc] Introduces RpcOptions and deprecates AkkaOptions (#24188)
mapohl
2024/01/29
(flink) branch release-1.18 updated: [FLINK-34115][table-planner] Fix TableAggregateITCase unstable test
jchan
2024/01/29
(flink) 02/03: [FLINK-34225][runtime] Fix the race condition in UnionResultSubpartitionView
guoweijie
2024/01/29
(flink) 01/03: [hotfix][runtime] Fix resource releasing and recovery logic in shuffle
guoweijie
2024/01/29
(flink) 03/03: [FLINK-34233][runtime] Avoid enqueuing input channel before subpartitions initialized
guoweijie
2024/01/29
(flink) branch master updated (bb01c3070ea -> 973190e8ca5)
guoweijie
2024/01/29
(flink-kubernetes-operator) branch main updated: [FLINK-34104][autoscaler] Improve the ScalingReport format of autoscaling
fanrui
2024/01/29
(flink) branch master updated: [FLINK-34115][table-planner] Fix TableAggregateITCase unstable test
jchan
2024/01/29
(flink) 01/02: [hotfix][test] Update test_configuration.py to test test_parse_jars_value.
zhuzh
2024/01/29
(flink) 02/02: [FLINK-34257][core] Update Flink YAML Parser to Support YAML 1.2 Specification.
zhuzh
2024/01/29
(flink) branch master updated (3b4fa6c424b -> 081051a2cac)
zhuzh
2024/01/29
(flink-connector-kafka) branch main updated: [hotfix] Update copyright year to 2024 (#82)
leonard
2024/01/29
(flink-connector-aws) branch main updated: [hotfix] Update copyright year to 2024
leonard
2024/01/29
(flink) branch master updated: [FLINK-34103][examples] Include flink-connector-datagen for AsyncIO example and bundle it into the dist by default
guoweijie
2024/01/29
(flink) branch master updated: [FLINK-34059][docs][table] Add documentation on STATE_TTL hint
jchan
2024/01/29
(flink) branch master updated: [FLINK-34053][table-planner] Support state ttl hint for group aggregate
jchan
2024/01/29
svn commit: r66995 - /dev/flink/flink-connector-jdbc-3.1.2-rc1/
snuyanzin
2024/01/29
svn commit: r66994 - in /dev/flink/flink-connector-jdbc-3.1.2-rc2: ./ flink-connector-jdbc-3.1.2-src.tgz flink-connector-jdbc-3.1.2-src.tgz.asc flink-connector-jdbc-3.1.2-src.tgz.sha512
snuyanzin
2024/01/29
svn commit: r66993 - /dev/flink/flink-connector-jdbc-3.1.2-rc2/
snuyanzin
2024/01/29
svn commit: r66991 - in /dev/flink/flink-connector-jdbc-3.1.2-rc2: ./ flink-connector-jdbc-3.1.2-src.tgz flink-connector-jdbc-3.1.2-src.tgz.asc flink-connector-jdbc-3.1.2-src.tgz.sha512
snuyanzin
2024/01/29
(flink-connector-jdbc) annotated tag v3.1.2-rc2 updated (911da002 -> 871196c5)
snuyanzin
2024/01/29
(flink) branch master updated: [FLINK-34058][table] Support optional parameters for named arguments (#24183)
shengkai
2024/01/29
(flink) branch master updated: [FLINK-34204][core] spotless:apply
mapohl
2024/01/29
(flink) 06/07: fixup! [FLINK-33976] Populate `scalingInterval{Min,Max}` options from the JobMaster's configuration instead of a Job configuration.
dmvk
2024/01/29
(flink) 07/07: fixup! [FLINK-33976] Consolidate AdaptiveScheduler options into AdaptiveSchduler#Settings object.
dmvk
2024/01/29
(flink) 02/07: [FLINK-33976] Populate `scalingInterval{Min,Max}` options from the JobMaster's configuration instead of a Job configuration.
dmvk
2024/01/29
(flink) 01/07: [FLINK-33976] Consolidate AdaptiveScheduler options into AdaptiveSchduler#Settings object.
dmvk
2024/01/29
(flink) 04/07: [hotfix] Speed up AdaptiveSchedulerClusterITCase by setting scalingIntervalMin to 1ms.
dmvk
2024/01/29
(flink) 03/07: [hotfix] Speed up AdaptiveSchedulerTest by setting scalingIntervalMin to 1ms.
dmvk
2024/01/29
(flink) 05/07: fixup! [FLINK-33976] Consolidate AdaptiveScheduler options into AdaptiveSchduler#Settings object.
dmvk
2024/01/29
(flink) branch master updated (ce67b7d7c38 -> e945a36de8c)
dmvk
2024/01/29
svn commit: r66912 - in /dev/flink/flink-connector-mongodb-1.1.0-rc1: ./ flink-connector-mongodb-1.1.0-src.tgz flink-connector-mongodb-1.1.0-src.tgz.asc flink-connector-mongodb-1.1.0-src.tgz.sha512
leonard
2024/01/29
(flink-connector-mongodb) annotated tag v1.1.0-rc1 updated (6c620cd -> b763ad5)
leonard
2024/01/29
(flink-connector-mongodb) branch main updated: [hotfix][Connector/MongoDB] Add release tools as submodule
leonard
2024/01/29
(flink-connector-mongodb) branch v1.1 updated: [hotfix][Connector/MongoDB] Add release tools as submodule
leonard
2024/01/29
(flink) branch master updated: [FLINK-34230][doc] Add -Pskip-webui-build to the config doc generation command
huweihua
2024/01/29
(flink-connector-mongodb) branch main updated: Update version to 1.2-SNAPSHOT
leonard
2024/01/29
(flink-connector-mongodb) branch v1.1 created (now a66f57e)
leonard
2024/01/29
(flink-connector-opensearch) branch main updated: [hotfix] Update copyright year to 2024
leonard
2024/01/29
(flink-connector-gcp-pubsub) branch main updated: [hotfix] Update copyright year to 2024
leonard
2024/01/29
(flink-connector-cassandra) branch main updated: [hotfix] Update copyright year to 2024
leonard
2024/01/29
(flink-connector-mongodb) branch main updated: [hotfix] Update copyright year to 2024
leonard
2024/01/29
(flink-connector-mongodb) branch main updated: [FLINK-33899][connectors/mongodb] Support Java 17 and Java 21 for mongodb connector
leonard
2024/01/28
(flink) 01/02: [FLINK-34052][examples] Install the shaded streaming example jars in the maven repo
guoweijie
2024/01/28
(flink) 02/02: [hotfix][examples] Doc on why MatrixVectorMul example is not bundled with Flink dist nor deployed in Maven repo
guoweijie
2024/01/28
(flink) branch master updated (20450485b20 -> 324a5e45c80)
guoweijie
2024/01/28
(flink) branch master updated: [FLINK-34222][table-planner] Supports mini-batch for streaming regular join
ron
2024/01/28
(flink) branch master updated: [FLINK-34249][runtime] Remove DefaultSlotTracker related logic.
fanrui
2024/01/28
(flink-connector-mongodb) branch main updated: [hotfix][test][connectors/mongodb] Update MongoWriterITCase to be compatible with updated SinkV2 interfaces
leonard
2024/01/28
(flink) branch master updated (2e56caf11c0 -> ddbf87f2a7a)
zhuzh
2024/01/27
(flink) branch master updated (11631cb5956 -> 2e56caf11c0)
guoweijie
2024/01/26
(flink-kubernetes-operator) branch main updated: [FLINK-33006] add e2e for flink operator ha
gyfora
2024/01/26
(flink-connector-jdbc) branch v3.1 updated: [FLINK-33365] include filters with Lookup joins
snuyanzin
2024/01/26
(flink) branch master updated: [FLINK-34145][connector/filesystem] support dynamic source parallelism inference in batch jobs
zhuzh
2024/01/26
(flink) branch master updated: [FLINK-33264][table] Support source parallelism setting for DataGen connector
libenchao
2024/01/26
(flink-connector-jdbc) branch main updated: [FLINK-33365] include filters with Lookup joins
snuyanzin
2024/01/26
svn commit: r66870 - in /dev/flink/flink-connector-kafka-3.1.0-rc1: ./ flink-connector-kafka-3.1.0-src.tgz flink-connector-kafka-3.1.0-src.tgz.asc flink-connector-kafka-3.1.0-src.tgz.sha512
martijnvisser
2024/01/26
(flink-connector-kafka) annotated tag v3.1.0-rc1 updated (e51adab0 -> 87b8d74d)
martijnvisser
2024/01/26
(flink-connector-kafka) branch v3.0 updated: [hotfix] Update copyright year to 2024
martijnvisser
2024/01/26
(flink-connector-kafka) branch v3.1 updated: [hotfix] Update copyright year to 2024
martijnvisser
2024/01/26
(flink-connector-kafka) branch main updated: [hotfix] Update copyright year to 2024
martijnvisser
2024/01/26
(flink-connector-kafka) annotated tag v3.1.0-rc1 deleted (was b28baaff)
martijnvisser
2024/01/26
svn commit: r66869 - /dev/flink/flink-connector-kafka-3.1.0-rc1/
martijnvisser
2024/01/26
svn commit: r66867 - in /dev/flink/flink-connector-kafka-3.1.0-rc1: ./ flink-connector-kafka-3.1.0-src.tgz flink-connector-kafka-3.1.0-src.tgz.asc flink-connector-kafka-3.1.0-src.tgz.sha512
martijnvisser
2024/01/26
(flink-connector-kafka) annotated tag v3.1.0-rc1 updated (4d298aba -> b28baaff)
martijnvisser
2024/01/26
(flink-connector-kafka) branch main updated: [hotfix] Add missing JDK17 test for 1.18 against v3.1
martijnvisser
2024/01/26
(flink-connector-kafka) branch main updated: [hotfix] Remove weekly test against 1.19-SNAPSHOT since that's currently broken and tracked under FLINK-34193
martijnvisser
2024/01/26
(flink-connector-kafka) branch main updated: [release] Update weekly CI to check against new release branch `v3.1`
martijnvisser
2024/01/26
(flink-connector-kafka) branch v3.1 created (now 4f300991)
martijnvisser
2024/01/26
(flink) branch master updated: [FLINK-34206][test] Temporarily disable CacheITCase#testRetryOnCorruptedClusterDataset
zhuzh
2024/01/26
(flink) branch master updated (d55f5f16c23 -> 8fceb101e7e)
zhuzh
2024/01/26
(flink) branch master updated (36feab0fb6d -> d55f5f16c23)
mapohl
2024/01/26
(flink-kubernetes-operator) branch main updated: [FLINK-33803] Set observedGeneration at end of reconciliation
gyfora
2024/01/26
(flink) branch master updated: [FLINK-31511][table][doc][doc-zh] Translate JSON functions and fix typo in sql_functions.yml
leonard
2024/01/26
(flink) branch master updated: [FLINK-34237] Revert the breaking changes to SourceReaderContext
xtsong
2024/01/26
(flink) branch release-1.18 updated: [FLINK-34117][filesystem] Fix CompactCoordinator data loss upon termination
leonard
2024/01/25
(flink) branch master updated: [FLINK-34196][Connectors][FLIP-389] Annotate SingleThreadFetcherManager as PublicEvolving
renqs
2024/01/25
(flink) branch master updated: [FLINK-33263][table-planner] Implement ParallelismProvider for sources in the table planner
libenchao
Later messages