目前，我有一个正在运行的Flink Kubernetes会话集群(Flink版本1.13.2)，并且我可以通过port-forward访问web，我也可以通过这个命令从本地环境提交WordCount jar但是，当我试图通过命令pyFlink提交./bin/flink run -m localhost:8081 -py examples/python/table/batch/word_count.py示例时，作业会冻结，日志显示正在等待结果。如何将python示例
浏览 4提问于2021-10-16得票数 2
PyFlink代码是 from pyflink.common.serialization import Encoder "file:///Users/samprabin/Documents/xealei_fall_detector/dataProcessorAndClassifier/jar/flin
浏览 286提问于2021-06-13得票数 0
:/usr/local/lib/python3.7/site-packages/pyflink/lib expose: - /
浏览 121提问于2020-10-11得票数 1
作为PyFlink pipeline.classpath配置的一部分传递的类加载类与将它们放入$FLINK_HOME\lib目录之间有什么区别？当我想使用flink-sql-connector-kafka-*.jar时，只要使用pipeline.classpath传递它就可以了，但是当我想使用一些具有一些外部依赖项的东西时，比如需要avro-*.jar jars的flink-avro-*.jar。它似乎加载了flink-avro-*.jar，但它似乎无法加载avro-*.jar<
浏览 15提问于2022-01-24得票数 0
回答已采纳
1回答
我只看过Pyflink表API中不包含连接建立()中的身份验证细节的kafka连接示例，即源表连接： CREATE TABLE source_tableStreamExecutionEnvironment.get_execution_environment()
浏览 4提问于2021-11-12得票数 0
回答已采纳
\bin\pyflink.bat examples\python\WordCount.pyStarting execution of program
Usage: ./bin/pyflink<2/3>.
浏览 1提问于2017-10-28得票数 1
是否有一个自包含存储库的例子显示如何执行PyFlink的SQL单元测试(如果可能的话，具体而言是1.13.x )？'flink-table-planner*-tests.jar' is not available.我尝试将flink-tabl
浏览 4提问于2022-04-23得票数 0
假设我编写了一个WordCount示例，然后在eclipse项目中包含一个外部jar文件，比如MyJar.jar。现在，如果我将整个WordCount项目导出为word.jar文件，然后输入我知道作业会执行，word.jar会有一个包含MyJar.jar文件的lib目录。现在，当调用这个jar文件的方
浏览 2提问于2012-07-15得票数 0
回答已采纳
我正在尝试通过PyFlink中的自定义UDAF调用外部函数。我使用的函数要求数据在字典对象中。我尝试使用row(t.rowtime, t.b, t.c).cast(schema)来达到这样的效果。from pyflink.common import Rowfrom pyflink.table.expr
浏览 43提问于2021-06-18得票数 1
回答已采纳
1回答
所以我有一个用PyFlink SQL API编写的简单的聚合作业。该作业从AWS Kinesis读取数据并将结果输出到kinesis。 我很好奇是否可以用pytest对我的流水线进行单元测试？但是我如何创建一个本地Flink会话来在pytest中运行作业呢？我们这里有没有最佳实践推荐？ 谢谢!
浏览 35提问于2021-11-12得票数 0
回答已采纳
我试图在SQL中执行python函数(1.14.0)from pyflink.table import DataTypes ret1.print();
}然后通过Flink客户端运行作业：
flink run /home/magic/workspace/
浏览 6提问于2021-12-03得票数 3
1回答
jarbeam-vendor-grpc-1_26_0.0.3.jarbeam-vendor-guava-26_0-jre-0.1.jarbeam-vendor-sdks-java-extensions-protobuf-2.20.jar我也可以排除这是由于我的代码，因为我已经测试了项目网站的以下示例代码：from pyflink.tableimport StreamTableEnvironment, DataTypes
fr
浏览 3提问于2020-05-05得票数 1
回答已采纳
我的输入数据是hdfs格式的。我只是想做字数统计，但有细微的差别。数据为json格式。所以每一行数据都是：{"author":"foo123", "text": "hello world"}我只想对"text“部分的单词进行统计。
浏览 3提问于2013-05-30得票数 6
回答已采纳
我正在编写一个oozie java操作，它将我的自定义代码放在作业./lib文件夹中的jar文件中。我还想在类路径中添加作业外部文件夹(即/home/me/otherjars/spark-assembly.jar)中的jar。
./lib文件夹会自动添加到类路径中。我怎样才能让oozie也添加外部jar呢？
浏览 0提问于2015-12-30得票数 2
我尝试使用外部JAR在Pyflink中注册一个Scala UDF，如下所示，但得到下面的错误。/target/scala-2.12/hello_scala_for_flink-assembly-0.1.jar /Users/py-r/opt/anaconda3/envs/venv_pyflink_37/lib/python3.7/site-packages/pyflin
浏览 20提问于2020-10-27得票数 1
回答已采纳
1回答
不管我做什么，如果我运行作业，输出会被单个输入记录的处理输出淹没。这是我的代码供参考：from pyflink.datastream.stream_execution_environment import StreamExecutionEnvironmentfrom pyflink.table import TableEnvironment, EnvironmentSettings, DataTypes, StreamTableEnvironment
frompyflink.table.udf imp
浏览 6提问于2022-03-14得票数 0
我有一个带有一些外部jar的java eclipse项目，比如SWT jar。现在这个项目是我已经做了一段时间的家庭作业了。我需要交作业，教授会审查代码，他也会在本地执行。那么如何在保持所有依赖项不变的情况下导出项目呢？我当然不能提交JAR文件。我已经尝试将项目导出为“文件系统”。但是，它没有保留外部依赖项。谢谢。
浏览 1提问于2016-11-23得票数 0
在Dev机器上，我没有问题，作业运行正常，而在一个由3个节点组成的Flink独立集群上，我遇到了上述错误。
你能帮帮我吗？
浏览 6提问于2018-01-12得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
