This is an automated email from the ASF dual-hosted git repository.
twalthr 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 07d9253 [hotfix][examples-table] Fix indention in ChangelogCsvFormat
07d9253 is described below
commit 07d925300faa684e26c0bf7a28c0ad1f05638821
Author: Timo Walther <[email protected]>
AuthorDate: Tue Jun 23 14:36:57 2020 +0200
[hotfix][examples-table] Fix indention in ChangelogCsvFormat
---
.../apache/flink/table/examples/java/connectors/ChangelogCsvFormat.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/connectors/ChangelogCsvFormat.java
b/flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/connectors/ChangelogCsvFormat.java
index 0f66748..c8c8689 100644
---
a/flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/connectors/ChangelogCsvFormat.java
+++
b/flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/connectors/ChangelogCsvFormat.java
@@ -50,7 +50,7 @@ public final class ChangelogCsvFormat implements
DecodingFormat<DeserializationS
final TypeInformation<RowData> producedTypeInfo =
(TypeInformation<RowData>) context.createTypeInformation(producedDataType);
// most of the code in DeserializationSchema will not work on
internal data structures
- // create a converter for conversion at the end
+ // create a converter for conversion at the end
final DataStructureConverter converter =
context.createDataStructureConverter(producedDataType);
// use logical types during runtime for parsing