Skip to content
This repository has been archived by the owner on Dec 14, 2022. It is now read-only.

[BUG] use pulsar + debezium-json format in flink 1.13.1 not work #378

Closed
haormj opened this issue Jul 27, 2021 · 0 comments · Fixed by #379
Closed

[BUG] use pulsar + debezium-json format in flink 1.13.1 not work #378

haormj opened this issue Jul 27, 2021 · 0 comments · Fixed by #379
Labels

Comments

@haormj
Copy link
Contributor

haormj commented Jul 27, 2021

use pulsar + debezium-json format in flink 1.13.1

2021-07-27T20:32:02.553947281+08:00 java.lang.RuntimeException: Please invoke DeserializationSchema#deserialize(byte[], Collector) instead.
2021-07-27T20:32:02.553967387+08:00 at org.apache.flink.formats.json.debezium.DebeziumJsonDeserializationSchema.deserialize(DebeziumJsonDeserializationSchema.java:120) ~[flink-json-1.13.1.jar:1.13.1]
2021-07-27T20:32:02.553974509+08:00 at org.apache.flink.formats.json.debezium.DebeziumJsonDeserializationSchema.deserialize(DebeziumJsonDeserializationSchema.java:55) ~[flink-json-1.13.1.jar:1.13.1]
2021-07-27T20:32:02.553980146+08:00 at org.apache.flink.streaming.util.serialization.ThreadSafeDeserializationSchema.deserialize(ThreadSafeDeserializationSchema.java:47) ~[pulsar-flink-sql-connector_2.11-1.13.1.1.jar:1.13.1.1]
2021-07-27T20:32:02.553999964+08:00 at org.apache.flink.api.common.serialization.DeserializationSchema.deserialize(DeserializationSchema.java:82) ~[flink-dist_2.11-1.13.1.jar:1.13.1]
2021-07-27T20:32:02.554008054+08:00 at org.apache.flink.streaming.connectors.pulsar.table.DynamicPulsarDeserializationSchema.deserialize(DynamicPulsarDeserializationSchema.java:120) ~[pulsar-flink-sql-connector_2.11-1.13.1.1.jar:1.13.1.1]
2021-07-27T20:32:02.554014465+08:00 at org.apache.flink.streaming.connectors.pulsar.table.DynamicPulsarDeserializationSchema.deserialize(DynamicPulsarDeserializationSchema.java:111) ~[pulsar-flink-sql-connector_2.11-1.13.1.1.jar:1.13.1.1]
2021-07-27T20:32:02.554019020+08:00 at org.apache.flink.streaming.connectors.pulsar.table.DynamicPulsarDeserializationSchema.deserialize(DynamicPulsarDeserializationSchema.java:42) ~[pulsar-flink-sql-connector_2.11-1.13.1.1.jar:1.13.1.1]
2021-07-27T20:32:02.554024158+08:00 at org.apache.flink.streaming.connectors.pulsar.internal.ReaderThread.emitRecord(ReaderThread.java:176) ~[pulsar-flink-sql-connector_2.11-1.13.1.1.jar:1.13.1.1]
2021-07-27T20:32:02.554028611+08:00 at org.apache.flink.streaming.connectors.pulsar.internal.ReaderThread.run(ReaderThread.java:111) ~[pulsar-flink-sql-connector_2.11-1.13.1.1.jar:1.13.1.1]

@haormj haormj changed the title [BUG] [BUG] use pulsar + debezium-json format in flink 1.13.1 not work Jul 27, 2021
haormj added a commit to haormj/pulsar-flink that referenced this issue Jul 27, 2021
@jianyun8023 jianyun8023 linked a pull request Jul 30, 2021 that will close this issue
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
Projects
None yet
Development

Successfully merging a pull request may close this issue.

1 participant