回答

收藏

SnappyData snappy-sql PUT INTO导致错误:spark.sql.execution.id已设置

技术问答 技术问答 290 人阅读 | 0 人回复 | 2023-09-12

我正在使用SnappyData SQL Shell(snappy-sql)并运行sql语句(PUT INTO),并遇到错误:
, }) }4 o5 \: m, C) tcaused by java.lang.IllegalArgumentException: spark.sql.execution.id is already set' was thrown while evaluating an expression.    at com.pivotal.gemfirexd.internal.iapi.error.StandardException.newException(StandardException.java:473)    at com.pivotal.gemfirexd.internal.engine.Misc.processFunctionException(Misc.java:808)    at com.pivotal.gemfirexd.internal.engine.Misc.processFunctionException(Misc.java:753)    at com.pivotal.gemfirexd.internal.engine.sql.execute.SnappySelectResultSet.setup(SnappySelectResultSet.java:282)    at com.pivotal.gemfirexd.internal.engine.distributed.message.GfxdFunctionMessage.executeFunction(GfxdFunctionMessage.java:332at com.pivotal.gemfirexd.internal.engine.distributed.message.GfxdFunctionMessage.executeFunction(GfxdFunctionMessage.(truncated for brevity.)caused by java.lang.IllegalArgumentException: spark.sql.execution.id is already set' was thrown while evaluating an expression.    at com.pivotal.gemfirexd.internal.iapi.error.StandardException.newException(StandardException.java:473)    at com.pivotal.gemfirexd.internal.engine.Misc.processFunctionException(Misc.java:808)    at com.pivotal.gemfirexd.internal.engine.Misc.processFunctionException(Misc.java:753)    at com.pivotal.gemfirexd.internal.engine.sql.execute.SnappySelectResultSet.setup(SnappySelectResultSet.java:282)    at com.pivotal.gemfirexd.internal.engine.distributed.message.GfxdFunctionMessage.executeFunction(GfxdFunctionMessage.java:332)        at com.pivotal.gemfirexd.internal.engine.distributed.message.GfxdFunctionMessage.executeFunction(GfxdFunctionMessage.(truncated for brevity.)这就是我所做的:从https://www.snappydata.io/download(v0.8)下载SnappyData二进制文件。解压缩,操作$ R. i% @. t4 p9 ~( S
sbin/snappy-start-all.shbin/snappy-sqlsnappy> connect client 'localhost:1527';snappy> create table table_a(key1 INT primary key,val INT);snappy> create table table_b(key1 INT primary key,val INT);snappy> insert into table_a values (1,1);snappy> insert into table_b values (1,2);snappy> insert into table_b values (2,3);snappy> select * from table_a;KEY      |VAL        -----------------------         |11 row selectedsnappy> select * from table_b;KEY      |VAL        -----------------------2                       |3                   |22 rows selectedsnappy> put into table_a select * from table_b;(then the above error.)搜索错误(已设置spark.sql.execution.id)以下错误:https
9 e1 I2 i& P; m" }://issues.apache.org/jira/browse/SPARK-13747  (SQL并发执行不适用于Scala- ~" S9 f$ I' c: W# U1 z$ g8 `
ForkJoinPool)似乎是Spark 2.2.0修复错误。8 |5 X9 H1 h; @% W6 U2 ?
这可能是因为SnappyData仍在使用spark 2.0(至少现在github上它说已经转移到了spark 2.0)。但我不确定。3 E. s4 y0 U% M  C6 @; h
现在,我尽量使用它PUT INTOSnappyData如果有人能帮我解决这个问题,我会很感激的。提前感谢
6 l  p9 Z/ ]# ^/ N  X7 n                                                               
  Y$ r1 [1 p6 ~& @! `- b    解决方案:
分享到:
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则