编译问题

dapeng · dapeng · commit 42e83e7eb13f · 2020-05-12T14:15:59.000+08:00
diff --git a/redis5/redis5-side/redis-async-side/src/main/java/com/dtstack/flink/sql/side/redis/RedisAsyncReqRow.java b/redis5/redis5-side/redis-async-side/src/main/java/com/dtstack/flink/sql/side/redis/RedisAsyncReqRow.java
@@ -144,7 +144,7 @@ public void accept(Map<String, String> values) {
                         dealCacheData(key,CacheObj.buildCacheObj(ECacheContentType.MultiLine, values));
                         resultFuture.complete(Collections.singleton(new CRow(row, input.change())));
                     } catch (Exception e) {
-                        dealFillDataError(resultFuture, e, input);
+                        dealFillDataError(input, resultFuture, e);
                     }
                 } else {
                     dealMissKey(input, resultFuture);

Original file line number	Diff line number	Diff line change
`@@ -144,7 +144,7 @@ public void accept(Map<String, String> values) {`
`144`	`144`	`dealCacheData(key,CacheObj.buildCacheObj(ECacheContentType.MultiLine, values));`
`145`	`145`	`resultFuture.complete(Collections.singleton(new CRow(row, input.change())));`
`146`	`146`	`} catch (Exception e) {`
`147`		`- dealFillDataError(resultFuture, e, input);`
	`147`	`+ dealFillDataError(input, resultFuture, e);`
`148`	`148`	`}`
`149`	`149`	`} else {`
`150`	`150`	`dealMissKey(input, resultFuture);`