是否可以生成技术SAML并在进行REST API调用时传播它？ 虽然flink文档并没有真正讨论SAML anywhere，但是否可以依赖外部Scala/Java依赖来实现这一点？
浏览 22提问于2021-05-10得票数 0
我在线程"main“中得到了一个异常:类org.apache.flink.state.api.runtime.SavepointLoader试图访问受保护的方法org.apache.flink.runtime.state.filesystem.AbstractFsCheckpointStorage.resolveCheckpointPointer(Ljava/lang/String;)Lorg/apache&#x
浏览 0提问于2020-01-20得票数 1
回答已采纳
我想分析一下Flink对RocksDB进行的每个应用程序接口调用所用的时间。但是，我找不到这些函数。我尝试在IDE中设置Flink的完整源代码，将我的流式示例集成到源代码中，启动调试器并执行许多调用，但都是徒劳的。示例如下： package org.apache.flink.streaming.examples.spendreport;
import org.<
浏览 21提问于2020-07-27得票数 0
回答已采纳
1回答
第一次尝试时，我希望从文件中读取JSON数据并将其传递给Flink。我定义了一个源(逐行读取JSON字符串)和一个占位符过滤器。见守则：from org.apache.flink.api.common.functions/json_parser_flink.py程序的
浏览 0提问于2019-03-06得票数 1
1.4.2 (1.4.x)运行相同的代码，我得到了以下错误：import org.apache.flink.api.common.functions.MapFunction;
import org.apache.flink
浏览 2提问于2018-03-24得票数 4
回答已采纳
在eclipse中尝试执行基本的Flink程序时，由于.print()被datastream_name.print()调用来打印我的数据，我得到了错误。(ClosureCleaner.java:106) at org.apache.flink.a
浏览 15提问于2022-06-26得票数 0
我在flink中有一个地图，一旦数据通过流，它就会被激活。 即使没有数据通过，我也要调用该地图。 我将map移动到一个函数中(无限函数调用)，但是flink作业永远不会运行。这个想法是，在一个无限循环中有一个映射，检查一些共享变量，另一个flink流监控kafka队列，如果数据进入它的进程，它会改变一个共享变量，以某种方式影响无限循环并继续。如何调用无限循环映射并同时运行flink映射？我尝试使用随机数据创建一个CollectionM
浏览 28提问于2019-05-07得票数 1
我开始研究用Scala语言编写的Apache Flink的CEP库，当我试图通过执行https://ci.apache.org/projects/flink/flink-docs-stable/devpackage FlinkCEPClasses
import org.apache.flink.api</em
浏览 50提问于2020-01-14得票数 0
回答已采纳
我们感兴趣的是从连接到常规的Flink流应用程序，最好使用Table。这样做的想法是查阅Statefun在Flink中注册的表，是否有此可能，如何做才是正确的方法？到目前为止，我的想法是在一些主函数中初始化我的表流，并注册一个有状态函数提供程序来连接到该表：public class，并在调用时简单地查询表：
pu
浏览 2提问于2020-04-11得票数 2
1回答
我已经写了一个小的flink应用程序。我有一些输入，并用来自外部源的数据来丰富它。它是一个RichAsyncFunction，在open方法中，我构造了一个用于丰富的http客户端。现在我想为我的工作写一个集成测试。但是由于http客户端是在open方法中创建的，所以我没有办法提供它，并在我的集成测试中模拟它。我试图在构造函数中重构它，但我总是得到序列化错误。这是我正在使用的示例：
浏览 28提问于2020-06-01得票数 2
我使用的是Flink v1.7.1。当我使用tableSource、SQL和tableSink完成Flink流作业时，我不知道如何为它添加单元测试。
浏览 21提问于2019-02-27得票数 2
回答已采纳
1回答
我试图在本地运行flink，为一个具有并行性的作业设置8个任务槽。我使用FlinkKafkaProducer011作为接收器。作业可以运行约20分钟，检查点在这段时间内会成功。但是，作业在此之后失败，我得到以下错误：
org.apache.flink.streaming.connectors.kafka.FlinkKafka011Exception:未能向Kafka发送数据
浏览 1提问于2019-07-12得票数 1
下面提到的Apache测试代码在我想使用KeyedOneInputStreamOperatorTestHarnessK、IN、Int或Long作为key (K)参数时不会在Scala中编译。可以使用字符串、整数或java.lang.Long类型的泛型参数编译相同的代码：importorg.apache.flink</
浏览 7提问于2021-12-31得票数 2
我已经编写了一个简单的示例来接收表，但是即使在实现了AppendTableSink接口之后，也可以在Apache中获得这个异常。; import org.apache.flink.api.common.typeinfo.TypeInformation;
import org.apache.<
浏览 1提问于2017-08-24得票数 0
2回答
我正在尝试从运行在clojure中的Apache中获得一个小示例，但是现在我被困住了，因为clojure中的类型暗示和flink中的一些奇怪的怪癖。这是我的代码： (:import (org.apac
浏览 2提问于2015-08-20得票数 5
回答已采纳
在java7环境中切换到org.joda (版本2.9)之后，对DataSets中的click对象的调用没有像以前那样执行。参见Flink中的org.apache.flink.api.java.typeutils.runtime.kryo.Serializers或，其中有带有静态方法registerJodaTime的。我头脑简单地尝试了
import org.apache.<em
浏览 11提问于2015-11-11得票数 4
回答已采纳
我试图在SQL中执行python函数(1.14.0)from pyflink.table import DataTypesflink run /home/magic/workspace/flink-jobs/UDF/pythonUDF/target/pythonUDF-1.0.0.jarorg.apache.<
浏览 6提问于2021-12-03得票数 3
1回答
当我将Flink Java应用程序从1.12.2升级到1.12.3时，我会得到一个新的运行时错误。不会触发Flink版本1.12.2的任何错误。(BlinkPlannerFactory.java:48)
浏览 8提问于2021-04-29得票数 0
回答已采纳
2回答
所以我在一个DataStream上运行一个映射函数，在这个映射函数中，我想连接两个独立的DataSets。我只是想知道这在Flink中是否可行。我知道map函数本身是作为单独分区的单独任务运行的，所以我想知道map函数内部是否允许分布式连接？
浏览 17提问于2018-01-21得票数 0
云服务器
对象存储
ICP备案
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号