flink Dockerfile：
ADD http://central.maven.org/maven2/org/apache/flink/flink-connector-kafkaorg/apache/flink/flink-avro-confluent-registry/1.7.2/flink-avro-con
浏览 0提问于2019-04-12得票数 1
回答已采纳
token, 1)); } }
运行这段代码后，我得到了以下错误：
线程"main“org.apache.flink.api.common.InvalidProgramException
浏览 0提问于2018-12-24得票数 0
回答已采纳
input_types=[DataTypes.INT()], result_type=DataTypes.INT()) return a + 1➜ flink-1.14.0 .ret1 = tEnv.executeSql("select add1(3)"); }然后通过Flink客户端运行作业：
flink run &#x
浏览 6提问于2021-12-03得票数 3
我使用代码中导入的下列依赖项：import org.apache.flink.api.java.tuple.Tuple2;import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
impo
浏览 2提问于2018-03-24得票数 4
回答已采纳
我试图使用Apache (org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness)中的OneInputStreamOperatorTestHarness
浏览 5提问于2021-12-20得票数 -1
:flink-annotations</exclude> <exclude>org.apache.<
浏览 0提问于2018-11-19得票数 0
我使用的是最新的Flink-1.1.2-Hadoop-27和flink-连接器-kafka-0.10.2-Hadoop 1罐。Flink消费者如下：以下是执行后得到的例外情况：
Exception in thread "main" java.lang.NoClassDefFoundError: org/apache&
浏览 2提问于2016-10-14得票数 7
回答已采纳
我开始研究用Scala语言编写的Apache Flink的CEP库，当我试图通过执行https://ci.apache.org/projects/flink/flink-docs-stable/dev/flink-cep-scala
libraryDependencies += "org.apache.flink" %% "flink-cep-scala" % "1.9
浏览 50提问于2020-01-14得票数 0
回答已采纳
我试图在win10专业版的桌面上运行flink集群。文档：ADD build/libs/demoapp-service-all.jar /opt/flink/usrlib/demoapp-service-all.jarADD conf/flink-conf.yaml /opt/flink&
浏览 2提问于2020-11-25得票数 3
我用maven编译了我的项目https://github.com/felipegutierrez/explore-flink，并用这个Dockerfile扩展了默认的flink图像flink:1.11.1/java/explore-flink /opt/explore-flinkRUN mvn clean install
FROM
浏览 89提问于2020-09-21得票数 1
回答已采纳
通过阅读，我得出结论，我应该使用per：https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/testing.html#testing-checkpointing-and-state-handling我原以为它可能是在flink-test-utils-junit中实现的，但事实并非如此。
浏览 104提问于2019-02-16得票数 0
回答已采纳
1回答
我正在尝试使用光束和Flink runner设置一个流处理管道。Flink是具有以下docker-compose文件的本地会话部署： version: "3"
jobmanager: container_name: flink-jobmanager FLINK_PROPERTIES: "jobmanager.rpc
浏览 94提问于2021-01-29得票数 3
我的目标是从Flink获得一个流，并将其插入到ElasticSearch中，感谢您的帮助。
浏览 0提问于2020-02-05得票数 0
我有一个在本地运行良好的Flink作业，但是当我尝试在集群上flink run作业时失败了。它基本上是读卡夫卡，做一些转换，并写到一个水槽。这是我的pom.xml，包括flink-connector-kafka。 </dependency> <groupId>org.apache.flink</e
浏览 16提问于2021-03-10得票数 0
回答已采纳
: org.apache.flink.core.memory.MemorySegmentFactory.initializeFactory(Lorg/apache/flink/core/memory/MemorySegmentFactory:118)at org.apache.fl
浏览 0提问于2017-03-17得票数 2
1回答
现在，我想使用下面的代码在Flink程序中使用console-consumer生成的输出
<artifactId>flink-streaming-java_2.10</artifactId>
<version>${flink.version<groupId>org.apache.
浏览 5提问于2017-08-22得票数 1
:flink-core:%s" % FLINK_VERSION, "org.apache.flink:flink-streaming-java_%s:%s" % (SCALA_VERSION, FLINK_VERSION),
"org.apache
浏览 0提问于2020-05-09得票数 1
我可以从web中查看任务管理器的日志：但是，假设我提交了一个作业，并使用log4j2将一些日志写到一个特定的文件中，我可以做一些配置以便从web查看日志吗？
浏览 0提问于2018-12-03得票数 1
回答已采纳
我正在尝试flink并在flink集群上部署作业时遇到异常(在kubernetes上)。设置斯卡拉- 2.11.12集群上的Flink对接图像-flink:1.4.2-scala_2.11-高寒ThisBuild / resolvers" %% "flink-scala" % flinkVersion % "provided",
"org.apache
浏览 1提问于2018-03-15得票数 0
3回答
</groupId> <version>1.3.2</version><dependency> <artifactId>flink-clients_2.11&
浏览 19提问于2017-11-28得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
对象存储
云直播活动推荐
腾讯云开发者
