Flink HBase SQL 连接器 为啥不支持数据类型?

Flink HBase SQL 连接器(flink-connector-hbase_2.11) 为啥不支持数据类型:ARRAY、MAP / MULTISET、ROW 不支持?https://nightlies.apache.org/flink/flink-docs-release-1.11/zh/d...

[帮助文档] PolarDB PostgreSQL版连接器

本文为您介绍如何使用PolarDB PostgreSQL版(Oracle语法兼容1.0)连接器。

实时数据分析:使用Flink实时发现最热Github项目

1 课时 |
404 人已学 |
免费

实时数据接入:5分钟上手 Flink MySQL 连接器

1 课时 |
204 人已学 |
免费

大数据知识图谱系列—基于ELK+Flink日志全观测最佳实践

1 课时 |
174 人已学 |
免费
开发者课程背景图

[帮助文档] 使用Kafka连接器进行Kerberos身份认证

Kerberos是一种网络身份验证协议,用于提供安全的身份验证服务,以保证通信的安全性。只有在Flink开发控制台正确配置Kerberos和Kafka服务的信息,Flink作业才能访问开启Kerberos认证服务的Kafka集群。本文为您介绍如何为Kafka客户端开启Kerberos认证。

flink sql问题之连接HBase报错如何解决

问题一:flink 1.11 sql作业提交JM报错 我使用flink 1.11提交sql作业,从JM日志中看到有如下异常。我的作业里会通过tEnv.executeSQL执行多个ddl语句,通过tEnv.createStatementSet add多个dml语句,并执行execute。 如下异常可能...

Flink CDC里flink sql clickhouse 有 支持的连接器吗?

Flink CDC里flink sql clickhouse 有 支持的连接器吗?

Flink CDC里mongodbcdc使用sql执行连接的话,并且数据量比较大会导致数据卡怎么办?

Flink CDC里我看mongodbcdc如果使用sql执行连接的话,并且数据量比较大会导致数据卡住,好像是因为必须快照完之后才会将状态刷新到检查点,是这样的吗?我发现没快照完的时候,检查点根本就没有大小,要加内存吗?文档上的解释没了为啥?这块我记得官方不是有写关于快照时不进行自动检查点吗?现在对...

Flink CDC中有用flink sql连接hive的吗?

Flink CDC中有大佬用flink sql连接hive的吗?

[帮助文档] 实时计算Flink版集成物联网平台数据的连接器

在使用Flink SQL开发作业集成物联网平台数据时,需要使用SQL连接器连接物联网平台的数据表(产品属性时序数据、产品事件数据和自定义时序存储表)。物联网平台提供了连接器作为实时计算Flink全托管自定义连接器使用。本文介绍如何使用实时计算Flink版集成物联网平台数据的连接器(IoT Conne...

Flink CDC我更改了mongo-cdc的名字,这样是一定会修改sql连接器的方式吗?

Flink CDC我更改了mongo-cdc的名字,这样是一定会修改sql连接器的方式吗?

Flink CDC中flink sql 连接报错这个 但是我数据库是有这个信息得 有谁知道原因吗?

Flink CDC中flink sql 连接报错这个 但是我数据库是有这个信息得 有谁知道原因吗?Can't find any matched tables, please check your configured database-name: [new] and table-name: [new...

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

产品推荐

社区圈子

阿里云实时计算Flink
阿里云实时计算Flink
一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。
199201+人已加入
加入
相关电子书
更多
基于 Flink SQL + Paimon 构建流式湖仓新方
基于 Flink CDC 打造 企业级实时数据集成方案
李劲松|Flink Table Store 典型应用场景
立即下载 立即下载 立即下载

实时计算 Flink版连接相关内容