Thanks @fhueske , looks like `var` in scala is not recommended, sorry that I'm still getting used to scala style. I've replaced it with an recursive internal function.
As for the nesting `match` blocks, I would like to keep it consistent with similar cases in `StreamTableEnvironment.registerTableSinkInternal()` and `BatchTableEnvironment.registerTableSinkInternal()`, which I think is better than `if` statement. What do you think? Or please just improve it if there is more clean way. Thanks. [ Full content available at: https://github.com/apache/flink/pull/6508 ] This message was relayed via gitbox.apache.org for [email protected]
