回答

收藏

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

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

我正在使用SnappyData SQL Shell(snappy-sql)并运行sql语句(PUT INTO),并遇到错误:
. _: U" @, ?9 v- B4 f6 y( \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: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二进制文件。解压缩,操作
8 E: H) m* l2 s& W# e  psbin/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+ _7 M4 D- O% U" @1 M6 |- A* a
://issues.apache.org/jira/browse/SPARK-13747  (SQL并发执行不适用于Scala
" r5 Q5 T  P9 s. g$ [- ~8 ~ForkJoinPool)似乎是Spark 2.2.0修复错误。
6 @4 D$ u7 @+ c: i; q这可能是因为SnappyData仍在使用spark 2.0(至少现在github上它说已经转移到了spark 2.0)。但我不确定。
% l4 f0 ?' S3 M. S) B4 b4 V  Y+ K* l现在,我尽量使用它PUT INTOSnappyData如果有人能帮我解决这个问题,我会很感激的。提前感谢 * z; g" J/ w! C7 ^
                                                                , ~* P6 B+ ^" [: J
    解决方案:
分享到:
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则