issues
search
Kristina-Pianykh
/
flink-multinode
Other
0
stars
0
forks
source link
issues
Newest
Newest
Most commented
Recently updated
Oldest
Least commented
Least recently updated
[chore]: add node ID to the plot title
#36
Kristina-Pianykh
closed
4 days ago
1
[chore]: parse inequality_inputs.json for plotting
#35
Kristina-Pianykh
closed
4 days ago
1
[feat]: automatize testing pipeline
#34
Kristina-Pianykh
closed
6 days ago
1
chore(monitor): pass arg to control adaptive strategy
#33
Kristina-Pianykh
closed
1 week ago
0
[feat]: pass a handle as input arg to manipulate adaptive strategy
#32
Kristina-Pianykh
closed
1 week ago
0
fix: event plotting
#31
Kristina-Pianykh
closed
1 week ago
0
feat: write monitoring data periodically; improve logging
#30
Kristina-Pianykh
closed
1 week ago
0
chore: stop matching multi-sink q on non-fallback nodes after switch
#29
Kristina-Pianykh
closed
2 weeks ago
0
[test]: create a test suite
#28
Kristina-Pianykh
closed
2 weeks ago
0
[chore]: set up logging for monitoring component
#27
Kristina-Pianykh
closed
1 week ago
2
feat: deduplicate output stream
#26
Kristina-Pianykh
closed
2 weeks ago
0
feat/refactor: restrospective matching 2x window size; ingest control events into data streams
#25
Kristina-Pianykh
closed
2 weeks ago
0
[chore] synchronize the timer for watermarking
#24
Kristina-Pianykh
opened
2 weeks ago
0
[chore]: synchronize concurrent blocks
#23
piankris
opened
2 weeks ago
0
fix: chain queries if on the same node
#22
Kristina-Pianykh
closed
2 weeks ago
0
[fix]: re-feed matches to a higher-level query if it uses another query on the same node as input
#21
Kristina-Pianykh
closed
2 weeks ago
1
[fix]: forwarding rules for the one-time buffer flush?
#20
Kristina-Pianykh
closed
2 weeks ago
1
feat: disable matching for multi-sink q on shift
#19
Kristina-Pianykh
closed
3 weeks ago
0
feat(coordinator): compute broadcast shift timestamp
#18
Kristina-Pianykh
closed
3 weeks ago
0
Executor
#17
Kristina-Pianykh
closed
3 weeks ago
1
[refactor]: wrap nullable types into `Optional`
#16
Kristina-Pianykh
opened
4 weeks ago
1
[fallback node]: create a second input stream with 2x window size for multisink query only
#15
Kristina-Pianykh
closed
2 weeks ago
0
[nonFallback nodes]: buffer partitioning events on drift detection
#14
Kristina-Pianykh
closed
3 weeks ago
1
[coordinator]: compute and broadcast shiftTimestamp
#13
Kristina-Pianykh
closed
3 weeks ago
0
feat: load and parse updated fwd tables
#12
Kristina-Pianykh
closed
1 month ago
0
[chore]: clean up module poms, let parents pom pass down the config
#11
Kristina-Pianykh
opened
1 month ago
0
[refucktor] modularize maven project
#10
Kristina-Pianykh
closed
1 month ago
1
refucktor: modularize maven project
#9
Kristina-Pianykh
closed
1 month ago
0
chore: adhoc monitoring
#8
Kristina-Pianykh
closed
1 month ago
1
Monitoring
#7
Kristina-Pianykh
closed
1 month ago
0
[fix]: Error handling
#6
Kristina-Pianykh
opened
2 months ago
0
[feat]: implement monitoring for each (multi-sink) node
#5
Kristina-Pianykh
closed
2 months ago
3
[feat]: update the forwarding rules of each node for a switch
#4
Kristina-Pianykh
closed
1 month ago
0
[feat]: set static flag to inject into incoming Events to control which pattern to apply
#3
Kristina-Pianykh
closed
3 weeks ago
1
[fix]: Deduplicate output stream when merged with input stream
#2
Kristina-Pianykh
closed
2 weeks ago
0
[chore]: update flink version
#1
Kristina-Pianykh
opened
3 months ago
0