Re: Flink sql using Hive for metastore throws Exception

2021-02-05 Thread Robert Metzger
I'm not sure if this is related, but you are mixing scala 2.11 and 2.12 dependencies (and mentioning scala 2.1.1 dependencies). On Tue, Feb 2, 2021 at 8:32 AM Eleanore Jin wrote: > Hi experts, > I am trying to experiment how to use Hive to store metadata along using > Flink SQL. I am running Hiv

Flink sql using Hive for metastore throws Exception

2021-02-01 Thread Eleanore Jin
Hi experts, I am trying to experiment how to use Hive to store metadata along using Flink SQL. I am running Hive inside a docker container locally, and running Flink SQL program through IDE. Flink version 1.12.0 the sample code looks like: StreamExecutionEnvironment bsEnv = StreamExecutionEnviro