本文主要是介绍Set cancelled by MemoryScratchSinkOperator,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
Bug信息
Caused by: com.starrocks.connector.spark.exception.StarrocksInternalException: StarRocks server StarRocks BE{host='10.9.14.39', port=9060} internal failed, status code [CANCELLED] error message is [Set cancelled by MemoryScratchSinkOperator]
Bug产生的代码
使用Spark Connector读Starrocks的时候报的错,代码参考的官网如下:
val starrocksSparkDF = spark.read.format("starrocks").option("starrocks.table.identifier", s"test.score_board").option("starrocks.fe.http.url", s"<fe_host>:<fe_http_port>").option("starrocks.fe.jdbc.url", s"jdbc:mysql://<fe_host>:<fe_query_port>").option("starrocks.user", s"root").opti
这篇关于Set cancelled by MemoryScratchSinkOperator的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!