ververica平台| Flink Required context属性不匹配
是一个基于Apache Flink的流处理和批处理框架的企业级解决方案。它提供了一套完整的工具和服务，帮助用户在云环境中构建、部署和管理大规模的实时数据应用。
在ververica平台中，Required context属性不匹配是指在Flink作业中，作业的上下文属性与所需的上下文属性不匹配的错误。上下文属性是作业在运行时需要的环境变量或配置参数，例如数据库连接信息、认证凭证等。当作业的Required context属性与实际环境中提供的属性不匹配时，就会出现这个错误。
解决这个问题的方法是确保作业的Required context属性与实际环境中提供的属性一致。可以通过以下步骤来解决：
- 检查作业的代码和配置文件，确保Required context属性的名称和类型与实际环境中提供的属性一致。
- 检查作业提交时所使用的命令行参数或配置文件，确保正确地指定了Required context属性。
- 检查作业所运行的集群环境，确保集群中的资源和配置与作业所需的上下文属性相匹配。
- 如果使用ververica平台进行作业管理，可以通过ververica平台的管理界面或API来配置和管理作业的上下文属性。
推荐的腾讯云相关产品是Tencent Cloud Flink，它是腾讯云提供的基于Apache Flink的流处理和批处理服务。Tencent Cloud Flink提供了高可用性、弹性扩展、易于管理的特性，可以帮助用户快速构建和部署大规模的实时数据应用。
更多关于Tencent Cloud Flink的信息和产品介绍，请访问以下链接： Tencent Cloud Flink
相关·内容
我正在尝试向Kubernates中部署的ververica平台提交作业，但我收到了下面的消息，我向Flink standalone提交了相同的代码，它的工作正常！！我使用的是Flink 1.10.1，代码是Scala 2.12。Caused by: org.apache.flink.client.program.ProgramInvocationException: The main method caused an errorReason: Required context</
浏览 74提问于2020-07-12得票数 1
回答已采纳
如何使用独立应用程序(本地执行环境或迷你集群)实现flink保存点。我在flink-config.yaml文件中配置了savepoint目录，但不确定如何在关闭应用程序之前获取保存点，以及如何在重新启动应用程序后恢复？是否有任何方法或必须先使用flink群集，然后再使用CLI。
感谢你的帮助。谢谢
浏览 0提问于2020-08-18得票数 0
2回答
我有一个从套接字读取并检测模式的flink cep代码。让我们说这个模式(单词)是“警觉”的。如果警告一词出现五次或更多次，则应创建警报。但是我得到了一个输入不匹配错误。Flink版本为1.3.0。package pattern;
import org.apache.flink.cep.PatternStream;
浏览 3提问于2017-07-11得票数 1
回答已采纳
我正在使用Flink 1.8试图连接到Kerberized经纪人。我将KafkaClient条目设置为jaas.conf，如下所示： com.sun.security.auth.module.Krb5LoginModule requireduseTicketCache=true serviceName="zookeeper";并通过在代码中设置该属性来指向该jaas文件，该属性将传递给卡夫卡消费者和其他所需
浏览 0提问于2019-09-16得票数 1
使用vscode扩展HTMLHint，有什么方法可以配置它来检查属性错读吗？我把required代替了required。它能检查所有可接受的属性，然后告诉我我的属性是否不匹配吗？
浏览 6提问于2022-06-19得票数 0
回答已采纳
2回答
context.ModelState.IsValid) context.Result = new BadRequestObjectResult(context.ModelState[Required] // This works!public string Name { get; set; }
}
这里的问题是，只有Perso
浏览 0提问于2015-08-11得票数 4
回答已采纳
在构建一个VS2017项目时，使用VC++只会遇到一个链接错误：
默认情况下，它是Visual Studio 2017 (v141)，但是第三方静态库是用VS2012构建的，其平台工具集是v110。是否可以将VS2012平台工具集添加到VS2017 VC++项目中，而无
浏览 0提问于2018-06-01得票数 0
回答已采纳
问题
如果不可能，在Kafka和HDFS都受到Kerberos保护的情况下，对于Kafka-Flink-HDFS数据流来说，什
浏览 0提问于2018-05-02得票数 5
回答已采纳
我有一种resultType of Context.this.type#c#universe#Type。我需要将它与Unit类型相匹配。我试过了 case q"Unit" => ...但我认为Unit只是一个字符串文本，显然不匹配。如何通过准types匹配类型？但是有一个错误：[error] found : S
浏览 1提问于2013-09-11得票数 4
回答已采纳
Apache的新手，我尝试过滤以字母"N“开头的单词，并得到输出，但是我如何获得不以单词"N”开头的单词，这是我正在使用的代码import org.apache.flink.api.common.functions.FlatMapFunction;import o
浏览 1提问于2020-05-12得票数 0
回答已采纳
我要确保'password_confirm‘和'password’匹配。如果它们不匹配，则表单应无效。如果输入不匹配但表单不是无效的，我可以显示验证消息，表示可以提交： <div class="form-group input text required " ng-class="{'has-error'"password_confirm" placeholder="Password
浏览 10提问于2020-07-15得票数 1
我有一个Visual 2012 .Net主项目，其构建属性中指定了一个平台目标x86。该项目由多个C++项目和C#项目组成。在我的配置管理器中，C#项目的平台是任何CPU，而C++项目的平台是Win32。我想引用一个第三方dll，它是针对AMD64的。当我添加引用时，我会得到以下警告：
警告:警告:正在构建的项目的处理器体系结构与引用"DALSA，processorArchitecture=AMD64“和"AMD64”的处理器体系结构不匹配。这种不
浏览 5提问于2014-12-17得票数 0
是否可以设置仍然允许additionalProperties的JSON模式，但如果存在非常特定的属性名，则不匹配吗？换句话说，我需要知道是否有可能与required声明完全相反。模式： "type": "object", "x": { "type": "integer" } "required}{
浏览 6提问于2015-05-28得票数 42
回答已采纳
当使用@DateTimeFormat注解格式化作为查询参数(@RequestParam)发送的日期时，它会自动将空字符串(作为日期接收)转换为null，而不会抛出类型不匹配异常。当日期参数是可选的时，这可以很好地工作，但是，当设置了required = true时，@DateTimeFormat接受空字符串并将其转换为null，而不抛出异常，因此不考虑required = truespring属性。我们有什么属性可以传递给@DateTimeFormat来选择空字符串是否
浏览 2提问于2021-03-29得票数 1
来自HTML5规范：
元素上存在一个布尔属性表示真值，而缺少该属性则表示虚值。如果属性存在，则其值必须是空字符串，或者是对属性的规范名称不区分大小写的ASCII值，没有前导或尾随空格。注意:布尔属性不允许值"true“和"false”。要表示虚值，必须完全省略该属性。我认为有一个有效的历史原因解释了为什么允许值(并且只允许不区分大小写的名称匹配).但我的问题是:如果有这些布尔属性的值，有什么好处
浏览 3提问于2015-04-17得票数 1
1回答
我已经建立了一个flink流作业，从kafka读取xml文件，转换文件，并将其写入数据库中。由于xml文件中的属性与数据库列名称不匹配，因此我为映射构建了一个切换用例。还有一个缺点是，对于我想要应用的此配置中的每个更改，我都必须重新启动flink作业。 我的问题是，是否有可能在运行时注入这种映射逻辑，例如通过自己的kafka主题。
浏览 12提问于2020-11-18得票数 0
回答已采纳
public class PrescriptionEditModel [Required] public Guid Id { get; set; }
[Display(Name = "Medicine")] [Display
浏览 12提问于2019-05-01得票数 0
我在我的github构建中得到了这个错误：
run: >
docker build -t ${{ env.image_name_cont
浏览 9提问于2021-12-11得票数 1
2回答
问题：
func delete(something: NSManagedObject, context: NSManagedObjectContext) {
context.performAndWait{ //Is context.perform / context</em
浏览 0提问于2018-04-30得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
云直播活动推荐
腾讯云开发者
