高思伟

[e2e] optimization for arm64

1

linked #1558 1 make sure mac with apple silicon chip can run the test case. 2 define the expose port 8081:8081 in JobManager's container.So when container is running, Flink web...

I want to debug the code with module flink-cdc-e2e-tests in IDE. While,although I have run the docker desktop in my mac.An exception still been throwed like this The current code...

Support rich initialization modes of RocketMQSource

2

perfect new features for new `Source` interface and sql connector. detail in #59

[ISSUE #67] Bugfix for consume blocking

1

Is there a better idea

[BUG]Consumer will be blocked after the server throws multiple exceptions.

1

Describe： RocketMQ server has some problems in consumer group verification.Source will receive exception when it pulls record from broker. After five retries ,none reocrds would be pulled and job is...

[BUG] topic route changed,job can't recover normally

6

1.Add partition Flink will check partition is changed in function of snapshotState.If route changed,job will switch state from running to failed. Then job will recover from checkpoint without new message...

Version below 4.6.0 does not support DefaultLitePullConsumer

7

DefaultMQPullConsumer has been instead of by DefaultLitePullConsumer.After I rebase master into my develop branch,some mistakes have occurred.And my company uses version `4.3` So I run the old version and everything...

[ISSUE #63] Support rich initialization modes of RocketMQSource & Fix some bugs

5

Support rich initialization modes of RocketMQSource Fix some bugs

hive3 外部表不支持复杂类型嘛

1

官网有和hive类型对比 ARRAY -> TEXT[] 但是创建复杂类型外部表报错