问答 2022-02-15 来自:开发者社区

flink-table-planner-blink_2.11-1.10.0.jar包中 #Flink

flink-table-planner-blink_2.11-1.10.0.jar包中 org.apache.flink.calcite.shaded.com.google.protobuf打头的包为啥没有shade进去呢? #Flink

问答 2022-02-15 来自:开发者社区

提交jar到Flink集群时候出现报错

提交jar到Flink集群时候出现:java.util.ServiceConfigurationError: org.apache.hadoop.fs.FileSystem: Provider org.apache.hadoop.fs.viewfs.ViewFileSystem could not be instantiated

问答 2022-02-15 来自:开发者社区

flink中如何在动态加载jar包#flink

在使用flinksql过程中 , 我们想要实现在main中动态的加载jar包 , 比如自定义的udf 目前了解的方法是通过flink run 的-C参数可以另外导入jar包 , 不知道有没有办法在main方法中动态加载自己的jar

问答 2022-02-15 来自:开发者社区

Beam jar无法在远程flink群集上运行

使用带有Flink 1.5.3的beam 2.6进行测试。beam运行本地flink runner没有问题。但无法在flink群集上运行。尝试mvn和flink提交作业。当使用mvn运行时,我用过:mvn clean package -Pflink-runner exec:java -Dexec.mainClass=org.apache.beam.examples.WordCount -Dexe....

问答 2022-02-15 来自:开发者社区

我们想把业务处理做成插件,然后每个job的main都是一个,通过动态load业务自定义jar,但flink这种结构做起来很麻烦,我不得不写了个重新打包的功能,你们blink是怎么实现这个功能的?

转自钉钉群21789141:我们想把业务处理做成插件,然后每个job的main都是一个,通过动态load业务自定义jar,但flink这种结构做起来很麻烦,我不得不写了个重新打包的功能,你们blink是怎么实现这个功能的?

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注