eagle-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From yonzhang2...@apache.org
Subject [20/52] [abbrv] incubator-eagle git commit: [EAGLE-499] Fix flushing entities for spark history job doFlush() was commented.. Adding back.
Date Wed, 07 Sep 2016 17:42:16 GMT
[EAGLE-499] Fix flushing entities for spark history job
doFlush() was commented.. Adding back.

https://issues.apache.org/jira/browse/EAGLE-499

Author: @pkuwm <ihuizhi.lu@gmail.com>
Reviewer: @DadanielZ <dazhou@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 <dazhou@apache.org>
Authored: Thu Aug 25 14:41:28 2016 -0700
Committer: DadanielZ <dazhou@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


Mime
View raw message