阿里云文档 2025-02-27

Catalog

本文介绍Catalog相关问题。

文章 2024-08-18 来自:开发者社区

实时计算 Flink版操作报错合集之在Docker上启动JobManager(JM)时遇到报错,,该怎么处理

问题一:flink sql 开启mini-batch会报错 flink版本1.15 在代码中设了如下参数来开启minibatch模式: tableEnv.getConfig().set("table.exec.mini-batch.enabled", "true"); tableEnv.getConfig().set("table.exec.mini-batch....

实时计算 Flink版操作报错合集之在Docker上启动JobManager(JM)时遇到报错,,该怎么处理
文章 2024-02-26 来自:开发者社区

Flink报错问题之flink 1.11 sql作业提交JM报错如何解决

问题一:flink1.10.1 flink sql消费kafka当parallelism大于1时不产生wat 本人使用的flink版本为flink 1.10.1, flink sql消费kafka, 当parallelism为1时正常运行,但讲parallelism修改为2时,在yarn-session web页面看不到watermark的指标信息了,也没有计算结果输出,sql如下: ...

问答 2023-04-19 来自:开发者社区

Flink中报错直接启动不了,进而导致pod里面的JM起不来了,该怎么办呢?

我的部署方式是flink on native k8s,使用application模式。其中,为了对接相关平台,我flink-conf.yaml中配置的jobmanager.rpc.address,没有用原生的servicename.namespace方式,而是使用了servicename直接指定。为此,我改造了flink-1.14.0\flink-kubernetes\src\main\java....

阿里云文档 2022-09-16

问题描述Dataphin新建Ververica Flink计算源,报错"测试连接失败,请确保填写连接信息无误,错误信息:DPN.ComputeEngine.Connect.Failed"。解决方案Dataphin计算源Project Name填写错误。如果计算源配置的是Flink Vvp(Verve...

阿里云文档 2022-01-13

问题描述Dataphin中Flink任务执行报错。CREATE TEMPORARY TABLE tbl_test( id int, num int ) WITH (   'connector' = 'kafka',   'topic' = 'order_line',   'properties.bo...

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

+关注