(flink) branch master updated: [FLINK-18255][state] Add API annotations to RocksDB user-facing classes (#24496)

2024-03-14 Thread hangxiang
This is an automated email from the ASF dual-hosted git repository. hangxiang pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 8fba491c9c2 [FLINK-18255][state] Add API

Re: [I] The main method caused an error: Invalid metadata key 'row_kind' in column 'operation' of table [flink-cdc]

2024-03-14 Thread via GitHub
KONEONE commented on issue #3117: URL: https://github.com/apache/flink-cdc/issues/3117#issuecomment-1998927158 > I use the `flink-connector-mysql-cdc version 3.0.1`, ran into the same issue. Can anyone check this please? I once reported this issue in the official group chat, but did

Re: [I] The main method caused an error: Invalid metadata key 'row_kind' in column 'operation' of table [flink-cdc]

2024-03-14 Thread via GitHub
KONEONE commented on issue #3117: URL: https://github.com/apache/flink-cdc/issues/3117#issuecomment-1998926892 > I use the `flink-connector-mysql-cdc version 3.0.1`, ran into the same issue. Can anyone check this please? I once reported this issue in the official group chat, but did not

Re: [I] mysql同步到starrocks时,当主键是bigint且有无符号时,会被识别为decimal类型,导致创建表失败 [flink-cdc]

2024-03-14 Thread via GitHub
loserwang1024 commented on issue #3120: URL: https://github.com/apache/flink-cdc/issues/3120#issuecomment-1998903673 I have added it in jira https://issues.apache.org/jira/browse/FLINK-34690 -- This is an automated message from the Apache Git Service. To respond to the message, please log

Re: [I] mysql同步到starrocks时,当主键是bigint且有无符号时,会被识别为decimal类型,导致创建表失败 [flink-cdc]

2024-03-14 Thread via GitHub
loserwang1024 commented on issue #3120: URL: https://github.com/apache/flink-cdc/issues/3120#issuecomment-1998892721 If starrocks supports unsigned bigint, maybe can transform DECIMAL(20, 0) to unsigned bigint in sink. -- This is an automated message from the Apache Git Service. To

Re: [I] mysql同步到starrocks时,当主键是bigint且有无符号时,会被识别为decimal类型,导致创建表失败 [flink-cdc]

2024-03-14 Thread via GitHub
TPSHION commented on issue #3120: URL: https://github.com/apache/flink-cdc/issues/3120#issuecomment-1998890050 所以只能修改表结构吗? | | chen | | ***@***.*** | 回复的原邮件 | 发件人 | Hongshun ***@***.***> | | 发送日期 | 2024年03月15日 11:50 | | 收件人 | apache/flink-cdc

Re: [I] The main method caused an error: Invalid metadata key 'row_kind' in column 'operation' of table [flink-cdc]

2024-03-14 Thread via GitHub
VincentYuuu commented on issue #3117: URL: https://github.com/apache/flink-cdc/issues/3117#issuecomment-1998889394 I use the flink-connector-mysql-cdc version 3.0.1, ran into the same issue. Can anyone check this please? -- This is an automated message from the Apache Git Service. To

Re: [I] mysql同步到starrocks时,当主键是bigint且有无符号时,会被识别为decimal类型,导致创建表失败 [flink-cdc]

2024-03-14 Thread via GitHub
loserwang1024 commented on issue #3120: URL: https://github.com/apache/flink-cdc/issues/3120#issuecomment-199625 Flink only have bigint type, if mysql data is unsigned bigint , maybe out of range, so cast to DECIMAL(20, 0). -- This is an automated message from the Apache Git Service.

Re: [I] mysql cdc 3.0, when start from savepoint, the modify of startup.options is not effective [flink-cdc]

2024-03-14 Thread via GitHub
loserwang1024 commented on issue #3136: URL: https://github.com/apache/flink-cdc/issues/3136#issuecomment-1998886955 @sufeng23c At present, it is not support. The state of this two mode's enumerator are not same, which is HybridPendingSplitsState and StreamPendingSplitsState. By the way,

Re: [I] 文档页面404 [flink-cdc]

2024-03-14 Thread via GitHub
loserwang1024 commented on issue #3138: URL: https://github.com/apache/flink-cdc/issues/3138#issuecomment-1998883310 The community is migrating and refractor the website content. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

(flink-kubernetes-operator) annotated tag release-1.8.0-rc1 updated (91d67d95 -> 9b61e9f3)

2024-03-14 Thread mxm
This is an automated email from the ASF dual-hosted git repository. mxm pushed a change to annotated tag release-1.8.0-rc1 in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git *** WARNING: tag release-1.8.0-rc1 was modified! *** from 91d67d95 (commit) to

svn commit: r67940 - /dev/flink/flink-kubernetes-operator-1.8.0-rc1/

2024-03-14 Thread mxm
Author: mxm Date: Thu Mar 14 15:18:09 2024 New Revision: 67940 Log: Apache Flink Kubernetes Operator, version 1.8.0, release candidate 1 Added: dev/flink/flink-kubernetes-operator-1.8.0-rc1/ dev/flink/flink-kubernetes-operator-1.8.0-rc1/flink-kubernetes-operator-1.8.0-helm.tgz (with

(flink-kubernetes-operator) branch release-1.8 created (now 6a8bc506)

2024-03-14 Thread mxm
This is an automated email from the ASF dual-hosted git repository. mxm pushed a change to branch release-1.8 in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git at 6a8bc506 [release] Update docs config for release This branch includes the following new

(flink-kubernetes-operator) 01/01: [release] Update docs config for release

2024-03-14 Thread mxm
This is an automated email from the ASF dual-hosted git repository. mxm pushed a commit to branch release-1.8 in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git commit 6a8bc506e9d925bbf682c9900a581b1e83a7 Author: Max Michels AuthorDate: Thu Mar 14 15:59:12 2024

(flink-kubernetes-operator) branch main updated: [FLINK-34619] Do not wait for scaling completion in UPGRADE state with in-place scaling (#793)

2024-03-14 Thread mxm
This is an automated email from the ASF dual-hosted git repository. mxm pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git The following commit(s) were added to refs/heads/main by this push: new 8938658e [FLINK-34619] Do not wait

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. [fli

2024-03-14 Thread via GitHub
byd-android-2017 commented on issue #1828: URL: https://github.com/apache/flink-cdc/issues/1828#issuecomment-1997562644 我也遇到同样的问题,我估计是表数据太多造成的,如超过1000W行数据,我测试过400W行,工作正常。 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

svn commit: r67937 - /release/flink/KEYS

2024-03-14 Thread mxm
Author: mxm Date: Thu Mar 14 13:48:38 2024 New Revision: 67937 Log: Refresh public keys for mxm Modified: release/flink/KEYS Modified: release/flink/KEYS == --- release/flink/KEYS (original) +++ release/flink/KEYS

(flink) branch master updated: [FLINK-34640][metrics] Replace DummyMetricGroup usage with UnregisteredMetricsGroup

2024-03-14 Thread jingge
This is an automated email from the ASF dual-hosted git repository. jingge pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new a0c811ec03d [FLINK-34640][metrics] Replace

(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

2024-03-14 Thread jchan
This is an automated email from the ASF dual-hosted git repository. jchan pushed a commit to branch release-1.19 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.19 by this push: new 4d5327d40a3

Re: [I] [Bug] Datetime data inconsistency (off by 8 hours) in snapshot phase [flink-cdc]

2024-03-14 Thread via GitHub
Xuxiaotuan commented on issue #2074: URL: https://github.com/apache/flink-cdc/issues/2074#issuecomment-1997167212 So far I have implemented it this way and the snapshot and incremental timestamp values are normal I can submit pr if necessary

(flink) branch release-1.19 updated: [FLINK-33798][statebackend/rocksdb] automatically clean up rocksdb logs when the task exited. (#23922)

2024-03-14 Thread fanrui
This is an automated email from the ASF dual-hosted git repository. fanrui pushed a commit to branch release-1.19 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.19 by this push: new 943d9a48fdc

(flink) branch release-1.18 updated: [FLINK-33798][statebackend/rocksdb] automatically clean up rocksdb logs when the task exited. (#23922)

2024-03-14 Thread fanrui
This is an automated email from the ASF dual-hosted git repository. fanrui pushed a commit to branch release-1.18 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.18 by this push: new 5a1fb807ab8

(flink) branch release-1.17 updated: [FLINK-33798][statebackend/rocksdb] automatically clean up rocksdb logs when the task exited. (#23922)

2024-03-14 Thread fanrui
This is an automated email from the ASF dual-hosted git repository. fanrui pushed a commit to branch release-1.17 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.17 by this push: new 09e448440b8

Re: [I] How to do MySQL to MySQL pipeline [flink-cdc]

2024-03-14 Thread via GitHub
ihadoop commented on issue #3140: URL: https://github.com/apache/flink-cdc/issues/3140#issuecomment-1997037995 you can create sink mysql table ```sql CREATE TABLE mysql_sink ( `id` bigint , `s_name` varchar(100) , `s_int` bigint, PRIMARY KEY(id) NOT ENFORCED

(flink) 01/03: [FLINK-34484][state]Move LOCAL_RECOVERY config from CheckpointingOptions to StateRecoveryOption

2024-03-14 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 1d1dca6d6b1a80c4fcd3337489a99c0d834692ea Author: Jinzhong Li AuthorDate: Tue Feb 27 18:08:03 2024 +0800

(flink) 02/03: [FLINK-34484][state] Split 'state.backend.local-recovery' into two options for checkpointing and recovery

2024-03-14 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit ed75795e97800177cb67141ab838632d5ec55bb5 Author: Jinzhong Li AuthorDate: Wed Feb 28 12:19:36 2024 +0800

(flink) 03/03: [FLINK-34484][tests] Add UT/IT tests to verify localBackup and localRecovery configs

2024-03-14 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 649e2b412e10c7f698721cbbd8697f9b02248977 Author: Jinzhong Li AuthorDate: Wed Feb 28 18:44:30 2024 +0800

(flink) branch master updated (3b9623e5d2e -> 649e2b412e1)

2024-03-14 Thread leiyanfei
This is an automated email from the ASF dual-hosted git repository. leiyanfei pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 3b9623e5d2e [FLINK-32076][checkpoint] Introduce blocking file pool to reuse files (#24418) new 1d1dca6d6b1

Re: [I] [Bug] Datetime data inconsistency (off by 8 hours) in snapshot phase [flink-cdc]

2024-03-14 Thread via GitHub
Xuxiaotuan commented on issue #2074: URL: https://github.com/apache/flink-cdc/issues/2074#issuecomment-1996836618 Hello, until now this problem still exists, is it dependent on upstream updates? #1739 This doesn't solve the problem Flink version 1.18 Flink CDC version

Re: [I] 文档页面404 [flink-cdc]

2024-03-14 Thread via GitHub
legen618 commented on issue #3138: URL: https://github.com/apache/flink-cdc/issues/3138#issuecomment-1996707764 @hirolee88 Sorry, I'm afraid I don't have the right to do assignment in this Repository. > According to rules of Github: > Anyone with write access to a repository can

Re: [I] 文档页面404 [flink-cdc]

2024-03-14 Thread via GitHub
legen618 commented on issue #3138: URL: https://github.com/apache/flink-cdc/issues/3138#issuecomment-1996702883 > @legen618 https://nightlies.apache.org/flink/flink-cdc-docs-release-3.0/docs/connectors/cdc-connectors/overview/ @gtk96 Thank you! It helps a lot. -- This is an

Re: [I] 文档页面404 [flink-cdc]

2024-03-14 Thread via GitHub
hirolee88 commented on issue #3138: URL: https://github.com/apache/flink-cdc/issues/3138#issuecomment-1996676970 @legen618 I'm willing to take this, Please assign to me. Thank you~ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

Re: [I] 文档页面404 [flink-cdc]

2024-03-14 Thread via GitHub
hirolee88 commented on issue #3138: URL: https://github.com/apache/flink-cdc/issues/3138#issuecomment-1996673179 我也发现了 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To

(flink-web) branch asf-site updated: [FLINK-34654] Add Special Thanks Page on the Flink Website (#725)

2024-03-14 Thread jark
This is an automated email from the ASF dual-hosted git repository. jark pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/flink-web.git The following commit(s) were added to refs/heads/asf-site by this push: new 8d252a5e7 [FLINK-34654] Add Special Thanks