commits
Thread
Date
Earlier messages
Later messages
Messages by Thread
(flink) branch master updated: [FLINK-35790][docs] Update docs for new schema definition in CTAS and RTAS
twalthr
(flink) branch master updated: [FLINK-35708][table-planner] Allow defining a schema in REPLACE TABLE AS (RTAS)
twalthr
(flink-cdc) branch master updated: [FLINK-36148][pipeline-connector/mysql] Fix that newly added table can not discovered by adding custom parser for CreateTableEvent
leonard
(flink) branch master updated (ae4eb7dc3ae -> 5bbdbb28892)
lincoln
(flink) 02/02: [FLINK-35965][table] Add the built-in function ENDSWITH
lincoln
(flink) 01/02: [FLINK-35964][table] Add the built-in function STARTSWITH
lincoln
(flink-cdc) branch master updated: [hotfix][cdc-runtime] Keep upstream pending requests in order to avoid checkpoint hanging & state inconsistency in timestamp startup mode
leonard
(flink) branch master updated (9bcd8f4b8f4 -> ae4eb7dc3ae)
lincoln
(flink) branch master updated (0daca7b6db8 -> 9bcd8f4b8f4)
gaborgsomogyi
(flink-cdc) branch master updated: [FLINK-36128][cdc-runtime] Fix potential unrecoverable in-flight data exception by promoting LENIENT as the default schema change behavior
leonard
(flink) branch master updated (4faf0966766 -> 0daca7b6db8)
pnowojski
(flink-kubernetes-operator) branch main updated: [FLINK-36039][autoscaler] Support clean historical event handler records in JDBC event handler (#865)
fanrui
(flink-cdc) branch master updated: [hotfix][cdc-connector][mongodb] Fix LegacyMongoDBSourceExampleTest cannot run (#3555)
gongzhongqiang
(flink) branch release-1.19 updated: [FLINK-35482][parquet][test] Fix timezone handling in ParquetInt64TimestampReaderTest
fcsaky
(flink) branch release-1.20 updated: [FLINK-35482][parquet][test] Fix timezone handling in ParquetInt64TimestampReaderTest
fcsaky
(flink) branch master updated: [FLINK-35482][parquet][test] Fix timezone handling in ParquetInt64TimestampReaderTest
fcsaky
(flink) branch master updated: [FLINK-36096] Add synchronous interfaces for State V2 API
zakelly
(flink-kubernetes-operator) branch main updated (a10fb450 -> 0ef627ed)
gyfora
(flink-kubernetes-operator) branch main updated: [FLINK-33803]remove metadata/generation fields from ReconciliationMetadata
gyfora
(flink-kubernetes-operator) branch main updated (39e10d0f -> b26a0f5f)
fanrui
(flink-kubernetes-operator) 02/02: [FLINK-36129][autoscaler] Autoscaler is compatible with Flink 1.20
fanrui
(flink-kubernetes-operator) 01/02: [FLINK-36129] Supporting Flink 1.20 and removing Flink 1.15
fanrui
(flink-cdc) branch master updated: [hotfix][cdc-runtime] Fix schema registry hanging in multiple parallelism
leonard
(flink-cdc) branch master updated: [FLINK-35056][cdc-connector/sqlserver] Fix scale mapping from SQL Server TIMESTAMP to Flink SQL timestamp
leonard
(flink) branch release-1.20 updated: [FLINK-36127][web] support sort watermark
tangyun
(flink) branch master updated: [FLINK-36127][web] support sort watermark
tangyun
(flink-cdc) branch master updated: [FLINK-36114][cdc-runtime] Make SchemaRegistryRequestHandler thread safe by blocking subsequent schemaChangeEvent
leonard
(flink-connector-kafka) branch main updated: [FLINK-33201][Connectors/Kafka] Fix memory leak in CachingTopicSelector
arvid
(flink-kubernetes-operator) branch main updated: [FLINK-36031] [kubernetes-client] Migrate to Fabric8 interceptor API
gyfora
[I] 我想通过api来提交yaml文件的flinKcdc 任务,来取代flink-cdc.sh task.yaml 目前支持吗? [flink-cdc]
via GitHub
Re: [I] 我想通过api来提交yaml文件的flinKcdc 任务,来取代flink-cdc.sh task.yaml 目前支持吗? [flink-cdc]
via GitHub
(flink-cdc) branch master updated: [FLINK-36115][pipeline-connector][mysql] Introduce scan.newly-added-table.enabled option for MySQL Source
leonard
(flink-cdc) branch master updated: [FLINK-36094][cdc-runtime] Improve the Exception that SchemaRegistryRequestHandler thrown
leonard
(flink) branch master updated: [FLINK-33681][Runtime/Metrics] Reuse input/output metrics of SourceOperator/SinkWriterOperator for task (#23998)
jqin
(flink) branch master updated: [FLINK-36126][table] Qualification of current catalog and current database should happen during execution, not parsing (#25230)
snuyanzin
(flink) branch master updated (e8c1d1b9d41 -> 9ecf4cf405c)
twalthr
(flink) branch master updated (9399e669e5a -> e8c1d1b9d41)
lincoln
(flink) 04/05: [FLINK-35962][table] Add the built-in function REGEXP_INSTR
lincoln
(flink) 03/05: [FLINK-35932][table] Add the built-in function REGEXP_COUNT
lincoln
(flink) 02/05: [FLINK-35931][table] Add the built-in function REGEXP_EXTRACT_ALL
lincoln
(flink) 01/05: [FLINK-35931][table-planner] Use a separate test class for the regexp family of functions
lincoln
(flink) 05/05: [FLINK-35963][table] Add the built-in function REGEXP_SUBSTR
lincoln
(flink) branch master updated (56c81995d3b -> 9399e669e5a)
pnowojski
(flink-connector-kafka) branch v3.2 updated: [FLINK-36083][docs] Fix kafka table api doc's Connector Options table broken. (#113)
gongzhongqiang
(flink) branch release-1.20 updated (9601e06bab1 -> 62750753ad4)
pnowojski
(flink) 01/11: [hotfix] Refactor SourceOperatorSlitWatermarkAlignmentTest and support pausing splits in MockSourceReader
pnowojski
(flink) 03/11: [FLINK-35886][task] Define RelativeClock interface
pnowojski
(flink) 05/11: [FLINK-35886][task] Implement PausableRelativeClock
pnowojski
(flink) 09/11: [FLINK-35886][task] Hide backpressure and watermark alignment from idleness detection in SourceOperator
pnowojski
(flink) 06/11: [FLINK-35886][task] Use RelativeClock in WatermarksWithIdleness
pnowojski
(flink) 11/11: [FLINK-35886][source] Do not track already finished splits in watermark alignment
pnowojski
(flink) 08/11: [FLINK-35886][task] Hide backpressure from idleness detection in TimestampsAndWatermarksOperator
pnowojski
(flink) 10/11: [FLINK-35886][task] Hide backpressure from idleness detection in WatermarkAssignerOperator
pnowojski
(flink) 02/11: [hotfix][test] Do not add three splits with the same splitId in testMetrics
pnowojski
(flink) 04/11: [FLINK-35886][task] Support markStart and markEnd listeners in TimerGauge
pnowojski
(flink) 07/11: [FLINK-35886][task] Expose Clock from ProcessingTimeService
pnowojski
(flink) branch release-1.19 updated (204db68ac41 -> 5da82f8ca4e)
pnowojski
(flink) 01/12: [hotfix] Refactor SourceOperatorSlitWatermarkAlignmentTest and support pausing splits in MockSourceReader
pnowojski
(flink) 02/12: [hotfix][test] Do not add three splits with the same splitId in testMetrics
pnowojski
(flink) 10/12: [FLINK-35886][task] Hide backpressure from idleness detection in WatermarkAssignerOperator
pnowojski
(flink) 12/12: [FLINK-35886][source] Exclude japi checks for the API changes
pnowojski
(flink) 09/12: [FLINK-35886][task] Hide backpressure and watermark alignment from idleness detection in SourceOperator
pnowojski
(flink) 08/12: [FLINK-35886][task] Hide backpressure from idleness detection in TimestampsAndWatermarksOperator
pnowojski
(flink) 05/12: [FLINK-35886][task] Implement PausableRelativeClock
pnowojski
(flink) 03/12: [FLINK-35886][task] Define RelativeClock interface
pnowojski
(flink) 06/12: [FLINK-35886][task] Use RelativeClock in WatermarksWithIdleness
pnowojski
(flink) 11/12: [FLINK-35886][source] Do not track already finished splits in watermark alignment
pnowojski
(flink) 04/12: [FLINK-35886][task] Support markStart and markEnd listeners in TimerGauge
pnowojski
(flink) 07/12: [FLINK-35886][task] Expose Clock from ProcessingTimeService
pnowojski
(flink) branch master updated: [FLINK-35772][filesystem] Drop DuplicatingFileSystem in favour of the newer PathsCopyingFileSystem
pnowojski
(flink-connector-kafka) branch main updated: [FLINK-36083][docs] Fix kafka table api doc's Connector Options table broken. (#112)
gongzhongqiang
(flink) branch master updated (36347e5731b -> 624bc5001c8)
lincoln
(flink) 01/02: [hotfix][table] Fix KeyedUpsertingSinkFunction's recovery logic and add restore test
lincoln
(flink) 02/02: [FLINK-36095][table-planner] KeyedLookupJoinWrapper should shuffle by input upsertKey instead of join key to avoid changelog disordering
lincoln
(flink-cdc) branch master updated: [FLINK-36081][cdc-connector][mysql] Remove the schemas of outdated tables in the BinlogSplit when restart (#3548)
ruanhang1993
(flink-kubernetes-operator) branch main updated: [FLINK-36106][autoscaler] Clean up the t_flink_autoscaler_event_handler table after each test
fanrui
(flink-cdc) branch master updated: [FLINK-36111][minor][pipeline-connector/paimon] Improve MultiTableCommittableChannelComputer Topology name
leonard
(flink) branch master updated (e4abd065256 -> 36347e5731b)
snuyanzin
(flink) 01/02: [FLINK-36050][table] Enhance `SHOW VIEW` syntax
snuyanzin
(flink-kubernetes-operator) branch main updated: [FLINK-35493][snapshot] Add historical cleanup for FlinkStateSnapshot CRs
gyfora
(flink) branch master updated: [FLINK-35939] Do not set empty config values via ConfigUtils#encodeCollectionToConfig
fcsaky
(flink-cdc) branch master updated: [FLINK-36076][minor][cdc-runtime] Set isSchemaChangeApplying as volatile for thread safe consideration
leonard
(flink-cdc) branch master updated: [FLINK-36088][pipeline-connector][paimon] Fix NPE in BucketAssignOperator when job restoration
leonard
(flink-cdc) branch master updated: [FLINK-36082][pipeline-connector][kafka] Fix lamda NotSerializableException in KafkaDataSink
leonard
(flink-cdc) branch master updated: [minor][docs] Compress images to reduce file size and improve website load speed
leonard
(flink) branch master updated (5f6200c7191 -> adb8368985a)
lzljs3620320
(flink-cdc) branch master updated: [FLINK-35638][OceanBase][test] Refactor OceanBase test cases and remove dependency on host network (#3439)
gongzhongqiang
(flink) branch master updated (99bf496b41c -> 5f6200c7191)
pnowojski
(flink) 02/11: [hotfix][test] Do not add three splits with the same splitId in testMetrics
pnowojski
(flink) 03/11: [FLINK-35886][task] Define RelativeClock interface
pnowojski
(flink) 04/11: [FLINK-35886][task] Support markStart and markEnd listeners in TimerGauge
pnowojski
(flink) 08/11: [FLINK-35886][task] Hide backpressure from idleness detection in TimestampsAndWatermarksOperator
pnowojski
(flink) 05/11: [FLINK-35886][task] Implement PausableRelativeClock
pnowojski
(flink) 07/11: [FLINK-35886][task] Expose Clock from ProcessingTimeService
pnowojski
(flink) 01/11: [hotfix] Refactor SourceOperatorSlitWatermarkAlignmentTest and support pausing splits in MockSourceReader
pnowojski
(flink) 06/11: [FLINK-35886][task] Use RelativeClock in WatermarksWithIdleness
pnowojski
(flink) 11/11: [FLINK-35886][source] Do not track already finished splits in watermark alignment
pnowojski
(flink) 09/11: [FLINK-35886][task] Hide backpressure and watermark alignment from idleness detection in SourceOperator
pnowojski
(flink) 10/11: [FLINK-35886][task] Hide backpressure from idleness detection in WatermarkAssignerOperator
pnowojski
(flink) branch master updated: [FLINK-36049][table-planner] Add CompiledPlan annotations to BatchExecSortLimit
snuyanzin
(flink) branch master updated (b460d3d6fe0 -> 500d274265d)
lincoln
(flink-connector-mongodb) branch main updated: [hotfix] Remove redundant maven properties with upgrade of flink-connector-parent to 1.1.0 (#42)
gongzhongqiang
(flink-connector-mongodb) branch main updated: [hotfix] Update weekly builds against the latest released v1.2 branch (#40)
jiabaosun
(flink-connector-mongodb) branch main updated (97ec9b4 -> 5f63e58)
jiabaosun
(flink-connector-mongodb) 01/02: [FLINK-36053][connectors/mongodb] Bump testcontainers version from 1.17.2 to 1.18.3
jiabaosun
(flink-connector-mongodb) 02/02: [FLINK-36053][connectors/mongodb] Support multi-version integration test in mongodb connector
jiabaosun
[I] flink1.18.1 + flink-cdc3.0.1 无法通过配置scanNewlyAddedTableEnabled=true实现无需重启作业能够识别符合tableList(正则表达式)的表采集数据 [flink-cdc]
via GitHub
Re: [I] flink1.18.1 + flink-cdc3.0.1 无法通过配置scanNewlyAddedTableEnabled=true实现无需重启作业能够识别符合tableList(正则表达式)的表采集数据 [flink-cdc]
via GitHub
Re: [I] flink1.18.1 + flink-cdc3.0.1 无法通过配置scanNewlyAddedTableEnabled=true实现无需重启作业能够识别符合tableList(正则表达式)的表采集数据 [flink-cdc]
via GitHub
Re: [I] flink1.18.1 + flink-cdc3.0.1 无法通过配置scanNewlyAddedTableEnabled=true实现无需重启作业能够识别符合tableList(正则表达式)的表采集数据 [flink-cdc]
via GitHub
Re: [I] flink1.18.1 + flink-cdc3.0.1 无法通过配置scanNewlyAddedTableEnabled=true实现无需重启作业能够识别符合tableList(正则表达式)的表采集数据 [flink-cdc]
via GitHub
(flink-connector-jdbc) branch main updated: [hotfix] Remove redundant maven properties with upgrade of flink-connector-parent to 1.1.0 (#139)
jiabaosun
(flink) branch master updated: [FLINK-36004] Deep copy the BinaryArrayData in ArrayDataSerializer#copy while using custom ArrayData (#25196)
xccui
(flink) branch master updated (a91085ebdbc -> 215ad96248c)
lincoln
(flink) branch master updated (729b8b81a77 -> a91085ebdbc)
lincoln
(flink) branch release-1.19 updated: [FLINK-35935][table-planner] Fix RTAS not supporting LIMIT
lincoln
(flink) branch release-1.20 updated: [FLINK-35935][table-planner] Fix RTAS not supporting LIMIT
lincoln
Re: [I] [Bug] 2.4.2 CDC启动之后新增的数据库和里面的表不会监听到. [flink-cdc]
via GitHub
(flink-cdc) branch master updated: [FLINK-36056][cdc][connector/elasticsearch] Change flink.connector.elasticsearch.version to a released version
leonard
(flink) branch master updated: [FLINK-35935][table-planner] Fix RTAS not supporting LIMIT
lincoln
(flink) branch master updated: [FLINK-33607][build] Updates Maven wrapper version and enables checksum verification for Maven wrapper
mapohl
(flink-kubernetes-operator) branch main updated (d10918c6 -> d03b8163)
gyfora
(flink-kubernetes-operator) branch main updated: [FLINK-35265][snapshot] Create FlinkStateSnapshot in the namespace of job
gyfora
(flink-cdc) annotated tag release-3.2.0-rc0 updated (c039cccc3 -> ac92fdf73)
renqs
svn commit: r70848 - in /dev/flink/flink-cdc-3.2.0-rc0: ./ flink-cdc-3.2.0-bin.tar.gz flink-cdc-3.2.0-bin.tar.gz.asc flink-cdc-3.2.0-bin.tar.gz.sha512 flink-cdc-3.2.0-src.tgz flink-cdc-3.2.0-src.tgz.asc flink-cdc-3.2.0-src.tgz.sha512
renqs
(flink-cdc) branch release-3.2 updated: [FLINK-36056][cdc][connector/elasticsearch] Change flink.connector.elasticsearch.version to a released version (#3543)
renqs
(flink) branch master updated: [FLINK-35858][State] Default namespace in async state (#25135)
zakelly
(flink-cdc) branch release-3.2 updated: [FLINK-36054][cdc][build] Fix Flink CDC parent pom and release scripts (#3541)
renqs
(flink-cdc) branch master updated: [FLINK-36054][cdc][build] Fix Flink CDC parent pom and release scripts (#3540)
renqs
(flink) branch master updated: [FLINK-36003][table-planner] Add CompiledPlan annotations to BatchExecExpand and BatchExecSortAggregate
twalthr
(flink) branch master updated: [FLINK-36038][table] Output for `SHOW CREATE VIEW` should follow the `CREATE VIEW` syntax
snuyanzin
(flink) branch master updated (ff3cfb498e1 -> e33028db6a7)
lincoln
(flink-cdc) branch release-3.2 updated: [FLINK-35805][transform] Add __data_event_type__ metadata column
leonard
(flink-cdc) branch master updated: [FLINK-35805][transform] Add __data_event_type__ metadata column
leonard
(flink) branch release-1.20 updated: [FLINK-35766][streaming] Fix hang issue in JobGraph generation when StreamGraph contains many YieldingOperatorFactory.
zhuzh
(flink) branch master updated: [FLINK-35766][streaming] Fix hang issue in JobGraph generation when StreamGraph contains many YieldingOperatorFactory.
zhuzh
(flink-connector-aws) branch main updated: [FLINK-35305][Connector/SQS] Amazon SQS Sink Connector
hong
(flink) branch master updated: [hotfix][docs] Add missing "Submitting a Flink job" section in Chinese version doc
guoweijie
(flink-cdc) branch master updated: [hotfix][cdc-runtime] Invalidate cache correctly to avoid classloader leakage
leonard
(flink) branch master updated: [FLINK-36030][state / changelog] Don't use negative values in changelog recovery tests
roman
(flink-cdc) branch release-3.2 updated: [hotfix][runtime] Invalidate cache correctly to avoid classloader leakage
leonard
(flink-cdc) branch release-3.2 updated: [hotfix][docs] Update documentation config for release-3.2
leonard
(flink-cdc) branch master updated: [release] Update version to 3.3-SNAPSHOT
leonard
(flink) branch master updated: [FLINK-26840][table-runtime] refactor topN functions adding a general TopNBufferCacheRemovalListener
lincoln
Re: [I] Flinkcdc 增量读取oralce ,正常输出数据一段时间后 异常关闭 [flink-cdc]
via GitHub
(flink) branch master updated (dafed7ed282 -> e126f382a1f)
lincoln
(flink) 02/02: [hotfix][table-planner] Fix LookupJoinTest incorrectly not enabling test case testAggAndLeftJoinWithTryResolveMode
lincoln
(flink) 01/02: [refactor][table-planner] Separate specific node logic from visit block for StreamNonDeterministicUpdatePlanVisitor to improve readability
lincoln
(flink-cdc) branch release-3.2 created (now 104209558)
renqs
[I] 驱动程序无法通过使用安全套接字层(SSL)加密与 SQL Server 建立安全连接。错误:“Unexpected rethrowing”。 [flink-cdc]
via GitHub
Re: [I] 驱动程序无法通过使用安全套接字层(SSL)加密与 SQL Server 建立安全连接。错误:“Unexpected rethrowing”。 [flink-cdc]
via GitHub
Re: [I] 驱动程序无法通过使用安全套接字层(SSL)加密与 SQL Server 建立安全连接。错误:“Unexpected rethrowing”。 [flink-cdc]
via GitHub
(flink-cdc) branch master updated (8137f9d74 -> 104209558)
leonard
(flink-cdc) 02/02: [FLINK-36034][cdc-runtime] Get rid of Flink table planner dependency in cdc runtime module
leonard
(flink-cdc) 01/02: [FLINK-35991][cdc-runtime] Resolve operator conflicts in transform SQL operator tables
leonard
(flink-cdc) branch master updated (15ab85860 -> 8137f9d74)
leonard
(flink-cdc) 01/02: [FLINK-35894][pipeline-connector][es] Introduce Elasticsearch Sink Connector for Flink CDC Pipeline
leonard
(flink-cdc) 02/02: [FLINK-35894][pipeline-connector][es] Support for ElasticSearch 6, 7 versions
leonard
(flink) branch release-1.20 updated: [FLINK-36021][network] Delegating the responsibility for compression to every tier
guoweijie
(flink) branch master updated (c00877260c0 -> dafed7ed282)
snuyanzin
(flink) 02/02: [hotfix] Make use of `CompiledPlan#asJsonString` instead of `getFormattedJson`
snuyanzin
(flink) 01/02: [FLINK-36026][table] Options from `OPTIONS` hint should be present in compiled plan
snuyanzin
(flink-cdc) branch master updated: [FLINK-35884][pipeline-connector][mysql] MySQL pipeline connector supports to set chunk key-column (#3490)
ruanhang1993
(flink) branch master updated: [FLINK-36021][network] Delegating the responsibility for compression to every tier
guoweijie
(flink-cdc) branch master updated: [FLINK-35891][pipeline-connector][paimon] Support dynamic bucket in Paimon sink
leonard
(flink-cdc) branch master updated: [FLINK-35984][cdc-runtime] Fix bug that metadata column name can not be used in transform rule
leonard
(flink-cdc) branch master updated: [FLINK-36023][cdc-composer] Flink CDC K8S Native Application Mode add wrong jar url (#3523)
renqs
(flink-cdc) branch master updated: [FLINK-35938][pipeline-connector][paimon] Use filterAndCommit API for retry Committable to avoid duplicate commit
leonard
(flink) branch master updated: [FLINK-34111][table] Add support for JSON_QUOTE, JSON_UNQUOTE
snuyanzin
(flink-cdc) branch master updated: [hotfix][doc] Fix doris document dead links and typo
leonard
(flink-cdc) branch release-3.0 updated: [hotfix][doc] Fix doris document dead links and typo
leonard
(flink-cdc) branch release-3.1 updated: [hotfix][doc] Fix doris document dead links and typo
leonard
(flink-cdc) branch master updated: [FLINK-35981][cdc-runtime] Transform supports referencing one column more than once
leonard
(flink-kubernetes-operator) branch main updated: [FLINK-35267][snapshot] FlinkStateSnapshot documentation and examples
gyfora
(flink-cdc) branch master updated: [FLINK-36007][[cdc-composer] Loading factory and added jar in one search
leonard
(flink-cdc) branch master updated (e0d6d1d1a -> e2bb917ad)
ruanhang1993
(flink-cdc) branch master updated: [FLINK-35442][cdc-connect][kafka] add key.format and partition.strategy option to make sure the same record sending to the same partition. (#3522)
renqs
(flink) branch release-1.19 updated: [FLINK-36000][table-planner] Fix DynamicTableSink#Context's getTargetColumns should return an Optional#empty instead of int[0] for insert stmt without column list
lincoln
(flink) branch release-1.20 updated: [FLINK-36000][table-planner] Fix DynamicTableSink#Context's getTargetColumns should return an Optional#empty instead of int[0] for insert stmt without column list
lincoln
(flink) branch release-1.19 updated: [FLINK-35885][table] Prohibit advancing the progress of processing time window through watermark
lincoln
(flink) branch release-1.20 updated: [FLINK-35885][table] Prohibit advancing the progress of processing time window through watermark
lincoln
(flink-cdc) branch master updated: [FLINK-34688][cdc-connector][mysql] Make scan newly table trigger condition strictly
leonard
(flink) branch master updated: [FLINK-35992][runtime] Close the TieredStorageMasterClient when NettyShuffleMaster close
guoweijie
(flink-cdc) branch master updated: [FLINK-35715][common] Ignore the compact optimize for mysql timestamp type in BinaryRecordData (#3511)
ruanhang1993
(flink-cdc) branch master updated: [FLINK-35143][pipeline-connector][mysql] Expose newly added tables capture in mysql pipeline connector. (#3411)
ruanhang1993
(flink-cdc) branch master updated: [hotfix][cdc-connector][mongodb] Fix unstable test cases for snapshot back-filling (#3506)
jiabaosun
(flink) branch release-1.19 updated: [FLINK-35974][e2e] Use docker compose v2 for E2E tests
guoweijie
(flink) branch release-1.20 updated: [FLINK-35974][e2e] Use docker compose v2 for E2E tests
guoweijie
(flink) branch master updated (8a45cd6cffb -> f1eb644024d)
chesnay
(flink-kubernetes-operator) branch main updated (7d90ce87 -> 98196653)
gyfora
(flink-kubernetes-operator) 02/04: [FLINK-35265] Remove type field from CheckpointSpec
gyfora
(flink-kubernetes-operator) 03/04: [FLINK-35265] Gracefully handle errors when fetching checkpoint path
gyfora
(flink-kubernetes-operator) 04/04: [FLINK-35265] Add namespace field to JobReference
gyfora
(flink-cdc) branch master updated: [FLINK-34853] Submit CDC Job To Flink K8S Native Application Mode (#3093)
renqs
(flink) branch master updated: [FLINK-35941][table-planner] Add CompiledPlan annotations to BatchExecLimit
twalthr
(flink-cdc) branch master updated: [FLINK-35730][cdc-cli] PipelineDefinitionParser supports parsing pipeline def in text format
leonard
(flink-cdc) branch master updated: [build][e2e] Separate Pipeline and Source E2e tests and cover flink 1.20 version
leonard
(flink) branch master updated (a885f4ffd08 -> 9457ae8c07b)
lincoln
(flink-cdc) branch master updated: [FLINK-35791][kafka] Add database and table info of Canal / Debezium json format for Kafka sink (#3461)
renqs
(flink) branch master updated: [FLINK-35943][table-planner] Add CompiledPlan annotations to BatchExecHashJoin and BatchExecNestedLoopJoin
twalthr
Earlier messages
Later messages