KannarFr commented on issue #5006: AvroSchema in pulsar function producer doesn't output correct message URL: https://github.com/apache/pulsar/issues/5006#issuecomment-524127712 Oh just remember about the version brokers v2.5.0-SNAPSHOT from monday (to handle the fix on schema deletion). Bookies are v2.4.0. I've got a broker exception: ``` Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: 00:30:16.991 [pulsar-io-22-5] WARN org.apache.pulsar.broker.service.ServerCnx - [/192.168.10.15:42368] Got exception BufferUnderflowException : null Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: java.nio.BufferUnderflowException: null Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at java.nio.Buffer.nextGetIndex(Buffer.java:506) ~[?:1.8.0_192] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at java.nio.HeapByteBuffer.getLong(HeapByteBuffer.java:412) ~[?:1.8.0_192] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at org.apache.pulsar.broker.service.schema.BookkeeperSchemaStorage.versionFromBytes(BookkeeperSchemaStorage.java:206) ~[org.apache.pulsar-pulsar-broker-2.5.0-SNAPSHOT.jar:2.5.0-SNAPSHOT] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at org.apache.pulsar.broker.service.schema.SchemaRegistryServiceImpl.versionFromBytes(SchemaRegistryServiceImpl.java:196) ~[org.apache.pulsar-pulsar-broker-2.5.0-SNAPSHOT.jar:2.5.0-SNAPSHOT] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at org.apache.pulsar.broker.service.schema.validator.SchemaRegistryServiceWithSchemaDataValidator.versionFromBytes(SchemaRegistryServiceWithSchemaDataValidator.java:106) ~[org.apache.pulsar-pulsar-broker-2.5.0-SNAPSHOT.jar:2.5.0-SNAPSHOT] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at org.apache.pulsar.broker.service.ServerCnx.handleGetSchema(ServerCnx.java:1334) ~[org.apache.pulsar-pulsar-broker-2.5.0-SNAPSHOT.jar:2.5.0-SNAPSHOT] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at org.apache.pulsar.common.protocol.PulsarDecoder.channelRead(PulsarDecoder.java:306) ~[org.apache.pulsar-pulsar-common-2.5.0-SNAPSHOT.jar:2.5.0-SNAPSHOT] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:323) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:297) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1434) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:965) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:799) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:433) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:330) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:909) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final] Aug 23 00:30:16 yo-pulsar-c1-n1 pulsar-broker[21249]: at java.lang.Thread.run(Thread.java:748) [?:1.8.0_192] ``` No errors client side.
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
