| fix(stream): 修复审计发现的全部P0-P3缺陷（41项）
- N17: MemoryInternalAppendingState累加器每次add前重置
- N1: WindowOperator存储累加器引用而非getLocalValue()
- N2: mergeWindowContents ClassCastException改为WARN日志
- K15: windowNamespace使用类名前缀避免namespace碰撞
- N7: emitWindowContents签名改为显式key参数
- N12+N16: snapshot/restore简化为super调用修复key分区和非Serializable ACC
- N3: MergingWindowSet.persist()重新接入ListState
- N19: instantiateOperators处理TimestampsAndWatermarksTransformation
- N22: ValueStateDescriptor传递typeInfo
- N23: StreamSourceOperator移除正常完成后的cancel()
- N29: KeySelectorPartitioner处理null key和Integer.MIN_VALUE
- K10: ChainingOutput side output改为WARN日志
- K4+K6: WindowedStreamImpl标注@Deprecated, 清理注释残留
- N8: getSimpleAccumulator抛UnsupportedOperationException
- N20: checkpointExecutorFactory改为实例字段
- N28: SimpleStreamOperatorFactory通过序列化创建新实例
- K11: WindowOperatorTimerService timer从Supplier获取key
- N25: MemoryMapState保存descriptor引用
- N26: accumulator标记transient + rebind重建
- N18: KeyedStreamImpl从parentStream获取environment
- N9: BatchLoaderSourceFunction loader在finally中关闭
- N10: DebeziumCdcSourceFunction用CountDownLatch替代Thread.sleep
- N27/N33: WindowAssignerContext可空标注, watermarkInterval可配置
- K14: JdbcCheckpointStorage标注MySQL only
- N41: StreamSinkOperator条件性rollback
- K17/K20/K24: TimerService/Configuration/累加器接口标注@Internal/@Deprecated
- N21: DataStreamImpl增加TypeInformation重载
- N34: UnknownTypeInformation实现Serializable
- N40: DataStreamImpl移除Serializable
- K19: 空壳模块pom.xml添加placeholder注释
- N4/N5/N6/N14/N11: 示例代码修复(CEP条件/事件类型/demo stub/用户检查/统一数据源)
| 13 天前 |
| fix(stream): 修复审计发现的全部P0-P3缺陷（41项）
- N17: MemoryInternalAppendingState累加器每次add前重置
- N1: WindowOperator存储累加器引用而非getLocalValue()
- N2: mergeWindowContents ClassCastException改为WARN日志
- K15: windowNamespace使用类名前缀避免namespace碰撞
- N7: emitWindowContents签名改为显式key参数
- N12+N16: snapshot/restore简化为super调用修复key分区和非Serializable ACC
- N3: MergingWindowSet.persist()重新接入ListState
- N19: instantiateOperators处理TimestampsAndWatermarksTransformation
- N22: ValueStateDescriptor传递typeInfo
- N23: StreamSourceOperator移除正常完成后的cancel()
- N29: KeySelectorPartitioner处理null key和Integer.MIN_VALUE
- K10: ChainingOutput side output改为WARN日志
- K4+K6: WindowedStreamImpl标注@Deprecated, 清理注释残留
- N8: getSimpleAccumulator抛UnsupportedOperationException
- N20: checkpointExecutorFactory改为实例字段
- N28: SimpleStreamOperatorFactory通过序列化创建新实例
- K11: WindowOperatorTimerService timer从Supplier获取key
- N25: MemoryMapState保存descriptor引用
- N26: accumulator标记transient + rebind重建
- N18: KeyedStreamImpl从parentStream获取environment
- N9: BatchLoaderSourceFunction loader在finally中关闭
- N10: DebeziumCdcSourceFunction用CountDownLatch替代Thread.sleep
- N27/N33: WindowAssignerContext可空标注, watermarkInterval可配置
- K14: JdbcCheckpointStorage标注MySQL only
- N41: StreamSinkOperator条件性rollback
- K17/K20/K24: TimerService/Configuration/累加器接口标注@Internal/@Deprecated
- N21: DataStreamImpl增加TypeInformation重载
- N34: UnknownTypeInformation实现Serializable
- N40: DataStreamImpl移除Serializable
- K19: 空壳模块pom.xml添加placeholder注释
- N4/N5/N6/N14/N11: 示例代码修复(CEP条件/事件类型/demo stub/用户检查/统一数据源)
| 13 天前 |
| fix(stream): 修复审计发现的全部P0-P3缺陷（41项）
- N17: MemoryInternalAppendingState累加器每次add前重置
- N1: WindowOperator存储累加器引用而非getLocalValue()
- N2: mergeWindowContents ClassCastException改为WARN日志
- K15: windowNamespace使用类名前缀避免namespace碰撞
- N7: emitWindowContents签名改为显式key参数
- N12+N16: snapshot/restore简化为super调用修复key分区和非Serializable ACC
- N3: MergingWindowSet.persist()重新接入ListState
- N19: instantiateOperators处理TimestampsAndWatermarksTransformation
- N22: ValueStateDescriptor传递typeInfo
- N23: StreamSourceOperator移除正常完成后的cancel()
- N29: KeySelectorPartitioner处理null key和Integer.MIN_VALUE
- K10: ChainingOutput side output改为WARN日志
- K4+K6: WindowedStreamImpl标注@Deprecated, 清理注释残留
- N8: getSimpleAccumulator抛UnsupportedOperationException
- N20: checkpointExecutorFactory改为实例字段
- N28: SimpleStreamOperatorFactory通过序列化创建新实例
- K11: WindowOperatorTimerService timer从Supplier获取key
- N25: MemoryMapState保存descriptor引用
- N26: accumulator标记transient + rebind重建
- N18: KeyedStreamImpl从parentStream获取environment
- N9: BatchLoaderSourceFunction loader在finally中关闭
- N10: DebeziumCdcSourceFunction用CountDownLatch替代Thread.sleep
- N27/N33: WindowAssignerContext可空标注, watermarkInterval可配置
- K14: JdbcCheckpointStorage标注MySQL only
- N41: StreamSinkOperator条件性rollback
- K17/K20/K24: TimerService/Configuration/累加器接口标注@Internal/@Deprecated
- N21: DataStreamImpl增加TypeInformation重载
- N34: UnknownTypeInformation实现Serializable
- N40: DataStreamImpl移除Serializable
- K19: 空壳模块pom.xml添加placeholder注释
- N4/N5/N6/N14/N11: 示例代码修复(CEP条件/事件类型/demo stub/用户检查/统一数据源)
| 13 天前 |
