 RockyJin
|
57e2f93f76
fix: The fix for #409, user can disable the cache
|
4 vuotta sitten |
 ngjaying
|
bc22dd11ef
fix(sink): sink cache error recovery (#410)
|
4 vuotta sitten |
|
ngjaying
|
f4e3436dfe
feat(rule): remove checkpoint and sink cache when dropping a rule
|
4 vuotta sitten |
|
ngjaying
|
3aed002017
feat(checkpoint): sink cache align with check point
|
4 vuotta sitten |
|
ngjaying
|
7a26bf9675
test(checkpoint): refactor test
|
4 vuotta sitten |
|
ngjaying
|
2894141c7f
refactor(checkpoint): do not add internal api to StreamContext
|
4 vuotta sitten |
|
ngjaying
|
5165eb99bf
refactor(util): get data loc return the test location for testing
|
4 vuotta sitten |
|
ngjaying
|
34c92c469a
feat(checkpoint): implement state store
|
4 vuotta sitten |
|
RockyJin
|
a3f5cf0b6a
feat(sink):merge code from master
|
4 vuotta sitten |
|
ngjaying
|
49effbfbd4
bug(stream): fix sink infinite resend after rule stopped problem (#278)
|
4 vuotta sitten |
|
ngjaying
|
cc9e78e1b4
sink cache problems (#108)
|
5 vuotta sitten |
|
ngjaying
|
80d8af9846
refactor(tests): use new mock clock for window testing
|
5 vuotta sitten |
|
ngjaying
|
1674c039b2
refactor(all): format by go fmt
|
5 vuotta sitten |
|
ngjaying
|
cce67f11e0
bug(test): fix processor test after adding sink cache
|
5 vuotta sitten |
|
ngjaying
|
e4f7c1c3e7
feat(stream): sink cache save/load
|
5 vuotta sitten |
|
ngjaying
|
7ffdeb046d
feat(stream): add cache for sink
|
5 vuotta sitten |
