Flink数据集程序不产生输出
我正在尝试使用< code > DataSet . writeastext(" file:///path/to/my/file ")将数据集API程序的结果写入一个文件。
但是，该程序不产生任何输出。也不会创建输出文件。这可能是什么原因？
共有1个答案
您是否执行了作业，即调用ExecutionEnvironment.execute（）？
// get execution environment
ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
// Specify your program ...
DataSet<X> ds1 = env...
DataSet<Y> ds2 = ds1.map(...)...
ds2.writeAsText(...);
// execute the program
env.execute();
-
我用Flink编写了一个小测试用例代码来对数据流进行排序。代码如下： 然而，代码只输出执行计划和其他几行。但它不会输出实际排序的数字。我做错了什么？
-
Flink是否支持数据集中的侧输出功能（批处理Api）？如果没有，从文件加载时如何处理有效和无效记录？
-
我是Flink的新手。如何了解flink的生产集群要求。以及如何确定纱线集群模式下每个作业执行的作业内存、任务内存和任务槽。例如，我每天必须使用datastream处理大约6-7亿条记录，因为这是一个实时数据。
-
我试图使用FlinkKafkaProducer010生成元素，但是当我打开消费者控制台窗口时，元素似乎出现了故障。 我使用kafka-topics.bat创建了主题 消费者是使用：kafka console consumer创建的。蝙蝠——zookeeper本地主机：2181——主题mytopic 我使用的Kafka制作人代码是： 当我查看Kafka日志文件时，我看到一个. log文件，其中的元素
-
这里有一个非常简单的java程序，我声明任何有7个元素的数组，输入前六个，将第四到第六个元素移动到第五到第七个位置，并获得第四个空位置的值： 然而，当所有数组元素都打印出来时，第六和第七个位置是0，我不知道为什么。原因和修复将不胜感激。注意：我不能使用任何数组方法，必须保持非常简单。 输入：1,2,3,4,5,6；然后1； 期望输出：1,2,3,4,5,1,6； 实际产出：1,2,3,4,1,0,
-
下面是我的流处理的伪代码。 上面的代码流程正在创建多个文件，我猜每个文件都有不同窗口的记录。例如，每个文件中的记录都有时间戳，范围在30-40秒之间，而窗口时间只有10秒。我预期的输出模式是将每个窗口数据写入单独的文件。对此的任何引用或输入都会有很大帮助。