master

TTideMacrokafka stop sp 数据重复问题

8f1986a2创建于 6 天前历史提交

文件	最后提交记录	最后更新时间
co	SQL CP SST 全量上传（其他算子补充 notifyCheckpointComplete、notifyCheckpointAborted）	1 个月前
sink	fix 安全扫描问题	17 天前
source	[fix] Fix the issue where Kafka source emit wrong watermark.	13 天前
util	检视意见修改	1 个月前
AbstractStreamOperator.h	NexmarkSourceFunction support CP&SP	28 天前
AbstractUdfStreamOperator.h	NexmarkSourceFunction support CP&SP	28 天前
BackendRestorerProcedure.cpp	update with yellow zone	7 个月前
BackendRestorerProcedure.h	update with yellow zone	7 个月前
ChainingStrategy.h	update with yellow zone	7 个月前
CountingOutput.cpp	update with yellow zone	7 个月前
CountingOutput.h	update with yellow zone	7 个月前
Input.h	update with yellow zone	7 个月前
InputSelection.h	update with yellow zone	7 个月前
InternalTimer.h	[fix] AggregateWindowOperator supports tumble window and hop window.	1 个月前
KeyContext.h	update with yellow zone	7 个月前
KeyedProcessOperator.h	补充 notifyCheckpointAborted	1 个月前
OneInputStreamOperator.h	update with yellow zone	7 个月前
OperatorSnapshotFinalizer.h	检视意见修改	1 个月前
OperatorSnapshotFutures.h	fix 安全扫描问题	17 天前
Output.h	update with yellow zone	7 个月前
ProcessOperator.h	Merge branch 'master' into fix_aggregate_window # Conflicts: # cpp/table/runtime/operators/window/AggregateWindowOperator.cpp	1 个月前
SourceOperator.cpp	update with yellow zone	7 个月前
SourceOperator.h	kafka stop sp 数据重复问题	6 天前
StreamCalc.cpp	support TIMESTAMP_WITH_LOCAL_TIME_ZONE(3) type	2 个月前
StreamCalc.h	update with yellow zone	7 个月前
StreamCalcBatch.cpp	fix expand sql	24 天前
StreamCalcBatch.h	update with yellow zone	7 个月前
StreamExpand.cpp	split watermark	24 天前
StreamExpand.h	fix expand sql	24 天前
StreamFilter.cpp	update with yellow zone	7 个月前
StreamFilter.h	shuffle conmunication mechanism, smart pointer, bug fixes	3 个月前
StreamFlatMap.cpp	update with yellow zone	7 个月前
StreamFlatMap.h	shuffle conmunication mechanism, smart pointer, bug fixes	3 个月前
StreamGroupedReduceOperator.h	-log	19 天前
StreamMap.cpp	update with yellow zone	7 个月前
StreamMap.h	-log	19 天前
StreamOperator.h	kafka stop sp 数据重复问题	6 天前
StreamOperatorFactory.cpp	Merge remote-tracking branch 'origin' into new	18 天前
StreamOperatorFactory.h	!259 [fix] Fix the issue of occasional coredump in SQL, when Kafka source operator advances watermark. From: @Ruiboss Reviewed-by: @yiding-wu See merge request: openeuler/OmniStream!259	1 个月前
StreamOperatorStateContext.h	update with yellow zone	7 个月前
StreamOperatorStateHandler.h	fix 安全扫描问题	17 天前
StreamSource.h	[fix] Fix the issue where first checkpoint gets stuck when Nexmark source is used.	22 天前
StreamTaskStateInitializerImpl.cpp	update with yellow zone	7 个月前
StreamTaskStateInitializerImpl.h	-log	19 天前
StreamingRuntimeContext.h	update with yellow zone	7 个月前
TimerHeapInternalTimer.h	add trait to aviod using keyselector	1 个月前
TimestampedCollector.cpp	update with yellow zone	7 个月前
TimestampedCollector.h	update with yellow zone	7 个月前
Triggerable.h	update with yellow zone	7 个月前
TwoInputStreamOperator.h	update with yellow zone	7 个月前
ValueCollector.h	update with yellow zone	7 个月前
operatorconstants.h	update with yellow zone	7 个月前