You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@giraph.apache.org by di...@apache.org on 2020/05/13 04:09:27 UTC
[giraph] branch trunk updated: GIRAPH-1245
This is an automated email from the ASF dual-hosted git repository.
dionysios pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/giraph.git
The following commit(s) were added to refs/heads/trunk by this push:
new 5e4d7fb GIRAPH-1245
5e4d7fb is described below
commit 5e4d7fbc87851bed43cb9d28c5bc7e894e1fcdc9
Author: Dionysios Logothetis <dl...@gmail.com>
AuthorDate: Tue May 12 21:09:08 2020 -0700
GIRAPH-1245
closes #136
---
.../giraph/block_app/framework/output/BlockOutputHandle.java | 8 ++++----
pom.xml | 2 +-
2 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/giraph-block-app/src/main/java/org/apache/giraph/block_app/framework/output/BlockOutputHandle.java b/giraph-block-app/src/main/java/org/apache/giraph/block_app/framework/output/BlockOutputHandle.java
index a16963d..07243eb 100644
--- a/giraph-block-app/src/main/java/org/apache/giraph/block_app/framework/output/BlockOutputHandle.java
+++ b/giraph-block-app/src/main/java/org/apache/giraph/block_app/framework/output/BlockOutputHandle.java
@@ -51,11 +51,11 @@ public class BlockOutputHandle implements BlockOutputApi {
Progressable hadoopProgressable) {
outputDescMap = BlockOutputFormat.createInitAndCheckOutputDescsMap(
conf, jobIdentifier);
- for (String confOption : outputDescMap.keySet()) {
- outputDescMap.get(confOption).preWriting();
- freeWriters.put(confOption,
+ for (Map.Entry<String, BlockOutputDesc> entry : outputDescMap.entrySet()) {
+ entry.getValue().preWriting();
+ freeWriters.put(entry.getKey(),
new ConcurrentLinkedQueue<BlockOutputWriter>());
- occupiedWriters.put(confOption,
+ occupiedWriters.put(entry.getKey(),
new ConcurrentLinkedQueue<BlockOutputWriter>());
}
initialize(conf, hadoopProgressable);
diff --git a/pom.xml b/pom.xml
index c02c1fa..bf5b6e8 100644
--- a/pom.xml
+++ b/pom.xml
@@ -776,7 +776,7 @@ under the License.
<plugin>
<groupId>org.codehaus.mojo</groupId>
<artifactId>findbugs-maven-plugin</artifactId>
- <version>3.0.0</version>
+ <version>3.0.4</version>
<configuration>
<xmlOutput>true</xmlOutput>
<findbugsXmlOutput>false</findbugsXmlOutput>