OmniStream/cpp/connector/kafka/sink · openEuler/OmniStream - AtomGit

lidangxin2000fix KafkaWriter coredump

文件	最后提交记录	最后更新时间
DeliveryGuarantee.h	update with yellow zone	7 个月前
DynamicKafkaRecordSerializationSchema.cpp	support kafka sink decimal type	1 个月前
DynamicKafkaRecordSerializationSchema.h	support kafka sink decimal type	1 个月前
FlinkFixedPartitioner.h	update with yellow zone	7 个月前
FlinkKafkaInternalProducer.cpp	update with yellow zone	7 个月前
FlinkKafkaInternalProducer.h	update with yellow zone	7 个月前
KafkaCommittable.cpp	update with yellow zone	7 个月前
KafkaCommittable.h	update with yellow zone	7 个月前
KafkaCommittableSerializer.cpp	SQL CP 功能相关 Co-authored-by: TideMacro<TideMacro@outlook.com> (cherry picked from commit eef068d1b495c0ea519ed235e5ad07b1e1e51fb0)	1 个月前
KafkaCommittableSerializer.h	SQL CP 功能相关 Co-authored-by: TideMacro<TideMacro@outlook.com> (cherry picked from commit eef068d1b495c0ea519ed235e5ad07b1e1e51fb0)	1 个月前
KafkaCommitter.cpp	SQL 支持OperatorState 恢复相关功能 Co-authored-by: IcE_test<1054919371@qq.com> (cherry picked from commit c8af23581f63d48a37c79bf6955eea16917360d5)	1 个月前
KafkaCommitter.h	SQL 支持OperatorState 恢复相关功能 Co-authored-by: IcE_test<1054919371@qq.com> (cherry picked from commit c8af23581f63d48a37c79bf6955eea16917360d5)	1 个月前
KafkaRecordSerializationSchema.h	update with yellow zone	7 个月前
KafkaSink.cpp	SQL CP 功能相关 Co-authored-by: TideMacro<TideMacro@outlook.com> (cherry picked from commit eef068d1b495c0ea519ed235e5ad07b1e1e51fb0)	1 个月前
KafkaSink.h	SQL CP 功能相关 Co-authored-by: TideMacro<TideMacro@outlook.com> (cherry picked from commit eef068d1b495c0ea519ed235e5ad07b1e1e51fb0)	1 个月前
KafkaWriter.cpp	fix KafkaWriter coredump	8 天前
KafkaWriter.h	【revert】【fix】修改带来的问题回退	1 个月前
KafkaWriterState.cpp	update with yellow zone	7 个月前
KafkaWriterState.h	update with yellow zone	7 个月前
KafkaWriterStateSerializer.cpp	SQL CP 功能相关 Co-authored-by: TideMacro<TideMacro@outlook.com> (cherry picked from commit eef068d1b495c0ea519ed235e5ad07b1e1e51fb0)	1 个月前
KafkaWriterStateSerializer.h	SQL CP 功能相关 Co-authored-by: TideMacro<TideMacro@outlook.com> (cherry picked from commit eef068d1b495c0ea519ed235e5ad07b1e1e51fb0)	1 个月前
KeyValueByteContainer.h	shuffle conmunication mechanism, smart pointer, bug fixes	3 个月前
ProducerConfig.h	update with yellow zone	7 个月前
Recyclable.cpp	update with yellow zone	7 个月前
Recyclable.h	update with yellow zone	7 个月前
TransactionAborter.cpp	update with yellow zone	7 个月前
TransactionAborter.h	update with yellow zone	7 个月前
TransactionalIdFactory.cpp	update with yellow zone	7 个月前
TransactionalIdFactory.h	update with yellow zone	7 个月前