Skip to content
This repository has been archived by the owner on Oct 30, 2023. It is now read-only.

Commit

Permalink
GIRAPH-1245
Browse files Browse the repository at this point in the history
closes #136
  • Loading branch information
dlogothetis committed May 13, 2020
1 parent 8dfb290 commit 5e4d7fb
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -51,11 +51,11 @@ public BlockOutputHandle(String jobIdentifier, Configuration conf,
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);
Expand Down
2 changes: 1 addition & 1 deletion pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -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>
Expand Down

0 comments on commit 5e4d7fb

Please sign in to comment.