[GitHub] [hudi] adward32135 commented on issue #7058: [SUPPORT]java.util.concurrent.ExecutionException: java.lang.RuntimeException: java.lang.AssertionError: assertion failed: Required select columns count: 46, Current select columns(including static partition column) count: 45，columns:

[GitBox <gi...@apache.org>]

adward32135 commented on issue #7058:
URL: https://github.com/apache/hudi/issues/7058#issuecomment-1291401038

   
   
   > @adward32135 Hello, can you provide more detailed exception information, and what is your hudi version?
   
   hudi version：0.11.x和0.12.0
   detail exception:
   connectionId = 73bb34bf-8f57-4bc0-a1c6-69788b23da1a, statementId = 0 -> SQLException: java.util.concurrent.ExecutionException: java.lang.RuntimeException: java.lang.AssertionError: assertion failed: Required select columns count: 46, Current select columns(including static partition column) count: 45，columns: (id,cid,shard,productcode,subproductcode,serialid,uin,appid,payeruin,payerappid,platform,projectid,regionid,zoneid,paymode,pid,actid,calcdate,starttime,endtime,calcnum,timespan,calcstatus,calcchannel,datastatus,settletype,params,parts,billingparams,reduceinfo,currency,price,money,totalcost,taxrate,taxamount,orderid,feebillid,addtime,modifytime,errormsg,riorderid,,0,ftime)
   	at scala.Predef$.assert(Predef.scala:223)
   	at org.apache.spark.sql.hudi.command.InsertIntoHoodieTableCommand$.alignOutputFields(InsertIntoHoodieTableCommand.scala:133)
   	at org.apache.spark.sql.hudi.command.InsertIntoHoodieTableCommand$.run(InsertIntoHoodieTableCommand.scala:87)
   	at org.apache.spark.sql.hudi.command.InsertIntoHoodieTableCommand.run(InsertIntoHoodieTableCommand.scala:48)
   	at org.apache.spark.sql.execution.command.ExecutedCommandExec.sideEffectResult$lzycompute(commands.scala:70)
   	at org.apache.spark.sql.execution.command.ExecutedCommandExec.sideEffectResult(commands.scala:68)
   	at org.apache.spark.sql.execution.command.ExecutedCommandExec.executeCollect(commands.scala:79)
   	at org.apache.spark.sql.Dataset.$anonfun$logicalPlan$1(Dataset.scala:231)
   	at org.apache.spark.sql.Dataset.$anonfun$withAction$1(Dataset.scala:3699)
   	at org.apache.spark.sql.execution.SQLExecution$.$anonfun$withNewExecutionId$5(SQLExecution.scala:105)
   	at org.apache.spark.sql.execution.SQLExecution$.withSQLConfPropagated(SQLExecution.scala:172)
   	at org.apache.spark.sql.execution.SQLExecution$.$anonfun$withNewExecutionId$1(SQLExecution.scala:92)
   	at org.apache.spark.sql.SparkSession.withActive(SparkSession.scala:801)
   	at org.apache.spark.sql.execution.SQLExecution$.withNewExecutionId(SQLExecution.scala:66)
   	at org.apache.spark.sql.Dataset.withAction(Dataset.scala:3697)
   	at org.apache.spark.sql.Dataset.<init>(Dataset.scala:231)
   	at org.apache.spark.sql.Dataset$.$anonfun$ofRows$2(Dataset.scala:102)
   	at org.apache.spark.sql.SparkSession.withActive(SparkSession.scala:801)
   	at org.apache.spark.sql.Dataset$.ofRows(Dataset.scala:96)
   	at org.apache.spark.sql.SparkSession.$anonfun$sql$1(SparkSession.scala:623)
   	at org.apache.spark.sql.SparkSession.withActive(SparkSession.scala:801)
   	at org.apache.spark.sql.SparkSession.sql(SparkSession.scala:616)
   	at org.apache.livy.thriftserver.session.SqlJob.executeSql(SqlJob.java:93)
   	at org.apache.livy.thriftserver.session.SqlJob.call(SqlJob.java:73)
   	at org.apache.livy.thriftserver.session.SqlJob.call(SqlJob.java:40)
   	at org.apache.livy.rsc.driver.JobWrapper.call(JobWrapper.java:84)
   	at org.apache.livy.rsc.driver.JobWrapper.call(JobWrapper.java:34)
   	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
   	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
   	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
   	at java.lang.Thread.run(Thread.java:745)
   
   	at org.apache.calcite.avatica.Helper.createException(Helper.java:68)
   	at org.apache.calcite.avatica.Helper.createSQLException(Helper.java:114)
   	at org.apache.calcite.avatica.AvaticaStatement.executeInternal(AvaticaStatement.java:234)
   	at org.apache.calcite.avatica.AvaticaStatement.execute(AvaticaStatement.java:287)
   	at jdk.internal.reflect.GeneratedMethodAccessor53.invoke(Unknown Source)
   	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
   	at java.base/java.lang.reflect.Method.invoke(Method.java:566)
   	at py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
   	at py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
   	at py4j.Gateway.invoke(Gateway.java:282)
   	at py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
   	at py4j.commands.CallCommand.execute(CallCommand.java:79)
   	at py4j.GatewayConnection.run(GatewayConnection.java:238)
   	at java.base/java.lang.Thread.run(Thread.java:829)


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org