commits
Thread
Date
Earlier messages
Messages by Date
2024/05/04
(flink-kubernetes-operator) branch main updated: [FLINK-35278] Fix occasional NPE on getting latest resource for status replace
mbalassi
2024/05/03
(flink-connector-elasticsearch) branch main updated: [FLINK-34369][connectors/elasticsearch] Elasticsearch connector supports SSL context
snuyanzin
2024/05/03
(flink-connector-pulsar) branch dependabot/maven/org.apache.commons-commons-compress-1.26.0 deleted (was 5631cef)
github-bot
2024/05/03
(flink-connector-pulsar) branch main updated: [FLINK-35182] Bump org.apache.commons:commons-compress to 1.26.1 (#90)
tison
2024/05/03
(flink-connector-pulsar) branch dependabot/maven/org.apache.commons-commons-compress-1.26.0 updated (21f424e -> 5631cef)
github-bot
2024/05/01
(flink-kubernetes-operator) branch main updated: [FLINK-35192] Remove usage of deleteOnExit() to reduce the memory usage of the operator
gyfora
2024/04/30
(flink) branch release-1.18 updated: [FLINK-35217] Add missing fsync to #closeForCommit in some subclasses of RecoverableFsDataOutputStream. (#24722) (#24752)
srichter
2024/04/30
(flink) branch release-1.19 updated: [FLINK-35217] Add missing fsync to #closeForCommit in some subclasses of RecoverableFsDataOutputStream. (#24722) (#24751)
srichter
2024/04/30
(flink) branch master updated: [FLINK-35217] Add missing fsync to #closeForCommit in some subclasses of RecoverableFsDataOutputStream. (#24722)
srichter
2024/04/30
(flink) branch master updated: [FLINK-34902][table] Fix IndexOutOfBoundsException for VALUES
twalthr
2024/04/29
(flink) branch master updated: [FLINK-35194][table] Support describe job statement for SqlGateway
ron
2024/04/29
(flink-cdc) annotated tag release-3.1.0-rc1 updated (63b42cb93 -> cdae15dab)
renqs
2024/04/29
svn commit: r68873 - in /dev/flink/flink-cdc-3.1.0-rc1: ./ flink-cdc-3.1.0-bin.tar.gz flink-cdc-3.1.0-bin.tar.gz.asc flink-cdc-3.1.0-bin.tar.gz.sha512 flink-cdc-3.1.0-src.tgz flink-cdc-3.1.0-src.tgz.asc flink-cdc-3.1.0-src.tgz.sha512
renqs
2024/04/29
(flink) branch release-1.19 updated: [FLINK-32622][table-planner] Optimize mini-batch assignment (#23470)
jingge
2024/04/29
(flink) branch master updated: [FLINK-35184][table-runtime] Fix mini-batch join hash collision when use InputSideHasNoUniqueKeyBundle
ron
2024/04/29
(flink) branch master updated: [FLINK-35191][table-api] Support alter materialized table related syntax: suspend, resume, refresh, set and reset
ron
2024/04/29
(flink-connector-kafka) branch main updated: [FLINK-35228][Connectors/Kafka] Fix: DynamicKafkaSource does not read re-added topic for the same cluster (#97)
masc
2024/04/29
(flink-connector-hbase) branch main updated: [FLINK-35233] Fix lookup cache reuse RowData object problem (#47)
martijnvisser
2024/04/29
(flink-cdc) branch release-3.1 updated: [FLINK-35264][cdc][runtime] Fix multiple transform rules do not take effect (#3281)
renqs
2024/04/29
(flink-cdc) branch master updated (23a67dcdb -> f61f0f44b)
renqs
2024/04/29
(flink-cdc) branch release-3.1 updated: [minor][docs] Fix route definition example in core concept docs (#3270)
renqs
2024/04/29
(flink-cdc) branch release-3.1 updated: [FLINK-35255][cdc][runtime] DataSinkWriterOperator adds overrides for the snapshotState and processWatermark methods (#3279)
renqs
2024/04/28
(flink) 03/03: [FLINK-35224][web] Show the JobType on Flink WebUI
fanrui
2024/04/28
(flink) branch master updated (f75c5188660 -> 86de622c807)
fanrui
2024/04/28
(flink) 01/03: [FLINK-35222][rest] Add getJobType for AccessExecutionGraph
fanrui
2024/04/28
(flink) 02/03: [FLINK-35223][rest] Add jobType in JobDetailsInfo related rest api
fanrui
2024/04/28
(flink-cdc) 02/02: [FLINK-34878][cdc][transform] Flink CDC pipeline transform supports CASE WHEN (#3228)
renqs
2024/04/28
(flink-cdc) 01/02: [FLINK-35259][cdc][transform] Fix FlinkCDC pipeline transform can't deal timestamp field (#3278)
renqs
2024/04/28
(flink-cdc) branch release-3.1 updated (711bc0038 -> 7a1947927)
renqs
2024/04/28
(flink) branch master updated: [hotfix][docs] Fix file reference
fanrui
2024/04/28
(flink) branch master updated (cca14d42106 -> 5e924d76250)
fanrui
2024/04/28
(flink-cdc) branch master updated: [FLINK-35255][cdc][runtime] DataSinkWriterOperator adds overrides for the snapshotState and processWatermark methods (#3271)
renqs
2024/04/28
(flink-cdc) branch master updated: [FLINK-34878][cdc][transform] Flink CDC pipeline transform supports CASE WHEN (#3228)
renqs
2024/04/28
(flink-cdc) branch master updated: [FLINK-35259][cdc][transform] Fix FlinkCDC pipeline transform can't deal timestamp field (#3278)
renqs
2024/04/28
Re: [I] Flink CDC3.0 Demo Mysql binlog to Starrocks Exception amount of AddColumnEvent is already existed[Bug] [flink-cdc]
via GitHub
2024/04/28
(flink) branch master updated: [FLINK-32622][table-planner] Optimize mini-batch assignment (#23470)
jingge
2024/04/28
(flink-cdc) branch release-3.1 updated: [FLINK-35251][cdc][runtime] Fix bug of serializing derivation mapping in SchemaDerivation
renqs
2024/04/28
(flink-cdc) branch release-3.1 updated: [FLINK-35256][runtime] Fix transform node does not respect type nullability (#3277)
renqs
2024/04/28
(flink-cdc) branch master updated: [minor][docs] Fix route definition example in core concept docs (#3269)
renqs
2024/04/28
(flink-cdc) annotated tag release-3.1.0-rc0 deleted (was 24404c726)
renqs
2024/04/28
(flink-cdc) branch master updated: [FLINK-35256][cdc][runtime] Fix transform node does not respect type nullability (#3272)
renqs
2024/04/28
(flink-cdc) branch release-3.1 updated: [FLINK-35258][cdc][doc] Fix broken links to Doris in documentation (#3274)
renqs
2024/04/28
(flink) branch master updated: [FLINK-34915][table] Support `DESCRIBE CATALOG` syntax
jchan
2024/04/28
(flink-cdc) branch release-3.0 updated: [FLINK-35258][cdc][doc] Fix broken links to Doris in documentation (#3275)
renqs
2024/04/28
(flink-cdc) branch master updated: [FLINK-35258][cdc][doc] Fix broken links to Doris in documentation (#3276)
renqs
2024/04/28
(flink) branch master updated: [FLINK-35208][python] Respect pipeline.cached-files during handling Python dependencies
dianfu
2024/04/27
(flink-kubernetes-operator) branch main updated: [hotfix] Using Flink ExceptionUtils#findThrowable for exception checking (#818)
fanrui
2024/04/27
(flink-cdc) branch master updated: [FLINK-35251][cdc][runtime] Fix bug of serializing derivation mapping in SchemaDerivation
leonard
2024/04/27
svn commit: r68830 - in /dev/flink/flink-connector-opensearch-2.0.0-rc1: ./ flink-connector-opensearch-2.0.0-src.tgz flink-connector-opensearch-2.0.0-src.tgz.asc flink-connector-opensearch-2.0.0-src.tgz.sha512
snuyanzin
2024/04/27
svn commit: r68829 - /dev/flink/flink-connector-opensearch-1.2.0-rc1/
snuyanzin
2024/04/27
(flink-cdc) annotated tag release-3.1.0-rc0 updated (0685d090a -> 24404c726)
renqs
2024/04/27
svn commit: r68816 - in /dev/flink/flink-cdc-3.1.0-rc0: ./ flink-cdc-3.1.0-bin.tar.gz flink-cdc-3.1.0-bin.tar.gz.asc flink-cdc-3.1.0-bin.tar.gz.sha512 flink-cdc-3.1.0-src.tgz flink-cdc-3.1.0-src.tgz.asc flink-cdc-3.1.0-src.tgz.sha512
renqs
2024/04/27
(flink-cdc) 03/06: [hotfix] Change parent POM's artifact ID to flink-cdc-parent
renqs
2024/04/27
(flink-cdc) 04/06: [hotfix] Use apache-release profile instead
renqs
2024/04/27
(flink-cdc) 01/06: [hotfix] Remove distribution management and add scm infomation in pom
renqs
2024/04/27
(flink-cdc) 05/06: [hotfix] Include LICENSE in binary release
renqs
2024/04/27
(flink-cdc) 06/06: [hotfix] Use flink-cdc as source release prefix
renqs
2024/04/27
(flink-cdc) branch release-3.1 updated (b96ea11cc -> 62fb38b9b)
renqs
2024/04/27
(flink-cdc) 02/06: [hotfix] Remove test-jar from parent pom and only add to necessary modules
renqs
2024/04/26
(flink) branch master updated: [FLINK-35246][test] Fix incorrect address construction in SqlClientSSLTest
guoweijie
2024/04/26
(flink) branch master updated (714d1cb2e0b -> 3ff2ba43720)
leiyanfei
2024/04/26
(flink) 03/03: [FLINK-35189][test-utils] Introduce test-filesystem connector and catalog based on filesystem to support materialized table
ron
2024/04/26
(flink) branch master updated (f64654e9749 -> 714d1cb2e0b)
ron
2024/04/26
(flink) 02/03: [FLINK-35189][connectors/filesystem] Modify the visibility of filesystem connector related methods to protected
ron
2024/04/26
(flink) 01/03: [FLINK-35189][table-common] CatalogPropertiesUtil support serialize and deserialize materialized table
ron
2024/04/26
(flink) branch master updated: add HTTP options to java-storage client
dannycranmer
2024/04/26
(flink-cdc) branch master updated: [FLINK-35235][pipeline-connector][kafka] Fix missing dependencies in the uber jar of Kafka pipeline sink
jiabaosun
2024/04/26
(flink-cdc) branch release-3.1 updated: [FLINK-35235][pipeline-connector][kafka] Fix missing dependencies in the uber jar of Kafka pipeline sink
jiabaosun
2024/04/26
(flink-cdc) branch release-3.1 updated: [FLINK-35173][cdc][mysql] Debezium custom time serializer for MySQL connector (#3240) (#3264)
renqs
2024/04/26
(flink-cdc) branch release-3.1 updated: [minor][cdc][docs] Add user guide about providing extra jar package in quickstart docs
jiabaosun
2024/04/26
(flink-cdc) branch master updated: [minor][cdc][docs] Add user guide about providing extra jar package in quickstart docs
jiabaosun
2024/04/25
(flink-cdc) branch master updated: [FLINK-35173][cdc][mysql] Debezium custom time serializer for MySQL connector (#3240)
renqs
2024/04/25
(flink-cdc) branch release-3.1 updated: [FLINK-35128][cdc-connector][cdc-base] Re-calculate the starting changelog offset after the new table added (#3230) (#3257)
renqs
2024/04/25
(flink-cdc) branch release-3.1 updated (1b8c73c6a -> 5096dc73a)
renqs
2024/04/25
(flink-cdc) 02/02: [hotfix][ci] Polish ci concurrency group to avoid warning message
renqs
2024/04/25
(flink) 03/03: [FLINK-35162][state] Attach the keyGroup and payload into RecordContext
hangxiang
2024/04/25
(flink) branch master updated (512f3fbaac8 -> fb5838042cd)
hangxiang
2024/04/25
(flink) 01/03: [FLINK-35125][state] Implement ValueState for ForStStateBackend
hangxiang
2024/04/25
(flink) 02/03: [FLINK-35162][state]Support grouping state get and put access
hangxiang
2024/04/25
(flink) branch master updated: [FLINK-35190][table-api] Support create materialized table syntax
ron
2024/04/25
(flink) 07/07: [FLINK-35047][state] Support FlinkEnv to init ForSt
hangxiang
2024/04/25
(flink) 02/07: [FLINK-35047][state] Introduce ForSt related options
hangxiang
2024/04/25
(flink) 05/07: [FLINK-35047][state] Support restoring and building ForSt
hangxiang
2024/04/25
(flink) 03/07: [FLINK-35047][state] Introduce Metrics for ForStStateBackend
hangxiang
2024/04/25
(flink) 04/07: [FLINK-35047][state] Introduce ResourceContainer for ForStStateBackend
hangxiang
2024/04/25
(flink) 06/07: [FLINK-35047][state] Introduce ForStStateBackend and ForStKeyedStateBackend
hangxiang
2024/04/25
(flink) 01/07: [FLINK-35047][state] Introduce forstjni dependency
hangxiang
2024/04/25
(flink) branch master updated (259aef0b66b -> 19577b0da7f)
hangxiang
2024/04/25
(flink) branch release-1.19 updated: [FLINK-35239] [docs] Unset outdated warning
uce
2024/04/25
(flink) 01/03: [FLINK-31223][sqlgateway] Introduce getFlinkConfigurationOptions to get all flink configurations copy in the form of map.
guoweijie
2024/04/25
(flink) 03/03: [FLINK-31223][sqlgateway] Pass all flink parameters to the SqlGatewayRestEndpoint.
guoweijie
2024/04/25
(flink) 02/03: [FLINK-31223][test] Abstract SqlClientTestBase.
guoweijie
2024/04/25
(flink) branch master updated (797cb9cd843 -> 259aef0b66b)
guoweijie
2024/04/25
(flink-cdc) branch master updated: [docs][hotfix] Correct shell scripts style in Quickstart document
leonard
2024/04/25
(flink) branch master updated: [hotfix][runtime] Make sure run RecordContext#release() in Task thread. (#24705)
leiyanfei
2024/04/25
(flink-cdc) branch master updated: [release] Update version to 3.2-SNAPSHOT
leonard
2024/04/25
(flink-connector-elasticsearch) branch main updated: [FLINK-35134][Connectors/Elasticsearch] Drop support for Flink 1.17
guoweijie
2024/04/25
(flink) branch master updated: [hotfix][docs] Fix the invalid link in 1.18 release note
guoweijie
2024/04/25
(flink-cdc) branch release-3.1 updated: [hotfix] Update version to 3.1-SNAPSHOT
renqs
2024/04/24
(flink) branch master updated: [FLINK-35156][Runtime] Make operators of DataStream V2 integrate with async state processing
leiyanfei
2024/04/24
(flink-cdc) branch master updated: [FLINK-35128][cdc-connector][cdc-base] Re-calculate the starting changelog offset after the new table added (#3230)
renqs
2024/04/24
(flink) branch release-1.18 updated: [FLINK-35097][table] Fix 'raw' format deserialization
twalthr
2024/04/24
(flink) 02/03: [FLINK-29050][test-utils] Use JUnit5 to re-write AbstractTestBase, JavaProgramTestBase MultipleProgramsTestBase and tag the corresponding old implementation classes as deprecated
fanrui
2024/04/24
(flink) branch master updated (09531994e3c -> 92eef24d4cc)
fanrui
2024/04/24
(flink) 03/03: [FLINK-29050][JUnit5 Migration] Module: flink-hadoop-compatibility
fanrui
2024/04/24
(flink-connector-jdbc) branch main updated: [FLINK-33460][Connector/JDBC] Support property authentication connection. (#115)
fanrui
2024/04/24
(flink) branch master updated (8576178c4c0 -> 09531994e3c)
fanrui
2024/04/24
(flink-connector-opensearch) branch main updated: [hotfix] Use jdk 1.8 for profile activation (#45)
snuyanzin
2024/04/24
(flink-connector-opensearch) branch dependabot/maven/flink-connector-opensearch/org.opensearch-opensearch-2.11.1 deleted (was f0c07d7)
github-bot
2024/04/24
svn commit: r68751 - in /dev/flink/flink-connector-opensearch-1.2.0-rc1: ./ flink-connector-opensearch-1.2.0-src.tgz flink-connector-opensearch-1.2.0-src.tgz.asc flink-connector-opensearch-1.2.0-src.tgz.sha512
snuyanzin
2024/04/24
svn commit: r68750 - /dev/flink/flink-connector-opensearch-1.2.0-rc1/
snuyanzin
2024/04/24
svn commit: r68749 - in /dev/flink/flink-connector-opensearch-1.2.0-rc1: ./ flink-connector-opensearch-1.2.0-src.tgz flink-connector-opensearch-1.2.0-src.tgz.asc flink-connector-opensearch-1.2.0-src.tgz.sha512
snuyanzin
2024/04/24
(flink-connector-opensearch) 03/03: [hotfix] Introduce profiles for releasing connectors for Opensearch 1 and 2
snuyanzin
2024/04/24
(flink-connector-opensearch) branch main updated (a4367c7 -> 22a2934)
snuyanzin
2024/04/24
(flink-connector-opensearch) 02/03: [hotfix] Apply for Opensearch 2.13.0 and 1.3.15
snuyanzin
2024/04/24
(flink) branch FLINK-31223-rest-ssl-fix deleted (was 05cfbb8b308)
guoweijie
2024/04/24
(flink) 01/03: [FLINK-31223][sqlgateway] Introduce getFlinkConfigurationOptions to get all flink configurations copy in the form of map.
guoweijie
2024/04/24
(flink) 03/03: [FLINK-31223][sqlgateway] Pass all flink parameters to the SqlGatewayRestEndpoint.
guoweijie
2024/04/24
(flink) 02/03: [FLINK-31223][test] Abstract SqlClientTestBase.
guoweijie
2024/04/24
(flink) branch FLINK-31223-rest-ssl-fix created (now 05cfbb8b308)
guoweijie
2024/04/24
(flink-cdc) branch master updated (990261da6 -> ddf557c8e)
leonard
2024/04/24
(flink-cdc) 03/03: [tests][cdc-connector][db2] Improve the DB2 tests
leonard
2024/04/24
(flink-cdc) 02/03: [minor][cdc-connector][db2] Fix typos and improve the code style
leonard
2024/04/24
(flink) branch master updated (9cc649898d0 -> 8576178c4c0)
ron
2024/04/24
(flink) 01/02: [FLINK-35188][table-api] Introduce CatalogMaterializedTable interface to support materialized table
ron
2024/04/24
(flink) 02/02: [FLINK-35188][table-api] Introduce RefreshHandler interface to support materialized table
ron
2024/04/24
(flink) branch master updated: [FLINK-35148][core] Improve InstantiationUtil for checking nullary public constructor
xtsong
2024/04/24
(flink-cdc) branch release-3.1 updated: [hotfix][docs] Update documentation config for release-3.1
renqs
2024/04/24
(flink-cdc) branch master updated: [hotfix][ci] Polish ci concurrency group to avoid warning message
leonard
2024/04/24
(flink-cdc) branch release-3.1 created (now 3fe0540df)
renqs
2024/04/24
(flink-cdc) branch master updated (65d670a58 -> 3fe0540df)
renqs
2024/04/24
(flink-connector-pulsar) annotated tag v4.2.0-rc1 deleted (was cb43feb)
dannycranmer
2024/04/24
(flink-connector-pulsar) annotated tag v4.2.0-rc1 updated (bad8a5f -> cb43feb)
dannycranmer
2024/04/24
svn commit: r68743 - in /dev/flink/flink-connector-pulsar-4.2.0-rc1: ./ flink-connector-pulsar-4.2.0-src.tgz flink-connector-pulsar-4.2.0-src.tgz.asc flink-connector-pulsar-4.2.0-src.tgz.sha512
dannycranmer
2024/04/24
(flink-connector-aws) branch main updated: [FLINK-33506][Connectors/AWS] Add support for jdk17 for AWS connectors (#115)
dannycranmer
2024/04/24
(flink-cdc) branch master updated: [FLINK-34188][cdc][build] Add scripts in tools/releasing to help release. (#3102)
renqs
2024/04/24
(flink-cdc) branch master updated: [FLINK-34648][cdc] Avoid RPC timeout when applying SchemaChangeEvent to downstream external systems
leonard
2024/04/24
(flink-cdc) branch master updated: [FLINK-35077][cdc] Add license checking CI scripts (#3218)
renqs
2024/04/24
(flink) branch release-1.19 updated: [FLINK-35097][table] Fix 'raw' format deserialization
twalthr
2024/04/23
(flink-cdc) branch master updated: [hotfix][e2e] Fix pipeline e2e test cases failures (#3246)
renqs
2024/04/23
(flink) branch master updated: [FLINK-35166][runtime] Make the SortBufferAccumulator use more buffers when the parallelism is small
guoweijie
2024/04/23
(flink-cdc) branch release-3.0 updated: [hotfix][docs] Use the download link of the release version instead of a snapshot version
leonard
2024/04/23
(flink) branch master updated (8475d284f2a -> d453bafe523)
masc
2024/04/23
Re: [I] Flink CDC3.0 Demo Mysql binlog to Starrocks Exception amount of AddColumnEvent is already existed[Bug] [flink-cdc]
via GitHub
2024/04/23
(flink) branch master updated (ea2eabe7da5 -> 8475d284f2a)
leiyanfei
2024/04/23
(flink) branch master updated: [FLINK-35214][runtime] Update result partition id for remote input channel when unknown input channel is updated
guoweijie
2024/04/23
(flink-cdc) branch master updated: [e2e][pipeline-connector][mysql] Add e2e test for mysql pipeline connector
leonard
2024/04/23
(flink-cdc) branch master updated: [FLINK-35055][cdc] Exclude connector dependencies with questionable licenses from fat jar packages (#3212)
renqs
2024/04/23
(flink-cdc) branch master updated: [pipeline-connector][kafka] Add kafka pipeline data sink connector. (#2938)
renqs
2024/04/23
(flink-cdc) branch master updated: [FLINK-34969][cdc][cli] Add support for both new and old Flink config files in Flink CDC (#3194)
renqs
2024/04/22
(flink) branch release-1.19 updated: [FLINK-35169][runtime] Recycle buffers to freeSegments before releasing data buffer for sort accumulator
guoweijie
2024/04/22
(flink) branch release-1.18 updated: [FLINK-35169][runtime] Recycle buffers to freeSegments before releasing data buffer for sort accumulator
guoweijie
2024/04/22
(flink-kubernetes-operator) branch main updated: [FLINK-34970] Translate architecture documents into Chinese
fanrui
2024/04/22
(flink-cdc) branch release-3.0 updated: [minor][docs] Fix outdated StarRocks quickstart guide
jiabaosun
2024/04/22
(flink-cdc) branch master updated: [minor][cdc][docs] Fix outdated StarRocks quickstart guide
jiabaosun
2024/04/22
svn commit: r68714 - in /dev/flink/flink-connector-kafka-3.2.0-rc1: ./ flink-connector-kafka-3.2.0-src.tgz flink-connector-kafka-3.2.0-src.tgz.asc flink-connector-kafka-3.2.0-src.tgz.sha512
dannycranmer
2024/04/22
(flink-connector-kafka) annotated tag v3.2.0-rc1 updated (d12f73c8 -> ada9e063)
dannycranmer
2024/04/22
(flink-connector-kafka) branch v3.2 updated: [hotfix] Setting default Flink version to 1.18.0
dannycranmer
2024/04/22
(flink) branch master updated (51d015b5704 -> 0b2e9880354)
leiyanfei
2024/04/22
(flink-connector-kafka) 01/01: [hotfix] Updating development version to 3.2-SNAPSHOT
dannycranmer
2024/04/22
(flink-connector-kafka) branch v3.2 created (now 5232dbe1)
dannycranmer
2024/04/22
svn commit: r68712 - in /dev/flink/flink-connector-cassandra-3.2.0-rc1: ./ flink-connector-cassandra-3.2.0-src.tgz flink-connector-cassandra-3.2.0-src.tgz.asc flink-connector-cassandra-3.2.0-src.tgz.sha512
dannycranmer
2024/04/22
(flink-connector-cassandra) annotated tag v3.2.0-rc1 updated (74debf8 -> 28beb69)
dannycranmer
2024/04/22
(flink-connector-cassandra) 01/01: [hotfix] Using SSH for release git submodule
dannycranmer
2024/04/22
(flink-connector-cassandra) branch v3.2 updated (8761d7d -> 632aefe)
dannycranmer
2024/04/22
(flink-connector-cassandra) 01/01: [hotfix] Change development version to 3.2-SNAPSHOT
dannycranmer
2024/04/22
(flink-connector-cassandra) branch v3.2 updated: [hotfix] Using SSH for release git submodule
dannycranmer
2024/04/22
(flink-connector-cassandra) branch v3.2 created (now 18e7f7a)
dannycranmer
2024/04/22
(flink-connector-cassandra) branch main updated: [FLINK-35133][Connectors/Cassandra] Adding support for Flink 1.19
dannycranmer
2024/04/22
(flink-cdc) branch master updated: [FLINK-35102][cdc][doris-sink] Correct Doris connector varchar type mapping
leonard
2024/04/22
(flink) 03/03: [FLINK-35097][table] Use var-args in RawFormatSerDeSchemaTest
twalthr
2024/04/22
(flink) 01/03: [FLINK-35097][table] Fix 'raw' format deserialization
twalthr
2024/04/22
(flink) branch master updated (68a84fd02fb -> 51d015b5704)
twalthr
2024/04/22
(flink) 02/03: [FLINK-35097][table] Update RawFormatSerDeSchemaTest to validate multiple serializations/deserializations
twalthr
2024/04/21
(flink) branch master updated (9336760ace7 -> 68a84fd02fb)
guoweijie
2024/04/21
(flink) branch master updated: [FLINK-35027][runtime/checkpoint] Implement checkpoint drain in AsyncExecutionController
leiyanfei
2024/04/21
(flink) branch master updated: [FLINK-35175][filesystem] Avoid reading with ByteBuffer on hadoop version below 3.3.0 (#24691)
hangxiang
2024/04/20
(flink) branch master updated: [FLINK-32315][k8s] Support uploading "local://" artifacts in Kubernetes Application Mode (#24303)
mbalassi
2024/04/19
(flink) branch master updated (39779829b88 -> 7c4dec63eb4)
thw
2024/04/19
(flink-kubernetes-operator) branch main updated: [FLINK-34574] Add CPU and memory size autoscaler quota
gyfora
2024/04/19
(flink) branch release-1.19 updated: [FLINK-35159] Transition ExecutionGraph to RUNNING after slot assignment
chesnay
2024/04/19
(flink) branch release-1.18 updated: [FLINK-35159] Transition ExecutionGraph to RUNNING after slot assignment
chesnay
2024/04/19
Re: [I] The XML dependency of Flink Oracle CDC conflicts with the XML related classes of Java8:ERROR StatusLogger Caught javax.xml.parsers.ParserConfigurationException [flink-cdc]
via GitHub
2024/04/19
(flink-connector-rabbitmq) branch main updated: [FLINK-35174][Connectors/RabbitMQ] Bump commons-compress to 1.26.1
dannycranmer
2024/04/19
(flink-connector-rabbitmq) 02/02: [hotfix] Fix the dependency convergence rule
dannycranmer
2024/04/19
(flink-connector-rabbitmq) branch main updated (1b0e2a8 -> 6b8a906)
dannycranmer
2024/04/19
(flink-connector-rabbitmq) 01/02: [hotfix] Update copyright year to 2024
dannycranmer
2024/04/19
(flink-connector-rabbitmq) branch main updated: [FLINK-35142][Connectors/RabbitMQ] Drop support for Flink 1.17
dannycranmer
2024/04/19
(flink-connector-rabbitmq) branch main updated: [hotfix] Bump version to 3.1-SNAPSHOT
dannycranmer
2024/04/19
(flink-connector-rabbitmq) branch dependabot/maven/org.apache.commons-commons-compress-1.26.0 deleted (was 107b33c)
dannycranmer
2024/04/19
(flink) branch master updated (131358b918b -> 39779829b88)
dannycranmer
2024/04/19
(flink-connector-aws) annotated tag v4.3.0-rc2 updated (a68f076 -> 009e133)
dannycranmer
2024/04/19
svn commit: r68649 - in /dev/flink/flink-connector-aws-4.3.0-rc2: ./ flink-connector-aws-4.3.0-src.tgz flink-connector-aws-4.3.0-src.tgz.asc flink-connector-aws-4.3.0-src.tgz.sha512
dannycranmer
2024/04/19
(flink-connector-aws) branch main updated: [FLINK-35115][Connectors/Kinesis] Allow kinesis consumer to snapshotState after cancelling operator
dannycranmer
2024/04/19
Re: [I] flink-sql-connector-oracle-cdc-2.4.0采集出现异常 [flink-cdc]
via GitHub
2024/04/19
(flink) branch master updated (a312a3bdd25 -> 131358b918b)
chesnay
2024/04/19
(flink-cdc) branch master updated: [FLINK-34903][cdc][mysql] Add mysql-pipeline-connector with tables.exclude option to exclude unnecessary tables (#3186)
renqs
2024/04/19
(flink-cdc) branch master updated: [FLINK-35127][cdc][values] Remove HybridSource from ValuesSource to avoid CI failure. (#3237)
renqs
2024/04/18
Re: [I] cause Could not find any factory for identifier 'sqlserver-cdc' that implements 'org.apache.flink.table.factories.DynamicTableFactory' in the classpath. [flink-cdc]
via GitHub
2024/04/18
(flink) branch master updated (43a3d50ce39 -> a312a3bdd25)
hangxiang
Earlier messages