TheNeuralBit commented on issue #22606: URL: https://github.com/apache/beam/issues/22606#issuecomment-1212224095
It looks like that might be an issue in the Python expansion service, which we should track down (the full stacktrace for the signal.pause error would help here). But that shouldn't actually block your specific application. In your case you'll need a Java expansion service (since KafkaIO is a Java transform). If you can share the full stacktrace for the first RuntimeError you got we can help diagnose the issue there. One possible cause: do you have Java installed? -- 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]
