read hudi data from trino in GCP

[Pavan792reddy]

hi all i am getting the below error while reading the hudi table using trino

2024-06-24T14:34:16.315Z INFO dispatcher-query-12 io.trino.event.QueryMonitor TIMELINE: Query 20240624_143414_00008_tz9za :: FAILED (NO_NODES_AVAILABLE) :: elapsed 1520ms :: planning 15ms :: waiting 352ms :: scheduling 1505ms :: running 0ms :: finishing 1505ms :: begin 2024-06-24T14:34:14.793Z :: end 2024-06-24T14:34:16.313Z
2024-06-24T14:34:39.647Z INFO hudi-split-manager-6 io.trino.plugin.hudi.table.HudiTableFileSystemView Building file system view for partition (direction=north)
2024-06-24T14:34:39.655Z INFO hudi-split-manager-7 io.trino.plugin.hudi.table.HudiTableFileSystemView Building file system view for partition (direction=south)
2024-06-24T14:34:39.667Z INFO hudi-split-manager-9 io.trino.plugin.hudi.table.HudiTableFileSystemView Building file system view for partition (direction=east)
2024-06-24T14:34:39.674Z INFO hudi-split-manager-8 io.trino.plugin.hudi.table.HudiTableFileSystemView Building file system view for partition (direction=west)
2024-06-24T14:34:39.717Z ERROR query-execution-6 io.trino.execution.scheduler.PipelinedQuerySchedulerFailure in distributed stage for query 20240624_143438_00009_tz9za
io.trino.spi.TrinoException: No nodes available to run query
at io.trino.execution.scheduler.UniformNodeSelector.computeAssignments(UniformNodeSelector.java:215)
at io.trino.execution.scheduler.DynamicSplitPlacementPolicy.computeAssignments(DynamicSplitPlacementPolicy.java:41)
at io.trino.execution.scheduler.SourcePartitionedScheduler.schedule(SourcePartitionedScheduler.java:292)
at io.trino.execution.scheduler.SourcePartitionedScheduler$1.schedule(SourcePartitionedScheduler.java:172)
at io.trino.execution.scheduler.PipelinedQueryScheduler$DistributedStagesScheduler.schedule(PipelinedQueryScheduler.java:1266)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
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:840)
2024-06-24T14:34:39.718Z INFO dispatcher-query-12 io.trino.event.QueryMonitor TIMELINE: Query 20240624_143438_00009_tz9za :: FAILED (NO_NODES_AVAILABLE) :: elapsed 1418ms :: planning 15ms :: waiting 317ms :: scheduling 1403ms :: running 0ms :: finishing 1403ms :: begin 2024-06-24T14:34:38.299Z :: end 2024-06-24T14:34:39.717Z
SELECT node_id,state,coordinator FROM system.runtime.nodes
node_id | state | coordinator
--------------------------------------+--------+-------------
bc6f4c57-66ce-4c70-bb06-a4740118f5e2 | active | true
9933b18f-bcc6-4059-a40c-d655537a83b5 | active | false
0b43db5d-2507-488d-9dc5-b30e120f2f82 | active | false
(3 rows)
Query 20240624_144836_00010_tz9za, FINISHED, 1 node
Splits: 1 total, 1 done (100.00%)
0.23 [3 rows, 207B] [13 rows/s, 908B/s]

[alberttwong]

I would try Trino 418.