1 réponse
- Le plus récent
- Le plus de votes
- La plupart des commentaires
Contenus pertinents
- demandé il y a 2 mois
- demandé il y a un an
- demandé il y a 7 mois
- AWS OFFICIELA mis à jour il y a 6 mois
- AWS OFFICIELA mis à jour il y a 4 ans
- AWS OFFICIELA mis à jour il y a 6 mois
- AWS OFFICIELA mis à jour il y a 4 ans
Follow the error: An error was encountered: [STREAM_FAILED] Query [id = 8e197d37-61c3-48de-b388-b5b7e4b0078d, runId = 7a4bf9bb-97af-495e-8f61-edd54ef7d8dc] terminated with exception: Unable to fetch committed metadata from previous batch id 0. Some data may have been missed Traceback (most recent call last): File "/mnt1/yarn/usercache/livy/appcache/application_1709526661976_0019/container_1709526661976_0019_01_000001/pyspark.zip/pyspark/sql/streaming/query.py", line 221, in awaitTermination return self._jsq.awaitTermination() File "/mnt1/yarn/usercache/livy/appcache/application_1709526661976_0019/container_1709526661976_0019_01_000001/py4j-0.10.9.7-src.zip/py4j/java_gateway.py", line 1322, in call return_value = get_return_value( File "/mnt1/yarn/usercache/livy/appcache/application_1709526661976_0019/container_1709526661976_0019_01_000001/pyspark.zip/pyspark/errors/exceptions/captured.py", line 185, in deco raise converted from None pyspark.errors.exceptions.captured.StreamingQueryException: [STREAM_FAILED] Query [id = 8e197d37-61c3-48de-b388-b5b7e4b0078d, runId = 7a4bf9bb-97af-495e-8f61-edd54ef7d8dc] terminated with exception: Unable to fetch committed metadata from previous batch id 0. Some data may have been missed
also I follow this example: https://github.com/aws-samples/spark-kinesis-connector-emr-sample