Re: Flink 1.11.2 读写Hive以及对hive的版本支持

[r pp]

嗨。提供一个解决的思路
       1.缺包
       2在yarn 的环境下缺包，可以把缺的包 放在集群统一的位置，在提交命令时，指名所在包的位置。

Jacob <[hidden email]> 于2020年12月18日周五 下午2:01写道：

> Dear All,
>
> Flink.11.2操作hive时，对hive的版本支持是怎样的
>
>
> 看官网介绍是支持1.0、1.1、1.2、2.0、2.1、2.2、2.3、3.1
> 我的执行环境：
>
> *Flink : 1.11.2*
> *Haoop : 2.6.0-cdh5.8.3*
> *Hive : 1.1.0-cdh5.8.3*
> *Job运行方式 ： on yarn*
>
> 同时对读写hive的demo，我不知道我写的是否正确：
>
>     public static void main(String[] args) throws Exception {
>
>         EnvironmentSettings settings = EnvironmentSettings
>                 .newInstance()
>                 .useBlinkPlanner()
>                 .inBatchMode()
>                 .build();
>
>         TableEnvironment tableEnv = TableEnvironment.create(settings);
>
>         String name = "myhive";
>         String defaultDatabase = "datafeed";
>         String hiveConfDir = "/opt/app/bigdata/hive-1.1.0-cdh5.8.3/conf";
> // hive-site.xml路径
>         String version = "1.1.0-cdh5.8.3";
>
>         HiveCatalog hive = new HiveCatalog(name, defaultDatabase,
> hiveConfDir, version);
>
>         tableEnv.registerCatalog("myhive", hive);
>         tableEnv.useCatalog("myhive");
>         String createDbSql = "INSERT INTO TABLE flink2hive_test VALUES
> ('55', \"333\", \"CHN\")";
>         tableEnv.sqlUpdate(createDbSql);
>     }
>
> 这样的job提交到yarn会报错：
>
> Caused by: java.lang.ClassNotFoundException:
> org.apache.hadoop.mapreduce.TaskAttemptContext
>
> 是缺少MapReduce的相关包吗？
>
>
>
>
>
> -----
> Thanks!
> Jacob
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/
>