Repository navigation
Commit d123e46
refactor: remove Flink/Arroyo/legacy Kafka-ingest infra from asap-tools (#721)
* refactor(rust): remove Flink/Arroyo/legacy-Kafka streaming engine support
Collapses StreamingEngine to a single Precompute variant across
asap-planner-rs and asap-query-engine, removes IngestConfig::Kafka and
the Kafka consumer driver, and rewires OTLP ingest to pair with
streaming_engine=precompute instead of the removed arroyo gate.
Also removes the now-unreachable Arroyo wire-format cluster:
PrecomputedOutput::deserialize_from_json_arroyo, each accumulator's
serialize_to_bytes_arroyo/deserialize_from_bytes_arroyo, the
test_offline_precomputes debug binary, the dump_precomputes config
knob, and the orphaned datafusion_summary_library crate (its only
consumer was the Arroyo/Kafka ingest path).
Part of #709.
Co-Authored-By: Claude Sonnet 5 <noreply@anthropic.com>
Claude-Session: https://claude.ai/code/session_01W3YXZoukBCkyRf7otqs7ow
* refactor(asap-tools): remove Flink/Arroyo/legacy Kafka-ingest infrastructure
Deletes asap-summary-ingest/ (the Arroyo pipeline generator) and all
asap-tools infra that only served Flink/Arroyo/Kafka: the installation
scripts, docker-compose includes, experiment service classes
(KafkaService, FlinkService, ArroyoService, PrometheusKafkaAdapterService,
ArroyoThroughputMonitor, DumbKafkaConsumerService), the standalone
Kafka/producer/benchmark-pipeline execution-utilities, and the
corresponding Hydra config knobs (streaming.engine choices,
use_kafka_ingest, profiling.flink/arroyo, use_container.arroyo,
dump_precomputes, replace_query_engine_with_dumb_consumer).
`precompute` (HTTP remote write into asap-query-engine) is now the only
supported streaming/ingest path.
Also removes other infra that only served the removed pipeline and had
no other caller: asap-tools/installation/kafka/, fake_kafka_exporter/
(a real Kafka producer), the ArroyoThroughputAnalyzer mode in
analyze_throughput.py, the confluent_kafka Python dependency, and the
now-dead asap-summary-ingest pytest job in the Python CI workflow.
Closes #709.
Co-Authored-By: Claude Sonnet 5 <noreply@anthropic.com>
Claude-Session: https://claude.ai/code/session_01W3YXZoukBCkyRf7otqs7ow
* docs: update architecture and how-to guides for Flink/Arroyo/Kafka removal
Rewrites the architecture diagrams and component descriptions in
docs/01-getting-started, docs/02-components, asap-tools/docs, and
asap-query-engine/docs to describe the actual current pipeline
(Prometheus remote write -> QueryEngine precompute engine directly,
no Arroyo/Flink/Kafka hop), and updates the manual-stack-run and
add-new-sketch how-to guides to the current config-file-based
query_engine_rust interface.
Part of #709.
Co-Authored-By: Claude Sonnet 5 <noreply@anthropic.com>
Claude-Session: https://claude.ai/code/session_01W3YXZoukBCkyRf7otqs7ow
---------
Co-authored-by: Claude Sonnet 5 <noreply@anthropic.com>1 parent 9b87c30 commit d123e46
234 files changed
Lines changed: 422 additions & 31759 deletions
File tree
- .github/workflows
- asap-common
- dependencies
- py/promql_utilities/promql_utilities
- query_logics
- streaming_config
- rs/datafusion_summary_library
- src
- physical
- installation
- asap-planner-rs
- src
- tests
- asap-query-engine
- docs
- examples
- src
- bin
- data_model
- drivers
- ingest
- precompute_engine
- precompute_operators
- stores
- tests
- utils
- tests
- asap-quickstart
- config
- asap-summary-ingest
- examples
- configs
- inputs
- json
- sql
- installation
- templates
- hashed_key_udfs
- old
- json
- sql
- udfs
- tests
- utils
- asap-tools
- data-sources/prometheus-exporters
- fake_kafka_exporter
- installation
- src
- installation
- docker
- kafka
- docs
- execution-utilities
- asap_benchmark_pipeline
- asap_query_latency
- clickhouse-benchmark-pipeline
- benchmark_importer
- clickhouse
- data_exporter
- src
- scripts
- high-throughput-kafka-producer-single-threaded
- src
- high-throughput-kafka-producer
- code_for_reference
- src
- kafka-consumer
- src
- kafka_toy_data_generator
- experiments
- config
- experiment_utils
- providers
- services
- post_experiment
- installation
- arroyo
- flink
- kafka
- prometheus_kafka_adapter
- benchmarks/config
- docs
- 01-getting-started
- 02-components
- 03-how-to-guides
- development
- operations
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
8 | 8 | | |
9 | 9 | | |
10 | 10 | | |
11 | | - | |
12 | 11 | | |
13 | 12 | | |
14 | 13 | | |
| |||
19 | 18 | | |
20 | 19 | | |
21 | 20 | | |
22 | | - | |
23 | 21 | | |
24 | 22 | | |
25 | 23 | | |
| |||
41 | 39 | | |
42 | 40 | | |
43 | 41 | | |
44 | | - | |
45 | 42 | | |
46 | 43 | | |
47 | 44 | | |
| |||
60 | 57 | | |
61 | 58 | | |
62 | 59 | | |
63 | | - | |
64 | | - | |
65 | | - | |
66 | 60 | | |
67 | 61 | | |
68 | 62 | | |
| |||
206 | 200 | | |
207 | 201 | | |
208 | 202 | | |
209 | | - | |
210 | | - | |
211 | | - | |
212 | | - | |
213 | | - | |
214 | | - | |
215 | | - | |
216 | | - | |
217 | | - | |
218 | | - | |
219 | | - | |
220 | | - | |
221 | | - | |
222 | | - | |
223 | | - | |
224 | | - | |
225 | | - | |
226 | | - | |
0 commit comments