DbTaskStorage: Fix getAuditLogs

6b4f6bff · Gian Merlino · 360c6a1d · 6b4f6bff
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

merger/src/main/java/com/metamx/druid/merger/coordinator/DbTaskStorage.java ...va/com/metamx/druid/merger/coordinator/DbTaskStorage.java +1 -1

未找到文件。
--- a/merger/src/main/java/com/metamx/druid/merger/coordinator/DbTaskStorage.java
+++ b/merger/src/main/java/com/metamx/druid/merger/coordinator/DbTaskStorage.java
@@ -379,7 +379,7 @@ public class DbTaskStorage implements TaskStorage
              public TaskAction apply(Map<String, Object> row)
              {
                try {
-                  return jsonMapper.readValue(row.get("payload").toString(), TaskAction.class);
+                  return jsonMapper.readValue(row.get("log_payload").toString(), TaskAction.class);
                } catch(Exception e) {
                  throw Throwables.propagate(e);
                }