Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Cannot run Kinesis apps due to "Reached end of STDIN of child process for shard" 2 #9

Closed
nziehn opened this issue May 20, 2015 · 1 comment

Comments

@nziehn
Copy link

nziehn commented May 20, 2015

I am trying to run the vanilla python example sample_kclpy_app.py and get the error listed below.

This seems to be similar to the issue #5 but I haven't made any changes to the code provided in this repository.

I did change the sample.properties file line: executableName = python sample_kclpy_app.py as suggested by this stack overflow answer: http://stackoverflow.com/questions/30043197/how-to-verify-that-amazon-kinesis-python-client-is-working

Without the last change, I don't get the error, but also my script does not seem to be executed (I don't get any log messages from my code and as I understand the comments in #5 I should get INFO log events, right?

May 20, 2015 2:06:17 AM com.amazonaws.services.kinesis.multilang.MultiLangProtocol waitForStatusMessage
SEVERE: Failed to get status message for initialize action for shard shardId-000000000000
java.util.concurrent.ExecutionException: java.lang.RuntimeException: Reached end of STDIN of child process for shard shardId-000000000000 so won't be able to return a message.
at java.util.concurrent.FutureTask.report(FutureTask.java:122)
at java.util.concurrent.FutureTask.get(FutureTask.java:192)
at com.amazonaws.services.kinesis.multilang.MultiLangProtocol.waitForStatusMessage(MultiLangProtocol.java:141)
at com.amazonaws.services.kinesis.multilang.MultiLangProtocol.waitForStatusMessage(MultiLangProtocol.java:116)
at com.amazonaws.services.kinesis.multilang.MultiLangProtocol.initialize(MultiLangProtocol.java:70)
at com.amazonaws.services.kinesis.multilang.MultiLangRecordProcessor.initialize(MultiLangRecordProcessor.java:131)
at com.amazonaws.services.kinesis.clientlibrary.lib.worker.InitializeTask.call(InitializeTask.java:74)
at com.amazonaws.services.kinesis.clientlibrary.lib.worker.MetricsCollectingTaskDecorator.call(MetricsCollectingTaskDecorator.java:48)
at com.amazonaws.services.kinesis.clientlibrary.lib.worker.MetricsCollectingTaskDecorator.call(MetricsCollectingTaskDecorator.java:23)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
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)
Caused by: java.lang.RuntimeException: Reached end of STDIN of child process for shard shardId-000000000000 so won't be able to return a message.
at com.amazonaws.services.kinesis.multilang.GetNextMessageTask.returnAfterEndOfInput(GetNextMessageTask.java:84)
at com.amazonaws.services.kinesis.multilang.GetNextMessageTask.returnAfterEndOfInput(GetNextMessageTask.java:31)
at com.amazonaws.services.kinesis.multilang.LineReaderTask.call(LineReaderTask.java:70)
... 4 more

May 20, 2015 2:06:17 AM com.amazonaws.services.kinesis.multilang.MultiLangRecordProcessor stopProcessing
SEVERE: Encountered an error while trying to initialize record processor
java.lang.RuntimeException: Failed to initialize child process
at     com.amazonaws.services.kinesis.multilang.MultiLangRecordProcessor.initialize(MultiLangRecordProcessor.java:132)
at com.amazonaws.services.kinesis.clientlibrary.lib.worker.InitializeTask.call(InitializeTask.java:74)
at com.amazonaws.services.kinesis.clientlibrary.lib.worker.MetricsCollectingTaskDecorator.call(MetricsCollectingTaskDecorator.java:48)
at com.amazonaws.services.kinesis.clientlibrary.lib.worker.MetricsCollectingTaskDecorator.call(MetricsCollectingTaskDecorator.java:23)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
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)

May 20, 2015 2:06:17 AM com.amazonaws.services.kinesis.multilang.LineReaderTask call
INFO: Starting: Draining STDOUT for shardId-000000000000
May 20, 2015 2:06:17 AM com.amazonaws.services.kinesis.multilang.LineReaderTask call
INFO: Stopping: Draining STDOUT for shardId-000000000000
May 20, 2015 2:06:17 AM com.amazonaws.services.kinesis.multilang.MultiLangRecordProcessor childProcessShutdownSequence
INFO: Child process exited with value: 2
@nziehn
Copy link
Author

nziehn commented May 20, 2015

Sorry, I just had a typo in my properties file.

@nziehn nziehn closed this as completed May 20, 2015
zengyu714 pushed a commit that referenced this issue Dec 29, 2021
Bump jackson-dataformat-cbor from 2.12.4 to 2.13.0 (#6)
Bump auth from 2.17.52 to 2.17.99 (#5)
Bump sts from 2.17.52 to 2.17.99 (#3)
Bump cloudwatch from 2.17.52 to 2.17.99 (#2)
Bump slf4j-api from 1.7.30 to 1.7.32 (#9)
Bump profiles from 2.17.52 to 2.17.99 (#8)
Bump aws-cbor-protocol from 2.17.52 to 2.17.99 (#7)
Bump dynamodb from 2.17.52 to 2.17.102 (#24)
Bump aws-java-sdk-sts from 1.12.3 to 1.12.131 (#23)
Bump aws-query-protocol from 2.17.52 to 2.17.102 (#22)
Bump netty-transport from 4.1.68.Final to 4.1.72.Final (#27)
Bump profiles from 2.17.52 to 2.17.102 (#26)
Bump logback-core from 1.2.7 to 1.2.10 (#28)

Signed-off-by: dependabot[bot] <[email protected]>
Co-Authored-By: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant