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

Reply via email to