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