我想在windows上使用flink的python api处理数据。但是当我使用该命令向本地集群提交作业时，它抛出了NullPointerException。bin/flink run -py D:\workspace\python-test\flink-test.py flink-test.py： from pyflink.dataset import ExecutionEnvironment
浏览 23提问于2019-12-19得票数 0
(2)用Flink Rest端点启动JobService :Restdocker run --net=host apache/beam_flink1.10_job_server:latest --flink-master我正在运行它，它再次成功地启动：
docker run --net=host apache/beam_flink1.13_job_server:latest --flink-master=localhost/site-pac
浏览 1提问于2021-07-26得票数 0
我希望在运行光束wordcount.py演示时如何设置--environment_config的指导。我想使用中描述的“分离Flink集群”来使用Flink runner来运行光束。当我运行此命令时，Flink确实接收并成功处理了DataSource子任务。它最终会在CHAIN MapPartition上超时。
浏览 20提问于2019-11-06得票数 1
回答已采纳
有没有人曾经成功地使用python和windows与flink一起运行？.\bin\pyflink.bat examples\python\WordCount.pyStarting execution of program
The program didn't contain a Flink</em
浏览 1提问于2017-10-28得票数 1
我想使用Flink从输入文件中读取，执行一些聚合，并将结果写入输出文件。作业处于批处理模式。请参阅下面的wordcount.py：table_env.execute_sql(my_sink_ddl)
# before run</
浏览 37提问于2021-03-15得票数 1
回答已采纳
/wordcount.py {--count | --topcount} file%run wordcount.py --countalice.txt
我遇到的问题是，当我以这种方式从控制台调用wordcount.py时，它忽略了我设置的任何断点，我需要逐行遍历我的代码。
浏览 0提问于2014-08-26得票数 3
回答已采纳
我正在尝试创建一个aws数据池任务，这将创建一个电子病历集群，并运行一个简单的wordcount.py火花程序。我使用了datapipeline定义，其中的步骤很简单，如下所示：现在，当我激活任务时，我会得到一个错误，类似于：
线程"main“中的
浏览 7提问于2016-06-21得票数 2
().build()
t_env = BatchTableEnvironment.create(evnironment_settings = env_settings) 但是我发现其中一个样式只适用于flinkrun -py batch.py，其他一些样式可以作为python batch.py运行在本地。我的问题是executionEnvironment和BatchTableEnvironment/StreamTableEnvironment有什么区别，什么时候可以使用flink</em
浏览 107提问于2020-12-18得票数 0
2回答
这是我得到的例外： at org.apache.flink.api.java.io.LocalCollectionOutputFormat.closeat java.lang.Thread.run(Thread.java:745)
org.apache.flink.client.program.ProgramInvocationException:The program exec
浏览 3提问于2015-04-30得票数 4
回答已采纳
1回答
我正试图在PyFlink项目中编写一个本地包。但我只能通过相对路径导入。from .package import func
浏览 6提问于2021-11-18得票数 0
回答已采纳
) at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.run(StreamTaskActionExecutor.java:87)
at org.apache.flink.streaming.runtime.tasks.ma
浏览 3提问于2020-10-10得票数 4
lit(1).count) \以下是错误： File "WordCount.py(ReflectionEngine.java:357) at org.apache.flink.a
浏览 2提问于2021-03-15得票数 2
回答已采纳
通过API调用运行Python火花应用程序-在提交应用程序-响应-失败的SSH到工作人员/root/spark/work/driver-id/wordcount.py错误可在显示以下错误- File "/root/wordcount.py", l
浏览 15提问于2016-07-13得票数 24
回答已采纳
我随身带着一个WordCount.py文件。spark-submit WordCount.py at py4j.GatewayConnection.run(GatewayConnection.java:214) File "E:&#x
浏览 0提问于2018-10-14得票数 0
回答已采纳
我在CheckpointedFuntion中使用运算符状态，但是在初始化MapState时遇到了NullPointerException：}下面是堆栈跟踪：
java.lang.NullPointerException(AbstractStreamO
浏览 0提问于2018-03-18得票数 0
1回答
我的结构项目是：├── store_xml_dir│ └── xml_parse.pyimport oscwdir = os.path.dirname(__file__)sys.path.append, key, values):
if __name_
浏览 1提问于2014-10-19得票数 0
当我使用以下代码在Flink CLI中运行Python文件时： python3 word_count.py 我得到的错误如下： Traceback (most recent call last):File "word_count.py", line 79, in <module> File "word_count.py", line 37, in word_countt_config = TableConfig()
File &q
浏览 47提问于2021-01-04得票数 0
"in") table = table.where("d.e = 'fail'") 到目前为止，我尝试的所有操作都导致了错误/run.sh File "/tmp/test.py", line 143, in <module>
main(
浏览 13提问于2020-11-28得票数 0
每当我尝试运行带有缓冲的INSERT查询时，我都会收到以下错误(缩写为简洁)： at org.apache.flink.streaming.connectors.kafka.table.ReducingUpsertWriter.flush.runThrowing(StreamTaskActionExecutor.java:50)
at org.apache.flink.streaming.runtime.tasks.mail
浏览 16提问于2022-02-01得票数 0
我试图让Flink (1.2.0)在启用了HA的Hadoop集群(CDH 5.10.0)上工作，但当我通过终止活动RM来测试它时，它会导致整个集群宕机。我已经在flink-conf.yml中配置了Flink的HAhigh-availability.zookeeper.quorum: zookeeper1org.apache.hadoop.yarn.server.resourcemanager.ResourceManager: Error in handling e
浏览 8提问于2017-03-08得票数 4
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
