gistfile1.txt

Notes:

SCHEMA_MIGRATION already exists in the database.

test.ex

Interactive Elixir (1.3.1) - press Ctrl+C to exit (type h() ENTER for help)
iex(1)> Snappyex.Client.executePrepared(statement_id, Snappyex.Model.Row.new(values: []), nil, token)
** (CompileError) iex:1: undefined function statement_id/0
    (stdlib) lists.erl:1354: :lists.mapfoldl/3
iex(1)> args = [host: "192.168.55.4", clientID: "ElixirClient1|0x" <> Base.encode16(inspect self), port: 1531, userName: "APP", password: "APP",  security: Snappyex.Model.SecurityMechanism.plain,  tokenSize: 16, useStringForDecimal: false, properties: :dict.new()]
[host: "192.168.55.4", clientID: "ElixirClient1|0x235049443C302E3233312E303E",
 port: 1531, userName: "APP", password: "APP",
 security: %Snappyex.Model.SecurityMechanism{ordinal: :plain, value: 1},
 tokenSize: 16, useStringForDecimal: false,
 properties: {:dict, 0, 16, 16, 8, 80, 48,
  {[], [], [], [], [], [], [], [], [], [], [], [], [], [], [], []},
  {{[], [], [], [], [], [], [], [], [], [], [], [], [], [], [], []}}}]
iex(2)> 
nil
iex(3)> {:ok, pid} = Snappyex.start_link(args)
{:ok, #PID<0.237.0>}
iex(4)> 
nil
iex(5)> params = Map.put_new(Map.new, :params, Snappyex.Model.Row.new(values: []))
%{params: %Snappyex.Model.Row{values: []}}
iex(6)> 
nil
iex(7)> Snappyex.prepare_execute(pid, "CREATE TABLE SCHEMA_MIGRATIONS(HOTEL_ID INT NOT NULL, BOOKING_DATE DATE NOT NULL,ROOMS_TAKEN INT DEFAULT 0, PRIMARY KEY (HOTEL_ID, BOOKING_DATE));", params, [])
** (EXIT from #PID<0.231.0>) bad return value: {{:tclient, :snappy_data_service_thrift, {:protocol, :thrift_binary_protocol, {:binary_protocol, {:transport, :thrift_buffered_transport, {:buffered_transport, {:transport, :thrift_socket_transport, {:data, #Port<0.7634>, :infinity}}, []}}, true, true}}, 0}, {:exception, {:SnappyException, {:SnappyExceptionData, "The exception 'createTable: Table SCHEMA_MIGRATIONS already exists.;' was thrown while evaluating an expression.", "38000", 20000}, "Server=snappydata.192.168.55.4.nip.io/192.168.55.4[1531] Thread=pool-3-thread-87", [{:SnappyExceptionData, "Server STACK: java.sql.SQLException(38000): The exception 'createTable: Table SCHEMA_MIGRATIONS already exists.;' was thrown while evaluating an expression.\n\tat com.pivotal.gemfirexd.internal.iapi.error.StandardException.newException(StandardException.java:214)\n\tat com.pivotal.gemfirexd.internal.engine.Misc.processFunctionException(Misc.java:680)\n\tat com.pivotal.gemfirexd.internal.engine.Misc.processFunctionException(Misc.java:661)\n\tat com.pivotal.gemfirexd.internal.engine.sql.execute.SnappySelectResultSet.setup(SnappySelectResultSet.java:281)\n\tat com.pivotal.gemfirexd.internal.engine.distributed.message.GfxdFunctionMessage.executeFunction(GfxdFunctionMessage.java:332)\n\tat com.pivotal.gemfirexd.internal.engine.distributed.message.GfxdFunctionMessage.executeFunction(GfxdFunctionMessage.java:274)\n\tat com.pivotal.gemfirexd.internal.engine.sql.execute.SnappyActivation.executeOnLeadNode(SnappyActivation.java:235)\n\tat com.pivotal.gemfirexd.internal.engine.sql.execute.SnappyActivation.executeWithResultSet(SnappyActivation.java:123)\n\tat com.pivotal.gemfirexd.internal.engine.sql.execute.SnappyActivation.execute(SnappyActivation.java:86)\n\tat com.pivotal.gemfirexd.internal.impl.sql.GenericActivationHolder.execute(GenericActivationHolder.java:462)\n\tat com.pivotal.gemfirexd.internal.impl.sql.GenericPreparedStatement.execute(GenericPreparedStatement.java:586)\n\tat com.pivotal.gemfirexd.internal.impl.jdbc.EmbedStatement.executeStatement(EmbedStatement.java:2132)\n\tat com.pivotal.gemfirexd.internal.impl.jdbc.EmbedPreparedStatement.executeStatement(EmbedPreparedStatement.java:1926)\n\tat com.pivotal.gemfirexd.internal.impl.jdbc.EmbedCallableStatement.executeStatement(EmbedCallableStatement.java:133)\n\tat com.pivotal.gemfirexd.internal.impl.jdbc.EmbedPreparedStatement.execute(EmbedPreparedStatement.java:1556)\n\tat io.snappydata.thrift.server.SnappyDataServiceImpl.executePrepared(SnappyDataServiceImpl.java:2367)\n\tat io.snappydata.thrift.SnappyDataService$Processor$executePrepared.getResult(SnappyDataService.java:1397)\n\tat io.snappydata.thrift.SnappyDataService$Processor$executePrepared.getResult(SnappyDataService.java:1381)\n\tat org.apache.thrift.ProcessFunction.process(ProcessFunction.java:39)\n\tat io.snappydata.thrift.server.SnappyDataServiceImpl$Processor.process(SnappyDataServiceImpl.java:158)\n\tat io.snappydata.thrift.server.SnappyThriftServerThreadPool$WorkerProcess.run(SnappyThriftServerThreadPool.java:270)\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)\n\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)\n\tat java.lang.Thread.run(Thread.java:745)\nCaused by: com.pivotal.gemfirexd.internal.engine.jdbc.GemFireXDRuntimeException: myID: snappydata(12344)<v1>:46301, caused by ERROR 38000: The exception 'createTable: Table SCHEMA_MIGRATIONS already exists.;' was thrown while evaluating an expression.\n\tat com.pivotal.gemfirexd.internal.engine.distributed.GfxdQueryStreamingResultCollector$Itr.moveNext(GfxdQueryStreamingResultCollector.java:451)\n\tat com.pivotal.gemfirexd.internal.engine.distributed.GfxdQueryStreamingResultCollector$Itr.<init>(GfxdQueryStreamingResultCollector.java:363)\n\tat com.pivotal.gemfirexd.internal.engine.distributed.GfxdQueryStreamingResultCollector.iterator(GfxdQueryStreamingResultCollector.java:207)\n\tat com.pivotal.gemfirexd.internal.engine.sql.execute.SnappySelectResultSet.setup(SnappySelectResultSet.java:276)\n\t... 20 more\nCaused by: ERROR 38000: The exception 'createTable: Table SCHEMA_MIGRATIONS already exists.;' was thrown while evaluating an expression.\n\tat Remote Member 'snappydata(12647)<v2>:40465' in com.pivotal.gemfirexd.internal.iapi.error.StandardException.newException(StandardException.java:473)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in com.pivotal.gemfirexd.internal.engine.distributed.message.LeadNodeExecutorMsg.execute(LeadNodeExecutorMsg.java:136)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in com.pivotal.gemfirexd.internal.engine.distributed.message.GfxdFunctionMessage.processMessage(GfxdFunctionMessage.java:739)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in com.pivotal.gemfirexd.internal.engine.distributed.GfxdMessage.basicProcess(GfxdMessage.java:406)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in com.gemstone.gemfire.internal.cache.AbstractOperationMessage.process(AbstractOperationMessage.java:212)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in com.gemstone.gemfire.distributed.internal.DistributionMessage.scheduleAction(DistributionMessage.java:429)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in com.gemstone.gemfire.distributed.internal.DistributionMessage$1.run(DistributionMessage.java:501)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in com.gemstone.gemfire.distributed.internal.DistributionManager.runUntilShutdown(DistributionManager.java:728)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in com.gemstone.gemfire.distributed.internal.DistributionManager$9$1.run(DistributionManager.java:1178)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in java.lang.Thread.run(Thread.java:745)\n\tat com.pivotal.gemfirexd.internal.iapi.error.StandardException.fixUpRemoteException(StandardException.java:162)\n\tat com.pivotal.gemfirexd.internal.engine.Misc.processFunctionException(Misc.java:679)\n\tat com.pivotal.gemfirexd.internal.engine.Misc.processFunctionException(Misc.java:661)\n\tat com.pivotal.gemfirexd.internal.engine.sql.execute.SnappySelectResultSet.setup(SnappySelectResultSet.java:281)\n\t... 20 more\nCaused by: org.apache.spark.sql.AnalysisException: createTable: Table SCHEMA_MIGRATIONS already exists.;\n\tat Remote Member 'snappydata(12647)<v2>:40465' in org.apache.spark.sql.SnappyContext.createTable(SnappyContext.scala:641)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in org.apache.spark.sql.CreateMetastoreTableUsing.run(snappyParsers.scala:928)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in org.apache.spark.sql.execution.ExecutedCommand.sideEffectResult$lzycompute(commands.scala:58)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in org.apache.spark.sql.execution.ExecutedCommand.sideEffectResult(commands.scala:56)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in org.apache.spark.sql.execution.ExecutedCommand.doExecute(commands.scala:70)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in org.apache.spark.sql.execution.SparkPlan$$anonfun$execute$5.apply(SparkPlan.scala:132)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in org.apache.spark.sql.execution.SparkPlan$$anonfun$execute$5.apply(SparkPlan.scala:130)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:150)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in org.apache.spark.sql.execution.SparkPlan.execute(SparkPlan.scala:130)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in org.apache.spark.sql.execution.QueryExecution.toRdd$lzycompute(QueryExecution.scala:55)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in org.apache.spark.sql.execution.QueryExecution.toRdd(QueryExecution.scala:55)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in org.apache.spark.sql.DataFrame.<init>(DataFrame.scala:145)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in org.apache.spark.sql.DataFrame.<init>(DataFrame.scala:130)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in org.apache.spark.sql.DataFrame$.apply(DataFrame.scala:52)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in org.apache.spark.sql.SQLContext.sql(SQLContext.scala:820)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in io.snappydata.gemxd.SparkSQLExecuteImpl.<init>(SparkSQLExecuteImpl.scala:60)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in io.snappydata.gemxd.ClusterCallbacksImpl$.getSQLExecute(ClusterCallbacksImpl.scala:78)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in com.pivotal.gemfirexd.internal.engine.distributed.message.LeadNodeExecutorMsg.execute(LeadNodeExecutorMsg.java:117)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in com.pivotal.gemfirexd.internal.engine.distributed.message.GfxdFunctionMessage.processMessage(GfxdFunctionMessage.java:739)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in com.pivotal.gemfirexd.internal.engine.distributed.GfxdMessage.basicProcess(GfxdMessage.java:406)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in com.gemstone.gemfire.internal.cache.AbstractOperationMessage.process(AbstractOperationMessage.java:212)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in com.gemstone.gemfire.distributed.internal.DistributionMessage.scheduleAction(DistributionMessage.java:429)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in com.gemstone.gemfire.distributed.internal.DistributionMessage$1.run(DistributionMessage.java:501)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in com.gemstone.gemfire.distributed.internal.DistributionManager.runUntilShutdown(DistributionManager.java:728)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in com.gemstone.gemfire.distributed.internal.DistributionManager$9$1.run(DistributionManager.java:1178)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in java.lang.Thread.run(Thread.java:745)\n", "X0Z35", 20000}]}}}

Interactive Elixir (1.3.1) - press Ctrl+C to exit (type h() ENTER for help)
iex(1)> 
nil
iex(2)> #Snappyex.execute(pid, query, params, [])
08:51:59.530 [error] GenServer Snappyex.Client terminating
** (stop) bad return value: {{:tclient, :snappy_data_service_thrift, {:protocol, :thrift_binary_protocol, {:binary_protocol, {:transport, :thrift_buffered_transport, {:buffered_transport, {:transport, :thrift_socket_transport, {:data, #Port<0.7634>, :infinity}}, []}}, true, true}}, 0}, {:exception, {:SnappyException, {:SnappyExceptionData, "The exception 'createTable: Table SCHEMA_MIGRATIONS already exists.;' was thrown while evaluating an expression.", "38000", 20000}, "Server=snappydata.192.168.55.4.nip.io/192.168.55.4[1531] Thread=pool-3-thread-87", [{:SnappyExceptionData, "Server STACK: java.sql.SQLException(38000): The exception 'createTable: Table SCHEMA_MIGRATIONS already exists.;' was thrown while evaluating an expression.\n\tat com.pivotal.gemfirexd.internal.iapi.error.StandardException.newException(StandardException.java:214)\n\tat com.pivotal.gemfirexd.internal.engine.Misc.processFunctionException(Misc.java:680)\n\tat com.pivotal.gemfirexd.internal.engine.Misc.processFunctionException(Misc.java:661)\n\tat com.pivotal.gemfirexd.internal.engine.sql.execute.SnappySelectResultSet.setup(SnappySelectResultSet.java:281)\n\tat com.pivotal.gemfirexd.internal.engine.distributed.message.GfxdFunctionMessage.executeFunction(GfxdFunctionMessage.java:332)\n\tat com.pivotal.gemfirexd.internal.engine.distributed.message.GfxdFunctionMessage.executeFunction(GfxdFunctionMessage.java:274)\n\tat com.pivotal.gemfirexd.internal.engine.sql.execute.SnappyActivation.executeOnLeadNode(SnappyActivation.java:235)\n\tat com.pivotal.gemfirexd.internal.engine.sql.execute.SnappyActivation.executeWithResultSet(SnappyActivation.java:123)\n\tat com.pivotal.gemfirexd.internal.engine.sql.execute.SnappyActivation.execute(SnappyActivation.java:86)\n\tat com.pivotal.gemfirexd.internal.impl.sql.GenericActivationHolder.execute(GenericActivationHolder.java:462)\n\tat com.pivotal.gemfirexd.internal.impl.sql.GenericPreparedStatement.execute(GenericPreparedStatement.java:586)\n\tat com.pivotal.gemfirexd.internal.impl.jdbc.EmbedStatement.executeStatement(EmbedStatement.java:2132)\n\tat com.pivotal.gemfirexd.internal.impl.jdbc.EmbedPreparedStatement.executeStatement(EmbedPreparedStatement.java:1926)\n\tat com.pivotal.gemfirexd.internal.impl.jdbc.EmbedCallableStatement.executeStatement(EmbedCallableStatement.java:133)\n\tat com.pivotal.gemfirexd.internal.impl.jdbc.EmbedPreparedStatement.execute(EmbedPreparedStatement.java:1556)\n\tat io.snappydata.thrift.server.SnappyDataServiceImpl.executePrepared(SnappyDataServiceImpl.java:2367)\n\tat io.snappydata.thrift.SnappyDataService$Processor$executePrepared.getResult(SnappyDataService.java:1397)\n\tat io.snappydata.thrift.SnappyDataService$Processor$executePrepared.getResult(SnappyDataService.java:1381)\n\tat org.apache.thrift.ProcessFunction.process(ProcessFunction.java:39)\n\tat io.snappydata.thrift.server.SnappyDataServiceImpl$Processor.process(SnappyDataServiceImpl.java:158)\n\tat io.snappydata.thrift.server.SnappyThriftServerThreadPool$WorkerProcess.run(SnappyThriftServerThreadPool.java:270)\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)\n\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)\n\tat java.lang.Thread.run(Thread.java:745)\nCaused by: com.pivotal.gemfirexd.internal.engine.jdbc.GemFireXDRuntimeException: myID: snappydata(12344)<v1>:46301, caused by ERROR 38000: The exception 'createTable: Table SCHEMA_MIGRATIONS already exists.;' was thrown while evaluating an expression.\n\tat com.pivotal.gemfirexd.internal.engine.distributed.GfxdQueryStreamingResultCollector$Itr.moveNext(GfxdQueryStreamingResultCollector.java:451)\n\tat com.pivotal.gemfirexd.internal.engine.distributed.GfxdQueryStreamingResultCollector$Itr.<init>(GfxdQueryStreamingResultCollector.java:363)\n\tat com.pivotal.gemfirexd.internal.engine.distributed.GfxdQueryStreamingResultCollector.iterator(GfxdQueryStreamingResultCollector.java:207)\n\tat com.pivotal.gemfirexd.internal.engine.sql.execute.SnappySelectResultSet.setup(SnappySelectResultSet.java:276)\n\t... 20 more\nCaused by: ERROR 38000: The exception 'createTable: Table SCHEMA_MIGRATIONS already exists.;' was thrown while evaluating an expression.\n\tat Remote Member 'snappydata(12647)<v2>:40465' in com.pivotal.gemfirexd.internal.iapi.error.StandardException.newException(StandardException.java:473)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in com.pivotal.gemfirexd.internal.engine.distributed.message.LeadNodeExecutorMsg.execute(LeadNodeExecutorMsg.java:136)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in com.pivotal.gemfirexd.internal.engine.distributed.message.GfxdFunctionMessage.processMessage(GfxdFunctionMessage.java:739)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in com.pivotal.gemfirexd.internal.engine.distributed.GfxdMessage.basicProcess(GfxdMessage.java:406)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in com.gemstone.gemfire.internal.cache.AbstractOperationMessage.process(AbstractOperationMessage.java:212)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in com.gemstone.gemfire.distributed.internal.DistributionMessage.scheduleAction(DistributionMessage.java:429)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in com.gemstone.gemfire.distributed.internal.DistributionMessage$1.run(DistributionMessage.java:501)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in com.gemstone.gemfire.distributed.internal.DistributionManager.runUntilShutdown(DistributionManager.java:728)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in com.gemstone.gemfire.distributed.internal.DistributionManager$9$1.run(DistributionManager.java:1178)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in java.lang.Thread.run(Thread.java:745)\n\tat com.pivotal.gemfirexd.internal.iapi.error.StandardException.fixUpRemoteException(StandardException.java:162)\n\tat com.pivotal.gemfirexd.internal.engine.Misc.processFunctionException(Misc.java:679)\n\tat com.pivotal.gemfirexd.internal.engine.Misc.processFunctionException(Misc.java:661)\n\tat com.pivotal.gemfirexd.internal.engine.sql.execute.SnappySelectResultSet.setup(SnappySelectResultSet.java:281)\n\t... 20 more\nCaused by: org.apache.spark.sql.AnalysisException: createTable: Table SCHEMA_MIGRATIONS already exists.;\n\tat Remote Member 'snappydata(12647)<v2>:40465' in org.apache.spark.sql.SnappyContext.createTable(SnappyContext.scala:641)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in org.apache.spark.sql.CreateMetastoreTableUsing.run(snappyParsers.scala:928)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in org.apache.spark.sql.execution.ExecutedCommand.sideEffectResult$lzycompute(commands.scala:58)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in org.apache.spark.sql.execution.ExecutedCommand.sideEffectResult(commands.scala:56)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in org.apache.spark.sql.execution.ExecutedCommand.doExecute(commands.scala:70)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in org.apache.spark.sql.execution.SparkPlan$$anonfun$execute$5.apply(SparkPlan.scala:132)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in org.apache.spark.sql.execution.SparkPlan$$anonfun$execute$5.apply(SparkPlan.scala:130)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:150)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in org.apache.spark.sql.execution.SparkPlan.execute(SparkPlan.scala:130)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in org.apache.spark.sql.execution.QueryExecution.toRdd$lzycompute(QueryExecution.scala:55)\n\tat Remote Member 'snappydata(12647)<v2>:40465' in org.apache.spark.sql.execution.QueryExecution.toRdd(QueryExecution.scala:55)\n\tat Remote Member 'snappydata(12647 (truncated)

nil