Re: flink1.12. The error message is maybe misguided
fine,I'll create a jira issue 胡伟华 于2022年3月24日周四 19:59写道： > HI, congpeng > > Thanks for your report, I agree with you, we should be more explicit about > not finding the corresponding Factory for the specified target. Could you > create a jira issue for this? > > > > 2022年3月24日 下午7:05，丛鹏 写道： > > > > Hi, I'm using flink1.12.2 a problem is found when submitting the task of > > yarn application, > > An example of the Flink official website submitting a task is > > ./bin/flink run-application -t yarn-application ./ > > examples/streaming/TopSpeedWindowing. jar > > If some of them are misspelled, then yen application is written as yen > > application > > Will report an error： > > > > java.lang.IllegalStateException: No ClusterClientFactory found. If you > were > > targeting a Yarn cluster, please make sure to export the HADOOP_CLASSPATH > > environment variable or have hadoop in your classpath. For more > information > > refer to the "Deployment" section of the official Apache Flink > > documentation. > > > > BUT > > > > I saw that the code is the 213 line configuration set encapsulated by > > clifrontend. There is a problem with effectiveconfiguration, resulting in > > defaultclusterclientserviceloader Java: 83 judgment entry error > > > > Eventually lead compatibleFactories.isEmpty() is true > > then > > > > "No ClusterClientFactory found. If you were targeting a Yarn cluster, " > >+ "please make sure to export the > > HADOOP_CLASSPATH environment variable or have hadoop in your " > >+ "classpath. For more information refer to > the > > \"Deployment\" section of the official " > >+ "Apache Flink documentation." > > > > > > I think there is something wrong with the description of the error > > information here, which will lead to misleading. Users mistakenly think > it > > is their own Hadoop_ There is a problem with the classpath environment. I > > hope you can reply > >
退订
退订
Re: flink1.12. The error message is maybe misguided
HI, congpeng Thanks for your report, I agree with you, we should be more explicit about not finding the corresponding Factory for the specified target. Could you create a jira issue for this? > 2022年3月24日 下午7:05，丛鹏 写道： > > Hi, I'm using flink1.12.2 a problem is found when submitting the task of > yarn application, > An example of the Flink official website submitting a task is > ./bin/flink run-application -t yarn-application ./ > examples/streaming/TopSpeedWindowing. jar > If some of them are misspelled, then yen application is written as yen > application > Will report an error： > > java.lang.IllegalStateException: No ClusterClientFactory found. If you were > targeting a Yarn cluster, please make sure to export the HADOOP_CLASSPATH > environment variable or have hadoop in your classpath. For more information > refer to the "Deployment" section of the official Apache Flink > documentation. > > BUT > > I saw that the code is the 213 line configuration set encapsulated by > clifrontend. There is a problem with effectiveconfiguration, resulting in > defaultclusterclientserviceloader Java: 83 judgment entry error > > Eventually lead compatibleFactories.isEmpty() is true > then > > "No ClusterClientFactory found. If you were targeting a Yarn cluster, " >+ "please make sure to export the > HADOOP_CLASSPATH environment variable or have hadoop in your " >+ "classpath. For more information refer to the > \"Deployment\" section of the official " >+ "Apache Flink documentation." > > > I think there is something wrong with the description of the error > information here, which will lead to misleading. Users mistakenly think it > is their own Hadoop_ There is a problem with the classpath environment. I > hope you can reply
flink1.12. The error message is maybe misguided
Hi, I'm using flink1.12.2 a problem is found when submitting the task of yarn application, An example of the Flink official website submitting a task is ./bin/flink run-application -t yarn-application ./ examples/streaming/TopSpeedWindowing. jar If some of them are misspelled, then yen application is written as yen application Will report an error： java.lang.IllegalStateException: No ClusterClientFactory found. If you were targeting a Yarn cluster, please make sure to export the HADOOP_CLASSPATH environment variable or have hadoop in your classpath. For more information refer to the "Deployment" section of the official Apache Flink documentation. BUT I saw that the code is the 213 line configuration set encapsulated by clifrontend. There is a problem with effectiveconfiguration, resulting in defaultclusterclientserviceloader Java: 83 judgment entry error Eventually lead compatibleFactories.isEmpty() is true then "No ClusterClientFactory found. If you were targeting a Yarn cluster, " + "please make sure to export the HADOOP_CLASSPATH environment variable or have hadoop in your " + "classpath. For more information refer to the \"Deployment\" section of the official " + "Apache Flink documentation." I think there is something wrong with the description of the error information here, which will lead to misleading. Users mistakenly think it is their own Hadoop_ There is a problem with the classpath environment. I hope you can reply
Re: Flink ad-hoc方向问题
是有这个规划的。 目前已经有一些相对零散的调度性能方面的优化在社区做起来了 [1]，后续还有一些比较大的 feature 还在酝酿中。 Thank you~ Xintong Song [1] https://issues.apache.org/jira/browse/FLINK-25318 On Thu, Mar 24, 2022 at 1:54 PM LuNing Wang wrote: > > Flink未来会在ad-hoc方向投入吗？类似Flink自带Trino/Presto的性能优化方式，这样批、流、OLAP/ad-hoc只需要一个引擎就可以。 >
