Merge pull request #6 from knaufk/datetimeparsing

Set DateTimeFormatter locale to us. Resolves #1.
knaufk · Jan 4, 2021 · 8f4d278 · 8f4d278
2 parents f56be9c + 378319d
commit 8f4d278
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/main/java/com/github/knaufk/flink/faker/FakerUtils.java b/src/main/java/com/github/knaufk/flink/faker/FakerUtils.java
@@ -4,6 +4,7 @@
 import java.math.BigInteger;
 import java.time.Instant;
 import java.time.format.DateTimeFormatter;
+import java.util.Locale;
 import org.apache.flink.table.data.DecimalData;
 import org.apache.flink.table.data.StringData;
 import org.apache.flink.table.data.TimestampData;
@@ -13,7 +14,8 @@ public class FakerUtils {
 
   public static final String FAKER_DATETIME_FORMAT = "EEE MMM dd HH:mm:ss zzz yyyy";
 
-  private static DateTimeFormatter formatter = DateTimeFormatter.ofPattern(FAKER_DATETIME_FORMAT);;
+  private static DateTimeFormatter formatter =
+      DateTimeFormatter.ofPattern(FAKER_DATETIME_FORMAT, new Locale("us"));
 
   static Object stringValueToType(String value, LogicalTypeRoot logicalType) {