我正在使用类似于的源函数从parquet中读取代码行，但是当我尝试计算正在处理的行数时，尽管作业已经完成，但什么也没有打印出来：
val env: StreamExecutionEnvironment
浏览 43提问于2021-03-10得票数 1
回答已采纳
我正在用flink做一个简单的程序，但是它不会在std输出中打印任何字符串。我尝试过在流上使用print()方法，对结果使用减函数和后置print()方法。.*/ env.execute("Flink Streaming Java Quickstart Mio"); }
return objec
浏览 4提问于2019-10-02得票数 0
我正在尝试调优使用FlinkOperator部署的flink作业的内存配置。下面是我正在使用的内存设置。如本文档所述，我只配置了全部内存。taskmanager.memory.task.off-heap.size: "500m"当作业开始处理时，指标显示flink_taskmanager_Status_Flink_Me
浏览 12提问于2022-12-04得票数 1
我从官方的flink存储库使用以下docker-compose.yml启动了flink。我只添加了到外部hadoop网络的连接。version: "2.1"
hadoop: name: flink_hadoop
jobmanager:image: flink:1.7.1-hadoop27-scala_2.11
container_name: f
浏览 1293提问于2019-01-04得票数 2
回答已采纳
如何在FLinkSQLv1.13中将带有DateTime的TZ转换为时间戳(3)？//returns NULL, which is silly because this was the result from the 2nd example
它不接受T and Z，但是“干净”日期的转换结果有
浏览 22提问于2021-12-16得票数 0
1回答
批量统计文本字符串
、、、
我一直在寻找，我能够找到在txt文件中计算行数的方法，但是有没有一种方法可以对特定的文本字符串进行计数，然后将该值放入日志文件中？
浏览 3提问于2012-10-23得票数 0
回答已采纳
当我启动一个flink独立集群时，它会在conf/log4j.properties文件中提到的文件中记录守护进程日志，当我在该集群中提交flink作业时，它会使用相同的属性文件来记录应用程序日志并在任务管理器上写入相同的日志文件我希望为在flink独立集群中提交的每个应用程序都有单独的日志文件。有什么办法可以做到这一点
浏览 1提问于2016-11-08得票数 1
基于Flink Scala快速入门，我已经创建了一个使用org.apache.flink.streaming.connectors.twitter.TwitterSource的示例作业。我使用本地流作业管理器/start-local-streaming.sh，并使用~/flink-0.10.0/bin/flink run target/quickstart-0.1.jar启动作业
在TwitterSou
浏览 0提问于2015-12-04得票数 2
我使用Flink local模式，并行度= 1。在我的Flink代码中，我尝试使用以下命令打印传入的源代码：ds.print();
在我本地的Flink_dir/ xxx.out文件夹中，我可以看到已经创建了一个日志文件，但是没有任何内容打
浏览 8提问于2017-07-11得票数 2
回答已采纳
2回答
我正在使用Apache开发一个项目，并使用junit测试我的操作员。但是，我面临一个问题:由于并行性，flink将以“随机”行顺序写入其输出csv文件，因此我很难断言输出文件与使用Junit的预期输出文件相等。性能不是一个问题，因为我们谈论的是小文件(<100行)，而且只用于测试。
有什么简单的解决办法吗？
浏览 4提问于2015-04-08得票数 5
回答已采纳
我需要显示总数，但我只找到命令列出已安装的包，如下所示：
ls -l /var/log/packages/
浏览 0提问于2017-02-15得票数 2
回答已采纳
我能够像预期的那样运行WordCount程序。但是当我运行SocketTextWordCount时，我没有得到任何结果。我通过nc发送数据(双方的本地主机:9999)
编辑-当我将结果改为文本文件时，没有问题。因此，问题似乎在于，counts.print()没有正确地写入我运行示例的控制台的标准输出。
浏览 0提问于2016-05-16得票数 3
回答已采纳
我有一个简单的Flink作业，它从ActiveMQ源代码和接收器读取到数据库和打印。我使用2 TaskManagers在Kubernetes中部署作业，每个任务的Task Slots为10 (taskmanager.numberOfTaskSlots: 10)。我配置的并行性超过了可用的总TaskSlots (本例中为10 )。当我看到Flink Dashboard时，我看到这个作业只在一个TaskManager<e
浏览 2提问于2020-03-06得票数 2
我在运行flink作业时遇到了问题，flink作业基本上是对mysql数据库运行查询，然后尝试创建一个必须从不同作业访问的临时视图。resultStream = tableEnv.toDataStream(resultTable);
env.execute();
我对Flink非常陌生，目前我正在使用为所有这些提供的API，但我不知道自己做错了什么。在我看来，通过在工作结束时打印结果来测试这个过程似乎是直截了
浏览 36提问于2022-02-14得票数 0
回答已采纳
1回答
我想多次使用org.apache.flink.api.scala.DataSet对象：
等。对于这些操作，Flink完全重新计算DataSet的值，而不是缓存它。我找不到像在Spark中那样的缓存()或持久化()函数。这确实对我的应用程序产生了巨大的影响，我的应用程序有~1.000.0
浏览 2提问于2017-09-15得票数 2
回答已采纳
1回答
我正在使用flink 1.8.0，并试图查询我的工作状态。ValueStateDescriptor("myState", Types.CASE_CLASS[Foo])根据，我使用了端口9067，这是默认端口，我的客户端：val jo
浏览 0提问于2019-06-25得票数 0
回答已采纳
EMR-Flink作业显示错误“超出GC开销限制错误”。EMR群集使用默认EMR角色在VPC内创建。Hadoop和Flink选项是从高级选项中选择的(我尝试了不同版本的Hadoop和Flink) Step方法用于提交带有参数集的自定义jar。作业从Aurora DB读取数据 问题:当从Aurora DB读取请求的行数较少时，作业会成功执行，但随着行数增加到数百万，我开始收到"GC开销限制超过错误“。我正在为
浏览 44提问于2020-01-21得票数 0
回答已采纳
我需要在K8上部署Flink应用程序的帮助 我们有3个源，将以SQL查询的形式发送触发条件。总查询数约为3-6k，有效地增加了flink实例的负载。由于大量的查询，我们决定为每个源创建多个flink应用实例。因此，一个flink实例实际上只能执行~1-2K个查询。上部署这些实例 问题： a)可以使用迷你集群(内置)部署独立的flink jar吗？b)如果K8的一个
浏览 31提问于2020-08-24得票数 1
由于我是卡夫卡flink连接器的新手，请帮助我提出一些简单的示例程序，其中kafka在一个主题中写作，flink侦听它，并与pom.xml一起显示值。
浏览 4提问于2020-01-19得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
对象存储
云直播活动推荐
腾讯云开发者
