Re: Properly using ConnectorDescriptor instead of registerTableSource

2020-05-18 Thread Timo Walther
Hi Nikola, the reason for deprecating `registerTableSource` is that we aim to have everything declarative in Table API. A table program should simply declare what it needs and the planner should find a suitable connector, regardless how the underlying class structure looks like. This might al

Properly using ConnectorDescriptor instead of registerTableSource

2020-05-16 Thread Nikola Hrusov
Hello, I am trying to update my cluster from flink 1.9.2 to 1.10.1 We are running batch jobs in it. So far everything has been smooth and I have seen one of my method calls being deprecated. Our code is selecting some ORC files' contents and running query on them. It is something of this nature: