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 <[email protected]>
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
