You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tw...@apache.org on 2020/06/23 12:39:21 UTC
[flink] branch master updated: [hotfix][examples-table] Fix
indention in ChangelogCsvFormat
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 <tw...@apache.org>
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