反序列化这里报错，老师看看是什么原因呢？

Question

1.14.5.jar:/root/CmbRiskCtrlSys/RnUxfflNVo/commons-io-2.8.0.jar:/root/CmbRiskCtrlSys/wADcSvO8PM/flink-shaded-netty-4.1.65.Final-14.0.jar:/root/CmbRiskCtrlSys/p7RJGcmxr5/flink-shaded-jackson-2.12.4-14.0.jar:/root/CmbRiskCtrlSys/zgU1byxsIR/flink-shaded-zookeeper-3-3.4.14-14.0.jar:/root/CmbRiskCtrlSys/koLKmXh2sb/commons-cli-1.3.1.jar:/root/CmbRiskCtrlSys/2xz4vdvuZ8/javassist-3.24.0-GA.jar:/root/CmbRiskCtrlSys/PbgCrSpcOj/snappy-java-1.1.8.3.jar:/root/CmbRiskCtrlSys/i4GFIVzOCe/lz4-java-1.8.0.jar:/root/CmbRiskCtrlSys/WAB8HHoAQe/flink-scala_2.11-1.14.5.jar:/root/CmbRiskCtrlSys/eq8tY7cN96/scala-reflect-2.11.12.jar:/root/CmbRiskCtrlSys/0uzivjrmTw/scala-library-2.11.12.jar:/root/CmbRiskCtrlSys/Zt3MGDArve/scala-compiler-2.11.12.jar:/root/CmbRiskCtrlSys/4mL5PjCutd/scala-xml_2.11-1.0.5.jar:/root/CmbRiskCtrlSys/DZjmbnDJjT/scala-parser-combinators_2.11-1.0.4.jar:/root/CmbRiskCtrlSys/K6r7Wmt9U6/chill_2.11-0.7.6.jar:/root/CmbRiskCtrlSys/9juk1X8GYu/chill-java-0.7.6.jar:/root/CmbRiskCtrlSys/7tUurM7Xn9/flink-shaded-guava-30.1.1-jre-14.0.jar:/root/CmbRiskCtrlSys/gvET66aaHg/flink-table-api-java-1.14.5.jar:/root/CmbRiskCtrlSys/fEhmIUuqKs/flink-table-common-1.14.5.jar:/root/CmbRiskCtrlSys/UAqVacz1S1/flink-connector-files-1.14.5.jar:/root/CmbRiskCtrlSys/Sdmgp6FRx8/flink-shaded-asm-7-7.1-14.0.jar:/root/CmbRiskCtrlSys/zbLfJZhLCk/flink-table-api-java-bridge_2.11-1.14.5.jar:/root/CmbRiskCtrlSys/JziyQlBJ7D/flink-table-planner_2.11-1.14.5.jar:/root/CmbRiskCtrlSys/O85LoqalCj/flink-table-api-scala_2.11-1.14.5.jar:/root/CmbRiskCtrlSys/sjHQZA7XpI/flink-table-api-scala-bridge_2.11-1.14.5.jar:/root/CmbRiskCtrlSys/U3f2FsKN2S/flink-streaming-scala_2.11-1.14.5.jar:/root/CmbRiskCtrlSys/wRPvas1wrC/flink-table-runtime_2.11-1.14.5.jar:/root/CmbRiskCtrlSys/2akl9KpG6S/flink-table-code-splitter-1.14.5.jar:/root/CmbRiskCtrlSys/0HiPxAlzFi/janino-3.1.7.jar:/root/CmbRiskCtrlSys/rxs14Jpclc/commons-compiler-3.1.7.jar:/root/CmbRiskCtrlSys/PqX2Nwyxfi/avatica-core-1.17.0.jar:/root/CmbRiskCtrlSys/n2cb32CH5s/flink-connector-redis_2.11-1.1.0.jar:/root/CmbRiskCtrlSys/sG4RBJqzbO/flink-connector-kafka_2.11-1.14.5.jar:/root/CmbRiskCtrlSys/PrJjxKu2oO/flink-connector-base-1.14.5.jar:/root/CmbRiskCtrlSys/lJ0m0hgyHn/kafka-clients-3.0.1.jar:/root/CmbRiskCtrlSys/Mfq7YIdbbc/zstd-jni-1.5.0-2.jar:/root/CmbRiskCtrlSys/0rs24DJWrb/flink-connector-jdbc_2.11-1.14.5.jar:/root/CmbRiskCtrlSys/ttxuR7HBfm/h2-1.4.200.jar:/root/CmbRiskCtrlSys/lmoDqNohaW/flink-test-utils_2.11-1.14.5.jar:/root/CmbRiskCtrlSys/t37yEsAR8Z/flink-test-utils-junit-1.14.5.jar:/root/CmbRiskCtrlSys/5Q733aSkHx/junit-vintage-engine-5.8.2.jar:/root/CmbRiskCtrlSys/q12ThRf1sc/junit-platform-engine-1.8.2.jar:/root/CmbRiskCtrlSys/5QSF8pMZWl/junit-4.13.2.jar:/root/CmbRiskCtrlSys/7Gsa26SKOD/hamcrest-core-2.2.jar:/root/CmbRiskCtrlSys/WeHoVb0klC/apiguardian-api-1.1.2.jar:/root/CmbRiskCtrlSys/e16HxJVdsh/log4j-slf4j-impl-2.18.0.jar:/root/CmbRiskCtrlSys/KvB4txv89I/log4j-api-2.18.0.jar:/root/CmbRiskCtrlSys/tw6x8ZBUss/log4j-core-2.18.0.jar:/root/CmbRiskCtrlSys/U2SZUcs66v/flink-runtime-1.14.5-tests.jar:/root/CmbRiskCtrlSys/NZEldZGmvp/flink-rpc-akka-loader-1.14.5-tests.jar:/root/CmbRiskCtrlSys/2MNaNzoxH3/flink-clients_2.11-1.14.5.jar:/root/CmbRiskCtrlSys/WzzcSbvDGn/flink-optimizer-1.14.5.jar:/root/CmbRiskCtrlSys/dT2nKQhL9G/junit-jupiter-5.8.2.jar:/root/CmbRiskCtrlSys/pC1LRihBYC/junit-jupiter-api-5.8.2.jar:/root/CmbRiskCtrlSys/dpjZg2rI9i/opentest4j-1.2.0.jar:/root/CmbRiskCtrlSys/iOxLH4RNEp/junit-platform-commons-1.8.2.jar:/root/CmbRiskCtrlSys/NTCUmsJ8wW/junit-jupiter-params-5.8.2.jar:/root/CmbRiskCtrlSys/4wRKjhOONG/junit-jupiter-engine-5.8.2.jar:/root/CmbRiskCtrlSys/wsxu1R8wyc/curator-test-2.12.0.jar:/root/CmbRiskCtrlSys/tzSsXgXEXi/zookeeper-3.4.8.jar:/root/CmbRiskCtrlSys/fMC6q03j0m/jline-0.9.94.jar:/root/CmbRiskCtrlSys/LP8XZZNpJl/netty-3.7.0.Final.jar:/root/CmbRiskCtrlSys/utXb3spSvB/guava-16.0.1.jar:/root/CmbRiskCtrlSys/8H6gvAChDA/flink-statebackend-changelog-1.14.5.jar:/root/CmbRiskCtrlSys/nMkMvJLLiu/flink-streaming-java_2.11-1.14.5-tests.jar:/root/CmbRiskCtrlSys/48F92Kurq6/jedis-3.7.1.jar:/root/CmbRiskCtrlSys/vK8sgpLdNF/commons-pool2-2.11.1.jar:/root/CmbRiskCtrlSys/HoOlpVnSZ3/clickhouse-jdbc-0.3.2-patch11.jar:/root/CmbRiskCtrlSys/cmjU53WPFs/clickhouse-cli-client-0.3.2-patch11-shaded.jar:/root/CmbRiskCtrlSys/Qfnq9JGhrY/clickhouse-grpc-client-0.3.2-patch11-shaded.jar:/root/CmbRiskCtrlSys/Bf9XkJ507l/clickhouse-http-client-0.3.2-patch11-shaded.jar:/root/CmbRiskCtrlSys/ISLTXqkjG3/gson-2.8.9.jar:/root/CmbRiskCtrlSys/TZKl11RADv/httpclient-4.5.13.jar:/root/CmbRiskCtrlSys/NxD3fL691C/httpcore-4.4.15.jar:/root/CmbRiskCtrlSys/hikz43iLQB/commons-logging-1.2.jar:/root/CmbRiskCtrlSys/MXKn0WUZGW/commons-codec-1.15.jar:/root/CmbRiskCtrlSys/ENoyrhvBAg/httpmime-4.5.13.jar:/root/CmbRiskCtrlSys/pngaJVVnUn/mysql-connector-java-5.1.38.jar:/root/CmbRiskCtrlSys/4ka6bpQY4c:/root/CmbRiskCtrlSys/oOgZaZYQ5i:/root/CmbRiskCtrlSys/uSN00hUvOe/spring-boot-starter-data-redis-2.6.11.jar:/root/CmbRiskCtrlSys/yXlbtzC3EX/spring-data-redis-2.6.6.jar:/root/CmbRiskCtrlSys/rLqjpyXkfP/spring-data-keyvalue-2.6.6.jar:/root/CmbRiskCtrlSys/jRaThwa1n5/spring-data-commons-2.6.6.jar:/root/CmbRiskCtrlSys/sV1gAr82Nd/spring-tx-5.3.22.jar:/root/CmbRiskCtrlSys/5X93wVCMYQ/spring-oxm-5.3.22.jar:/root/CmbRiskCtrlSys/xVYx8cgi8z/spring-aop-5.3.22.jar:/root/CmbRiskCtrlSys/RDtcOIbRQf/spring-context-support-5.3.22.jar:/root/CmbRiskCtrlSys/eDDbvtuicM/lettuce-core-6.1.9.RELEASE.jar:/root/CmbRiskCtrlSys/ILIxHjNfv3/netty-common-4.1.79.Final.jar:/root/CmbRiskCtrlSys/2rTTEniWKR/netty-handler-4.1.79.Final.jar:/root/CmbRiskCtrlSys/9Mm3hotEFk/netty-resolver-4.1.79.Final.jar:/root/CmbRiskCtrlSys/xDATwYtls4/netty-buffer-4.1.79.Final.jar:/root/CmbRiskCtrlSys/uNxbke1fqh/netty-transport-native-unix-common-4.1.79.Final.jar:/root/CmbRiskCtrlSys/DPBku60Pe8/netty-codec-4.1.79.Final.jar:/root/CmbRiskCtrlSys/hzpXltwnlK/netty-transport-4.1.79.Final.jar:/root/CmbRiskCtrlSys/p8PDcIDf6n/reactor-core-3.4.22.jar:/root/CmbRiskCtrlSys/0GHNBk4Yfi/reactive-streams-1.0.4.jar:/root/CmbRiskCtrlSys/xRnajeDlUj/hbase-client-2.0.6.jar:/root/CmbRiskCtrlSys/PXVQ2hgK9I/hbase-shaded-protobuf-2.1.0.jar:/root/CmbRiskCtrlSys/vDzYZ9hQtJ/hbase-common-2.0.6.jar:/root/CmbRiskCtrlSys/MOUOrvmbUR/findbugs-annotations-1.3.9-1.jar:/root/CmbRiskCtrlSys/wtu8xmv1du/hbase-hadoop-compat-2.0.6.jar:/root/CmbRiskCtrlSys/JQvYqpUpxU/hbase-metrics-api-2.0.6.jar:/root/CmbRiskCtrlSys/NZpKggNEhm/hbase-hadoop2-compat-2.0.6.jar:/root/CmbRiskCtrlSys/qG3qlIZEdB/hbase-metrics-2.0.6.jar:/root/CmbRiskCtrlSys/d0At9wGxp0/hbase-protocol-shaded-2.0.6.jar:/root/CmbRiskCtrlSys/UybPaSk8O5/hbase-protocol-2.0.6.jar:/root/CmbRiskCtrlSys/NN560aH8UC/hbase-shaded-miscellaneous-2.1.0.jar:/root/CmbRiskCtrlSys/jfACaiYLCI/protobuf-java-2.5.0.jar:/root/CmbRiskCtrlSys/JdJsEK7brq/hbase-shaded-netty-2.1.0.jar:/root/CmbRiskCtrlSys/oFjfb4WsMB/htrace-core4-4.2.0-incubating.jar:/root/CmbRiskCtrlSys/xMZ0K3LIKG/jcodings-1.0.18.jar:/root/CmbRiskCtrlSys/qmnrcC6D0i/joni-2.1.11.jar:/root/CmbRiskCtrlSys/xCbbYf1hm0/metrics-core-4.2.11.jar:/root/CmbRiskCtrlSys/pMuPhVNOjA/commons-crypto-1.0.0.jar:/root/CmbRiskCtrlSys/e8tvIh241s/jackson-databind-2.13.3.jar:/root/CmbRiskCtrlSys/3rtVK3wc4Z/jackson-annotations-2.13.3.jar:/root/CmbRiskCtrlSys/04UeaK319F/jackson-core-2.13.3.jar:/root/CmbRiskCtrlSys/P480FrZCEp/hadoop-auth-2.7.7.jar:/root/CmbRiskCtrlSys/ZoYcGJwKZR/apacheds-kerberos-codec-2.0.0-M15.jar:/root/CmbRiskCtrlSys/GAiSbarBh5/apacheds-i18n-2.0.0-M15.jar:/root/CmbRiskCtrlSys/IMRLh3C1xi/api-asn1-api-1.0.0-M20.jar:/root/CmbRiskCtrlSys/SEzqrVr19j/api-util-1.0.0-M20.jar:/root/CmbRiskCtrlSys/sIvYHLR4ji/curator-framework-2.7.1.jar:/root/CmbRiskCtrlSys/UmwECDkkYx/audience-annotations-0.5.0.jar:/root/CmbRiskCtrlSys/2ODfTIrIlG/hadoop-common-2.7.7.jar:/root/CmbRiskCtrlSys/otrqb0Gsdy/hadoop-annotations-2.7.7.jar:/usr/lib/tools.jar:/root/CmbRiskCtrlSys/1vTnFYHJQm/xmlenc-0.52.jar:/root/CmbRiskCtrlSys/Eote2MHMbH/commons-httpclient-3.1.jar:/root/CmbRiskCtrlSys/I3jk0ykDVK/commons-net-3.1.jar:/root/CmbRiskCtrlSys/9XGybDfCfR/servlet-api-2.5.jar:/root/CmbRiskCtrlSys/pGQ6BdmWz6/jetty-6.1.26.jar:/root/CmbRiskCtrlSys/RDUqUeS7sA/jetty-util-6.1.26.jar:/root/CmbRiskCtrlSys/9V4NwasADY/jetty-sslengine-6.1.26.jar:/root/CmbRiskCtrlSys/yS5UBThaRa/jsp-api-2.1.jar:/root/CmbRiskCtrlSys/PjxQx9ljHV/jersey-core-1.9.jar:/root/CmbRiskCtrlSys/8wYpnGDzbA/jersey-json-1.9.jar:/root/CmbRiskCtrlSys/USKq4vnO2G/jettison-1.1.jar:/root/CmbRiskCtrlSys/TRVwJ1kzhr/jaxb-impl-2.2.3-1.jar:/root/CmbRiskCtrlSys/XpaySEBZmC/jaxb-api-2.3.1.jar:/root/CmbRiskCtrlSys/7t0pgn1ojQ/javax.activation-api-1.2.0.jar:/root/CmbRiskCtrlSys/gKDOArSbwQ/jackson-jaxrs-1.8.3.jar:/root/CmbRiskCtrlSys/lcVqPt72q0/jackson-xc-1.8.3.jar:/root/CmbRiskCtrlSys/d6qdj0gRl7/jersey-server-1.9.jar:/root/CmbRiskCtrlSys/wQokXYVDdZ/asm-3.1.jar:/root/CmbRiskCtrlSys/gloxmdTrEw/log4j-1.2.17.jar:/root/CmbRiskCtrlSys/iP3AVXyL3a/jets3t-0.9.0.jar:/root/CmbRiskCtrlSys/gwe1cpxhNc/java-xmlbuilder-0.4.jar:/root/CmbRiskCtrlSys/rnyu8L1pNr/commons-lang-2.6.jar:/root/CmbRiskCtrlSys/PBGuQX6IQ6/commons-configuration-1.6.jar:/root/CmbRiskCtrlSys/zoa5vZXCT8/commons-digester-1.8.jar:/root/CmbRiskCtrlSys/eeVDc4Lf6q/commons-beanutils-1.7.0.jar:/root/CmbRiskCtrlSys/DMCO5hTJ8N/commons-beanutils-core-1.8.0.jar:/root/CmbRiskCtrlSys/vuNp0rXYF2/slf4j-reload4j-1.7.36.jar:/root/CmbRiskCtrlSys/P6SMbmMZtu/reload4j-1.2.19.jar:/root/CmbRiskCtrlSys/8r31E55mFp/jackson-core-asl-1.9.13.jar:/root/CmbRiskCtrlSys/u6cRuwdAMA/jackson-mapper-asl-1.9.13.jar:/root/CmbRiskCtrlSys/mpDOcuV8im/avro-1.7.4.jar:/root/CmbRiskCtrlSys/KgSW9mTvj7/paranamer-2.3.jar:/root/CmbRiskCtrlSys/P2MRsah8Bn/jsch-0.1.54.jar:/root/CmbRiskCtrlSys/wa3ifEq2vn/curator-client-2.7.1.jar:/root/CmbRiskCtrlSys/nNj2KLSQ2R/curator-recipes-2.7.1.jar:/root/CmbRiskCtrlSys/w2WMRWe9cE/htrace-core-3.1.0-incubating.jar:/root/CmbRiskCtrlSys/LwQ9YVImWu/fastjson2-2.0.12.jar:/root/CmbRiskCtrlSys/y5gV4VXWCW/fastjson2-extension-2.0.12.jar:/root/CmbRiskCtrlSys/erB0n5bhSw/spring-boot-starter-2.6.11.jar:/root/CmbRiskCtrlSys/gGpHA84QeK/spring-boot-2.6.11.jar:/root/CmbRiskCtrlSys/JgueryYSuc/spring-context-5.3.22.jar:/root/CmbRiskCtrlSys/JrSANlE8V4/spring-beans-5.3.22.jar:/root/CmbRiskCtrlSys/967Iv1QzGQ/spring-expression-5.3.22.jar:/root/CmbRiskCtrlSys/rld2gBVRQn/spring-boot-autoconfigure-2.6.11.jar:/root/CmbRiskCtrlSys/URWqtuF3zS/jakarta.annotation-api-1.3.5.jar:/root/CmbRiskCtrlSys/ZZNFp24wLz/spring-core-5.3.22.jar:/root/CmbRiskCtrlSys/F7a8JVL0HA/spring-jcl-5.3.22.jar:/root/CmbRiskCtrlSys/l4ywkRjS7F/snakeyaml-1.29.jar:/root/CmbRiskCtrlSys/YXhhDe8ckE/spring-boot-starter-test-2.6.11.jar:/root/CmbRiskCtrlSys/bhzIOSxd22/spring-boot-test-2.6.11.jar:/root/CmbRiskCtrlSys/lJDfiiYkk7/spring-boot-test-autoconfigure-2.6.11.jar:/root/CmbRiskCtrlSys/2i1rWpi9aL/json-path-2.6.0.jar:/root/CmbRiskCtrlSys/2jXKdBUYrl/json-smart-2.4.8.jar:/root/CmbRiskCtrlSys/cjcS64Iiwu/accessors-smart-2.4.8.jar:/root/CmbRiskCtrlSys/yY8psceH52/asm-9.1.jar:/root/CmbRiskCtrlSys/GuvjlLJm8O/jakarta.xml.bind-api-2.3.3.jar:/root/CmbRiskCtrlSys/3jFvkL1EbA/jakarta.activation-api-1.2.2.jar:/root/CmbRiskCtrlSys/WHeT9Lg7Md/assertj-core-3.21.0.jar:/root/CmbRiskCtrlSys/wz8dIQeF8R/hamcrest-2.2.jar:/root/CmbRiskCtrlSys/nPtz2MAjiI/mockito-core-4.0.0.jar:/root/CmbRiskCtrlSys/7Ei93IQLEG/byte-buddy-1.11.22.jar:/root/CmbRiskCtrlSys/Em5YVMnLgC/byte-buddy-agent-1.11.22.jar:/root/CmbRiskCtrlSys/g2EG4nJi35/objenesis-3.2.jar:/root/CmbRiskCtrlSys/S9YBXFnDjL/mockito-junit-jupiter-4.0.0.jar:/root/CmbRiskCtrlSys/lSMnackccr/jsonassert-1.5.1.jar:/root/CmbRiskCtrlSys/15whDq4nGN/android-json-0.0.20131108.vaadin1.jar:/root/CmbRiskCtrlSys/dfEXBv16hx/spring-test-5.3.22.jar:/root/CmbRiskCtrlSys/5PQT8ZPEYA/xmlunit-core-2.8.4.jar:/root/CmbRiskCtrlSys/BAVCOG0YVz/lombok-1.18.22.jar com.intellij.rt.junit.JUnitStarter -ideVersion5 -junit5 com.cmb.risksys.flink.utils.KafkaUtilTest,testRead
SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/root/CmbRiskCtrlSys/e16HxJVdsh/log4j-slf4j-impl-2.18.0.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/root/CmbRiskCtrlSys/vuNp0rXYF2/slf4j-reload4j-1.7.36.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]

org.apache.flink.runtime.client.JobExecutionException: Job execution failed.

	at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144)
	at org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:137)
	at java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616)
	at java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591)
	at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
	at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
	at org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$1(AkkaInvocationHandler.java:258)
	at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
	at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
	at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
	at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
	at org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1389)
	at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$null$1(ClassLoadingUtils.java:93)
	at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
	at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$2(ClassLoadingUtils.java:92)
	at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
	at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
	at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
	at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
	at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$1.onComplete(AkkaFutureUtils.java:47)
	at akka.dispatch.OnComplete.internal(Future.scala:300)
	at akka.dispatch.OnComplete.internal(Future.scala:297)
	at akka.dispatch.japi$CallbackBridge.apply(Future.scala:224)
	at akka.dispatch.japi$CallbackBridge.apply(Future.scala:221)
	at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60)
	at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$DirectExecutionContext.execute(AkkaFutureUtils.java:65)
	at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68)
	at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284)
	at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284)
	at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284)
	at akka.pattern.PromiseActorRef.$bang(AskSupport.scala:621)
	at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:24)
	at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:23)
	at scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532)
	at scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29)
	at scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29)
	at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60)
	at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:63)
	at akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:100)
	at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12)
	at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:81)
	at akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:100)
	at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:49)
	at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:48)
	at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
	at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
	at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
	at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy
	at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138)
	at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82)
	at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:252)
	at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:242)
	at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:233)
	at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:684)
	at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:79)
	at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:444)
	at sun.reflect.GeneratedMethodAccessor9.invoke(Unknown Source)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:498)
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:316)
	at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:314)
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217)
	at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78)
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163)
	at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
	at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
	at scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
	at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
	at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
	at akka.actor.Actor.aroundReceive(Actor.scala:537)
	at akka.actor.Actor.aroundReceive$(Actor.scala:535)
	at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)
	at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580)
	at akka.actor.ActorCell.invoke(ActorCell.scala:548)
	at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
	at akka.dispatch.Mailbox.run(Mailbox.scala:231)
	at akka.dispatch.Mailbox.exec(Mailbox.scala:243)
	... 4 more
Caused by: java.io.IOException: Failed to deserialize consumer record due to
	at org.apache.flink.connector.kafka.source.reader.KafkaRecordEmitter.emitRecord(KafkaRecordEmitter.java:54)
	at org.apache.flink.connector.kafka.source.reader.KafkaRecordEmitter.emitRecord(KafkaRecordEmitter.java:32)
	at org.apache.flink.connector.base.source.reader.SourceReaderBase.pollNext(SourceReaderBase.java:143)
	at org.apache.flink.streaming.api.operators.SourceOperator.emitNext(SourceOperator.java:354)
	at org.apache.flink.streaming.runtime.io.StreamTaskSourceInput.emitNext(StreamTaskSourceInput.java:68)
	at org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65)
	at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:496)
	at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:203)
	at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:809)
	at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:761)
	at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958)
	at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:937)
	at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:766)
	at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575)
	at java.lang.Thread.run(Thread.java:750)
Caused by: java.io.IOException: Failed to deserialize consumer record ConsumerRecord(topic = imoocevent, partition = 0, leaderEpoch = 0, offset = 0, CreateTime = 1694306713601, serialized key size = -1, serialized value size = 3, headers = RecordHeaders(headers = [], isReadOnly = false), key = null, value = [B@3e2c9219).
	at org.apache.flink.connector.kafka.source.reader.deserializer.KafkaDeserializationSchemaWrapper.deserialize(KafkaDeserializationSchemaWrapper.java:57)
	at org.apache.flink.connector.kafka.source.reader.KafkaRecordEmitter.emitRecord(KafkaRecordEmitter.java:51)
	... 14 more
Caused by: com.alibaba.fastjson2.JSONException: illegal character 桩, offset 1, character 桩, line 1, column 2, fastjson-version 2.0.12 桩�
	at com.alibaba.fastjson2.JSONReaderUTF16.readFieldNameHashCode(JSONReaderUTF16.java:786)
	at com.alibaba.fastjson2.reader.ObjectReader_1.readObject(Unknown Source)
	at com.alibaba.fastjson2.JSON.parseObject(JSON.java:459)
	at com.cmb.risksys.utils.json.JsonUtils.jsonStr2Obj(JsonUtils.java:32)
	at com.cmb.risksys.flink.kafka.CmbDeserializationSchema.deserialize(CmbDeserializationSchema.java:55)
	at com.cmb.risksys.flink.kafka.CmbDeserializationSchema.deserialize(CmbDeserializationSchema.java:29)
	at org.apache.flink.streaming.connectors.kafka.KafkaDeserializationSchema.deserialize(KafkaDeserializationSchema.java:79)
	at org.apache.flink.connector.kafka.source.reader.deserializer.KafkaDeserializationSchemaWrapper.deserialize(KafkaDeserializationSchemaWrapper.java:54)
	... 15 more


Process finished with exit code 255

Answer 1

小简同学 2023-09-15 16:35:18

同学你好, 可以更新git，重新安装一下, 执行脚本 sh bin/flume-to-kafka.sh，将数据导入到flume和kafka， 再通过idea拉取kafka数据，应该不会有报错，我测试过 10万的数据读取，都没有报反序列的错误。你可以试一下。

• 提问者 maomaoking #1

  我本周回去试试

• 提问者 maomaoking #2

  非常感谢！

• 提问者 maomaoking #3

  老师，我刚试了，更新git后，重新安装，重跑后，反序列化没有问题，谢谢老师！