编译问题

DTStack · May 12, 2020 · 42e83e7 · 42e83e7
1 parent b331085
commit 42e83e7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ide/redis-async-side/src/main/java/com/dtstack/flink/sql/side/redis/RedisAsyncReqRow.java b/...ide/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);