bugfix

sishu@dtstack.com · sishu@dtstack.com · commit d91101ca514a · 2018-12-05T20:53:51.000+08:00
diff --git a/cassandra/cassandra-side/cassandra-all-side/src/main/java/com/dtstack/flink/sql/side/cassandra/CassandraAllReqRow.java b/cassandra/cassandra-side/cassandra-all-side/src/main/java/com/dtstack/flink/sql/side/cassandra/CassandraAllReqRow.java
@@ -81,7 +81,7 @@ public CassandraAllReqRow(RowTypeInfo rowTypeInfo, JoinInfo joinInfo, List<Field
     }
 
     @Override
-    protected Row fillData(Row input, Object sideInput) {
+    public Row fillData(Row input, Object sideInput) {
         Map<String, Object> cacheInfo = (Map<String, Object>) sideInput;
         Row row = new Row(sideInfo.getOutFieldInfoList().size());
         for (Map.Entry<Integer, Integer> entry : sideInfo.getInFieldIndex().entrySet()) {

Original file line number	Diff line number	Diff line change
`@@ -81,7 +81,7 @@ public CassandraAllReqRow(RowTypeInfo rowTypeInfo, JoinInfo joinInfo, List<Field`
`81`	`81`	`}`
`82`	`82`
`83`	`83`	`@Override`
`84`		`- protected Row fillData(Row input, Object sideInput) {`
	`84`	`+ public Row fillData(Row input, Object sideInput) {`
`85`	`85`	`Map<String, Object> cacheInfo = (Map<String, Object>) sideInput;`
`86`	`86`	`Row row = new Row(sideInfo.getOutFieldInfoList().size());`
`87`	`87`	`for (Map.Entry<Integer, Integer> entry : sideInfo.getInFieldIndex().entrySet()) {`