1

Alluxio 上で Presto クエリを実行しているときに、このスタック トレースに遭遇しました。クエリが成功することもありますが、このエラーで失敗することもあります。それはどういう意味ですか、どうすれば修正できますか?

com.facebook.presto.spi.PrestoException: Hive 分割 alluxio://xxxxx:19998/s3/data/m-00025 (offset=100663296, length=53990296) org.apache.hadoop.mapred.TextInputFormat: Channel を使用して開くときにエラーが発生しました[id: 0xfa748b02, L:/xxxxx:34874 ! R:xxxxx/xxxxx:29999] は終了しました。
    com.facebook.presto.hive.HiveUtil.createRecordReader (HiveUtil.java:219) で
    com.facebook.presto.hive.GenericHiveRecordCursorProvider.lambda$createRecordCursor$0(GenericHiveRecordCursorProvider.java:71) で
    com.facebook.presto.hive.authentication.NoHdfsAuthentication.doAs (NoHdfsAuthentication.java:23) で
    com.facebook.presto.hive.HdfsEnvironment.doAs (HdfsEnvironment.java:80) で
    com.facebook.presto.hive.GenericHiveRecordCursorProvider.createRecordCursor (GenericHiveRecordCursorProvider.java:70) で
    com.facebook.presto.hive.HivePageSourceProvider.createHivePageSource (HivePageSourceProvider.java:183) で
    com.facebook.presto.hive.HivePageSourceProvider.createPageSource (HivePageSourceProvider.java:93) で
    com.facebook.presto.spi.connector.classloader.ClassLoaderSafeConnectorPageSourceProvider.createPageSource(ClassLoaderSafeConnectorPageSourceProvider.java:44) で
    com.facebook.presto.split.PageSourceManager.createPageSource(PageSourceManager.java:56) で
    com.facebook.presto.operator.ScanFilterAndProjectOperator.getOutput(ScanFilterAndProjectOperator.java:216) で
    com.facebook.presto.operator.Driver.processInternal(Driver.java:379)で
    com.facebook.presto.operator.Driver.lambda$processFor$8(Driver.java:283) で
    com.facebook.presto.operator.Driver.tryWithLock(Driver.java:675) で
    com.facebook.presto.operator.Driver.processFor(Driver.java:276) で
    com.facebook.presto.execution.SqlTask​​Execution$DriverSplitRunner.processFor (SqlTask​​Execution.java:1053) で
    com.facebook.presto.execution.executor.PrioritizedSplitRunner.process(PrioritizedSplitRunner.java:162)で
    com.facebook.presto.execution.executor.TaskExecutor$TaskRunner.run (TaskExecutor.java:456) で
    java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1149) で
    java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) で
    java.lang.Thread.run(Thread.java:748) で
原因: java.io.IOException: Channel [id: 0xfa748b02, L:/xxxxx:34874 ! R:xxxxx/xxxxx:29999] は終了しました。
    alluxio.client.block.stream.NettyPacketReader$PacketReadHandler.channelUnregistered(NettyPacketReader.java:314) で
    alluxio.core.client.runtime.io.netty.channel.AbstractChannelHandlerContext.invokeChannelUnregistered (AbstractChannelHandlerContext.java:176) で
4

1 に答える 1