[ https://issues.apache.org/jira/browse/SAMZA-723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Navina Ramesh updated SAMZA-723: -------------------------------- Attachment: SAMZA-723-2.patch Merged Yan's patch Here is the RB - https://reviews.apache.org/r/39464/ > hello-samza hangs when we use StreamAppender > -------------------------------------------- > > Key: SAMZA-723 > URL: https://issues.apache.org/jira/browse/SAMZA-723 > Project: Samza > Issue Type: Bug > Components: hello-samza > Affects Versions: 0.10.0 > Reporter: Navina Ramesh > Assignee: Yan Fang > Fix For: 0.10.0 > > Attachments: SAMZA-723-2.patch, SAMZA-723-asynAppender.patch, > SAMZA-723.1.patch > > > I added StreamAppender to log4j.xml , task.log4j.system=kafka in the config > and added a simple log line in process call to see if it creates the logging > event correctly. > When I deploy the job (WikipediaFeedStreamTask.java), the AppMaster seems to > just hang in the bootstrap method. I don’t get any exceptions in the > AppMaster logs. I checked the kafka logs and found some socket closed errors > in the stack trace. > ==> deploy/kafka/logs/kafka.log <== > [2015-06-25 16:48:01,179] ERROR Closing socket for /172.21.132.57 because of > error (kafka.network.Processor) > java.io.IOException: Connection reset by peer > at sun.nio.ch.FileDispatcherImpl.write0(Native Method) > at sun.nio.ch.SocketDispatcher.write(SocketDispatcher.java:47) > at sun.nio.ch.IOUtil.writeFromNativeBuffer(IOUtil.java:93) > at sun.nio.ch.IOUtil.write(IOUtil.java:65) > at sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:471) > at kafka.api.TopicDataSend.writeTo(FetchResponse.scala:123) > at kafka.network.MultiSend.writeTo(Transmission.scala:101) > at kafka.api.FetchResponseSend.writeTo(FetchResponse.scala:231) > at kafka.network.Processor.write(SocketServer.scala:472) > at kafka.network.Processor.run(SocketServer.scala:342) > at java.lang.Thread.run(Thread.java:745) > ==> deploy/kafka/logs/server.log <== > [2015-06-25 16:48:01,179] ERROR Closing socket for /172.21.132.57 because of > error (kafka.network.Processor) > java.io.IOException: Connection reset by peer > at sun.nio.ch.FileDispatcherImpl.write0(Native Method) > at sun.nio.ch.SocketDispatcher.write(SocketDispatcher.java:47) > at sun.nio.ch.IOUtil.writeFromNativeBuffer(IOUtil.java:93) > at sun.nio.ch.IOUtil.write(IOUtil.java:65) > at sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:471) > at kafka.api.TopicDataSend.writeTo(FetchResponse.scala:123) > at kafka.network.MultiSend.writeTo(Transmission.scala:101) > at kafka.api.FetchResponseSend.writeTo(FetchResponse.scala:231) > at kafka.network.Processor.write(SocketServer.scala:472) > at kafka.network.Processor.run(SocketServer.scala:342) > at java.lang.Thread.run(Thread.java:745) > Need to investigate this issue further. looks like the CoordinatorStream is > conflicting with the StreamAppender components. -- This message was sent by Atlassian JIRA (v6.3.4#6332)