aditiwari01 commented on issue #2802:
URL: https://github.com/apache/hudi/issues/2802#issuecomment-829195644


   @n3nash Sorry for the delay. Attaching the complete stack trace for the 
issue faced. 
   Note: Here "newCol" was not present in the initial schema. I updated only 
one partition out of four with the new schema and when I try to do a select * 
on rt table the following error is thrown:
   
   ```
   2021-04-29T17:49:00,849  WARN [HiveServer2-HttpHandler-Pool: Thread-61] 
thrift.ThriftCLIService: Error fetching results: 
   org.apache.hive.service.cli.HiveSQLException: java.io.IOException: 
org.apache.hudi.exception.HoodieException: Field newcol not found in log 
schema. Query cannot proceed! Derived Schema Fields: [_hoodie_commit_time, 
_hoodie_partition_path, _hoodie_record_key, dim, _hoodie_commit_seqno, value, 
key, _hoodie_file_name, updatedat]
        at 
org.apache.hive.service.cli.operation.SQLOperation.getNextRowSet(SQLOperation.java:465)
 ~[hive-service-3.1.2.fk.10.jar:3.1.2.fk.10]
        at 
org.apache.hive.service.cli.operation.OperationManager.getOperationNextRowSet(OperationManager.java:309)
 ~[hive-service-3.1.2.fk.10.jar:3.1.2.fk.10]
        at 
org.apache.hive.service.cli.session.HiveSessionImpl.fetchResults(HiveSessionImpl.java:911)
 ~[hive-service-3.1.2.fk.10.jar:3.1.2.fk.10]
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) 
~[?:1.8.0_172]
        at 
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) 
~[?:1.8.0_172]
        at 
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
 ~[?:1.8.0_172]
        at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_172]
        at 
org.apache.hive.service.cli.session.HiveSessionProxy.invoke(HiveSessionProxy.java:78)
 ~[hive-service-3.1.2.fk.10.jar:3.1.2.fk.10]
        at 
org.apache.hive.service.cli.session.HiveSessionProxy.access$000(HiveSessionProxy.java:36)
 ~[hive-service-3.1.2.fk.10.jar:3.1.2.fk.10]
        at 
org.apache.hive.service.cli.session.HiveSessionProxy$1.run(HiveSessionProxy.java:63)
 ~[hive-service-3.1.2.fk.10.jar:3.1.2.fk.10]
        at java.security.AccessController.doPrivileged(Native Method) 
~[?:1.8.0_172]
        at javax.security.auth.Subject.doAs(Subject.java:422) ~[?:1.8.0_172]
        at 
org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1729)
 ~[hadoop-common-3.1.1.jar:?]
        at 
org.apache.hive.service.cli.session.HiveSessionProxy.invoke(HiveSessionProxy.java:59)
 ~[hive-service-3.1.2.fk.10.jar:3.1.2.fk.10]
        at com.sun.proxy.$Proxy57.fetchResults(Unknown Source) ~[?:?]
        at 
org.apache.hive.service.cli.CLIService.fetchResults(CLIService.java:561) 
~[hive-service-3.1.2.fk.10.jar:3.1.2.fk.10]
        at 
org.apache.hive.service.cli.thrift.ThriftCLIService.FetchResults(ThriftCLIService.java:787)
 ~[hive-service-3.1.2.fk.10.jar:3.1.2.fk.10]
        at 
org.apache.hive.service.rpc.thrift.TCLIService$Processor$FetchResults.getResult(TCLIService.java:1837)
 ~[hive-exec-3.1.2.jar:3.1.2.fk.10]
        at 
org.apache.hive.service.rpc.thrift.TCLIService$Processor$FetchResults.getResult(TCLIService.java:1822)
 ~[hive-exec-3.1.2.jar:3.1.2.fk.10]
        at org.apache.thrift.ProcessFunction.process(ProcessFunction.java:39) 
~[hive-exec-3.1.2.jar:3.1.2.fk.10]
        at org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:39) 
~[hive-exec-3.1.2.jar:3.1.2.fk.10]
        at org.apache.thrift.server.TServlet.doPost(TServlet.java:83) 
~[hive-exec-3.1.2.jar:3.1.2.fk.10]
        at 
org.apache.hive.service.cli.thrift.ThriftHttpServlet.doPost(ThriftHttpServlet.java:207)
 ~[hive-service-3.1.2.fk.10.jar:3.1.2.fk.10]
        at javax.servlet.http.HttpServlet.service(HttpServlet.java:707) 
~[javax.servlet-api-3.1.0.jar:3.1.0]
        at javax.servlet.http.HttpServlet.service(HttpServlet.java:790) 
~[javax.servlet-api-3.1.0.jar:3.1.0]
        at 
org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:848) 
~[jetty-runner-9.3.20.v20170531.jar:9.3.20.v20170531]
        at 
org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:584) 
~[jetty-runner-9.3.20.v20170531.jar:9.3.20.v20170531]
        at 
org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:224)
 ~[jetty-runner-9.3.20.v20170531.jar:9.3.20.v20170531]
        at 
org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1180)
 ~[jetty-runner-9.3.20.v20170531.jar:9.3.20.v20170531]
        at 
org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:512) 
~[jetty-runner-9.3.20.v20170531.jar:9.3.20.v20170531]
        at 
org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:185)
 ~[jetty-runner-9.3.20.v20170531.jar:9.3.20.v20170531]
        at 
org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1112)
 ~[jetty-runner-9.3.20.v20170531.jar:9.3.20.v20170531]
        at 
org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141) 
~[jetty-runner-9.3.20.v20170531.jar:9.3.20.v20170531]
        at 
org.eclipse.jetty.server.handler.gzip.GzipHandler.handle(GzipHandler.java:493) 
~[jetty-runner-9.3.20.v20170531.jar:9.3.20.v20170531]
        at 
org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:134) 
~[jetty-runner-9.3.20.v20170531.jar:9.3.20.v20170531]
        at org.eclipse.jetty.server.Server.handle(Server.java:534) 
~[jetty-runner-9.3.20.v20170531.jar:9.3.20.v20170531]
        at org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:320) 
~[jetty-runner-9.3.20.v20170531.jar:9.3.20.v20170531]
        at 
org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:251) 
~[jetty-runner-9.3.20.v20170531.jar:9.3.20.v20170531]
        at 
org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:283)
 ~[jetty-io-9.3.20.v20170531.jar:9.3.20.v20170531]
        at org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:108) 
~[jetty-io-9.3.20.v20170531.jar:9.3.20.v20170531]
        at 
org.eclipse.jetty.io.SelectChannelEndPoint$2.run(SelectChannelEndPoint.java:93) 
~[jetty-io-9.3.20.v20170531.jar:9.3.20.v20170531]
        at 
org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.executeProduceConsume(ExecuteProduceConsume.java:303)
 ~[jetty-runner-9.3.20.v20170531.jar:9.3.20.v20170531]
        at 
org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.produceConsume(ExecuteProduceConsume.java:148)
 ~[jetty-runner-9.3.20.v20170531.jar:9.3.20.v20170531]
        at 
org.eclipse.jetty.util.thread.strategy.ExecuteProduceConsume.run(ExecuteProduceConsume.java:136)
 ~[jetty-runner-9.3.20.v20170531.jar:9.3.20.v20170531]
        at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) 
~[?:1.8.0_172]
        at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) 
~[?:1.8.0_172]
        at java.lang.Thread.run(Thread.java:748) [?:1.8.0_172]
   Caused by: java.io.IOException: org.apache.hudi.exception.HoodieException: 
Field newcol not found in log schema. Query cannot proceed! Derived Schema 
Fields: [_hoodie_commit_time, _hoodie_partition_path, _hoodie_record_key, dim, 
_hoodie_commit_seqno, value, key, _hoodie_file_name, updatedat]
        at 
org.apache.hadoop.hive.ql.exec.FetchOperator.getNextRow(FetchOperator.java:602) 
~[hive-exec-3.1.2.jar:3.1.2.fk.10]
        at 
org.apache.hadoop.hive.ql.exec.FetchOperator.pushRow(FetchOperator.java:509) 
~[hive-exec-3.1.2.jar:3.1.2.fk.10]
        at org.apache.hadoop.hive.ql.exec.FetchTask.fetch(FetchTask.java:146) 
~[hive-exec-3.1.2.jar:3.1.2.fk.10]
        at org.apache.hadoop.hive.ql.Driver.getResults(Driver.java:2737) 
~[hive-exec-3.1.2.jar:3.1.2.fk.10]
        at 
org.apache.hadoop.hive.ql.reexec.ReExecDriver.getResults(ReExecDriver.java:229) 
~[hive-exec-3.1.2.jar:3.1.2.fk.10]
        at 
org.apache.hive.service.cli.operation.SQLOperation.getNextRowSet(SQLOperation.java:460)
 ~[hive-service-3.1.2.fk.10.jar:3.1.2.fk.10]
        ... 46 more
   Caused by: org.apache.hudi.exception.HoodieException: Field newcol not found 
in log schema. Query cannot proceed! Derived Schema Fields: 
[_hoodie_commit_time, _hoodie_partition_path, _hoodie_record_key, dim, 
_hoodie_commit_seqno, value, key, _hoodie_file_name, updatedat]
        at 
org.apache.hudi.hadoop.utils.HoodieRealtimeRecordReaderUtils.generateProjectionSchema(HoodieRealtimeRecordReaderUtils.java:138)
 ~[?:?]
        at 
org.apache.hudi.hadoop.realtime.AbstractRealtimeRecordReader.init(AbstractRealtimeRecordReader.java:107)
 ~[?:?]
        at 
org.apache.hudi.hadoop.realtime.AbstractRealtimeRecordReader.<init>(AbstractRealtimeRecordReader.java:67)
 ~[?:?]
        at 
org.apache.hudi.hadoop.realtime.RealtimeCompactedRecordReader.<init>(RealtimeCompactedRecordReader.java:53)
 ~[?:?]
        at 
org.apache.hudi.hadoop.realtime.HoodieRealtimeRecordReader.constructRecordReader(HoodieRealtimeRecordReader.java:70)
 ~[?:?]
        at 
org.apache.hudi.hadoop.realtime.HoodieRealtimeRecordReader.<init>(HoodieRealtimeRecordReader.java:47)
 ~[?:?]
        at 
org.apache.hudi.hadoop.realtime.HoodieParquetRealtimeInputFormat.getRecordReader(HoodieParquetRealtimeInputFormat.java:123)
 ~[?:?]
        at 
org.apache.hadoop.hive.ql.exec.FetchOperator$FetchInputFormatSplit.getRecordReader(FetchOperator.java:776)
 ~[hive-exec-3.1.2.jar:3.1.2.fk.10]
        at 
org.apache.hadoop.hive.ql.exec.FetchOperator.getRecordReader(FetchOperator.java:344)
 ~[hive-exec-3.1.2.jar:3.1.2.fk.10]
        at 
org.apache.hadoop.hive.ql.exec.FetchOperator.getNextRow(FetchOperator.java:540) 
~[hive-exec-3.1.2.jar:3.1.2.fk.10]
        at 
org.apache.hadoop.hive.ql.exec.FetchOperator.pushRow(FetchOperator.java:509) 
~[hive-exec-3.1.2.jar:3.1.2.fk.10]
        at org.apache.hadoop.hive.ql.exec.FetchTask.fetch(FetchTask.java:146) 
~[hive-exec-3.1.2.jar:3.1.2.fk.10]
        at org.apache.hadoop.hive.ql.Driver.getResults(Driver.java:2737) 
~[hive-exec-3.1.2.jar:3.1.2.fk.10]
        at 
org.apache.hadoop.hive.ql.reexec.ReExecDriver.getResults(ReExecDriver.java:229) 
~[hive-exec-3.1.2.jar:3.1.2.fk.10]
        at 
org.apache.hive.service.cli.operation.SQLOperation.getNextRowSet(SQLOperation.java:460)
 ~[hive-service-3.1.2.fk.10.jar:3.1.2.fk.10]
        ... 46 more
   ```


-- 
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.

For queries about this service, please contact Infrastructure at:
[email protected]


Reply via email to