Flink: Upgrade version from 1.11.0 to 1.12.1#1956

Merged

openinx merged 11 commits intoapache:masterfrom

stevenzwu:flink12Upgrade

Feb 2, 2021

Commits on Feb 1, 2021

upgrade flink version from 1.11.0 to 1.12.0
Steven Wu
committed
only create table env once and close the table result itertor in TestFlinkScanSql
Steven Wu
committed
disable CoreOptions.CHECK_LEAKED_CLASSLOADER for FlinkTestBase
Steven Wu
committed
use try-with-resources statement for collecting table result
Steven Wu
committed
update TestFlinkTableSourc with Flink 1.12 upgrade as the behavior changed: (1) like '%' or '%%' now matches null (2) NOT IN filter push down may not maintain the same order
Steven Wu
committed
update Flink version from 1.12.0 to 1.12.1
Steven Wu
committed
address the review comments
Steven Wu
committed
fix javadoc
Steven Wu
committed
create our own MiniClusterBase class that disable classloader check, because Flink tests can still use Flink's classloader to read and validate table result after the Flink job is terminated.
Steven Wu
committed
enable TestFlinkCatalogTable#testCreateTableIfNotExists now we are on Flink 1.12.
Steven Wu
committed

Commits on Feb 2, 2021

Address latest review comments
Steven Wu
committed