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 解决方案: |
|
|
|
|
|