Repository: carbondata Updated Branches: refs/heads/master faf74209a -> 1dc86d291
[CARBONDATA-2711] carbonFileList is not initalized when updatetablelist call bug fix: carbon is not initalized within updatetablelist method when we execute 'SELECT table_name FROM information_schema.tables WHERE table_schema = 'tmp_sbu_vadmdb' from command line This closes #2468 Project: http://git-wip-us.apache.org/repos/asf/carbondata/repo Commit: http://git-wip-us.apache.org/repos/asf/carbondata/commit/1dc86d29 Tree: http://git-wip-us.apache.org/repos/asf/carbondata/tree/1dc86d29 Diff: http://git-wip-us.apache.org/repos/asf/carbondata/diff/1dc86d29 Branch: refs/heads/master Commit: 1dc86d2919d4e5e0b3285c3fb28f3b6e816380ae Parents: faf7420 Author: peter.wei <[email protected]> Authored: Mon Jul 9 22:07:15 2018 +0800 Committer: chenliang613 <[email protected]> Committed: Tue Jul 10 16:26:04 2018 +0800 ---------------------------------------------------------------------- .../java/org/apache/carbondata/presto/impl/CarbonTableReader.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/carbondata/blob/1dc86d29/integration/presto/src/main/java/org/apache/carbondata/presto/impl/CarbonTableReader.java ---------------------------------------------------------------------- diff --git a/integration/presto/src/main/java/org/apache/carbondata/presto/impl/CarbonTableReader.java b/integration/presto/src/main/java/org/apache/carbondata/presto/impl/CarbonTableReader.java index 77c8ce5..7441f4b 100755 --- a/integration/presto/src/main/java/org/apache/carbondata/presto/impl/CarbonTableReader.java +++ b/integration/presto/src/main/java/org/apache/carbondata/presto/impl/CarbonTableReader.java @@ -246,6 +246,7 @@ public class CarbonTableReader { * @return */ private Set<String> updateTableList(String schemaName) { + updateCarbonFile(); List<CarbonFile> schema = Stream.of(carbonFileList.listFiles()).filter(a -> schemaName.equals(a.getName())) .collect(Collectors.toList()); @@ -571,4 +572,4 @@ public class CarbonTableReader { public void setQueryId(String queryId) { this.queryId = queryId; } -} \ No newline at end of file +}
