flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From xccui <...@git.apache.org>
Subject [GitHub] flink pull request #5662: [FLINK-8854] [table] Fix schema mapping with time ...
Date Mon, 12 Mar 2018 16:30:49 GMT
Github user xccui commented on a diff in the pull request:

    https://github.com/apache/flink/pull/5662#discussion_r173860901
  
    --- Diff: flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaJsonTableSourceFactoryTestBase.java
---
    @@ -89,9 +94,10 @@ private void testTableSource(FormatDescriptor format) {
     		// construct table source using a builder
     
     		final Map<String, String> tableJsonMapping = new HashMap<>();
    +		tableJsonMapping.put("name", "name");
    --- End diff --
    
    This "name" to "name" mapping should not exist since we've already explicitly defined
the "fruit-name" to "name" mapping.


---

Mime
View raw message