akashk99 commented on issue #31313: URL: https://github.com/apache/beam/issues/31313#issuecomment-2153313439
Hi @je-ik , was just able to reproduce the issue by manually running the jar file. Started the job by running `java -cp <jar> <class> --runner=flink --flinkMaster=...` and then used `flink stop` with savepoint to take a savepoint. afterwards, I reran, `java -cp <jar> <class> --runner=flink --flinkMaster=... --savepointPath=...` with the snapshot I just took. After observing the task manager logs, I see: ``` Terminal Log: Jun 06, 2024 12:55:08 PM org.apache.flink.client.program.rest.RestClusterClient lambda$null$6 INFO: Successfully submitted job <jobName> (6651a9570e4c9d1df81539b07e6e91ce) to 'http://localhost:8081'. Task Manager Logs: 2024-06-06 12:55:11,979 INFO org.apache.beam.sdk.io.aws2.kinesis.SimplifiedKinesisClient [] - Starting getIterator request GetShardIteratorRequest(StreamName=<streamName>, ShardId=shardId-000000000012, ShardIteratorType=AT_SEQUENCE_NUMBER, 2024-06-06 12:55:13,279 INFO org.apache.beam.sdk.io.aws2.kinesis.SimplifiedKinesisClient [] - Starting getIterator request GetShardIteratorRequest(StreamName=<streamName>, ShardId=shardId-000000000012, ShardIteratorType=LATEST) ``` this was a few seconds after the job was submitted. I trimmed the output, but these two logs were there for all of my shards. -- 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]
