[FLINK-3241] Fix Scala 2.11 build by moving some flink-table classes …

…into the right directory
apache · Jan 19, 2016 · 018f1fe · 018f1fe
1 parent 046f044
commit 018f1fe
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/.../apache/flink/api/table/explain/Node.java → .../apache/flink/api/table/explain/Node.java b/.../apache/flink/api/table/explain/Node.java → .../apache/flink/api/table/explain/Node.java
diff --git a/...ink/api/table/explain/PlanJsonParser.java → ...ink/api/table/explain/PlanJsonParser.java b/...ink/api/table/explain/PlanJsonParser.java → ...ink/api/table/explain/PlanJsonParser.java
@@ -59,13 +59,16 @@ public static String getSqlExecutionPlan(String t, Boolean extended) throws Exce
 
 			//drop the hashcode of object instance
 			int dele = tempNode.getContents().indexOf("@");
-			if (dele > -1) content = tempNode.getContents().substring(0, dele);
+			if (dele > -1) {
+				content = tempNode.getContents().substring(0, dele);
+			}
 
 			//replace with certain content if node is dataSource to pass
 			//unit tests, because java and scala use different api to
 			//get input element
-			if (tempNode.getPact().equals("Data Source"))
+			if (tempNode.getPact().equals("Data Source")) {
 				content = "collect elements with CollectionInputFormat";
+			}
 			pw.print("content : " + content + "\n");
 
 			List<Predecessors> predecessors = tempNode.getPredecessors();