Я работаю над потоковой передачей Kafka Spark с использованием Java, когда я выполняю writeStream () для консоли, я получаю ошибку ниже.
18/06/11 22:26:59 ERROR MicroBatchExecution: Query [id = 38e7ebe2-41bb-40e7-83fa-6c14aad5e519, runId = b09f10fd-c594-424b-ba7a-42b2747ed7fd] terminated with error java.lang.IllegalArgumentException: Expected e.g. {"topicA":{"0":23,"1":-1},"topicB":{"0":-2}}, got from-beginning. Exception in thread "main" org.apache.spark.sql.streaming.StreamingQueryException: Expected e.g. {"topicA":{"0":23,"1":-1},"topicB":{"0":-2}}, got from-beginning. === Streaming Query === Identifier: [id = 38e7ebe2-41bb-40e7-83fa-6c14aad5e519, runId = b09f10fd-c594-424b-ba7a-42b2747ed7fd]
Я пытался расширить SparkQueryException, но безрезультатно.Почему это происходит и как я могу это исправить.