关于Flink对中标/银河麒麟和统信的适配

2022-07-21 Thread
尊敬的Flink贡献者您好: 由于政策问题,很多国企和央企都将要采用银河麒麟或者中标麒麟或者统信,请问Flink/PyFlink在以上三个系统中有进行适配应用吗?有无问题?以及和在Centos部署的有何不同呢? 期望得到回复,万分感谢!

关于PyFlink的环境问题,期望得到回复。

2022-06-19 Thread
您好: 我是西南财经大学一个在读博士,目前想使用PyFlink,但是遇到了一个问题,我的集群采用的CDH6.2.0,其中的Hadoop为3.0.0版本。当我在pytlink的程序里引入hadoop-common-3.0.0.jar(或hadoop-common-3.0.0-cdh6.2.0.jar)的时候,运行程序就会报错: Caused by: java.lang.NoClassDefFoundError: Could not initialize class org.apache.hadoop.security.UserGroupInformation

关于PyFlink的开发环境问题

2022-06-14 Thread
您好: 我是一名学习使用pyflink的用户,我想在ubuntu20.04上开发pyflink,但是在运行代码的时候,报错为: Traceback (most recent call last): File "/root/.py", line 6, in s_env = StreamExecutionEnvironment.get_execution_environment() File