issues
search
ArroyoSystems
/
arroyo
Distributed stream processing engine in Rust
https://arroyo.dev
Apache License 2.0
3.43k
stars
189
forks
source link
issues
Newest
Newest
Most commented
Recently updated
Oldest
Least commented
Least recently updated
State restoration in pipeline clusters
#668
mwylde
closed
3 days ago
0
Submit programs via RPC instead of env var or files
#667
mwylde
closed
4 days ago
0
Bump and release version 0.1.1 of UDF lib
#666
mwylde
closed
4 days ago
0
Support UDFs on raw_bytes
#665
mwylde
closed
4 days ago
0
Re-add support for joins on structs by rewriting expression
#664
mwylde
closed
1 week ago
0
Redesign create pipeline UX and pipeline outputs for greater density and performance
#663
mwylde
closed
1 week ago
0
Pipeline clusters
#662
mwylde
closed
1 week ago
0
Introduce jitter into initial checkpoints to reduce checkpoint alignment across pipelines on controller restart
#661
mwylde
closed
2 weeks ago
0
Support for avro union types
#660
kvedes
opened
2 weeks ago
2
Migrate arroyo-bin cmd to arroyo and consolidate docker images
#659
mwylde
closed
2 weeks ago
0
Kafka source protobuf format
#658
loicalleyne
opened
2 weeks ago
0
Add additional config options
#657
mwylde
closed
2 weeks ago
0
Add table for kafka exactly-once state
#655
mwylde
closed
2 weeks ago
0
Add option to deploy kubernetes programs as configmaps rather than env vars
#654
mwylde
closed
2 weeks ago
0
Arroyo throws "This feature is not implemented" when attempting to insert data from a CTE
#653
GoldToothRichards
opened
3 weeks ago
2
setting imagePullSecrets for workers
#652
chokosabe
opened
3 weeks ago
1
Arroyo should use a single image in helm
#651
chokosabe
opened
3 weeks ago
1
Fix regression in DATABASE_PORT config
#650
mwylde
closed
3 weeks ago
0
Support per-slot k8s resource management
#649
mwylde
closed
3 weeks ago
0
Fix broken metric graphs when subtask has no data
#648
mwylde
closed
3 weeks ago
0
Add libssl-dev to Dockerfile
#647
benjamin-awd
closed
3 weeks ago
2
Deploy pods directly for k8s instead of replica sets and k8s robustness improvements
#646
mwylde
closed
3 weeks ago
0
Allow to configure worker's IRSA through worker's ServiceAccount annotation
#645
rparme
opened
3 weeks ago
0
Unify sql error handling on datafusion errors to improve error wrapping
#643
mwylde
closed
3 weeks ago
0
[Question] Ready to replace Flink SQL?
#642
zhanglistar
closed
3 weeks ago
1
Register Worker call fails on Kubernetes
#641
chokosabe
opened
4 weeks ago
2
Add new json functions from datafusion-functions-json
#640
mwylde
opened
1 month ago
0
Failed to start test server from cmd, the error is "OS can't spawn worker thread: Operation not permitted (os error 1)"
#639
jiajie999
opened
1 month ago
1
Add a new config system
#638
mwylde
closed
1 month ago
0
Clean up old preview pipelines and filter out non-running pipelines on controller start
#637
mwylde
closed
1 month ago
0
Support dynamically updating the checkpoint interval
#636
mwylde
closed
1 month ago
0
Cascade deletes for sqlite
#635
mwylde
closed
1 month ago
0
Add object store cache for GCS
#634
benjamin-awd
closed
1 month ago
1
Suppress NATS heartbeat error
#633
benjamin-awd
closed
4 weeks ago
0
Runtime failure when using `source.offset` as `group` when starting a job for the first time
#632
prakkashm
opened
1 month ago
2
Feature request: Kafka record timestamp column in Kafka Source Connector
#631
Wrekkers
opened
1 month ago
0
Support metrics for web UI natively instead of using prometheus
#630
mwylde
closed
1 month ago
0
Change checkpoint interval dynamically
#629
benjaminawd-flowdesk
closed
1 month ago
1
ignore tests with deps
#628
mxfactorial
opened
1 month ago
2
state machine not started error
#627
mxfactorial
opened
1 month ago
0
Add Sqlite support for the control plane
#626
mwylde
closed
1 month ago
0
Add raw_binary format
#625
mwylde
closed
1 month ago
0
Better error messages when a service fails to bind
#624
mwylde
closed
1 month ago
0
Update to arrow 51 and Datafusion 37.1
#623
mwylde
closed
1 month ago
0
Run apt-get update before trying to install clang
#622
mwylde
closed
1 month ago
0
API throttle when using GCS as checkpoint backend
#621
gbto
closed
1 month ago
0
Add integration tests for most API endpoints
#620
mwylde
closed
1 month ago
0
flush kafka on close
#619
jacksonrnewhouse
closed
1 month ago
0
pkg-config issue is still there in 0.10.1
#618
chokosabe
closed
1 month ago
1
Report error message in helm when required configs are not set
#617
FourSpaces
closed
1 month ago
2
Next