In my thought , I think I should config the correct flink jobserver for
flink task
LakeShen 于2020年3月4日周三 下午2:07写道：
> Hi community,
> now we plan to move all flink tasks to k8s cluster. For one flink
> task , we want to see this flink task web ui . First , we create the k8s
> Service to
Hi community,
now we plan to move all flink tasks to k8s cluster. For one flink
task , we want to see this flink task web ui . First , we create the k8s
Service to expose 8081 port of jobmanager, then we use ingress controller
so that we can see it outside.But the flink web like this :
??sql??sql??hive??sql??
??2020??03??4??
Hi jun,
Jira: https://issues.apache.org/jira/browse/FLINK-16413
FYI
Best,
Jingsong Lee
--
From:JingsongLee
Send Time:2020年3月3日(星期二) 19:06
To:Jun Zhang <825875...@qq.com>; user-zh@flink.apache.org
Cc:user-zh@flink.apache.org ;
也是一种 hack 的方法，不过社区肯定不能在 master 上这么搞就是了（x
Best,
tison.
aven.wu 于2020年3月3日周二 下午4:44写道：
> 感谢回答
> 后来我查了Flink run脚本的classpath设置，我修改了脚本将我的jar包指定在flink classpath的最前面得以解决问题
>
> Best
> Aven
>
> 发件人: tison
> 发送时间: 2020年3月3日 14:16
> 收件人: user-zh
> 主题: Re: CliFrontend 未优先加载用户jar包中的class
>
>
>
hi all??Java??
https://s2.ax1x.com/2020/03/03/34yyvT.png
https://s2.ax1x.com/2020/03/03/34y5P1.png
??
Hi jun,
很好的建议~ 这是一个优化点~ 可以建一个JIRA
Best,
Jingsong Lee
--
From:Jun Zhang <825875...@qq.com>
Send Time:2020年3月3日(星期二) 18:45
To:user-zh@flink.apache.org ; JingsongLee
Cc:user-zh@flink.apache.org ; like
Subject:回复：
datanucleus是在HMS端使用的，如果没有datanucleus会报错的话说明你的代码在尝试创建embedded
metastore。这是预期的行为么？我理解你们应该是有一个远端的HMS，然后希望HiveCatalog去连接这个HMS吧？
On Tue, Mar 3, 2020 at 4:00 PM 叶贤勋 wrote:
> hive conf应该是对的，前面UserGroupInfomation登录时都是成功的。
> datanucleus的依赖不加的话，会报claas not found等异常。
> 1、java.lang.ClassNotFoundException:
hi??jinsong??
??10??
??sql select * from mytable limit 1;
hive??mytable??10??10??
??2020??03??2?? 16:38??JingsongLee
这是我和flink社区沟通的记录，你可以看下。
| |
叶贤勋
|
|
yxx_c...@163.com
|
签名由网易邮箱大师定制
在2020年03月3日 16:00，叶贤勋 写道：
hive conf应该是对的，前面UserGroupInfomation登录时都是成功的。
datanucleus的依赖不加的话，会报claas not found等异常。
1、java.lang.ClassNotFoundException:
org.datanucleus.api.jdo.JDOPersistenceManagerFactory
2、Caused by:
感谢回答
后来我查了Flink run脚本的classpath设置，我修改了脚本将我的jar包指定在flink classpath的最前面得以解决问题
Best
Aven
发件人: tison
发送时间: 2020年3月3日 14:16
收件人: user-zh
主题: Re: CliFrontend 未优先加载用户jar包中的class
https://github.com/apache/flink/commit/0f30c263eebd2fc3ecbeae69a4ce9477e1d5d774
Best,
tison.
tison 于2020年3月3日周二
hive conf应该是对的，前面UserGroupInfomation登录时都是成功的。
datanucleus的依赖不加的话，会报claas not found等异常。
1、java.lang.ClassNotFoundException:
org.datanucleus.api.jdo.JDOPersistenceManagerFactory
2、Caused by: org.datanucleus.exceptions.NucleusUserException: There is no
available StoreManager of type "rdbms". Please
12 matches
Mail list logo
