[
https://issues.apache.org/jira/browse/ASTERIXDB-1385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15221944#comment-15221944
]
Abdullah Alamoudi commented on ASTERIXDB-1385:
----------------------------------------------
The thing is that socket data source is expected to handle a socket connection
at a time and when it is done with a connection, it listens for the next one.
If we stop the socket at a point when it is waiting for a new connection, this
exception will not happen. In this specific test case, <The only test case
where there is a 4 seconds wait>, sometimes, we disconnect the feed before it
has read all the input. Hence, sometimes we see this stack trace.
We swallow the exception so nothing bad happens. but we just log it and do
nothing else.
Not sure if we want to do something about this or not.
> Swallowed "java.net.SocketException: Socket closed" exception in feeds test
> using socket adapter
> ------------------------------------------------------------------------------------------------
>
> Key: ASTERIXDB-1385
> URL: https://issues.apache.org/jira/browse/ASTERIXDB-1385
> Project: Apache AsterixDB
> Issue Type: Bug
> Components: Feeds
> Reporter: Ildar Absalyamov
> Assignee: Abdullah Alamoudi
> Priority: Minor
>
> When executing socket-based feed test (e.g.
> runtiments/feeds/feed-push-socket) the following exception gets written into
> the output. The exception is swallowed and does not seem to break anything,
> but if that's completely normal situation should the stacktrace be even
> logged?
> {noformat}
> java.net.SocketException: Socket closed
> at java.net.SocketInputStream.socketRead0(Native Method)
> at java.net.SocketInputStream.socketRead(SocketInputStream.java:116)
> at java.net.SocketInputStream.read(SocketInputStream.java:170)
> at java.net.SocketInputStream.read(SocketInputStream.java:141)
> at
> org.apache.asterix.external.input.stream.SocketServerInputStream.read(SocketServerInputStream.java:73)
> at
> org.apache.asterix.external.input.stream.AsterixInputStreamReader.read(AsterixInputStreamReader.java:92)
> at
> org.apache.asterix.external.input.stream.AsterixInputStreamReader.read(AsterixInputStreamReader.java:65)
> at
> org.apache.asterix.external.input.record.reader.stream.SemiStructuredRecordReader.hasNext(SemiStructuredRecordReader.java:84)
> at
> org.apache.asterix.external.dataflow.FeedRecordDataFlowController.start(FeedRecordDataFlowController.java:62)
> at
> org.apache.asterix.external.dataset.adapter.FeedAdapter.start(FeedAdapter.java:36)
> at
> org.apache.asterix.external.feed.runtime.AdapterExecutor.run(AdapterExecutor.java:59)
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
> at java.lang.Thread.run(Thread.java:745)
> {noformat}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
