Dear all:
flink??6
??kafka??hdfs??100G
??kafkakerberos??kerberos
??
1.??checkpoint??
2.??flink??kafka??/et
Dear all:
flink??6
??kafka??hdfs??100G
??kafkakerberos??kerberos
??
1.??checkpoint??
2.??flink??kafka??/et
谢谢，看起来好像可以，暂时没报错了，只是还没有正确读到hadoop的配置。
在 2020-03-07 17:06:48，"tison" 写道：
>报错前面加上这两行
>
>final YarnConfiguration yarnConfiguration = new YarnConfiguration();
>yarnClient.init(yarnConfiguration);
>
>如果还不对就查一下 HADOOP_CLASSPATH 和 yarn-site 这些配置有没有正确配置上
>
>Best,
>tison.
>
>
>nicygan 于2020年3月7日周六 下午4
报错前面加上这两行
final YarnConfiguration yarnConfiguration = new YarnConfiguration();
yarnClient.init(yarnConfiguration);
如果还不对就查一下 HADOOP_CLASSPATH 和 yarn-site 这些配置有没有正确配置上
Best,
tison.
nicygan 于2020年3月7日周六 下午4:53写道：
> tison，你好。
>
>
> 版本是1.9，没啥隐私，代码如下：
> JobGraph jobGraph = env.getStreamGrap
tison，你好。
版本是1.9，没啥隐私，代码如下：
JobGraph jobGraph = env.getStreamGraph("StreamSql").getJobGraph();
YarnConfiguration yarnConfiguration = new YarnConfiguration();
String configurationDirectory =
CliFrontend.getConfigurationDirectoryFromEnv();
Configuration flinkConfiguration =
Glo
