1.背景

spark structured sql 任务启动报错，这个是在一个开发测试集群上是好的，但是移交到测试集群，测试人员进行测试的时候报错。查看程序，感觉没什么问题。

错误如下

19/08/01 17:36:52 WARN consumer.ConsumerConfig: The configuration max.poll.records = 1 was supplied but isn't a known config.
19/08/01 17:36:52 ERROR streaming.StreamExecution: Query topic_lcc [id = fff32e45-d354-4a4f-af2c-106fa9801bd0, runId = 562ca67e-8acd-40eb-9a92-e88a3ed99266] terminated with errorat org.apache.spark.sql.kafka010.SubscribeStrategy.createConsumer(ConsumerStrategy.scala:63)at org.apache.spark.sql.kafka010.KafkaOffsetReader.createConsumer(KafkaOffsetReader.scala:314)at org.apache.spark.sql.kafka010.KafkaOffsetReader.<init>(KafkaOffsetReader.s

ERROR streaming.StreamExecution: Query topic_lcc [id =xx, runId=xx] terminated with error相关推荐

ERROR streaming.StreamExecution：createConsumer(ConsumerStrategy.scala:63)
1. 背景写的Spark Structured SQL 任务,然后用的spark版本为 <spark.version>2.3.0.cloudera2</spark.version& ...
Error:Application and test application id cannot be the same: both are 'cn.deu.bztc.happyidiom.activ
Error:Application and test application id cannot be the same: both are 'cn.deu.bztc.happyidiom.activ ...
vue-router报Uncaught (in promise) Error: Redirected when going from “XX“ to “XX“，并且无法正常进入路由
vue-router报Uncaught (in promise) Error: Redirected when going from "XX" to "XX", ...
hive启动时出现javax.jdo.JDODataStoreException: Error executing SQL query
启动metastore和hiveserver2后, 发现hiveserver2启动失败,因为没有被占用10000端口 $HIVE_HOME/logs下出现如下报错: 2020-05-27T22:39: ...
Error:(2, 0) Plugin with id 'com.github.dcendents.android-maven' not found
导入开源项目的时候老是报这个错 Error:(2, 0) Plugin with id 'com.github.dcendents.android-maven' not found http://bl ...
ERROR ITMS-90206:Invalid Bundle. The bundle at ‘xx.app/xx/xx.framework' contan
ERROR ITMS-90206:"Invalid Bundle. The bundle at 'xx.app/xx/xx.framework' contains disallwed fil ...
Android Studio之Error:(158) Error: Expected resource of type id [ResourceType]
Android Studio在输出apk包时,在检查代码规范性方面相比Eclipse要严格得多,以下代码可在Eclipse编译通过, Android Studio控制台报错:Error:(158) E ...
关于STM32 Hal 库函数编写的程序在编译时报错：“Error: L6218E: Undefined symbol 函数名 (referred from xx.o)” 的解决办法
问题描述:在借鉴别人的程序时,直接把部分hal库的程序拿来用,在编译时出现下图所示的问题 1 . 尝试解决但是没有成功的办法: 1.1 头文件包含问题一开始以为是没有包含头文件,将头文件包含后,再次 ...
java.sql.SQLException: Table 'test.customer' doesn't exist Query: Select id,name,address,phone from
信息: Initializing c3p0 pool... com.mchange.v2.c3p0.ComboPooledDataSource [ acquireIncrement -> 5, ...

ERROR streaming.StreamExecution: Query topic_lcc [id =xx, runId=xx] terminated with error

1.背景

ERROR streaming.StreamExecution: Query topic_lcc [id =xx, runId=xx] terminated with error相关推荐

最新文章

热门文章