fix list table names (#69)

vesoft-inc · Jul 19, 2022 · 428de90 · 428de90
1 parent 93df7a1
commit 428de90
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/connector/src/main/java/org.apache.flink/connector/nebula/catalog/NebulaCatalog.java b/connector/src/main/java/org.apache.flink/connector/nebula/catalog/NebulaCatalog.java
@@ -133,10 +133,10 @@ public List<String> listTables(String graphSpace) throws DatabaseNotExistExcepti
         List<String> tables = new ArrayList<>();
         try {
             for (TagItem tag : metaClient.getTags(graphSpace)) {
-                tables.add("VERTEX" + NebulaConstant.POINT + tag.tag_name);
+                tables.add("VERTEX" + NebulaConstant.POINT + new String(tag.tag_name));
             }
             for (EdgeItem edge : metaClient.getEdges(graphSpace)) {
-                tables.add("EDGE" + NebulaConstant.POINT + edge.edge_name);
+                tables.add("EDGE" + NebulaConstant.POINT + new String(edge.edge_name));
             }
         } catch (TException | ExecuteFailedException e) {
             LOG.error("get tags or edges error,", e);