ppawel commented on PR #38603: URL: https://github.com/apache/beam/pull/38603#issuecomment-5330160463
@stankiewicz @iht In our tests with this PR on top of Beam 2.75.0 we see in multiple tests some unexpected behavior. Example logs: ``` 2026-08-18 14:02:18,917 WARN [direct-runner-worker] o.a.b.s.i.s.r.SolaceCheckpointMark : SolaceIO.Read: Reader with UUID f2ede850-3831-4937-ba96-75e215b6fa80 not found in registry. Checkpoint 1 cannot be finalized. Messages will be redelivered if session is closed. 2026-08-18 14:02:25,074 INFO [direct-runner-worker] o.a.b.s.i.s.r.UnboundedSolaceReader : SolaceIO.Read: Closing session for the reader with uuid 97959b65-cc77-4aaf-8638-c5b1c14fb67b as it has been idle for over PT1M. 2026-08-18 14:02:25,074 INFO [direct-runner-worker] c.s.j.protocol.impl.TcpClientChannel : Client-2593: Channel Closed (smfclient 2593) 2026-08-18 14:02:41,220 INFO [direct-runner-worker] o.a.b.s.i.s.r.UnboundedSolaceReader : SolaceIO.Read: Closing session for the reader with uuid 3d250516-078b-4013-9403-e5d432e48d23 as it has been idle for over PT1M. 2026-08-18 14:02:41,220 INFO [direct-runner-worker] c.s.j.protocol.impl.TcpClientChannel : Client-2686: Channel Closed (smfclient 2686) 2026-08-18 14:02:48,983 WARN [direct-runner-worker] o.a.b.s.i.s.r.UnboundedSolaceReader : SolaceIO.Read: Checkpoint 1 timed out after 30066ms. Nacking messages. 2026-08-18 14:02:48,984 WARN [pool-2428-thread-1] o.a.b.s.i.s.r.UnboundedSolaceReader : SolaceIO.Read: Failed to nack message 2026-08-18 14:02:48,984 com.solacesystems.jcsmp.InvalidOperationException: Flow does not support outcome FAILED at com.solacesystems.jcsmp.impl.JCSMPXMLMessage.settle(JCSMPXMLMessage.java:575) at com.solacesystems.jcsmp.impl.MessageImpl.settle(MessageImpl.java:43) at org.apache.beam.sdk.io.solace.read.UnboundedSolaceReader.lambda$checkTimeouts$3(UnboundedSolaceReader.java:259) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1090) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:614) at java.base/java.lang.Thread.run(Thread.java:1474) 2026-08-18 14:02:48,984 WARN [pool-2428-thread-2] o.a.b.s.i.s.r.UnboundedSolaceReader : SolaceIO.Read: Failed to nack message 2026-08-18 14:02:48,984 com.solacesystems.jcsmp.InvalidOperationException: Flow does not support outcome FAILED at com.solacesystems.jcsmp.impl.JCSMPXMLMessage.settle(JCSMPXMLMessage.java:575) at com.solacesystems.jcsmp.impl.MessageImpl.settle(MessageImpl.java:43) at org.apache.beam.sdk.io.solace.read.UnboundedSolaceReader.lambda$checkTimeouts$3(UnboundedSolaceReader.java:259) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1090) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:614) at java.base/java.lang.Thread.run(Thread.java:1474) ``` I will analyze this deeper and let you know if I manage to find some useful info. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
