yiduwangkai

[#35] Use `LitePullConsumer` model instead of default pull consumer

4

close #35 Use `DefaultLitePullConsumer` model instead of default pull consumer. Tips Thank you very much for contributing to Apache rocketmq-flink. What is the purpose of the pull request *solve some...

The following files had format violations: [ERROR] src/main/java/org/apache/rocketmq/flink/sink/table/RocketMQDynamicTableSink.java [ERROR] @@ -199,7 +199,8 @@ [ERROR] ········return·producerProps; [ERROR] ····} [ERROR] [ERROR] -····protected·static·RowTypeInfo·convertToRowTypeInfo(DataType·fieldsDataType,·String[]·fieldNames)·{ [ERROR] +····protected·static·RowTypeInfo·convertToRowTypeInfo( [ERROR] +············DataType·fieldsDataType,·String[]·fieldNames)·{ [ERROR] ········final·TypeInformation[]·fieldTypes·= [ERROR] ················fieldsDataType.getChildren().stream() [ERROR] ························.map(LegacyTypeInfoDataTypeConverter::toLegacyTypeInfo)...

upgrade Flink version to 1.13.1

1

现在flink 1.14已经发布，master分支依赖的flink还是1.12.5， 有必要升级master分支依赖的flink版本到1.13.1

how to use bytebuddy to implement my code

2

i want to implement the following code `public byte[] toJsonBytes(Object o) throws Exception { return gson.toJson(o).getBytes(); }` i write the code like this `Method toJsonBytesMethod = gsonClass.getDeclaredMethod("toJson", Object.class); builder =...

1.[fix lite pull consumer api]

1

[fix lite pull consumer api] Version below 4.6.0 does not support DefaultLitePullConsumer

can not connect docker.sock

1

`00:11:38.397 [main] DEBUG o.t.c.o.WaitingConsumer - STDERR: panic: Cannot connect to the Docker daemon at unix:///var/run/docker.sock. Is the docker daemon running? 00:11:38.397 [main] DEBUG o.t.c.o.WaitingConsumer - STDERR: 2023/09/16 16:11:38 Pinging Docker...`...