You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@paimon.apache.org by "macdoor (via GitHub)" <gi...@apache.org> on 2023/10/21 05:54:38 UTC
[I] [Bug] Error in querying table with row type column under trino 430 [incubator-paimon]
macdoor opened a new issue, #2159:
URL: https://github.com/apache/incubator-paimon/issues/2159
### Search before asking
- [X] I searched in the [issues](https://github.com/apache/incubator-paimon/issues) and found nothing similar.
### Paimon version
paimon-trino-422-0.6-20231020.000452-45.jar
### Compute Engine
Linux hb3-dev-gem-bnpmp-000 5.10.0-60.91.0.115.oe2203.x86_64 https://github.com/apache/incubator-paimon/pull/1 SMP Thu Apr 20 07:08:44 UTC 2023 x86_64 x86_64 x86_64 GNU/Linux
openjdk version "17.0.8" 2023-07-18 LTS
OpenJDK Runtime Environment (Red_Hat-17.0.8.0.7-1) (build 17.0.8+7-LTS)
OpenJDK 64-Bit Server VM (Red_Hat-17.0.8.0.7-1) (build 17.0.8+7-LTS, mixed mode, sharing)
Trino 430
### Minimal reproduce step
create 3 tables
drop table if exists svc1_paimon_prod.dxx.with_row;
```
CREATE TABLE svc1_paimon_prod.dxx.with_row (
id string,
order_attrs row<
ordernum string,
paymentmode string
>,
skuNum string,
PRIMARY KEY (id,skuNum) NOT ENFORCED
)
PARTITIONED BY (skuNum);
drop table if exists svc1_paimon_prod.dxx.without_row;
CREATE TABLE svc1_paimon_prod.dxx.without_row (
id string,
skuNum string,
PRIMARY KEY (id,skuNum) NOT ENFORCED
)
PARTITIONED BY (skuNum);
drop table if exists svc1_paimon_prod.dxx.with_row_append;
CREATE TABLE svc1_paimon_prod.dxx.with_row_append (
id string,
order_attrs row<
ordernum string,
paymentmode string
>,
skuNum string
)
PARTITIONED BY (skuNum);
```
insert 1 row data into each table
```
INSERT INTO svc1_paimon_prod.dxx.with_row VALUES ('1', row('2', '2'), '3');
INSERT INTO svc1_paimon_prod.dxx.without_row VALUES ('1', '3');
INSERT INTO svc1_paimon_prod.dxx.with_row_append VALUES ('1', row('2', '2'), '3');
```
### What doesn't meet your expectations?
execute sql in sql-client.sh
```
SELECT t.* FROM with_row t;
SELECT t.* FROM with_row_append t;
```
throw exception
```
[2023-10-21 13:42:10] [65536] Query failed (#20231021_054210_00001_mkcwi): Unhandled type for SqlRow: row(url varchar, headers varchar, body varchar, size bigint, querystring varchar, uri varchar, method varchar)
[2023-10-21 13:42:10] io.trino.spi.TrinoException: Unhandled type for SqlRow: row(url varchar, headers varchar, body varchar, size bigint, querystring varchar, uri varchar, method varchar)
```
It is okay under trino 429
### Anything else?
Full exception
```
2023-10-21T13:45:47.812+0800 ERROR SplitRunner-2-114 io.trino.execution.executor.timesharing.TimeSharingTaskExecutor Error processing Split 20231021_054545_00000_uq3tq.1.0.0-0 {} (start = 5.843536938496729E9, wall = 215 ms, cpu = 0 ms, wait = 0 ms, calls = 1): GENERIC_INTERNAL_ERROR: Unhandled type for SqlRow: row(ordernum varchar, paymentmode varchar)
io.trino.spi.TrinoException: Unhandled type for SqlRow: row(ordernum varchar, paymentmode varchar)
at org.apache.paimon.trino.TrinoPageSourceBase.appendTo(TrinoPageSourceBase.java:209)
at org.apache.paimon.trino.TrinoPageSourceBase.nextPage(TrinoPageSourceBase.java:140)
at org.apache.paimon.trino.TrinoPageSourceBase.lambda$getNextPage$0(TrinoPageSourceBase.java:121)
at org.apache.paimon.trino.ClassLoaderUtils.runWithContextClassLoader(ClassLoaderUtils.java:30)
at org.apache.paimon.trino.TrinoPageSourceBase.getNextPage(TrinoPageSourceBase.java:118)
at io.trino.operator.TableScanOperator.getOutput(TableScanOperator.java:302)
at io.trino.operator.Driver.processInternal(Driver.java:395)
at io.trino.operator.Driver.lambda$process$8(Driver.java:298)
at io.trino.operator.Driver.tryWithLock(Driver.java:694)
at io.trino.operator.Driver.process(Driver.java:290)
at io.trino.operator.Driver.processForDuration(Driver.java:261)
at io.trino.execution.SqlTaskExecution$DriverSplitRunner.processFor(SqlTaskExecution.java:887)
at io.trino.execution.executor.timesharing.PrioritizedSplitRunner.process(PrioritizedSplitRunner.java:187)
at io.trino.execution.executor.timesharing.TimeSharingTaskExecutor$TaskRunner.run(TimeSharingTaskExecutor.java:565)
at io.trino.$gen.Trino_430____20231021_054528_2.run(Unknown Source)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
at java.base/java.lang.Thread.run(Thread.java:833)
2023-10-21T13:45:47.826+0800 ERROR remote-task-callback-1 io.trino.execution.scheduler.PipelinedStageExecution Pipelined stage execution for stage 20231021_054545_00000_uq3tq.1 failed
io.trino.spi.TrinoException: Unhandled type for SqlRow: row(ordernum varchar, paymentmode varchar)
at org.apache.paimon.trino.TrinoPageSourceBase.appendTo(TrinoPageSourceBase.java:209)
at org.apache.paimon.trino.TrinoPageSourceBase.nextPage(TrinoPageSourceBase.java:140)
at org.apache.paimon.trino.TrinoPageSourceBase.lambda$getNextPage$0(TrinoPageSourceBase.java:121)
at org.apache.paimon.trino.ClassLoaderUtils.runWithContextClassLoader(ClassLoaderUtils.java:30)
at org.apache.paimon.trino.TrinoPageSourceBase.getNextPage(TrinoPageSourceBase.java:118)
at io.trino.operator.TableScanOperator.getOutput(TableScanOperator.java:302)
at io.trino.operator.Driver.processInternal(Driver.java:395)
at io.trino.operator.Driver.lambda$process$8(Driver.java:298)
at io.trino.operator.Driver.tryWithLock(Driver.java:694)
at io.trino.operator.Driver.process(Driver.java:290)
at io.trino.operator.Driver.processForDuration(Driver.java:261)
at io.trino.execution.SqlTaskExecution$DriverSplitRunner.processFor(SqlTaskExecution.java:887)
at io.trino.execution.executor.timesharing.PrioritizedSplitRunner.process(PrioritizedSplitRunner.java:187)
at io.trino.execution.executor.timesharing.TimeSharingTaskExecutor$TaskRunner.run(TimeSharingTaskExecutor.java:565)
at io.trino.$gen.Trino_430____20231021_054528_2.run(Unknown Source)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
at java.base/java.lang.Thread.run(Thread.java:833)
2023-10-21T13:45:47.829+0800 ERROR stage-scheduler io.trino.execution.scheduler.PipelinedQueryScheduler Failure in distributed stage for query 20231021_054545_00000_uq3tq
io.trino.spi.TrinoException: Unhandled type for SqlRow: row(ordernum varchar, paymentmode varchar)
at org.apache.paimon.trino.TrinoPageSourceBase.appendTo(TrinoPageSourceBase.java:209)
at org.apache.paimon.trino.TrinoPageSourceBase.nextPage(TrinoPageSourceBase.java:140)
at org.apache.paimon.trino.TrinoPageSourceBase.lambda$getNextPage$0(TrinoPageSourceBase.java:121)
at org.apache.paimon.trino.ClassLoaderUtils.runWithContextClassLoader(ClassLoaderUtils.java:30)
at org.apache.paimon.trino.TrinoPageSourceBase.getNextPage(TrinoPageSourceBase.java:118)
at io.trino.operator.TableScanOperator.getOutput(TableScanOperator.java:302)
at io.trino.operator.Driver.processInternal(Driver.java:395)
at io.trino.operator.Driver.lambda$process$8(Driver.java:298)
at io.trino.operator.Driver.tryWithLock(Driver.java:694)
at io.trino.operator.Driver.process(Driver.java:290)
at io.trino.operator.Driver.processForDuration(Driver.java:261)
at io.trino.execution.SqlTaskExecution$DriverSplitRunner.processFor(SqlTaskExecution.java:887)
at io.trino.execution.executor.timesharing.PrioritizedSplitRunner.process(PrioritizedSplitRunner.java:187)
at io.trino.execution.executor.timesharing.TimeSharingTaskExecutor$TaskRunner.run(TimeSharingTaskExecutor.java:565)
at io.trino.$gen.Trino_430____20231021_054528_2.run(Unknown Source)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
at java.base/java.lang.Thread.run(Thread.java:833)
2023-10-21T13:45:47.833+0800 ERROR stage-scheduler io.trino.execution.StageStateMachine Stage 20231021_054545_00000_uq3tq.1 failed
io.trino.spi.TrinoException: Unhandled type for SqlRow: row(ordernum varchar, paymentmode varchar)
at org.apache.paimon.trino.TrinoPageSourceBase.appendTo(TrinoPageSourceBase.java:209)
at org.apache.paimon.trino.TrinoPageSourceBase.nextPage(TrinoPageSourceBase.java:140)
at org.apache.paimon.trino.TrinoPageSourceBase.lambda$getNextPage$0(TrinoPageSourceBase.java:121)
at org.apache.paimon.trino.ClassLoaderUtils.runWithContextClassLoader(ClassLoaderUtils.java:30)
at org.apache.paimon.trino.TrinoPageSourceBase.getNextPage(TrinoPageSourceBase.java:118)
at io.trino.operator.TableScanOperator.getOutput(TableScanOperator.java:302)
at io.trino.operator.Driver.processInternal(Driver.java:395)
at io.trino.operator.Driver.lambda$process$8(Driver.java:298)
at io.trino.operator.Driver.tryWithLock(Driver.java:694)
at io.trino.operator.Driver.process(Driver.java:290)
at io.trino.operator.Driver.processForDuration(Driver.java:261)
at io.trino.execution.SqlTaskExecution$DriverSplitRunner.processFor(SqlTaskExecution.java:887)
at io.trino.execution.executor.timesharing.PrioritizedSplitRunner.process(PrioritizedSplitRunner.java:187)
at io.trino.execution.executor.timesharing.TimeSharingTaskExecutor$TaskRunner.run(TimeSharingTaskExecutor.java:565)
at io.trino.$gen.Trino_430____20231021_054528_2.run(Unknown Source)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
at java.base/java.lang.Thread.run(Thread.java:833)
2023-10-21T13:45:47.901+0800 INFO dispatcher-query-4 io.trino.event.QueryMonitor TIMELINE: Query 20231021_054545_00000_uq3tq :: FAILED (GENERIC_INTERNAL_ERROR) :: elapsed 1996ms :: planning 193ms :: waiting 552ms :: scheduling 1586ms :: running 198ms :: finishing 19ms :: begin 2023-10-21T13:45:45.837+08:00 :: end 2023-10-21T13:45:47.833+08:00
```
### Are you willing to submit a PR?
- [ ] I'm willing to submit a PR!
--
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: issues-unsubscribe@paimon.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] [Bug] Error in querying table with row type column under trino 430 [incubator-paimon]
Posted by "JingsongLi (via GitHub)" <gi...@apache.org>.
JingsongLi closed issue #2159: [Bug] Error in querying table with row type column under trino 430
URL: https://github.com/apache/incubator-paimon/issues/2159
--
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: issues-unsubscribe@paimon.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org