Kafka-Source Csv格式下，多字符支持

未关闭

#351 创建于 2020年8月27日 0 条评论 0 个 reaction 已指派 0 人在 GitHub 查看

还没有人认领这个 Issue。

评估

首先跟踪使用 Flink 的 CsvRowDeserializationSchema 和 jackson-dataformat-csv API 的 Kafka-Source CSV 路径。确认当前单字符分隔符的配置方式，然后将完成标准定义为能够使用多字符分隔符成功解析 Kafka CSV 消息。

由索引模型根据 Issue 内容生成。

目前，Kafka-Source插件csv数据格式，用于读取kafka消息，使用的是flink官方的CsvRowDeserializationSchema（调用jackson-dataformat-csv的API进行解析），只支持单字符分隔符。是否考虑添加多字符分隔符。这个应该很实用！！！

这个仓库没有索引到贡献指南

Flink SQL 使用滚动窗口，能不能获取到延迟数据，跟datastream一样，可以放到侧输出里面未关闭

难度 5/5 一周以上新手友好度 20/100

DTStack/flinkStreamSQL#467 · 1 条评论 · 2024年9月27日创建
这个如何引入使用flink-connector-hive啊未关闭

难度 4/5 3-5 天新手友好度 25/100

DTStack/flinkStreamSQL#437 · 3 条评论 · 2022年2月25日创建
kudu sink writemode参数没填写报NULLPointerException 未关闭

难度 3/5 1-2 天新手友好度 38/100

DTStack/flinkStreamSQL#432 · 1 条评论 · 2021年11月16日创建
新版FlinkStreamSQL已经融合进FlinkX项目未关闭

难度 5/5 一周以上新手友好度 15/100

DTStack/flinkStreamSQL#431 · 2021年11月1日创建
有无对sql 语法校验的方法未关闭

难度 5/5 一周以上新手友好度 15/100

DTStack/flinkStreamSQL#430 · 1 条评论 · 2021年10月8日创建

build-scan-xunit: accept ISO offset timestamps in test reports 未关闭

难度 2/5 1-3 小时新手友好度 75/100

elastic/gradle-plugins#157 · 2026年9月23日创建
Counterexamples differ when using `-recover` (`-workers`, `-fp`, `-seed` must match the original run) 未关闭

enhancement Tools

难度 1/5 1 小时以内新手友好度 75/100

tlaplus/tlaplus#1444 · 2 条评论 · 2026年9月23日创建
[Studio][Bug] rmq.instance.metrics advertises an invalid MCP input contract 未关闭

难度 2/5 1-3 小时新手友好度 70/100

apache/rocketmq-dashboard#5008 · 2026年9月23日创建
[Bug] A cell read into a ReadCellData field loses its row and column index 未关闭

bug

难度 2/5 1-3 小时新手友好度 75/100

apache/fesod#1131 · 1 条评论 · 2026年9月23日创建
DETECT_PARAMETER_NAMES=false silently disables @ConstructorProperties-based Creator detection too 未关闭

难度 2/5 1-3 小时新手友好度 70/100

FasterXML/jackson-databind#6229 · 2026年9月23日创建