twalthr commented on a change in pull request #13910:
URL: https://github.com/apache/flink/pull/13910#discussion_r518662387
##########
File path:
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java
##########
@@ -179,13 +183,37 @@ public ScanRuntimeProvider
getScanRuntimeProvider(ScanContext context) {
@Override
public Map<String, DataType> listReadableMetadata() {
final Map<String, DataType> metadataMap = new LinkedHashMap<>();
+
+ // add value format metadata with prefix
Review comment:
actually the order doesn't matter here, but I just noticed that the
order should be the other way around if format metadata should have higher
precedence
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
