SQL kafka数据的相关内容

[帮助文档] 如何获取SQl查询返回的日期类型数据

使用SQL语句查询到时间类型（包括Datetime、Date和Time）数据后，您可以需要根据实际获取具体数据。

想请问下大家，有遇到使用 Flink SQL 把Kafka 数据写入Hive 时，报的这个错误吗？

想请问下大家，有遇到使用 Flink SQL 把Kafka 数据写入Hive 时，报的这个错误吗？用的的Flink 1.14.5版本，网上是说 flink-connector-hive_2.12 的 guava 包冲突。用IDEA的maven help 插件把相关的冲突都排出了，还是报错

如何在 PolarDB-X 中优化慢 SQL

2 课时 |

113 人已学 |

加入学习

SQL完全自学手册

61 课时 |

3601 人已学 |

加入学习

SQL Server on Linux入门教程

14 课时 |

4329 人已学 |

加入学习

问个小白问题：Flink SQL里，source读取kafka数据，然后根据orderId 统计总？

问个小白问题：Flink SQL里，source读取kafka数据，然后根据orderId 统计总量；我使用 SELECT COUNT(orderId) FROM source_table；的方式来计算总数；我的疑问点是，flink是如何处理这些source数据的，比如 kafka推过来 100W条...

flink sql如何过滤掉kafka topic中canal json格式的delete类型数据？

请问dataworks odps sql中能创建向kafka中写数据的external外表吗?

Flink 我在sql cli执行连接kafka建表sql（该kafka接收csv数据），然后有一条

Flink 我在sql cli执行连接kafka建表sql（该kafka接收csv数据），然后有一条数据造的不符合字段格式，导致报错，然后该flink作业就无法继续running了，请问该如何处理呢？

Flink SQL读取Kafka数据并写入 Kafka另外一个主题，为何总是持续重启？

各位大佬，flink sql 通过Upsert-Kafka下发更新数据有value 为null的情况

各位大佬，flink sql 通过Upsert-Kafka下发更新数据有value 为null的情况，怎么可以让null值不下发到kafka，求指点。

Sql往kafka表写聚合数据报错

如下，想用sql直接往kafka写聚合结果，版本是1.11，请问能有什么办法解决，还是只能转换成datastream？？谢谢 Exception in thread "main" org.apache.flink.table.api.TableException: Table sink 'defa...

flink sql 1.11 kafka source with子句使用新参数，下游消费不到数据

根据文档https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/connectors/kafka.html#start-reading-position，使用新参数创建kafka_table，下游消费不到数据，使...