我想了解LocalExecutionEnvironment的局限性，以及它是否可以在生产中运行？ 感谢任何帮助/洞察力。谢谢
浏览 26提问于2019-12-24得票数 1
回答已采纳
我想通过以下代码在本地使用Flink-API读取CSV文件：List<Tuple2<String, Double>> csv= env.readCsvFile:408)at org.apache.flink.client.LocalExecutor.executePlan(LocalExec
浏览 22提问于2017-01-11得票数 0
1回答
我正在尝试将移植到安卓系统。这个框架部分是用Scala编写的，在执行单词计数示例时，会抛出一个异常(还有许多其他的异常，我不会发布)：at org.apache.flink.runtime.minicluster.FlinkMiniCluster.<init>(FlinkMiniCluster.scala:76)at o
浏览 4提问于2016-03-15得票数 0
回答已采纳
对于文件、csv和HDFS，有很多方法()，但没有一个方法显式地用于cassandra。Exception in thread "main" org.apache.flink.optimizer.CompilerException: (org.apache.flink.batch.connectors.cassandra.CassandraI
浏览 4提问于2017-05-11得票数 0
回答已采纳
1回答
我需要在生产中运行Flink作业，我只有一台机器(不是集群)。我正在尝试为生产设置我的Flink作业，并以最好的方式完成它，就像我现在拥有的那样(以java应用程序java -jar flink_job.jar的形式运行)。我在中读到，这种部署模式只用于测试或试验，因此，对于生产，我认为我应该转到独立集群，但是，在独立集群部署模式中，我需要设置一个主服务器和至少一个工作人员。我的问题是，我必须在生产中只运行一个节点(主节点)：
--在我的情况下，在<e
浏览 9提问于2020-08-21得票数 0
虽然我已经导入了org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011，但是我得到了以下错误。FlinkKafkaProducer011() {
public static class NextTransactionalIdHint extends org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer.NextTransactionalIdHintKafkaTransactionContex
浏览 5提问于2020-08-11得票数 0
回答已采纳
我试图在Exactly-Once集成中实现Flink-Kafka语义。我的生产者模块如下所示： env.setParallelism(1)那么假设在推送这些数据的时候，生产者能够把数据推到第四记录，并且由于一些失败，所以当它重新启动并运行时，它会从第五次开始推高记录吗？我的财产够吗？
我将按照第一个用户提到的在使用者端添加一个属性。我是否也应该在生产者端添加Idempotent
浏览 1提问于2022-01-07得票数 1
回答已采纳
1回答
另外，建议是否将flink managed memory设置为false。documentation提到默认值不适用于生产
浏览 22提问于2021-07-04得票数 0
我有one动物园管理员集群，并希望将其用于几种环境(分期、生产等)。recovery.zookeeper.path.root: /{{ env }}/flinkrecovery.zookeeper.path.leader: /{{ env }}/leaderrecovery.
浏览 2提问于2016-04-06得票数 1
回答已采纳
我已经使用flink consumer和producer概念创建了一个Flink应用程序/作业。现在我还有一个需求，比如我需要创建一个Producer应用程序，该应用程序将数据发布到在Flink应用程序之上使用的topic。但我还需要将此Producer应用程序作为Flink作业运行。我做了谷歌搜索，我无法找到细节，以创建一个Flink应用程序只与生产者。
浏览 5提问于2020-07-12得票数 1
1回答
生成“假”流数据。卡夫卡
、、、、
我正在使用Flink环境作为消费者，但我不知道哪个是最好的解决方案的生产者。(如果可能的话，Java语法比Scala更好)
我应该直接从卡夫卡得到数据吗？如果是的话，最好的方法是什么？或者，如果我把Flink制作出来的数据作为一个制作人，发送给Kafka，然后用Flink在结束时再使用它，也许会更好？我怎么才能从弗林克那里做到呢？
浏览 2提问于2018-08-20得票数 2
我是flink和Kafka的新手。我正在尝试使用Confluent Schema注册表对avro数据进行反序列化。我已经在ec2机器上安装了flink和Kafka。：https://gist.github.com/mandar2174/5dc13350b296abf127b92d0697c320f2 作为实现的一部分，代码执行以下操作： 1) Create a flink运行flink可执行jar的命令： ./bin/flink run -c c
浏览 43提问于2019-04-22得票数 1
1回答
我使用flink 1.5.2来解决CEP问题。
使用pattern_stream.select( ...implement选择接口.)将复杂事件结果作为
浏览 1提问于2018-08-10得票数 0
回答已采纳
事实证明，生产站点上的某些页面有一个子域，比如members.mycompany.com而不是www.mycompany.com。测试还需要能够完全在具有不同域的测试环境上运行，而且在测试环境中根本没有子域，即使对于在生产站点中具有子域的页面也是如此。因此，将完整的URL放入每个SitePrism::Page并不是一个选项。subdomain_flag=false) when :test
domain = "https://
浏览 2提问于2014-01-09得票数 0
回答已采纳
1回答
我使用Apache Flink将来自给定的Kafka主题集的更新传播到Elasticsearch集群中。我面临的问题是，有时Elasticsearch集群会进化，而我必须通过(1)修改映射，当我不得不将Flink作业指向新的别名/索引时，(2)复制到data...and时，就会有大量的更新到旧的索引。我试图使Flink作业减速或暂停(Kafka)输入源，直到迁移完成，但我没有找到任何端点。
Flink作业在应用程序模式下运行。如果有人能够解释一下如何做到这一点:通过API或其他类似工具暂停/恢复作业，
浏览 5提问于2022-06-21得票数 0
我对Flink，Kafka和Elastic Search的不同版本有问题。我使用的是Flink 1.8.1版本，但我不知道该使用哪个版本的Kafka。另一方面，我想使用版本6进行弹性搜索。你认为哪些版本适合Flink，Kafka和Elastic Search？下面的链接是Kafka的一个版本，但在评论部分，它是作为测试版enter link description here介绍的
浏览 9提问于2019-12-24得票数 2
从这个中，它说我们可以通过start-local.bat运行flink。但是flink 1.1x已经没有这样的.bat文件了。从最近的开始，您必须通过WSL或Cygwin运行flink。
浏览 3提问于2021-01-21得票数 0
纱线上的Flink 1.13.2 (Flink SQL) -文件系统是“有界和无界扫描，Lookup"
仅 -标记为可用于查找的JDBC .如果是-如何使用Flink SQL？(我用FOR SYSTEM_TIME AS OF a.event_datetime尝试过简单的左联接--它在测试环境中使用少量的Kafka事件，但是在生产中我得到了GC overhead limit exceed
浏览 1提问于2021-09-20得票数 1
回答已采纳
我有一个在生产中运行的Flink应用程序，它将数据写入外部供应商拥有的Kafka主题。
供应商通知我们，他们将迁移他们的集群，因此在无法使用Kafka代理的情况下将有停机时间。我的问题是，当主题无法写入数据时，Flink应用程序数据会发生什么情况？我是否可以允许我的Flink应用程序继续运行，或者我是否应该停止它并等待代理启动和运行？
浏览 9提问于2022-08-03得票数 0
在将消息发布到flink应用程序的kafka主题时，会出现此错误。相同的代码在我们的测试环境中工作，具有类似的生产者配置，但在生产环境中失败。我找不到这个问题的原因。(FlinkKafkaProducer.java:907)at org.apache.flink.streami
浏览 1提问于2022-04-15得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
