| commit | 8b1cadb32a72578eaa38c99ad591d35766b45d65 | [log] [tgz] |
|---|---|---|
| author | Seth Wiesman <sjwiesman@gmail.com> | Fri Oct 09 09:59:34 2020 -0500 |
| committer | Seth Wiesman <sjwiesman@gmail.com> | Fri Oct 09 09:59:49 2020 -0500 |
| tree | e54b0bec7c6eace0c325050bd9174e4cb3a08902 | |
| parent | 811760b4171238a8bfc25219e9c29e2622fafccb [diff] | |
| parent | 1560c7886fa8598446698ede105456036533f7d9 [diff] |
[hotfix] Update datetime formatter to actually produce and store per-hour data This closes #17
diff --git a/docker/data-generator/src/main/java/org/apache/flink/playground/datagen/model/TransactionSerializer.java b/docker/data-generator/src/main/java/org/apache/flink/playground/datagen/model/TransactionSerializer.java index b57b5f0..aa6a7d3 100644 --- a/docker/data-generator/src/main/java/org/apache/flink/playground/datagen/model/TransactionSerializer.java +++ b/docker/data-generator/src/main/java/org/apache/flink/playground/datagen/model/TransactionSerializer.java
@@ -26,7 +26,7 @@ public class TransactionSerializer implements Serializer<Transaction> { private static final DateTimeFormatter formatter = - DateTimeFormatter.ofPattern("yyyy-MM-dd hh:mm:ss"); + DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); @Override public void configure(Map<String, ?> map, boolean b) {}