(rocketmq-flink) branch main updated: [ISSUE #105] Fix sink retryTimes does not work (#106)

2024-01-10 Thread nicholasjiang
This is an automated email from the ASF dual-hosted git repository. nicholasjiang pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-flink.git The following commit(s) were added to refs/heads/main by this push: new 0a1a033 [ISSUE #105] Fix sink

(rocketmq-flink) branch main updated: [ISSUE #95] Fix source can not consume new queue's messages when topic queue expansion (#96)

2024-01-10 Thread nicholasjiang
This is an automated email from the ASF dual-hosted git repository. nicholasjiang pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-flink.git The following commit(s) were added to refs/heads/main by this push: new b686501 [ISSUE #95] Fix source can

[rocketmq-flink] branch main updated: bump rocketmq schema registry version (#71)

2022-11-14 Thread nicholasjiang
This is an automated email from the ASF dual-hosted git repository. nicholasjiang pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-flink.git The following commit(s) were added to refs/heads/main by this push: new 9d0e78d bump rocketmq schema

[rocketmq-flink] branch main updated: [ISSUE #67] Bugfix for consume blocking

2022-10-27 Thread nicholasjiang
This is an automated email from the ASF dual-hosted git repository. nicholasjiang pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-flink.git The following commit(s) were added to refs/heads/main by this push: new 3af5c0d [ISSUE #67] Bugfix for

[rocketmq-flink] branch main updated: [ISSUE #35] Use `LitePullConsumer` model instead of default pull consumer(#46)

2022-10-27 Thread nicholasjiang
This is an automated email from the ASF dual-hosted git repository. nicholasjiang pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-flink.git The following commit(s) were added to refs/heads/main by this push: new ebbba23 [ISSUE #35] Use

[rocketmq-flink] branch main updated: update README.md (#66)

2022-10-18 Thread nicholasjiang
This is an automated email from the ASF dual-hosted git repository. nicholasjiang pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-flink.git The following commit(s) were added to refs/heads/main by this push: new 90b00be update README.md (#66

[rocketmq-flink] branch main updated: [ISSUE #59] Support rich initialization modes of RocketMQ source (#62)

2022-10-10 Thread nicholasjiang
This is an automated email from the ASF dual-hosted git repository. nicholasjiang pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-flink.git The following commit(s) were added to refs/heads/main by this push: new e8d5350 [ISSUE #59] Support rich

[rocketmq-flink] branch main updated: [ISSUE #57] Fix some problems with the catalog (#61)

2022-09-29 Thread nicholasjiang
This is an automated email from the ASF dual-hosted git repository. nicholasjiang pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-flink.git The following commit(s) were added to refs/heads/main by this push: new 460694b [ISSUE #57] Fix some

[rocketmq-flink] 01/01: Revert "Fix some problems with the catalog (#58)"

2022-09-29 Thread nicholasjiang
This is an automated email from the ASF dual-hosted git repository. nicholasjiang pushed a commit to branch revert-58-feature_catalog_fix in repository https://gitbox.apache.org/repos/asf/rocketmq-flink.git commit 9591c0c67fe092f158f482add411f7be2c417f6d Author: Nicholas Jiang AuthorDate: Thu

[rocketmq-flink] branch revert-58-feature_catalog_fix created (now 9591c0c)

2022-09-29 Thread nicholasjiang
This is an automated email from the ASF dual-hosted git repository. nicholasjiang pushed a change to branch revert-58-feature_catalog_fix in repository https://gitbox.apache.org/repos/asf/rocketmq-flink.git at 9591c0c Revert "Fix some problems with the catalog (#58)" T

[rocketmq-flink] branch main updated: Revert "Fix some problems with the catalog (#58)" (#60)

2022-09-29 Thread nicholasjiang
This is an automated email from the ASF dual-hosted git repository. nicholasjiang pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-flink.git The following commit(s) were added to refs/heads/main by this push: new afba019 Revert "Fix some pro

[rocketmq-flink] branch main updated: Fix some problems with the catalog (#58)

2022-09-29 Thread nicholasjiang
This is an automated email from the ASF dual-hosted git repository. nicholasjiang pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-flink.git The following commit(s) were added to refs/heads/main by this push: new 6909cbc Fix some problems with the

[rocketmq-flink] branch main updated: [ISSUE #12] Support scan startup mode (#54)

2022-08-29 Thread nicholasjiang
This is an automated email from the ASF dual-hosted git repository. nicholasjiang pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-flink.git The following commit(s) were added to refs/heads/main by this push: new 0e27ff8 [ISSUE #12] Support scan

[rocketmq-flink] branch main updated: [issues-32] Implement of Apache RocketMQ Flink Catalog. (#49)

2022-08-22 Thread nicholasjiang
This is an automated email from the ASF dual-hosted git repository. nicholasjiang pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-flink.git The following commit(s) were added to refs/heads/main by this push: new b7c00f3 [issues-32] Implement of

[rocketmq-flink] branch main updated: [issues-44] support access control (#47)

2022-07-26 Thread nicholasjiang
This is an automated email from the ASF dual-hosted git repository. nicholasjiang pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-flink.git The following commit(s) were added to refs/heads/main by this push: new 017db20 [issues-44] support access

[rocketmq-flink] branch main updated: [Hotfix] RocketMQSourceFunction retains offsets after multiple retry times of topic route change (#43)

2022-07-26 Thread nicholasjiang
This is an automated email from the ASF dual-hosted git repository. nicholasjiang pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-flink.git The following commit(s) were added to refs/heads/main by this push: new cc923f1 [Hotfix

[rocketmq-flink] branch main updated: [issues-44] support access control

2022-07-26 Thread nicholasjiang
This is an automated email from the ASF dual-hosted git repository. nicholasjiang pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-flink.git The following commit(s) were added to refs/heads/main by this push: new 034c4f2 [issues-44] support access

[rocketmq-flink] branch main updated: [Hotfix] RocketMQSourceFunction persists offset in notifyCheckpointComplete

2022-07-20 Thread nicholasjiang
This is an automated email from the ASF dual-hosted git repository. nicholasjiang pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-flink.git The following commit(s) were added to refs/heads/main by this push: new 6656964 [Hotfix

[rocketmq-flink] branch main updated (a21cc04 -> 0106c3d)

2022-07-14 Thread nicholasjiang
This is an automated email from the ASF dual-hosted git repository. nicholasjiang pushed a change to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-flink.git from a21cc04 Merge pull request #38 from hunter-cloud09/1.0.0 new 37358b4 support message queue

[rocketmq-flink] branch main updated (64c11ff -> 9d131e7)

2022-06-05 Thread nicholasjiang
This is an automated email from the ASF dual-hosted git repository. nicholasjiang pushed a change to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-flink.git from 64c11ff Merge pull request #31 from GOODBOY008/bump_flink_version new 95de766 [issues-21] support

[rocketmq-flink] branch main updated: Bump flink version to 1.15.0.

2022-05-25 Thread nicholasjiang
This is an automated email from the ASF dual-hosted git repository. nicholasjiang pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-flink.git The following commit(s) were added to refs/heads/main by this push: new 619e889 Bump flink version to

[rocketmq-flink] branch main updated: convertToRowTypeInfo() return field types and name

2021-09-27 Thread nicholasjiang
This is an automated email from the ASF dual-hosted git repository. nicholasjiang pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-flink.git The following commit(s) were added to refs/heads/main by this push: new 7c2fc19 convertToRowTypeInfo