腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
2
回答
flink
run -py与
python
run的区别
、
、
().build() t_env = BatchTableEnvironment.create(evnironment_settings = env_settings) 但是我发现其中一个样式只适用于
flink
run -py batch.py,其他一些样式可以作为
python
batch.py运行在本地。我的问题是executionEnvironment和BatchTableEnvironment/StreamTableEnvironment有什么区别,什么时候可以使用
flink
运行-py,什么时候可以通过安装了pyflink的<
浏览 107
提问于2020-12-18
得票数 0
1
回答
python
-在运行
Flink
作业时存档而不是目录异常- PyFlink
、
、
、
、
="/root/
Python
3.6/venv.zip", target_dir=None))I'm中使用UDF运行
flink
作业successfully集存档路径,如果我取出UDF,则不会得到这个异常并运行(PythonEnvironmentManagerUtils.java:154) at org.apache.
flink
.
python
.env.beam.ProcessPythonEnvironmentManager.createEnvironment(
浏览 22
提问于2022-03-16
得票数 0
回答已采纳
2
回答
Flink
1.2在流媒体编程中支持
python
吗?
、
参考在线
python
编程指南:,我没有看到任何与流媒体编程相关的材料,比如kafka连接器等等。谢谢!
浏览 16
提问于2017-08-11
得票数 2
回答已采纳
1
回答
如何在AWS EMR上运行pyflink脚本?
、
> /usr/lib/
flink
/examples/batch/WordCount.jar 试着用
python
运行同样的程序,但是没有骰子。sudo
flink
run -m yarn-cluster -yid <application_id> -py /usr/lib/
flink
/examples/
python
/table/word_count.p
浏览 17
提问于2022-01-29
得票数 2
回答已采纳
1
回答
python
分期付款未能找到文件/
flink
-1.12-SNAPSHOT-bin/
flink
-1.12-SNAPSHOT/opt/
flink
-
python
_*.jar
、
、
我跟随安装
Flink
git clone https://github.com/apache/
flink
mvn clean install -DskipTests-Dfastcd
flink
python
-m pip install -r
flink
-
python
&
浏览 5
提问于2020-07-09
得票数 0
3
回答
Python
版本的WordCount在
Flink
上失败
、
、
、
在CentOS (CentOS 8.0.1905 (64位))上,我尝试在
Flink
(1.9)上运行
Python
(3.6.8)版本的WordCount程序,如所述。我得到的错误如下。/bin/
flink
run -py examples/
python
/table/batch/word_count.pyorg.apache.
flink
.client.program.OptimizerPl
浏览 7
提问于2020-01-16
得票数 0
2
回答
Apache 1.14.0 -无法通过Java中的SQL使用
python
、
、
我试图在SQL中执行
python
函数(1.14.0)from pyflink.table import DataTypes➜
flink
-1.14.0 .客户端运行作业:
flink
run /home/magic/workspace/
flink
-jobs/UDF/pythonUDF/target/pythonUDF-1.0.0.
浏览 6
提问于2021-12-03
得票数 3
1
回答
Flink
Python
API Bug
、
我刚刚试用了
flink
python
api。当我尝试的时候:我得到了:该错误是由于以下位置中的路径处理导致的:
flink
-staging/
flink
-language-binding/
flink
-
python</em
浏览 2
提问于2015-06-18
得票数 2
1
回答
Apache 1.11无法在SQL函数DDL中使用
Python
、
、
、
、
根据这一汇合点页面:
python
位于
Flink
1.11中,可用于SQL函数中。我在这里看了
flink
的医生: https://ci.apache.org/projects/
flink
浏览 1
提问于2020-07-09
得票数 0
1
回答
如何将一些外部jars库配置到
flink
docker容器
、
、
:/usr/local/lib/
python
3.7/site-packages/pyflink/lib expose: expose:
浏览 121
提问于2020-10-11
得票数 1
1
回答
Flink
码头图像
、
、
、
Step 12/23 : ARG job_artifacts=NOT_SET ---> e11400e03120 Step 13/23 : ARG
python
_version" = "2" ]; then apk add --no-cache
python
; elif [ "$
python
_version" = "3" ]; then apk add --no-cache
浏览 2
提问于2019-12-09
得票数 0
回答已采纳
1
回答
在apache
flink
上运行apache波束
、
我想在Apache上使用Apache运行
Python
代码。apache站点在Apache上启动
Python
代码的命令如下: docker run --net=host apachebeam/
flink
1.9_job_server:latest --
flink
-master
浏览 6
提问于2020-03-01
得票数 0
1
回答
在PyFlink中导入本地包
、
、
喜欢是否可以在导入为PyFlink的env.add_
python
_file('/path_to_project')项目中的包中使用绝对路径?
浏览 6
提问于2021-11-18
得票数 0
回答已采纳
2
回答
apache beam for
python
是否在商业上支持
flink
runner?
apache beam for
python
现在支持
flink
runner吗?或者甚至是便携式跑步器?beam for java是否得到了
flink
runner的商业支持?
浏览 1
提问于2019-03-22
得票数 1
1
回答
PyFlink -在JAR中使用Scala UDF的问题
、
(MethodInvoker.java:244) at org.apache.
flink
.api.
python
.shaded.py4j.Gateway.invoke(Gateway.java:282) at org.apache.
flink
.api.
python</e
浏览 20
提问于2020-10-27
得票数 1
回答已采纳
2
回答
Flink
运行
python
文件失败,出现错误“PyFlink不支持3.5之前的
Python
版本”
、
、
我还将t_env.get_config().set_
python
_executable("
python
3")添加到py文件中,但仍然存在相同的错误: at org.
浏览 6
提问于2020-04-28
得票数 1
1
回答
apache
flink
状态有趣的
python
sdk构建分发问题
、
我曾计划用
python
statefun示例(链接:https://github.com/apache/
flink
-statefun/tree/master/statefun-examples/statefun-
python
-greeter-examplesetup( version='2.1-SNAPSHOT', pac
浏览 23
提问于2020-05-04
得票数 0
1
回答
PyFlink java.io.EOFException at java.io.DataInputStream.readFully
、
(MethodInvoker.java:244) at org.apache.
flink
.api.
python
.shaded.py4j.Gateway.invoke(Gateway.java:282) at org.apache.
flink
.api.
python</e
浏览 2
提问于2021-03-18
得票数 1
回答已采纳
1
回答
pyflink Table api中的Py4JJavaError
、
(MethodInvoker.java:244) at org.apache.
flink
.api.
python
.shaded.py4j.Gateway.invoke(Gateway.java:282) at org.apache.
flink
.api.
python</e
浏览 102
提问于2020-07-16
得票数 0
回答已采纳
2
回答
org.apache.
flink
.table.api.ValidationException:无法为编写表“default_catalog.default_database.hTable”创建接收器
、
、
、
、
(MethodInvoker.java:244) at org.apache.
flink
.api.
python
.shaded.py4j.Gateway.invoke(Gateway.java:282) at org.apache.
flink
.api.<
浏览 73
提问于2022-10-21
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Flink基础教程(二):初探Flink
Apache Flink 进阶(六):Flink 作业执行深度解析
《从0到1学习Flink》——Apache Flink 介绍
flink handbook-flink数据流编程模型
Flink基础教程(三):生产环境中的Flink
热门
标签
更多标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
活动推荐
运营活动
广告
关闭
领券