I am getting the following error even though that file exists in hdfs
0: jdbc:drill:zk=local> select * from
hdfs.`/user/train/xd/tweets/tmp/tweets-0.txt`;
Oct 22, 2014 5:16:31 PM org.eigenbase.sql.validate.SqlValidatorException
<init>
SEVERE: org.eigenbase.sql.validate.SqlValidatorException: Table
'hdfs./user/train/xd/tweets/tmp/tweets-0.txt' not found
Oct 22, 2014 5:16:31 PM org.eigenbase.util.EigenbaseException <init>
SEVERE: org.eigenbase.util.EigenbaseContextException: From line 1, column
15 to line 1, column 18: Table
'hdfs./user/train/xd/tweets/tmp/tweets-0.txt' not found
Query failed: Failure while parsing sql. Table
'hdfs./user/train/xd/tweets/tmp/tweets-0.txt' not found
[7e1d5c73-0521-480e-b74b-a4fa50e3f4a7]
Error: exception while executing query: Failure while trying to get next
result batch. (state=,code=0)
I created new plugin called hdfs.
{
"type": "file",
"enabled": true,
"connection": "hdfs://10.225.156.201:9000/",
"workspaces": {
"json": {
"location": "/user/train/xd/tweets/tmp",
"writable": false,
"storageformat": "json"
}
},
"formats": {
"json": {
"type": "json"
}
}
}
|