This is an automated email from the ASF dual-hosted git repository. rmetzger pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push: new ca8145e [FLINK-12187] Bug fixes, Use BufferedWriter in a loop instead of FileWriter ca8145e is described below commit ca8145e54607aa46b275d09e785e7c1653f0181c Author: bd2019us <bd201...@126.com> AuthorDate: Sat Apr 13 23:33:42 2019 -0500 [FLINK-12187] Bug fixes, Use BufferedWriter in a loop instead of FileWriter --- .../flink/examples/java/relational/util/WebLogDataGenerator.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/relational/util/WebLogDataGenerator.java b/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/relational/util/WebLogDataGenerator.java index f68ece1..7bc7ca9 100644 --- a/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/relational/util/WebLogDataGenerator.java +++ b/flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/relational/util/WebLogDataGenerator.java @@ -20,6 +20,7 @@ package org.apache.flink.examples.java.relational.util; import org.apache.flink.examples.java.relational.WebLogAnalysis; +import java.io.BufferedWriter; import java.io.FileWriter; import java.io.IOException; import java.util.Calendar; @@ -98,7 +99,7 @@ public class WebLogDataGenerator { Random rand = new Random(Calendar.getInstance().getTimeInMillis()); - try (FileWriter fw = new FileWriter(path)) { + try (BufferedWriter fw = new BufferedWriter(new FileWriter(path))) { for (int i = 0; i < noDocs; i++) { int wordsInDoc = rand.nextInt(40) + 10; @@ -136,7 +137,7 @@ public class WebLogDataGenerator { Random rand = new Random(Calendar.getInstance().getTimeInMillis()); - try (FileWriter fw = new FileWriter(path)) { + try (BufferedWriter fw = new BufferedWriter(new FileWriter(path))) { for (int i = 0; i < noDocs; i++) { // Rank StringBuilder rank = new StringBuilder(rand.nextInt(100) + "|"); @@ -168,7 +169,7 @@ public class WebLogDataGenerator { Random rand = new Random(Calendar.getInstance().getTimeInMillis()); - try (FileWriter fw = new FileWriter(path)) { + try (BufferedWriter fw = new BufferedWriter(new FileWriter(path))) { for (int i = 0; i < noVisits; i++) { int year = 2000 + rand.nextInt(10); // yearFilter 3