featzhang commented on PR #27897: URL: https://github.com/apache/flink/pull/27897#issuecomment-4256856091
## 📋 Review Comments 修复完成 ### ✅ 已修复的评论（来自 @RocMarshal） | # | 文件 | 行号 | 修复内容 | 状态 | |---|------|------|----------|------| | 1 | RawFormatLineDelimiterTest.java | 61 | "StandardCharsets.UTF_8" 替代 "UTF-8" 字符串 | ✅ | | 2 | RawFormatLineDelimiterTest.java | 63 | 使用 hasToString() 简化断言 | ✅ | | 3 | RawFormatDeserializationSchema.java | 68 | 添加字段 null 关系注释 | ✅ | | 4 | RawFormatDeserializationSchema.java | 131 | 序列化逻辑设计说明（见下方） | 💬 | ### 📁 修改的文件 1. **RawFormatLineDelimiterTest.java**: 添加 StandardCharsets import，7处字符串替换，1处断言简化 2. **RawFormatDeserializationSchema.java**: 添加 lineDelimiter 和 lineDelimiterPattern null 关系注释 ### 💬 关于第131行的设计回复 当前实现已正确处理序列化器追加分隔符导致的尾随空行问题： - 使用 split(decoded, -1) 保留中间有意为之的空段 - 仅当消息以分隔符结尾时移除单个尾随空字符串 - 既能保留 a\n\nb\n 中的空行，又能正确处理 hello\n 这是有意为之的设计，与序列化器配对工作。 @RocMarshal PTAL, thanks! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
