Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/5662#discussion_r173888555
--- Diff:
flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaJsonTableSourceFactoryTestBase.java
---
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5662#discussion_r173881141
--- Diff:
flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaJsonTableSourceFactoryTestBase.java
---
Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/5662#discussion_r173879267
--- Diff:
flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaJsonTableSourceFactoryTestBase.java
---
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5662#discussion_r173863375
--- Diff:
flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaJsonTableSourceFactoryTestBase.java
---
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
---
Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/5662#discussion_r173857218
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/SchemaValidator.scala
---
@@ -148,6 +148,13 @@ object SchemaValidator
Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/5662#discussion_r173791129
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/SchemaValidator.scala
---
@@ -148,6 +148,13 @@ object SchemaValidator
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5662#discussion_r173786510
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/SchemaValidator.scala
---
@@ -148,6 +148,13 @@ object
Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/5662#discussion_r173784883
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/SchemaValidator.scala
---
@@ -148,6 +148,13 @@ object SchemaValidator
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5662#discussion_r173465435
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/SchemaValidator.scala
---
@@ -198,14 +205,20 @@ object
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5662
---
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/5662
[FLINK-8854] [table] Fix schema mapping with time attributes
## What is the purpose of the change
This PR fixes the invalid field mapping and improves the mapping of time
attributes in
12 matches
Mail list logo