You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eagle.apache.org by yo...@apache.org on 2016/09/07 17:42:16 UTC
[20/52] [abbrv] incubator-eagle git commit: [EAGLE-499] Fix flushing
entities for spark history job doFlush() was commented.. Adding back.
[EAGLE-499] Fix flushing entities for spark history job
doFlush() was commented.. Adding back.
https://issues.apache.org/jira/browse/EAGLE-499
Author: @pkuwm <ih...@gmail.com>
Reviewer: @DadanielZ <da...@apache.org>
Closes #385
Project: http://git-wip-us.apache.org/repos/asf/incubator-eagle/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-eagle/commit/36f9a848
Tree: http://git-wip-us.apache.org/repos/asf/incubator-eagle/tree/36f9a848
Diff: http://git-wip-us.apache.org/repos/asf/incubator-eagle/diff/36f9a848
Branch: refs/heads/master
Commit: 36f9a8481e507d3ac0a4522da28a600f0ec6d451
Parents: c5d05ab
Author: DadanielZ <da...@apache.org>
Authored: Thu Aug 25 14:41:28 2016 -0700
Committer: DadanielZ <da...@apache.org>
Committed: Thu Aug 25 14:41:28 2016 -0700
----------------------------------------------------------------------
.../java/org/apache/eagle/jpm/spark/crawl/JHFSparkEventReader.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/36f9a848/eagle-jpm/eagle-jpm-entity/src/main/java/org/apache/eagle/jpm/spark/crawl/JHFSparkEventReader.java
----------------------------------------------------------------------
diff --git a/eagle-jpm/eagle-jpm-entity/src/main/java/org/apache/eagle/jpm/spark/crawl/JHFSparkEventReader.java b/eagle-jpm/eagle-jpm-entity/src/main/java/org/apache/eagle/jpm/spark/crawl/JHFSparkEventReader.java
index a5e630a..edb3854 100644
--- a/eagle-jpm/eagle-jpm-entity/src/main/java/org/apache/eagle/jpm/spark/crawl/JHFSparkEventReader.java
+++ b/eagle-jpm/eagle-jpm-entity/src/main/java/org/apache/eagle/jpm/spark/crawl/JHFSparkEventReader.java
@@ -709,6 +709,7 @@ public class JHFSparkEventReader {
private void doFlush(List entities) throws Exception {
LOG.info("start flushing entities of total number " + entities.size());
+ client.create(entities);
LOG.info("finish flushing entities of total number " + entities.size());
}
}
\ No newline at end of file