我正在用flink + java使用Table API做一个简单的教程。我想要做的非常简单-我想从本地文件系统中读取csv文件，使用模式并打印出来。我是这样做的(下面的代码是从Flink的网站教程部分中编译出来的)：import org.apache.flink.api.java.utils.ParameterToolcabs").select("*");
result.exe
浏览 55提问于2022-08-22得票数 0
回答已采纳
我是新的Flink，并试图创建一个原型，可以做一个连续的查询以及按需的查询。第一部分已经起作用了(使用预定义的查询)，但与第二个部分斗争。有可以使用的SQL。我已经看到了Flink木星笔记本集成，这告诉我，这应该工作的方式从一个网页界面。但是，不知道如何做到这一点，每次都不提交一个完整的JAR。见和
对我们还能探索什么有什么建议吗？
浏览 12提问于2022-01-15得票数 0
回答已采纳
急切的执行函数，在第145行，所以我尝试重新上传jar文件，这次删除了print()，我得到了一个不同的错误，它说：
2022-01-07 17:15:56,391 ERROR org.apache.flink.runtime.webmonitor.handlers.JarRunHandler
浏览 32提问于2022-01-07得票数 0
在每一开始，我们都试图了解流入DB和Flink之间的数据传输过程。我们的基本思想是: Flink读取来自influxDB的数据，Flink利用这些数据进行一些基于Flink的ML库的建模。但是，我们只找到一些开源存储库，它们提供了一个接收器，可以将数据从Flink发送到InfluxDB (例如Flink InfluxDB连接器)。因此，如果你知道一些好的例子，如我所描述的，请告诉我。
浏览 0提问于2019-12-12得票数 1
回答已采纳
2回答
在使用Scala代码将数据从输出NiFi端口传输到Flink方面，我需要一些帮助。import org.apache.flink.streaming.connectors.nifi.NiFiSourceimport org.apache.flink.streaming.api.functions.sourc
浏览 0提问于2017-07-17得票数 0
回答已采纳
虽然Flink网站上的所有文档都没有提到“外部状态”，但我们在一篇论文中遇到了这个概念(http://www.vldb.org/pvldb/vol10/p1718-carbone.pdf 4.1节)。
浏览 26提问于2020-09-03得票数 0
回答已采纳
1回答
几天前，我在一个ubuntu集群上安装了Flink版本1.3.1。我绝对需要最后的版本1.3.2，但我没有找到任何程序在谷歌安全卸载flink。我没有建立应用程序，但我想确定我将没有剩菜。删除文件夹够了吗？
浏览 2提问于2017-09-11得票数 0
回答已采纳
在Flink中，我使用Python在FlatMapFunction中生成自定义度量。/#configurationmetrics.scope.jm.job: flink.jobmanager.jobmetrics.scope.tm.job: flink.taskmanager.job
metrics.scope.task: flink
浏览 16提问于2022-11-16得票数 0
我试图在dataset上进行实时预测，如何将svm、nb和cnn包含在apache上，以便在python中进行预测/分类。
浏览 4提问于2022-08-03得票数 0
当我在本地运行这个程序时，我会得到错误：
原因: org.apache.flink.api.common.functions.InvalidTypesException:输入不匹配:基本类型期望。
浏览 0提问于2020-05-04得票数 0
回答已采纳
假设我有一个可执行的jar文件，里面没有任何flink代码，我的工作是让它与flink一起分发。我已经在代码中的某个地方创建并执行了StreamExecutionEnvironment，并将可以分发的jar代码放在flink运算符(即映射函数)中，从而做到了这一点。他们告诉我要找到一种方法来包装这个无flink的jar，这样它就可以被flink集群执行(不需要像我上面那样注入代码和修改jar )。有没有办法做到这一点？jar声明，为了支持从打包的jar执行，程序必须使用由StreamExecutionEn
浏览 15提问于2020-06-02得票数 0
我正在寻找一个可视化的编程工具，以抽象化的代码，当创建数据流流，以建立在Flink或束-Flink中的CEP应用程序。类似于Nifi或流设置数据收集器的图形设计器。
有人知道这样的计划吗？
浏览 5提问于2017-04-30得票数 4
回答已采纳
1回答
<R>process(org.apache.flink.streaming.api.functions.windowing.ProcessWindowFunction<org.apache.flink.api.java.tuple.Tuple2<java.lang.String,java.lang.String>,R,org.apache.flink.api.java.tuple.Tuple,org.apache.flink.streaming.api.windowing.windows.Ti
浏览 1提问于2018-10-01得票数 2
回答已采纳
Dataproc是一种完全托管且高度可扩展的服务，用于运行Apache Spark、Apache Flink、Presto和30+开源工具和框架。
浏览 34提问于2021-10-01得票数 3
回答已采纳
使用远程功能的Flink 涉及到Flink StateFun集群将计算任务的执行交给通过某种FaaS机制部署的远程员工，例如AWS Lambda。在大规模流传输系统中，特别是如果由单个Lambda调用执行的工作相对于在该时段中在数据流中遇到的密钥的数量而言相对较长，则可以想象Flink StateFun集群可能遇到Lambda节流事件。Flink是如何处理这个问题的？它实现回退/重试了吗?相对于数据流中的事件顺序，这是如何处理的？
浏览 9提问于2021-10-18得票数 0
1回答
我正在深入研究Flink内部，看看如何在项目中使用它，并向创作者/高级思想家提出了一个问题。为什么Flink使用Yarn作为默认的资源管理器？请注意-我是刚认识亚恩的-只是读了一下。也是新的
浏览 2提问于2018-03-01得票数 2
回答已采纳
如何使用独立应用程序(本地执行环境或迷你集群)实现flink保存点。我在flink-config.yaml文件中配置了savepoint目录，但不确定如何在关闭应用程序之前获取保存点，以及如何在重新启动应用程序后恢复？是否有任何方法或必须先使用flink群集，然后再使用CLI。
感谢你的帮助。谢谢
浏览 0提问于2020-08-18得票数 0
我遵循创建集群，但不清楚如何向集群提供？例如，我想指定jobmanager.heap.size=2048m。
浏览 0提问于2019-08-13得票数 2
回答已采纳
我从github克隆了flink代码，并用Intellij Idea打开它，我没有在IJ或代码中做任何配置(我已经安装了IJ scala插件和scala sdk)，我直接在Intellij Idea中运行以下两个示例我能够成功地运行批处理模式字数统计示例(代码是类org.apache.flink.examples.scala.wordcount.WordCount in flink-examples-batch_但是当我尝试运行流单词统计示例(代码是类org.apache.flink.streaming.scala.exa
浏览 2提问于2019-01-12得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
