Hi @fhueske, thanks for your review. I thought about your comment, and I found it's hard to come up with a test case that `inputType` here is of `CRowTypeInfo`. Since only a datastream of these types (Row, POJO, Tuple, Case class, and Atomic Type) can be registered as a Table, the `inputType` here can never be `CRowTypeInfo`. May be we can remove the If condition here. Correct me if I am wrong.
[ Full content available at: https://github.com/apache/flink/pull/6666 ] This message was relayed via gitbox.apache.org for [email protected]
