EOFException while listening to open_events after several hours

21 views

Skip to first unread message

DMJessieSP

unread,

Apr 30, 2017, 3:40:48 PM4/30/17

to Meetup API

I get a EOFException (see stack trace below) after several hours of streaming open_events. I know the stream didn't end as it is an endless stream and it isn't an internet connection issue as I tried disconnecting and it led to a java.net.SocketException: Software caused connection abort: recv failed. It happened after streaming open_events for about 4 hours. I tried streaming photos too to see the difference, and for photos it happened after only about 10-15 minutes. I tried pasting http://stream.meetup.com/2/open_events directly into chrome, and that stream stops when I get the EOFException, but when opening a new tab in chrome with the stream it works without a problem, while the stream in the first tab is still stuck. I have researched this and the most common reason for this exception is a malformed response from the server. What could be the problem and how can I solve this?

Stack trace:

java.io.EOFException

at okio.RealBufferedSource.require(RealBufferedSource.java:64)

at okio.RealBufferedSource.readHexadecimalUnsignedLong(RealBufferedSource.java:270)

at okhttp3.internal.http1.Http1Codec$ChunkedSource.readChunkSize(Http1Codec.java:444)

at okhttp3.internal.http1.Http1Codec$ChunkedSource.read(Http1Codec.java:425)

at okio.RealBufferedSource.read(RealBufferedSource.java:50)

at okio.ForwardingSource.read(ForwardingSource.java:35)

at retrofit2.OkHttpCall$ExceptionCatchingRequestBody$1.read(OkHttpCall.java:285)

at okio.RealBufferedSource.exhausted(RealBufferedSource.java:60)

at com.example.meetup.MeetupListener$1.call(MeetupListener.java:159)

at com.example.meetup.MeetupListener$1.call(MeetupListener.java:153)

at rx.Observable.unsafeSubscribe(Observable.java:8666)

at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:250)

at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:147)

at rx.internal.operators.OperatorMap$MapSubscriber.onNext(OperatorMap.java:74)

at rx.internal.operators.OperatorMerge$MergeSubscriber.emitScalar(OperatorMerge.java:505)

at rx.internal.operators.OperatorMerge$MergeSubscriber.tryEmit(OperatorMerge.java:463)

at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:246)

at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:147)

at rx.internal.operators.OperatorMap$MapSubscriber.onNext(OperatorMap.java:74)

at retrofit2.adapter.rxjava.RxJavaCallAdapterFactory$CallOnSubscribe.call(RxJavaCallAdapterFactory.java:146)

at retrofit2.adapter.rxjava.RxJavaCallAdapterFactory$CallOnSubscribe.call(RxJavaCallAdapterFactory.java:125)

at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:50)

at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)

at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:50)

at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)

at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:50)

at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)

at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:50)

at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)

at rx.Observable.subscribe(Observable.java:8759)

at rx.Observable.subscribe(Observable.java:8726)

at rx.Observable.subscribe(Observable.java:8549)

at com.example.meetup.MeetupListener.<init>(MeetupListener.java:144)

at com.example.meetup.MeetupApplication.main(MeetupApplication.java:16)

at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)

at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)

at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)

at java.lang.reflect.Method.invoke(Method.java:498)

at com.intellij.rt.execution.application.AppMain.main(AppMain.java:147)

Exception in thread "main" rx.exceptions.OnErrorNotImplementedException

at rx.internal.util.InternalObservableUtils$ErrorNotImplementedAction.call(InternalObservableUtils.java:386)

at rx.internal.util.InternalObservableUtils$ErrorNotImplementedAction.call(InternalObservableUtils.java:383)

at rx.internal.util.ActionSubscriber.onError(ActionSubscriber.java:44)

at rx.observers.SafeSubscriber._onError(SafeSubscriber.java:157)

at rx.observers.SafeSubscriber.onError(SafeSubscriber.java:120)

at rx.internal.operators.OperatorMerge$MergeSubscriber.reportError(OperatorMerge.java:268)

at rx.internal.operators.OperatorMerge$MergeSubscriber.checkTerminate(OperatorMerge.java:812)

at rx.internal.operators.OperatorMerge$MergeSubscriber.emitLoop(OperatorMerge.java:573)

at rx.internal.operators.OperatorMerge$MergeSubscriber.emit(OperatorMerge.java:562)

at rx.internal.operators.OperatorMerge$InnerSubscriber.onError(OperatorMerge.java:846)

at com.example.meetup.MeetupListener$1.call(MeetupListener.java:170)