-
Bug
-
Resolution: Done
-
Major
-
2.1.3.Final, 2.2.0.Beta1
-
None
-
False
-
None
-
False
-
-
When an Infinispan cache entry is evicted and reloaded from disk or deserialized from a remote cache, the deserialization fails with the following failure related to the existing test associated with DBZ-6120, which creates a table with a space in its name:
2023-04-01 11:58:03,750 ERROR OracleConnectorIT||engine Error while trying to run connector class 'io.debezium.connector.oracle.OracleConnector' [io.debezium.connector.oracle.OracleConnectorIT] org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped. at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:53) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:226) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:60) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:174) at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:141) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:109) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at java.base/java.lang.Thread.run(Thread.java:833) Caused by: org.infinispan.client.hotrod.exceptions.HotRodClientException: ISPN004034: Unable to unmarshall bytes 820108446D6C4576656E748A01840108011207353536393737311A194F52434C504442312E444542455A49554D2E51312120E8A1A8221241414153564441414D414141425A634141422A182030783030303032352E30303033613130382E30303130203214323032332D30342D30315431353A35383A30325A3A180801120132220751312120E8A1A82A08444542455A49554D at org.infinispan.client.hotrod.marshall.MarshallerUtil.bytes2obj(MarshallerUtil.java:74) at org.infinispan.client.hotrod.DataFormat.valueToObj(DataFormat.java:155) at org.infinispan.client.hotrod.impl.operations.GetOperation.acceptResponse(GetOperation.java:45) at org.infinispan.client.hotrod.impl.transport.netty.HeaderDecoder.decode(HeaderDecoder.java:146) at org.infinispan.client.hotrod.impl.transport.netty.HintedReplayingDecoder.callDecode(HintedReplayingDecoder.java:94) at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:279) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357) at io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:286) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357) at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919) at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:166) at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:722) at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:658) at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:584) at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:496) at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997) at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ... 3 common frames omitted Caused by: java.lang.IllegalArgumentException: Unexpected input: 表 at io.debezium.relational.TableIdParser$ParsingState$3.handleCharacter(TableIdParser.java:154) at io.debezium.relational.TableIdParser$TableIdTokenizer.tokenize(TableIdParser.java:71) at io.debezium.text.TokenStream.start(TokenStream.java:446) at io.debezium.relational.TableIdParser.parse(TableIdParser.java:36) at io.debezium.relational.TableIdParser.parse(TableIdParser.java:30) at io.debezium.relational.TableId.parseParts(TableId.java:80) at io.debezium.relational.TableId.parse(TableId.java:54) at io.debezium.relational.TableId.parse(TableId.java:30) at io.debezium.connector.oracle.logminer.processor.infinispan.marshalling.DmlEventAdapter.factory(DmlEventAdapter.java:54) at io.debezium.connector.oracle.logminer.processor.infinispan.marshalling.DmlEventAdapter$___Marshaller_ae32577eb017d89cb121c27c7fa34887a854760037a89f84046b59276ca6788c.read(DmlEventAdapter$___Marshaller_ae32577eb017d89cb121c27c7fa34887a854760037a89f84046b59276ca6788c.java:127) at io.debezium.connector.oracle.logminer.processor.infinispan.marshalling.DmlEventAdapter$___Marshaller_ae32577eb017d89cb121c27c7fa34887a854760037a89f84046b59276ca6788c.read(DmlEventAdapter$___Marshaller_ae32577eb017d89cb121c27c7fa34887a854760037a89f84046b59276ca6788c.java:15) at org.infinispan.protostream.impl.ProtobufTagMarshallerDelegate.unmarshall(ProtobufTagMarshallerDelegate.java:32) at org.infinispan.protostream.WrappedMessage.readMessage(WrappedMessage.java:539) at org.infinispan.protostream.WrappedMessage.read(WrappedMessage.java:351) at org.infinispan.protostream.ProtobufUtil.fromWrappedByteArray(ProtobufUtil.java:129) at org.infinispan.commons.marshall.ImmutableProtoStreamMarshaller.objectFromByteBuffer(ImmutableProtoStreamMarshaller.java:31) at org.infinispan.commons.marshall.AbstractMarshaller.objectFromByteBuffer(AbstractMarshaller.java:82) at org.infinispan.client.hotrod.marshall.MarshallerUtil.bytes2obj(MarshallerUtil.java:58)
The issue here is that the table name is serialized to the cache as:
ORCLPDB1.DEBEZIUM.Q1! 表
The issue is that the TableIdParser does not expect spaces unless the table name is double-quoted. We should serialize the name of the table into the cache with double quotes, effectively being written with this format:
"ORCLPDB1"."DEBEZIUM"."Q1! 表"
- relates to
-
-
- Closed
-