[
https://issues.apache.org/jira/browse/CARBONDATA-3177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723988#comment-16723988
]
Ravindra Pesala commented on CARBONDATA-3177:
---------------------------------------------
I will check.
> Nameservice support for presto on carbondata
> --------------------------------------------
>
> Key: CARBONDATA-3177
> URL: https://issues.apache.org/jira/browse/CARBONDATA-3177
> Project: CarbonData
> Issue Type: Improvement
> Affects Versions: 1.5.1
> Reporter: Ryan Sun
> Assignee: Ravindra Pesala
> Priority: Major
>
> Hey team,
>
> As per the carbondata-presto integration reference, the carbondata-store is
> configured with specified namenode address, e.g.
> hdfs://namenode:9000/test/carbondata.
>
> However we leverage namenode federation so the hdfs entry is configured with
> nameservice, e.g. hdfs://nameservice1/test/carbondata. The nameservice
> information is configured in hdfs-site.xml. It seems that carbondata
> connector has no way to load this configuration file. So it fails with
> exception message:
> {code:java}
> Query 20181217_142352_01851_paya2 failed: java.lang.IllegalArgumentException:
> java.net.UnknownHostException: nameservice1
> java.lang.RuntimeException: java.lang.IllegalArgumentException:
> java.net.UnknownHostException: nameservice1
> at
> org.apache.carbondata.presto.impl.CarbonTableReader.updateCarbonFile(CarbonTableReader.java:204)
> at
> org.apache.carbondata.presto.impl.CarbonTableReader.updateSchemaList(CarbonTableReader.java:216)
> at
> org.apache.carbondata.presto.impl.CarbonTableReader.getSchemaNames(CarbonTableReader.java:189)
> at
> org.apache.carbondata.presto.CarbondataMetadata.listSchemaNamesInternal(CarbondataMetadata.java:86)
> at
> org.apache.carbondata.presto.CarbondataMetadata.getTableMetadata(CarbondataMetadata.java:135)
> at
> org.apache.carbondata.presto.CarbondataMetadata.getTableMetadataInternal(CarbondataMetadata.java:240)
> at
> org.apache.carbondata.presto.CarbondataMetadata.getTableMetadata(CarbondataMetadata.java:232)
> at
> com.facebook.presto.spi.connector.classloader.ClassLoaderSafeConnectorMetadata.getTableMetadata(ClassLoaderSafeConnectorMetadata.java:162)
> at
> com.facebook.presto.metadata.MetadataManager.getTableMetadata(MetadataManager.java:423)
> at
> com.facebook.presto.sql.analyzer.StatementAnalyzer$Visitor.visitTable(StatementAnalyzer.java:857)
> at
> com.facebook.presto.sql.analyzer.StatementAnalyzer$Visitor.visitTable(StatementAnalyzer.java:262)
> at com.facebook.presto.sql.tree.Table.accept(Table.java:53)
> at com.facebook.presto.sql.tree.AstVisitor.process(AstVisitor.java:27)
> at
> com.facebook.presto.sql.analyzer.StatementAnalyzer$Visitor.process(StatementAnalyzer.java:276)
> at
> com.facebook.presto.sql.analyzer.StatementAnalyzer$Visitor.analyzeFrom(StatementAnalyzer.java:1780)
> at
> com.facebook.presto.sql.analyzer.StatementAnalyzer$Visitor.visitQuerySpecification(StatementAnalyzer.java:962)
> at
> com.facebook.presto.sql.analyzer.StatementAnalyzer$Visitor.visitQuerySpecification(StatementAnalyzer.java:262)
> at
> com.facebook.presto.sql.tree.QuerySpecification.accept(QuerySpecification.java:127)
> at com.facebook.presto.sql.tree.AstVisitor.process(AstVisitor.java:27)
> at
> com.facebook.presto.sql.analyzer.StatementAnalyzer$Visitor.process(StatementAnalyzer.java:276)
> at
> com.facebook.presto.sql.analyzer.StatementAnalyzer$Visitor.process(StatementAnalyzer.java:286)
> at
> com.facebook.presto.sql.analyzer.StatementAnalyzer$Visitor.visitQuery(StatementAnalyzer.java:683)
> at
> com.facebook.presto.sql.analyzer.StatementAnalyzer$Visitor.visitQuery(StatementAnalyzer.java:262)
> at com.facebook.presto.sql.tree.Query.accept(Query.java:94)
> at com.facebook.presto.sql.tree.AstVisitor.process(AstVisitor.java:27)
> at
> com.facebook.presto.sql.analyzer.StatementAnalyzer$Visitor.process(StatementAnalyzer.java:276)
> at
> com.facebook.presto.sql.analyzer.StatementAnalyzer.analyze(StatementAnalyzer.java:248)
> at com.facebook.presto.sql.analyzer.Analyzer.analyze(Analyzer.java:76)
> at com.facebook.presto.sql.analyzer.Analyzer.analyze(Analyzer.java:68)
> at
> com.facebook.presto.execution.SqlQueryExecution.<init>(SqlQueryExecution.java:206)
> at
> com.facebook.presto.execution.SqlQueryExecution.<init>(SqlQueryExecution.java:96)
> at
> com.facebook.presto.execution.SqlQueryExecution$SqlQueryExecutionFactory.createQueryExecution(SqlQueryExecution.java:752)
> at
> com.facebook.presto.execution.SqlQueryManager.createQueryInternal(SqlQueryManager.java:361)
> at
> com.facebook.presto.execution.SqlQueryManager.lambda$createQuery$4(SqlQueryManager.java:303)
> at
> com.facebook.presto.$gen.Presto_0_214_9_g36965f8_dirty__0_214_100_2____20181217_102607_1.run(Unknown
> Source)
> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
> at java.util.concurrent.FutureTask.run(FutureTask.java:266)
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> at java.lang.Thread.run(Thread.java:748)
> Caused by: java.lang.IllegalArgumentException: java.net.UnknownHostException:
> nameservice1
> at
> org.apache.hadoop.security.SecurityUtil.buildTokenService(SecurityUtil.java:378)
> at
> org.apache.hadoop.hdfs.NameNodeProxies.createNonHAProxy(NameNodeProxies.java:310)
> at
> org.apache.hadoop.hdfs.NameNodeProxies.createProxy(NameNodeProxies.java:176)
> at org.apache.hadoop.hdfs.DFSClient.<init>(DFSClient.java:678)
> at org.apache.hadoop.hdfs.DFSClient.<init>(DFSClient.java:619)
> at
> org.apache.hadoop.hdfs.DistributedFileSystem.initialize(DistributedFileSystem.java:149)
> at org.apache.hadoop.fs.FileSystem.createFileSystem(FileSystem.java:2669)
> at org.apache.hadoop.fs.FileSystem.access$200(FileSystem.java:94)
> at org.apache.hadoop.fs.FileSystem$Cache.getInternal(FileSystem.java:2703)
> at org.apache.hadoop.fs.FileSystem$Cache.get(FileSystem.java:2685)
> at org.apache.hadoop.fs.FileSystem.get(FileSystem.java:373)
> at org.apache.hadoop.fs.Path.getFileSystem(Path.java:295)
> at
> org.apache.carbondata.core.datastore.filesystem.AbstractDFSCarbonFile.<init>(AbstractDFSCarbonFile.java:74)
> at
> org.apache.carbondata.core.datastore.filesystem.AbstractDFSCarbonFile.<init>(AbstractDFSCarbonFile.java:66)
> at
> org.apache.carbondata.core.datastore.filesystem.HDFSCarbonFile.<init>(HDFSCarbonFile.java:41)
> at
> org.apache.carbondata.core.datastore.impl.DefaultFileTypeProvider.getCarbonFile(DefaultFileTypeProvider.java:51)
> at
> org.apache.carbondata.core.datastore.impl.FileFactory.getCarbonFile(FileFactory.java:102)
> at
> org.apache.carbondata.presto.impl.CarbonTableReader.updateCarbonFile(CarbonTableReader.java:202)
> ... 39 more
> {code}
>
> Any suggestion or workaround is appreciated.
>
> Thanks
>
> Best regards,
> Ryan
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
