commits
Thread
Date
Earlier messages
Messages by Thread
(flink) branch master updated: [FLINK-34121][core] Introduce pipeline.force-kryo-avro to control whether to force registration of Avro serializer with Kryo
guoweijie
(flink-cdc) branch master updated: [FLINK-34681][cdc][doc] add standalone.md under deployment directory. (#3166)
renqs
(flink-cdc) branch master updated: [FLINK-34685][cdc][doc] add kubernetes.md under deployment directory. (#3165)
renqs
(flink-docker) branch master updated: [FLINK-34701][release] Update docker-entrypoint.sh for 1.19.0
lincoln
(flink-cdc) branch gh-pages deleted (was eb63c4e1c)
renqs
(flink-docker) branch dev-master updated: [hotfix] Improve docker-entrypoint.sh to Use Arrays for Configuration Parameters Instead of Eval and String Concatenation
lincoln
(flink-cdc) branch master updated: [minor][cdc][docs] Improve the quickstart examples for Flink CDC docs
leonard
(flink) branch master updated: [FLINK-34719][streaming] Fix unstable test StreamRecordTest.testWithTimestamp above jdk8
jiabaosun
(flink-cdc) branch master updated: [FLINK-34671][cdc][docs] Update README file of Flink CDC project
leonard
(flink-cdc) branch master updated: [FLINK-34679][cdc][docs] Add core concept pages for Flink CDC docs
leonard
(flink-cdc) branch master updated: [FLINK-34680][cdc][docs] Add overview page for CDC connectors and optimize connector docs
leonard
(flink-cdc) branch master updated: [FLINK-34682][cdc][docs] Add "Understand Flink CDC API" page for Flink CDC docs
leonard
(flink) branch release-1.19 updated: [FLINK-34716][release] Build 1.19 docs in GitHub Action and mark 1.19 as stable in docs
lincoln
(flink-cdc) branch master updated: [FLINK-34715][cdc][cdc-connector][mysql] Correctly close BinlogSplitReader in MySQL UTCase
leonard
(flink-cdc) branch master updated (bd760b10d -> 776dcbab3)
leonard
(flink-cdc) 01/02: [FLINK-34683][cdc][docs] Add contributing page for Flink CDC docs
leonard
(flink-cdc) 02/02: [FLINK-34684][cdc][docs] Add licenses page for Flink CDC docs
leonard
(flink-cdc) branch master updated: [FLINK-34678][cdc][docs] Add introduction page for Flink CDC docs
leonard
(flink-web) branch asf-site updated (0fccd9ad3 -> f11ba16e6)
lincoln
(flink-web) 01/02: Add announcement blog post for Flink 1.19 (#721)
lincoln
(flink) branch release-1.19 updated: [FLINK-34593][release] Add release note for version 1.19
lincoln
(flink-docker) branch dev-1.19 updated: Add GPG key for 1.19.0 release
lincoln
(flink-cdc) branch master updated (84ca4dd14 -> aa9e91ce4)
leonard
(flink-cdc) 02/02: [FLINK-34687][cdc][docs][zh] Build the home page of Flink CDC documentation
leonard
(flink-cdc) 01/02: [FLINK-34687][cdc][docs] Build the home page of Flink CDC documentation
leonard
(flink) branch master updated: [FLINK-32074][checkpoint] Merge file across checkpoints
hangxiang
(flink) branch master updated (e79df3544a5 -> 0921968bb7d)
hangxiang
(flink) branch master updated: [FLINK-34660][checkpoint] Parse cluster configuration for AutoRescalingITCase#testCheckpointRescalingInKeyedState
hangxiang
(flink) branch release-1.19 updated: [FLINK-34571][test] Fix flaky test SortMergeResultPartitionReadSchedulerTest.testOnReadBufferRequestError
guoweijie
(flink-cdc) branch master updated: [FLINK-34677][cdc][dcos] Refactor the structure of Flink CDC website documentation
leonard
(flink-docker) branch master updated: Update Dockerfiles for 1.19.0 release
lincoln
(flink-docker) branch dev-master updated: Add GPG key for 1.19.0 release
lincoln
(flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/follow-redirects-1.15.6 created (now 9904004e6d4)
github-bot
(flink-ml) branch dependabot/maven/org.apache.zookeeper-zookeeper-3.8.4 created (now d306ffa1)
github-bot
(flink) branch master updated: [FLINK-34643][tests] Fix JobIDLoggingITCase
roman
(flink) branch master updated: [hotfix] In case of unexpected errors do not loose the primary failure reason
pnowojski
(flink) branch master updated: [FLINK-33816][streaming] Fix unstable test SourceStreamTaskTest.testTriggeringStopWithSavepointWithDrain
pnowojski
(flink) branch master updated: [FLINK-34194][ci] Updates test CI container to be based on Ubuntu 22.04
mapohl
(flink) branch master updated: [FLINK-34593][release] Add release note for version 1.19
lincoln
(flink-kubernetes-operator) branch main updated: [release] Update version to 1.9-SNAPSHOT (#798)
mxm
(flink) annotated tag release-1.19.0 updated (eaffd227d85 -> 518023aa69e)
lincoln
svn commit: r67958 - /dev/flink/flink-1.19.0-rc2/ /release/flink/flink-1.19.0/
leonard
(flink) branch master updated: [FLINK-34546] Emit span with failure labels on failure in AdaptiveScheduler. (#24498)
srichter
[I] 社区群满了,还有其他群吗 [flink-cdc]
via GitHub
Re: [I] 社区群满了,还有其他群吗 [flink-cdc]
via GitHub
(flink) branch master updated: [FLINK-18255][state] Add API annotations to RocksDB user-facing classes (#24496)
hangxiang
(flink-kubernetes-operator) annotated tag release-1.8.0-rc1 updated (91d67d95 -> 9b61e9f3)
mxm
svn commit: r67940 - /dev/flink/flink-kubernetes-operator-1.8.0-rc1/
mxm
(flink-kubernetes-operator) branch release-1.8 created (now 6a8bc506)
mxm
(flink-kubernetes-operator) 01/01: [release] Update docs config for release
mxm
(flink-kubernetes-operator) branch main updated: [FLINK-34619] Do not wait for scaling completion in UPGRADE state with in-place scaling (#793)
mxm
Re: [I] Caused by: io.debezium.DebeziumException: The db history topic or its content is fully or partially missing. Please check database history topic configuration and re-execute the snapshot. [flink-cdc]
via GitHub
svn commit: r67937 - /release/flink/KEYS
mxm
(flink) branch master updated: [FLINK-34640][metrics] Replace DummyMetricGroup usage with UnregisteredMetricsGroup
jingge
(flink) branch release-1.19 updated: [FLINK-29114][connector][filesystem] Fix issue of file overwriting caused by multiple writes to the same sink table and shared staging directory
jchan
(flink) branch release-1.19 updated: [FLINK-33798][statebackend/rocksdb] automatically clean up rocksdb logs when the task exited. (#23922)
fanrui
(flink) branch release-1.18 updated: [FLINK-33798][statebackend/rocksdb] automatically clean up rocksdb logs when the task exited. (#23922)
fanrui
(flink) branch release-1.17 updated: [FLINK-33798][statebackend/rocksdb] automatically clean up rocksdb logs when the task exited. (#23922)
fanrui
(flink) branch master updated (3b9623e5d2e -> 649e2b412e1)
leiyanfei
(flink) 02/03: [FLINK-34484][state] Split 'state.backend.local-recovery' into two options for checkpointing and recovery
leiyanfei
(flink) 03/03: [FLINK-34484][tests] Add UT/IT tests to verify localBackup and localRecovery configs
leiyanfei
(flink) 01/03: [FLINK-34484][state]Move LOCAL_RECOVERY config from CheckpointingOptions to StateRecoveryOption
leiyanfei
Re: [I] [Bug] Datetime data inconsistency (off by 8 hours) in snapshot phase [flink-cdc]
via GitHub
Re: [I] [Bug] Datetime data inconsistency (off by 8 hours) in snapshot phase [flink-cdc]
via GitHub
(flink-web) branch asf-site updated: [FLINK-34654] Add Special Thanks Page on the Flink Website (#725)
jark
(flink-cdc) branch master updated: [FLINK-34664][cdc] Add .asf.yaml file for project
leonard
(flink) branch master updated (a021db68a85 -> 3b9623e5d2e)
hangxiang
(flink-connector-opensearch) branch main updated: [FLINK-33925][connectors/opensearch] Allow customising bulk failure handling
guoweijie
(flink) branch master updated (aa7158934bb -> a021db68a85)
guoweijie
(flink) 02/05: [FLINK-34543][datastream] Introduce the MapPartition API on PartitionWindowedStream
guoweijie
(flink) 05/05: [FLINK-34543][datastream] Introduce the SortPartition API on PartitionWindowedStream
guoweijie
(flink) 01/05: [FLINK-34543][datastream] Introduce the PartitionWindowedStream
guoweijie
(flink) 03/05: [FLINK-34543][datastream] Introduce the Reduce API on PartitionWindowedStream
guoweijie
(flink) 04/05: [FLINK-34543][datastream] Introduce the Aggregate API on PartitionWindowedStream
guoweijie
Re: [I] [Bug] timeout when Invocating Remote RPC. [flink-cdc]
via GitHub
(flink-kubernetes-operator) branch main updated: [FLINK-34655] Copy IOMetricsInfo to `flink-autoscaler-standalone` module
fanrui
(flink-web) branch asf-site updated: [FLINK-34180][docs] Add links to Flink CDC quickstart and documentation (#722)
renqs
[PR] [FLINK-34664][cdc] Add .asf.yaml file [flink-cdc]
via GitHub
Re: [PR] [FLINK-34664][cdc] Add .asf.yaml file [flink-cdc]
via GitHub
Re: [PR] [FLINK-34664][cdc] Add .asf.yaml file [flink-cdc]
via GitHub
Re: [PR] [FLINK-34664][cdc] Add .asf.yaml file [flink-cdc]
via GitHub
Re: [PR] [FLINK-34664][cdc] Add .asf.yaml file [flink-cdc]
via GitHub
[I] 一个单节点群集中flink cdc任务超过20个后出错,请问如何调整 [flink-cdc]
via GitHub
Re: [I] 一个单节点群集中flink cdc任务超过20个后出错,请问如何调整 [flink-cdc]
via GitHub
Re: [I] 一个单节点群集中flink cdc任务超过20个后出错,请问如何调整 [flink-cdc]
via GitHub
(flink-cdc) branch master updated: [FLINK-34180][cdc] Add issue template to remind users about the new bug and feature reporting way (#3139)
renqs
(flink) branch master updated: [FLINK-34660][checkpoint] Avoid randomizing changelog-related config when it's pre-defined (#24488)
hangxiang
(flink) branch master updated: [FLINK-29122][core] Improve robustness of FileUtils.expandDirectory() (#24307)
rmetzger
[I] Flink CDC may occur binlog can't be find when dynamic added table repeatedly [flink-cdc]
via GitHub
[I] How to do MySQL to MySQL pipeline [flink-cdc]
via GitHub
Re: [I] How to do MySQL to MySQL pipeline [flink-cdc]
via GitHub
Re: [I] 文档页面404 [flink-cdc]
via GitHub
Re: [I] 文档页面404 [flink-cdc]
via GitHub
Re: [I] 文档页面404 [flink-cdc]
via GitHub
Re: [I] 文档页面404 [flink-cdc]
via GitHub
Re: [I] 文档页面404 [flink-cdc]
via GitHub
Re: [I] 文档页面404 [flink-cdc]
via GitHub
[PR] [FLINK-34180][cdc] Add issue template to remind users about the new bug and feature reporting way [flink-cdc]
via GitHub
Re: [PR] [FLINK-34180][cdc] Add issue template to remind users about the new bug and feature reporting way [flink-cdc]
via GitHub
Re: [PR] [FLINK-34180][cdc] Add issue template to remind users about the new bug and feature reporting way [flink-cdc]
via GitHub
(flink) branch master updated: [FLINK-29114][connector][filesystem] Fix issue of file overwriting caused by multiple writes to the same sink table and shared staging directory
jchan
[I] mysql cdc 3.0, when start from savepoint, the modify of startup.options is not effective [flink-cdc]
via GitHub
Re: [I] mysql cdc 3.0, when start from savepoint, the modify of startup.options is not effective [flink-cdc]
via GitHub
Re: [I] mysql cdc 3.0, when start from savepoint, the modify of startup.options is not effective [flink-cdc]
via GitHub
Re: [I] mysql cdc 3.0, when start from savepoint, the modify of startup.options is not effective [flink-cdc]
via GitHub
[I] 使用oracle-cdc ,table api的方式一直监听不到数据,但是也不报错 [flink-cdc]
via GitHub
[PR] [FLINK-34634]Fix that Restarting the job will not read the changelog anymore if it stops before the synchronization of meta information is complete and some table is removed [flink-cdc]
via GitHub
Re: [PR] [FLINK-34634]Fix that Restarting the job will not read the changelog anymore if it stops before the synchronization of meta information is complete and some table is removed [flink-cdc]
via GitHub
Re: [PR] [pipeline-connector][paimon] add paimon pipeline data sink connector. [flink-cdc]
via GitHub
Re: [PR] [pipeline-connector][paimon] add paimon pipeline data sink connector. [flink-cdc]
via GitHub
(flink) branch master updated: [FLINK-33798][statebackend/rocksdb] automatically clean up rocksdb logs when the task exited. (#23922)
fanrui
[I] mysql to sr pipeline, float value bug [flink-cdc]
via GitHub
Re: [I] mysql to sr pipeline, float value bug [flink-cdc]
via GitHub
Re: [I] mysql to sr pipeline, float value bug [flink-cdc]
via GitHub
Re: [I] mysql to sr pipeline, float value bug [flink-cdc]
via GitHub
Re: [I] mysql to sr pipeline, float value bug [flink-cdc]
via GitHub
Re: [I] mysql to sr pipeline, float value bug [flink-cdc]
via GitHub
Re: [PR] [FLINK-34653] Support table merging with route [flink-cdc]
via GitHub
Re: [PR] [FLINK-34653] Support table merging with route [flink-cdc]
via GitHub
Re: [I] 如何实现精准一次性读取数据 [flink-cdc]
via GitHub
Re: [PR] [cdc-connector][oceanbase] support debezium deserializer [flink-cdc]
via GitHub
Re: [PR] [cdc-connector][oceanbase] support debezium deserializer [flink-cdc]
via GitHub
[PR] [hotfix][cdc-common] Fix cdc `RowType` can not convert to flink type [flink-cdc]
via GitHub
Re: [PR] [mysql] Fix the restoration fail when checkpoint happened in a mysql transaction [flink-cdc]
via GitHub
Re: [PR] [FLINK-34648] add waitChangeResultRequest and WaitChangeResultResponse to avoid RPC timeout. [flink-cdc]
via GitHub
Re: [PR] [FLINK-34648] add waitChangeResultRequest and WaitChangeResultResponse to avoid RPC timeout. [flink-cdc]
via GitHub
Re: [PR] [FLINK-34648] add waitChangeResultRequest and WaitChangeResultResponse to avoid RPC timeout. [flink-cdc]
via GitHub
Re: [PR] [FLINK-34648] add waitChangeResultRequest and WaitChangeResultResponse to avoid RPC timeout. [flink-cdc]
via GitHub
Re: [PR] [FLINK-34648] add waitChangeResultRequest and WaitChangeResultResponse to avoid RPC timeout. [flink-cdc]
via GitHub
(flink) branch master updated: [FLINK-34624][state/changelog] Enable local recovery in ChangelogRescalingITCase (#24470)
leiyanfei
[I] readme勘误 [flink-cdc]
via GitHub
(flink) branch master updated (5f38a5702fc -> c2a6feee16c)
snuyanzin
(flink) branch master updated: [FLINK-34494][table] Migrate ReplaceIntersectWithSemiJoinRule to java
snuyanzin
(flink-kubernetes-operator) branch main updated: [FLINK-34524] Scale down JM deployment to 0 before deletion
gyfora
(flink-kubernetes-operator) branch main updated: [FLINK-34642] Add a test for zero lower utilization boundary (#796)
mxm
[PR] [FLINK-34639] Support debezium deserializer in OceanBase source connector [flink-cdc]
via GitHub
Re: [PR] [FLINK-34639] Support debezium deserializer in OceanBase source connector [flink-cdc]
via GitHub
(flink-kubernetes-operator) branch main updated (726e484c -> 63d83393)
gyfora
(flink-kubernetes-operator) 01/02: [hotfix] Fix ineffective scaling event triggering
gyfora
(flink-kubernetes-operator) 02/02: [hotfix] Handle missing busy time gracefully in IOMetricsInfo
gyfora
(flink) branch master updated (22309fdca62 -> 2ec2a606a4f)
pnowojski
(flink) 01/03: [hotfix][e2e] Fix naming of MAX_NUM_METRICS
pnowojski
(flink) 03/03: [hotfix] Add toString to StateHandleDownloadSpec
pnowojski
(flink) 02/03: [hotfix][e2e] Fix wait_oper_metric_num_in_records
pnowojski
(flink) branch master updated (fcf61b91089 -> 22309fdca62)
hangxiang
Re: [I] [bug] [Pipeline-cdc] The new table in the pipeline-cdc cannot synchronize the table structure and data [flink-cdc]
via GitHub
Re: [I] [Bug] After starting Streaming ELT from MySQL to StarRocks using Flink CDC 3.0, the newly created tables are not being synchronized. [flink-cdc]
via GitHub
Re: [I] [Bug] After starting Streaming ELT from MySQL to StarRocks using Flink CDC 3.0, the newly created tables are not being synchronized. [flink-cdc]
via GitHub
Re: [PR] [test][mysql] add env variables to support executing the test cases locally [flink-cdc]
via GitHub
(flink) branch master updated: [FLINK-34571][test] Fix flaky test SortMergeResultPartitionReadSchedulerTest.testOnReadBufferRequestError
guoweijie
Re: [PR] [cdc-common] add field of defaultValue to Column. [flink-cdc]
via GitHub
[I] mysql同步到StarRocks时,如果StarRocks和flink不是同一台服务器时,同步失败 [flink-cdc]
via GitHub
Re: [I] mysql同步到StarRocks时,如果StarRocks和flink不是同一台服务器时,同步失败 [flink-cdc]
via GitHub
Re: [I] mysql同步到StarRocks时,如果StarRocks和flink不是同一台服务器时,同步失败 [flink-cdc]
via GitHub
Re: [I] Flink CDC3.0 Demo Mysql binlog to Starrocks Exception amount of AddColumnEvent is already existed[Bug] [flink-cdc]
via GitHub
(flink) branch master updated (d6a4eb966fb -> eb9bcfa5893)
fanrui
Re: [I] Support default value of table column. [flink-cdc]
via GitHub
Re: [I] Support default value of table column. [flink-cdc]
via GitHub
[PR] [hotfix][docs] Add catalog page in try flink cdc and fix oceanbase-cdc.md wrong link. [flink-cdc]
via GitHub
Re: [PR] [hotfix][docs] Add catalog page in try flink cdc and fix oceanbase-cdc.md wrong link. [flink-cdc]
via GitHub
(flink-cdc) branch master updated: [hotfix][cdc][build] Include cdc-common module when shaded for module flink-sql-connector-mysql-cdc
jiabaosun
Re: [PR] [pipeline-connector][doris] Extract type mapping logic [flink-cdc]
via GitHub
Re: [I] [Bug] Mysql is synchronized to doris, and an error is reported when adding or deleting data after dropping column. [flink-cdc]
via GitHub
Re: [I] [Bug] mysql-to-doris 作业运行一段时间报错了 [flink-cdc]
via GitHub
[I] mysql同步到starrocks时,当主键是bigint且有无符号时,会被识别为decimal类型,导致创建表失败 [flink-cdc]
via GitHub
Re: [I] mysql同步到starrocks时,当主键是bigint且有无符号时,会被识别为decimal类型,导致创建表失败 [flink-cdc]
via GitHub
Re: [I] mysql同步到starrocks时,当主键是bigint且有无符号时,会被识别为decimal类型,导致创建表失败 [flink-cdc]
via GitHub
Re: [I] mysql同步到starrocks时,当主键是bigint且有无符号时,会被识别为decimal类型,导致创建表失败 [flink-cdc]
via GitHub
Re: [I] mysql同步到starrocks时,当主键是bigint且有无符号时,会被识别为decimal类型,导致创建表失败 [flink-cdc]
via GitHub
Re: [I] mysql同步到starrocks时,当主键是bigint且有无符号时,会被识别为decimal类型,导致创建表失败 [flink-cdc]
via GitHub
Re: [I] mysql同步到starrocks时,当主键是bigint且有无符号时,会被识别为decimal类型,导致创建表失败 [flink-cdc]
via GitHub
[I] mysql [flink-cdc]
via GitHub
Re: [I] mysql [flink-cdc]
via GitHub
Re: [I] mysql [flink-cdc]
via GitHub
[PR] [FLINK-34584][cdc][mysql] include cdc-common module when packaging to avoid Fix ClassNotFoundException. [flink-cdc]
via GitHub
Re: [PR] [FLINK-34584][cdc][mysql] include cdc-common module when packaging to avoid Fix ClassNotFoundException. [flink-cdc]
via GitHub
Re: [PR] [hotfix][cdc][build] Include cdc-common module when shaded for module flink-sql-connector-mysql-cdc [flink-cdc]
via GitHub
[I] The main method caused an error: Invalid metadata key 'row_kind' in column 'operation' of table [flink-cdc]
via GitHub
Re: [I] The main method caused an error: Invalid metadata key 'row_kind' in column 'operation' of table [flink-cdc]
via GitHub
Re: [I] The main method caused an error: Invalid metadata key 'row_kind' in column 'operation' of table [flink-cdc]
via GitHub
Re: [I] The main method caused an error: Invalid metadata key 'row_kind' in column 'operation' of table [flink-cdc]
via GitHub
Re: [I] The main method caused an error: Invalid metadata key 'row_kind' in column 'operation' of table [flink-cdc]
via GitHub
(flink) branch master updated: [FLINK-34417] Log Job ID via MDC
roman
(flink-kubernetes-operator) branch main updated: [FLINK-34566] Pass a FixedThreadPool to set reconciliation parallelism correctly
gyfora
(flink) annotated tag release-1.19.0-rc2 updated (eaffd227d85 -> 4bf5901d42b)
lincoln
Re: [I] java.lang.NoSuchMethodError: 'org.apache.flink.table.catalog.CatalogTable org.apache.flink.table.factories.DynamicTableFactory$Context.getCatalogTable()' [flink-cdc]
via GitHub
(flink) branch master updated (1d8cbe9065e -> 4171b980717)
guoweijie
(flink) branch master updated: [FLINK-34483][docs] Improve the documentation of 'state.checkpoints.dir' and 'state.checkpoint-storage' (#24401)
leiyanfei
(flink) branch release-1.18 updated: [FLINK-34622][docs] fix typo in execution_mode.md
tangyun
(flink) branch release-1.19 updated: [FLINK-34617][docs] Correct the Javadoc of org.apache.flink.api.common.time.Time
tangyun
(flink) branch release-1.19 updated: [FLINK-34622][docs] fix typo in execution_mode.md
tangyun
(flink) branch master updated: [FLINK-34617][docs] Correct the Javadoc of org.apache.flink.api.common.time.Time
tangyun
(flink) branch master updated (21306f4f5db -> 17487c0c944)
tangyun
[I] 后续有计划支持,多物理库分库分表同步、相同数据库合并源、通过SQL创建整库同步这几个功能吗? [flink-cdc]
via GitHub
(flink) branch release-1.18 updated: [FLINK-34616][python] Fix python dist dir doesn't clean when open method construct resource has exception.
hxb
(flink) branch release-1.19 updated: [FLINK-34616][python] Fix python dist dir doesn't clean when open method construct resource has exception.
hxb
(flink) branch master updated: [FLINK-34616][python] Fix python dist dir doesn't clean when open method construct resource has exception.
hxb
[I] 官网404 [flink-cdc]
via GitHub
Re: [I] 官网404,好几天了。 [flink-cdc]
via GitHub
Re: [I] 官网404,好几天了。 [flink-cdc]
via GitHub
Earlier messages