| solve the core dump problem in expand kafka cases | 3 个月前 |
| solve the core dump problem in expand kafka cases | 3 个月前 |
| update with yellow zone | 7 个月前 |
| update with yellow zone | 7 个月前 |
| [fix] Fix the cleanup logic of OmniStreamTask. | 29 天前 |
| [fix] Fix the cleanup logic of OmniStreamTask. | 29 天前 |
| Revert "fix bug: kafka source fail to cancel" This reverts commit 08d0073e238c1a6367343fb1aceb689742acdd70. | 1 个月前 |
| shuffle conmunication mechanism, smart pointer, bug fixes | 4 个月前 |
| fix(OmniSourceStreamTask): route EndDate event through mailbox to preserve ordering in multiprocessing | 5 天前 |
| [fix] Fix the issue where first checkpoint gets stuck when Nexmark source is used. | 24 天前 |
| kafka stop sp 数据重复问题 | 8 天前 |
| kafka stop sp 数据重复问题 | 8 天前 |
| Merge branch 'master' into fix_oom # Conflicts: # cpp/streaming/runtime/io/OmniAbstractStreamTaskNetworkInput.h # cpp/streaming/runtime/tasks/omni/OmniTwoInputStreamTask.cpp | 3 个月前 |
| rescal recover | 3 个月前 |
