[ 
https://issues.apache.org/jira/browse/NIFI-13352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17851837#comment-17851837
 ] 

ASF subversion and git services commented on NIFI-13352:
--------------------------------------------------------

Commit ab2cea4c229f71ff9c967cb36e70328b3027fa57 in nifi's branch 
refs/heads/main from David Handermann
[ https://gitbox.apache.org/repos/asf?p=nifi.git;h=ab2cea4c22 ]

NIFI-13352 Adjusted Shutdown handling in ListenOTLP and Test Class
This closes #8913

- Added quick duration for shutdown quiet period in ListenOTLP HttpServerFactory
- Added TestRunner.stop() to ListenOTLPTest to close listening sockets
- Increased Connect Timeout from 5 to 10 seconds in ListenOTLPTest

Signed-off-by: Joseph Witt <joew...@apache.org>


> Intermittent Failures in ListenOTLPTest
> ---------------------------------------
>
>                 Key: NIFI-13352
>                 URL: https://issues.apache.org/jira/browse/NIFI-13352
>             Project: Apache NiFi
>          Issue Type: Bug
>          Components: Extensions
>    Affects Versions: 2.0.0-M3
>            Reporter: David Handermann
>            Assignee: David Handermann
>            Priority: Major
>          Time Spent: 0.5h
>  Remaining Estimate: 0h
>
> The {{ListenOTLPTest}} throws failures intermittently when running on GitHub 
> Actions, related to socket connection issues.
> {noformat}
> Error:  Tests run: 11, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 
> 4.199 s <<< FAILURE! -- in 
> org.apache.nifi.processors.opentelemetry.ListenOTLPTest
> Error:  
> org.apache.nifi.processors.opentelemetry.ListenOTLPTest.testGetMethodNotAllowed
>  -- Time elapsed: 0.054 s <<< ERROR!
> org.apache.nifi.web.client.api.WebClientServiceException: Request execution 
> failed HTTP Method [GET] URI [https://localhost:65351/v1/logs]
>       at 
> org.apache.nifi.web.client.StandardWebClientService$StandardHttpRequestBodySpec.execute(StandardWebClientService.java:273)
>       at 
> org.apache.nifi.web.client.StandardWebClientService$StandardHttpRequestBodySpec.retrieve(StandardWebClientService.java:258)
>       at 
> org.apache.nifi.processors.opentelemetry.ListenOTLPTest.testGetMethodNotAllowed(ListenOTLPTest.java:225)
>       at java.base/java.lang.reflect.Method.invoke(Method.java:580)
>       at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
>       at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
> Caused by: java.net.ConnectException: Failed to connect to 
> localhost/[0:0:0:0:0:0:0:1]:65351
>       at 
> okhttp3.internal.connection.RealConnection.connectSocket(RealConnection.kt:297)
>       at 
> okhttp3.internal.connection.RealConnection.connect(RealConnection.kt:207)
>       at 
> okhttp3.internal.connection.ExchangeFinder.findConnection(ExchangeFinder.kt:226)
>       at 
> okhttp3.internal.connection.ExchangeFinder.findHealthyConnection(ExchangeFinder.kt:106)
>       at okhttp3.internal.connection.ExchangeFinder.find(ExchangeFinder.kt:74)
>       at 
> okhttp3.internal.connection.RealCall.initExchange$okhttp(RealCall.kt:255)
>       at 
> okhttp3.internal.connection.ConnectInterceptor.intercept(ConnectInterceptor.kt:32)
>       at 
> okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.kt:109)
>       at 
> okhttp3.internal.cache.CacheInterceptor.intercept(CacheInterceptor.kt:95)
>       at 
> okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.kt:109)
>       at 
> okhttp3.internal.http.BridgeInterceptor.intercept(BridgeInterceptor.kt:83)
>       at 
> okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.kt:109)
>       at 
> okhttp3.internal.http.RetryAndFollowUpInterceptor.intercept(RetryAndFollowUpInterceptor.kt:76)
>       at 
> okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.kt:109)
>       at 
> okhttp3.internal.connection.RealCall.getResponseWithInterceptorChain$okhttp(RealCall.kt:201)
>       at okhttp3.internal.connection.RealCall.execute(RealCall.kt:154)
>       at 
> org.apache.nifi.web.client.StandardWebClientService$StandardHttpRequestBodySpec.execute(StandardWebClientService.java:271)
>       ... 5 more
>       Suppressed: java.net.SocketException: An established connection was 
> aborted by the software in your host machine
>               at java.base/sun.nio.ch.SocketDispatcher.read0(Native Method)
>               at 
> java.base/sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:46)
>               at 
> java.base/sun.nio.ch.NioSocketImpl.tryRead(NioSocketImpl.java:262)
>               at 
> java.base/sun.nio.ch.NioSocketImpl.implRead(NioSocketImpl.java:313)
>               at 
> java.base/sun.nio.ch.NioSocketImpl.read(NioSocketImpl.java:352)
>               at 
> java.base/sun.nio.ch.NioSocketImpl$1.read(NioSocketImpl.java:802)
>               at 
> java.base/java.net.Socket$SocketInputStream.read(Socket.java:1111)
>               at 
> java.base/sun.security.ssl.SSLSocketInputRecord.read(SSLSocketInputRecord.java:489)
>               at 
> java.base/sun.security.ssl.SSLSocketInputRecord.readHeader(SSLSocketInputRecord.java:483)
>               at 
> java.base/sun.security.ssl.SSLSocketInputRecord.bytesInCompletePacket(SSLSocketInputRecord.java:70)
>               at 
> java.base/sun.security.ssl.SSLSocketImpl.readApplicationRecord(SSLSocketImpl.java:1461)
>               at 
> java.base/sun.security.ssl.SSLSocketImpl$AppInputStream.read(SSLSocketImpl.java:1066)
>               at okio.InputStreamSource.read(JvmOkio.kt:93)
>               at okio.AsyncTimeout$source$1.read(AsyncTimeout.kt:153)
>               at okio.RealBufferedSource.request(RealBufferedSource.kt:210)
>               at okio.RealBufferedSource.require(RealBufferedSource.kt:203)
>               at 
> okhttp3.internal.http2.Http2Reader.nextFrame(Http2Reader.kt:89)
>               at 
> okhttp3.internal.http2.Http2Connection$ReaderRunnable.invoke(Http2Connection.kt:618)
>               at 
> okhttp3.internal.http2.Http2Connection$ReaderRunnable.invoke(Http2Connection.kt:609)
>               at 
> okhttp3.internal.concurrent.TaskQueue$execute$1.runOnce(TaskQueue.kt:98)
>               at 
> okhttp3.internal.concurrent.TaskRunner.runTask(TaskRunner.kt:116)
>               at 
> okhttp3.internal.concurrent.TaskRunner.access$runTask(TaskRunner.kt:42)
>               at 
> okhttp3.internal.concurrent.TaskRunner$runnable$1.run(TaskRunner.kt:65)
>               at 
> java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
>               at 
> java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
>               at java.base/java.lang.Thread.run(Thread.java:1583)
> Caused by: java.net.ConnectException: Connection refused: getsockopt
>       at java.base/sun.nio.ch.Net.pollConnect(Native Method)
>       at java.base/sun.nio.ch.Net.pollConnectNow(Net.java:682)
>       at 
> java.base/sun.nio.ch.NioSocketImpl.timedFinishConnect(NioSocketImpl.java:548)
>       at java.base/sun.nio.ch.NioSocketImpl.connect(NioSocketImpl.java:598)
>       at java.base/java.net.SocksSocketImpl.connect(SocksSocketImpl.java:327)
>       at java.base/java.net.Socket.connect(Socket.java:759)
>       at okhttp3.internal.platform.Platform.connectSocket(Platform.kt:128)
>       at 
> okhttp3.internal.connection.RealConnection.connectSocket(RealConnection.kt:295)
>       ... 21 more
> {noformat}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to