Kalmár Róbert created NIFI-12036:
------------------------------------
Summary: ListenTCPRecord throws exception when SSL is configured
with JsonTreeReader with infer schema
Key: NIFI-12036
URL: https://issues.apache.org/jira/browse/NIFI-12036
Project: Apache NiFi
Issue Type: Bug
Reporter: Kalmár Róbert
Call stack
{code:java}
2023-09-07 13:39:46,286 ERROR
org.apache.nifi.processors.standard.ListenTCPRecord:
ListenTCPRecord[id=6fdea6b5-018a-1000-0000-000039ac1fb1] Error processing
records: End of Stream found for Channel Read
java.io.EOFException: End of Stream found for Channel Read
at
org.apache.nifi.remote.io.socket.ssl.SSLSocketChannel.unwrapBufferReadChannel(SSLSocketChannel.java:500)
at
org.apache.nifi.remote.io.socket.ssl.SSLSocketChannel.read(SSLSocketChannel.java:347)
at
org.apache.nifi.remote.io.socket.ssl.SSLSocketChannelInputStream.read(SSLSocketChannelInputStream.java:46)
at
java.base/java.io.BufferedInputStream.fill(BufferedInputStream.java:252)
at
java.base/java.io.BufferedInputStream.read1(BufferedInputStream.java:292)
at
java.base/java.io.BufferedInputStream.read(BufferedInputStream.java:351)
at
org.apache.nifi.stream.io.NonCloseableInputStream.read(NonCloseableInputStream.java:48)
at
com.fasterxml.jackson.core.json.UTF8StreamJsonParser._loadMore(UTF8StreamJsonParser.java:258)
at
com.fasterxml.jackson.core.json.UTF8StreamJsonParser._skipWSOrEnd2(UTF8StreamJsonParser.java:3150)
at
com.fasterxml.jackson.core.json.UTF8StreamJsonParser._skipWSOrEnd(UTF8StreamJsonParser.java:3145)
at
com.fasterxml.jackson.core.json.UTF8StreamJsonParser.nextToken(UTF8StreamJsonParser.java:757)
at org.apache.nifi.json.JsonRecordSource.next(JsonRecordSource.java:65)
at org.apache.nifi.json.JsonRecordSource.next(JsonRecordSource.java:32)
at
org.apache.nifi.schema.inference.HierarchicalSchemaInference.inferSchema(HierarchicalSchemaInference.java:45)
at
org.apache.nifi.schema.inference.InferSchemaAccessStrategy.getSchema(InferSchemaAccessStrategy.java:49)
at
org.apache.nifi.serialization.SchemaRegistryService.getSchema(SchemaRegistryService.java:126)
at
org.apache.nifi.json.JsonTreeReader.createRecordReader(JsonTreeReader.java:166)
at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:566)
at
org.apache.nifi.controller.service.StandardControllerServiceInvocationHandler.invoke(StandardControllerServiceInvocationHandler.java:254)
at
org.apache.nifi.controller.service.StandardControllerServiceInvocationHandler.invoke(StandardControllerServiceInvocationHandler.java:105)
at com.sun.proxy.$Proxy203.createRecordReader(Unknown Source)
at
org.apache.nifi.record.listen.SSLSocketChannelRecordReader.createRecordReader(SSLSocketChannelRecordReader.java:69)
at
org.apache.nifi.processors.standard.ListenTCPRecord.onTrigger(ListenTCPRecord.java:364)
at
org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27)
at
org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1361)
at
org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java:247)
at
org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:102)
at org.apache.nifi.engine.FlowEngine$2.run(FlowEngine.java:110)
at
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
at
java.base/java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305)
at
java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305)
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:834) {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
