org.apache.flink.streaming.api.TimeCharacteristic
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironmentimport org.apache.flink.streaming.a
浏览 26提问于2020-06-26得票数 0
回答已采纳
尝试在Scala2.10.4中使用0.10.0Flink版本的流api。在试图编译这个第一个版本时：import org.apache.flink.streaming.api.scal
浏览 16提问于2015-11-15得票数 3
回答已采纳
1回答
我使用Apache Flink在scala中运行了一个简单的脚本。我从一个Apache Kafka制作人那里读到了数据。这是我的代码。import java.util.Properties
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironmentimport org.apache.<em
浏览 2提问于2017-08-01得票数 0
回答已采纳
:84) at org.apache.flink.streaming.api.environment.Strea
浏览 2提问于2020-07-22得票数 7
(ClosureCleaner.java:72) at org.apache.flink.streaming.api.datastre
浏览 1提问于2018-04-03得票数 2
回答已采纳
1.4.2 (1.4.x)运行相同的代码，我得到了以下错误：在线上
Ca
浏览 2提问于2018-03-24得票数 4
回答已采纳
import org.apache.flink.cep.CEPimport org.apache.flink.core.fs.FileSystemimport org.apache.flink.streaming.api.Tim
浏览 50提问于2020-01-14得票数 0
回答已采纳
作为参考，我有："org.apache.flink" %% "flink-streaming-scala"(Preconditions.java:104)
at org.apache
浏览 0提问于2020-06-05得票数 0
1回答
'scala.collection.mutable.ArrayOps scala.Predef$.refArrayOps(java.lang.Object[])' at org.apache.flink
浏览 8提问于2021-04-29得票数 0
回答已采纳
2回答
下面是Flink的快速启动示例：。这个例子是用Java实现的，我正在Scala中实现它，如下所示： * Wikipedia Edit Monitoringobject WikipediaEditMonitoring= StreamExecutionEnvironment.getExecutionEnvironment
// execute p
浏览 3提问于2017-11-05得票数 7
回答已采纳
1回答
package com.knoldusimport org.apache.flink.streaming.api.scala._
import org.apache.flink.streaming.api.windowin
浏览 102提问于2020-03-23得票数 1
我无法在zepplin中运行flink (1.0.3)进程。它处于挂起状态，web ui未记录该过程:在群集模式和本地模式下都是如此。Flink本身在命令行和intellij中运行良好。
浏览 4提问于2016-08-01得票数 1
我正在尝试建立一个非常基本的flink工作。at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.getStreamGraph(StreamExecutionEnvironment.java:1535)
at org.apache.flink.streaming.api</e
浏览 1提问于2019-03-04得票数 11
回答已采纳
1回答
我正在尝试从将Apache教程中的维基百科编辑流分析重写到Scalaimport org.apache.flink.api.common.functions.FoldFunction;import org.apache.flink.
浏览 1提问于2016-12-29得票数 0
回答已采纳
import org.apache.flink.api.scala._import org.apache.flink.streaming.api.<e
浏览 3提问于2020-08-05得票数 2
回答已采纳
1回答
._import org.apache.flink.streaming.api.scala{DataStream, StreamExecutionEnvironment}
import org.apache.flink.stre
浏览 3提问于2017-05-02得票数 1
回答已采纳
时，我收到以下错误： Caused by: org.apache.flink.api.common.InvalidProgramException: The implementation of the(ClosureCleaner.java:99)
at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.clean(St
浏览 132提问于2019-04-02得票数 0
这是我的代码：import org.apache.flink.streaming.api.scala.{StreamExecutionEnvironment, _}
import org.apache.flink.<e
浏览 1提问于2018-11-30得票数 6
1回答
org.apache.flink.streaming.api.scala.DataStream
import org.apache.flink.streaming.api.scala.StreamExecutionEnvironmentimport org.apache.flink.streaming<
浏览 4提问于2016-11-06得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
云直播
腾讯会议活动推荐
腾讯云开发者
