GitHub / feldera/feldera / commits
| SHA | Message | Author | Date | Stats |
|---|---|---|---|---|
| d8951cab |
[DEMO] Name connectors in demos
Signed-off-by: Mihai Budiu <m****u@f****m> |
Mihai Budiu <m****u@f****m>
Committed by: Mihai Budiu <m****u@g****m> |
13 days ago | |
| b4bf119a |
[profiler] Search in profiler matches on table/view names (or substrings)
Signed-off-by: Mihai Budiu <m****u@f****m> |
Mihai Budiu <m****u@f****m>
Committed by: Mihai Budiu <m****u@g****m> |
13 days ago | |
| d792b60d |
dbsp: keep the compaction test below the level-0 merge trigger
Signed-off-by: Leonid Ryzhyk <r****k@g****m> |
Leonid Ryzhyk <r****k@g****m> | 13 days ago | |
| 9ba9b288 |
delta: name the column and file in follow-read conversion errors
Signed-off-by: Swanand Mulay <7****x@u****m> |
Swanand Mulay <7****x@u****m> | 13 days ago | |
| 59a73ea4 |
[DOC] Fixes to SQL documentation following audit
Signed-off-by: Mihai Budiu <m****u@f****m> |
Mihai Budiu <m****u@f****m>
Committed by: Mihai Budiu <m****u@g****m> |
14 days ago | |
| f69fdb2d |
[DBSP] Fix incorrect hashing in UpsertHandle
Signed-off-by: Mihai Budiu <m****u@f****m> |
Mihai Budiu <m****u@f****m>
Committed by: Mihai Budiu <m****u@g****m> |
14 days ago | |
| 2b5fb550 |
tests: fix datafusion_memory_mb wiring and parameterize on workers/hosts
Signed-off-by: Ben Pfaff <b****p@f****m> |
Ben Pfaff <b****p@f****m> | 14 days ago | |
| d771f840 |
[tests] Fix racy barrier in Iceberg snapshot tests
Signed-off-by: Leonid Ryzhyk <r****k@g****m> |
Leonid Ryzhyk <r****k@g****m> | 14 days ago | |
| a58d26c8 |
[dbsp] Avoid race updating checkpoint catalog file.
Signed-off-by: Ben Pfaff <b****p@f****m> |
Ben Pfaff <b****p@f****m> | 14 days ago | |
| 55f528a7 | ci: Prepare for v0.326.0 | release-feldera-feldera[bot] <r****]@u****m> | 14 days ago | |
| a47b6ee2 |
[web-console] Fix content in CHange Stream tab resets when opening Interacti...
Signed-off-by: Karakatiza666 <b****6@g****m> |
Karakatiza666 <b****6@g****m> | 14 days ago | |
| 2cabf573 |
delta: null-fill missing struct child in field-id realign
Signed-off-by: Swanand Mulay <7****x@u****m> |
Swanand Mulay <7****x@u****m> | 14 days ago | |
| b67a5895 |
delta: harden field-id realign to coerce container types
Signed-off-by: Swanand Mulay <7****x@u****m> |
Swanand Mulay <7****x@u****m> | 15 days ago | |
| f191aa2a |
delta: resolve follow-read columns by Parquet field id
Signed-off-by: Swanand Mulay <7****x@u****m> |
Swanand Mulay <7****x@u****m> | 15 days ago | |
| ed9f4299 |
connector: read uc:// follow files via object store, not ListingTable
Signed-off-by: Swanand Mulay <7****x@u****m> |
Swanand Mulay <7****x@u****m> | 15 days ago | |
| 41d63d31 |
adapters: report which connector stalled a completion token in tests
Signed-off-by: Leonid Ryzhyk <r****k@g****m> |
Leonid Ryzhyk <r****k@g****m> | 15 days ago | |
| de65d1c0 |
adapters: republish completion counters when an output endpoint goes away
Signed-off-by: Leonid Ryzhyk <r****k@g****m> |
Leonid Ryzhyk <r****k@g****m> | 15 days ago | |
| 026dedd6 |
connectors: resolve nested column-mapped fields in follow/CDC reads
Signed-off-by: Swanand Mulay <7****x@u****m> |
Swanand Mulay <7****x@u****m> | 15 days ago | |
| 95217705 | [adapters] Fix the tick-accounting race in test_clock | Leonid Ryzhyk <r****k@g****m> | 15 days ago | |
| e8f19886 |
[ci] apply automatic fixes
Signed-off-by: feldera-bot <f****t@f****m> |
feldera-bot <f****t@f****m>
Committed by: Leonid Ryzhyk <r****k@g****m> |
15 days ago | |
| 2e5a544c |
[python] Wait for listener records instead of guessing at timing
Signed-off-by: Leonid Ryzhyk <r****k@g****m> |
Leonid Ryzhyk <r****k@g****m> | 15 days ago | |
| 0934f31c |
[python] Read the UDF view with an ad-hoc query, not a listener
Signed-off-by: Leonid Ryzhyk <r****k@g****m> |
Leonid Ryzhyk <r****k@g****m> | 15 days ago | |
| 103d7310 |
[ci] apply automatic fixes
Signed-off-by: feldera-bot <f****t@f****m> |
feldera-bot <f****t@f****m>
Committed by: Leonid Ryzhyk <r****k@g****m> |
15 days ago | |
| bbcfb7e9 |
[qa] drop the redundant transmitted-record waits in the bootstrap tests
Signed-off-by: Leonid Ryzhyk <r****k@g****m> |
Leonid Ryzhyk <r****k@g****m> | 16 days ago | |
| b5e5fc08 |
adapters: seed output progress only for caught-up endpoints
Signed-off-by: Leonid Ryzhyk <r****k@g****m> |
Leonid Ryzhyk <r****k@g****m> | 16 days ago | |
| 0d3441cd |
connectors: delta fix uc:// follow reads (No suitable object store found)
Signed-off-by: Swanand Mulay <7****x@u****m> |
Swanand Mulay <7****x@u****m> | 16 days ago | |
| 7ba15518 |
[adapters] Stop the circuit when its initialization result is refused
Signed-off-by: Leonid Ryzhyk <r****k@g****m> |
Leonid Ryzhyk <r****k@g****m> | 16 days ago | |
| 03e81ae0 |
[adapters] Report a lost command reply instead of panicking
Signed-off-by: Leonid Ryzhyk <r****k@g****m> |
Leonid Ryzhyk <r****k@g****m> | 16 days ago | |
| 54e75190 |
use v0.32.3-feldera-unity-fix branch
Signed-off-by: Swanand Mulay <7****x@u****m> |
Swanand Mulay <7****x@u****m> | 16 days ago | |
| fb71ee94 |
[adapters] Report a suspend as complete only once it has completed
Signed-off-by: Leonid Ryzhyk <r****k@g****m> |
Leonid Ryzhyk <r****k@g****m> | 16 days ago | |
| a75eb981 |
[adapters] Guard the controller and the phase with one lock
Signed-off-by: Leonid Ryzhyk <r****k@g****m> |
Leonid Ryzhyk <r****k@g****m> | 16 days ago | |
| 9d5655c8 |
ci: wait for transmitted records in the bootstrap tests
Signed-off-by: Gerd Zellweger <m****l@g****m> |
Gerd Zellweger <m****l@g****m> | 16 days ago | |
| 3126fe7d |
ci: delete test_events_retained
Signed-off-by: Gerd Zellweger <m****l@g****m> |
Gerd Zellweger <m****l@g****m> | 16 days ago | |
| 8c001a85 |
ci: shorten test names near the pipeline name length limit
Signed-off-by: Gerd Zellweger <m****l@g****m> |
Gerd Zellweger <m****l@g****m> | 16 days ago | |
| c7e29a16 |
ci: distinguish concurrent test suites in pipeline names
Signed-off-by: Gerd Zellweger <m****l@g****m> |
Gerd Zellweger <m****l@g****m> | 16 days ago | |
| cb768f2b |
[adapters] Report fatal errors that race the end of initialization
Signed-off-by: Leonid Ryzhyk <r****k@g****m> |
Leonid Ryzhyk <r****k@g****m> | 17 days ago | |
| d6572176 |
[nexmark] Fix harness race that aborts the benchmark near the last batch
Signed-off-by: Leonid Ryzhyk <l****d@f****m> |
Leonid Ryzhyk <l****d@f****m>
Committed by: Leonid Ryzhyk <r****k@g****m> |
17 days ago | |
| 5fdcb43d |
ci: retry the checkpoint-sync visibility check
Signed-off-by: Gerd Zellweger <m****l@g****m> |
Gerd Zellweger <m****l@g****m> | 17 days ago | |
| 40352c5f |
ci: relax platform test timeouts for fresh k8s installs
Signed-off-by: Gerd Zellweger <m****l@g****m> |
Gerd Zellweger <m****l@g****m> | 17 days ago | |
| ddc753b5 |
ci: request 3 GiB for every aggtest pipeline
Signed-off-by: Gerd Zellweger <m****l@g****m> |
Gerd Zellweger <m****l@g****m> | 17 days ago | |
| 40439e52 |
ci: give the constant-table pipeline honest memory bounds
Signed-off-by: Gerd Zellweger <m****l@g****m> |
Gerd Zellweger <m****l@g****m> | 17 days ago | |
| 2499efeb |
[adapters] Fix subscribe-at-latest race in fault-tolerant Kafka input
Signed-off-by: Leonid Ryzhyk <r****k@g****m> |
Leonid Ryzhyk <r****k@g****m> | 17 days ago | |
| cd84e54c |
ci: read the GKE instance hosts from FELDERA_HOST_CI_GKE_* org variables
Signed-off-by: Gerd Zellweger <m****l@g****m> |
Gerd Zellweger <m****l@g****m>
Committed by: Gerd Zellweger <g****z@f****m> |
18 days ago | |
| e46c696b |
ci: raise now-test memory request to 6 GB
Signed-off-by: Gerd Zellweger <m****l@g****m> |
Gerd Zellweger <m****l@g****m>
Committed by: Gerd Zellweger <g****z@f****m> |
18 days ago | |
| 3a1c801a |
ci: ignore the remaining kafka offset-latest tests
Signed-off-by: Gerd Zellweger <m****l@g****m> |
Gerd Zellweger <m****l@g****m>
Committed by: Gerd Zellweger <g****z@f****m> |
18 days ago | |
| 4d3e7724 |
Ensure only one connection serves each multihost exchange sender
Signed-off-by: Ben Pfaff <b****p@f****m> |
Ben Pfaff <b****p@f****m> | 18 days ago | |
| 1271243b |
ci: raise provisioning timeout to 180s and drop workload memory limits
Signed-off-by: Gerd Zellweger <m****l@g****m> |
Gerd Zellweger <m****l@g****m>
Committed by: Gerd Zellweger <g****z@f****m> |
18 days ago | |
| ecb29802 |
ci: give the aggregate-join pipeline honest memory bounds
Signed-off-by: Gerd Zellweger <m****l@g****m> |
Gerd Zellweger <m****l@g****m>
Committed by: Gerd Zellweger <g****z@f****m> |
18 days ago | |
| 8c3b2022 |
ci: give the now-test pipeline honest memory bounds
Signed-off-by: Gerd Zellweger <m****l@g****m> |
Gerd Zellweger <m****l@g****m>
Committed by: Gerd Zellweger <g****z@f****m> |
18 days ago | |
| 7968f735 |
ci: ignore two flaky tests
Signed-off-by: Gerd Zellweger <m****l@g****m> |
Gerd Zellweger <m****l@g****m>
Committed by: Gerd Zellweger <g****z@f****m> |
18 days ago | |
| 8a650a19 |
ci: fix checkpoint cache probe path and self-heal partial syncs
Signed-off-by: Gerd Zellweger <m****l@g****m> |
Gerd Zellweger <m****l@g****m>
Committed by: Gerd Zellweger <g****z@f****m> |
18 days ago | |
| 5ed03e7d |
ci: address the OSS pipeline-manager service by name
Signed-off-by: Gerd Zellweger <m****l@g****m> |
Gerd Zellweger <m****l@g****m>
Committed by: Gerd Zellweger <g****z@f****m> |
18 days ago | |
| a08d6360 | test(sql): add integer temporal filter boundary type probe |
ShengHuang <h****x@1****m>
Committed by: Mihai Budiu <m****u@g****m> |
18 days ago | |
| c23cb08a |
ci: fix GCS S3-interop auth and checksums in integration tests
Signed-off-by: Gerd Zellweger <m****l@g****m> |
Gerd Zellweger <m****l@g****m>
Committed by: Gerd Zellweger <g****z@f****m> |
18 days ago | |
| 95dcfe8c |
[adapters] NATS: fix replay disruption test races
Signed-off-by: Gerd Zellweger <m****l@g****m> |
Gerd Zellweger <m****l@g****m>
Committed by: Gerd Zellweger <g****z@f****m> |
18 days ago | |
| e29d17a5 |
ci: start redpanda with a reachable advertised address
Signed-off-by: Gerd Zellweger <m****l@g****m> |
Gerd Zellweger <m****l@g****m>
Committed by: Gerd Zellweger <g****z@f****m> |
18 days ago | |
| e04bc500 |
ci: scope the GCS HMAC env to the build-jar job
Signed-off-by: Gerd Zellweger <m****l@g****m> |
Gerd Zellweger <m****l@g****m>
Committed by: Gerd Zellweger <g****z@f****m> |
18 days ago | |
| 9da8806e |
ci: address adapter-test sidecars by service name
Signed-off-by: Gerd Zellweger <m****l@g****m> |
Gerd Zellweger <m****l@g****m>
Committed by: Gerd Zellweger <g****z@f****m> |
18 days ago | |
| 3e1b02f5 |
ci: bump configure-aws-credentials to v6.2.3
Signed-off-by: Gerd Zellweger <m****l@g****m> |
Gerd Zellweger <m****l@g****m>
Committed by: Gerd Zellweger <g****z@f****m> |
18 days ago | |
| 812fef09 |
ci: pin cargo cache paths to CARGO_HOME
Signed-off-by: Gerd Zellweger <m****l@g****m> |
Gerd Zellweger <m****l@g****m>
Committed by: Gerd Zellweger <g****z@f****m> |
18 days ago | |
| 502f49bb |
ci: use the GKE instance API keys, drop the node echo steps
Signed-off-by: Gerd Zellweger <m****l@g****m> |
Gerd Zellweger <m****l@g****m>
Committed by: Gerd Zellweger <g****z@f****m> |
18 days ago | |
| dac7ffef |
ci: run against the GKE CI cluster
Signed-off-by: Gerd Zellweger <m****l@g****m> |
Gerd Zellweger <m****l@g****m>
Committed by: Gerd Zellweger <g****z@f****m> |
18 days ago | |
| e8fd54bf |
[CI] Stop at first failed integration test
Signed-off-by: Mihai Budiu <m****u@f****m> |
Mihai Budiu <m****u@f****m>
Committed by: Mihai Budiu <m****u@g****m> |
18 days ago | |
| 26dc5c35 | ci: abort stalled artifact downloads instead of hanging indefinitely |
Jyotshna Yaparla <j****a@f****m>
Committed by: Mihai Budiu <m****u@g****m> |
19 days ago | |
| 18ece850 | [SQL] Fix DATE temporal window boundary types |
ShengHuang <h****x@1****m>
Committed by: Mihai Budiu <m****u@g****m> |
19 days ago | |
| 6c37ab1b |
[adapters] Increase is_replaying wait to 10s in ft controller test.
Signed-off-by: Leonid Ryzhyk <r****k@g****m> |
Leonid Ryzhyk <r****k@g****m>
Committed by: Mihai Budiu <m****u@g****m> |
19 days ago | |
| 8b877a11 | adapters: serialize Avro ubigint as string |
Song Huang <x****h@g****m>
Committed by: Mihai Budiu <m****u@g****m> |
19 days ago | |
| c5a09735 | adapters: serialize Avro timestamptz as micros |
Song Huang <x****h@g****m>
Committed by: Leonid Ryzhyk <r****k@g****m> |
19 days ago | |
| 2247824d | adapters: validate Avro map key type |
Song Huang <x****h@g****m>
Committed by: Mihai Budiu <m****u@g****m> |
19 days ago | |
| 1a379266 |
[CI] Make artifact download script robust to failures
Signed-off-by: Mihai Budiu <m****u@f****m> |
Mihai Budiu <m****u@f****m>
Committed by: Mihai Budiu <m****u@g****m> |
19 days ago | |
| bdc5459c | ci: Prepare for v0.325.0 | release-feldera-feldera[bot] <r****]@u****m> | 20 days ago | |
| 302345bb |
[dbsp] Count steps and track latency for all transactions.
Signed-off-by: Ben Pfaff <b****p@f****m> |
Ben Pfaff <b****p@f****m>
Committed by: Mihai Budiu <m****u@g****m> |
20 days ago | |
| 06a62b78 |
[pipeline-manager] Fix ad-hoc not working in Chromium-based browsers by confi...
Signed-off-by: Karakatiza666 <b****6@g****m> |
Karakatiza666 <b****6@g****m> | 20 days ago | |
| c93f80af |
Disable json_bench test
Signed-off-by: Mihai Budiu <m****u@f****m> |
Mihai Budiu <m****u@f****m>
Committed by: Mihai Budiu <m****u@g****m> |
20 days ago | |
| 4496a750 |
[SQL] Remove unneeded http5 dependencies from maven file pom.xml
Signed-off-by: Mihai Budiu <m****u@f****m> |
Mihai Budiu <m****u@f****m>
Committed by: Mihai Budiu <m****u@g****m> |
20 days ago | |
| 37087e2c | kafka: ignore tombstone payloads |
Song Huang <x****h@g****m>
Committed by: Ben Pfaff <b****p@f****m> |
20 days ago | |
| 08b5e059 |
[CI] Do not fail test test_upgrade_from_local_checkpoint if Rust cannot be bu...
Signed-off-by: Mihai Budiu <m****u@f****m> |
Mihai Budiu <m****u@f****m>
Committed by: Mihai Budiu <m****u@g****m> |
20 days ago | |
| 41948830 |
[adapters] Omit storage status from `/coordination/status` output.
Signed-off-by: Ben Pfaff <b****p@f****m> |
Ben Pfaff <b****p@f****m> | 20 days ago | |
| 92b29a43 |
[dbsp] Avoid repeatedly listing files in storage with no checkpoints.
Signed-off-by: Ben Pfaff <b****p@f****m> |
Ben Pfaff <b****p@f****m> | 20 days ago | |
| c015c224 |
[adapters] Make `/stats` query parameters public.
Signed-off-by: Ben Pfaff <b****p@f****m> |
Ben Pfaff <b****p@f****m>
Committed by: Swanand Mulay <7****x@u****m> |
21 days ago | |
| 50fb21b7 |
connector: postgres sink respect column DEFAULTs for omitted columns
Signed-off-by: Swanand Mulay <7****x@u****m> |
Swanand Mulay <7****x@u****m>
Committed by: Leonid Ryzhyk <r****k@g****m> |
21 days ago | |
| 9ca0a3c7 | Continue Avro schema validation after missing nullable fields |
Song Huang <x****h@g****m>
Committed by: Mihai Budiu <m****u@g****m> |
21 days ago | |
| 86fed099 | Fix coercion of ignored Avro fields |
Song Huang <x****h@g****m>
Committed by: Mihai Budiu <m****u@g****m> |
21 days ago | |
| 4e756351 |
[connectors] retry Iceberg table opens
Signed-off-by: Swanand Mulay <7****x@u****m> |
Swanand Mulay <7****x@u****m> | 21 days ago | |
| 4bc4a35f |
[dbsp] Improve logging for remote connections on exchange.
Signed-off-by: Ben Pfaff <b****p@f****m> |
Ben Pfaff <b****p@f****m> | 21 days ago | |
| 7a3bb19e |
[web-console] Add tracking for 'conversion' events via posthog and conceptualhq
Signed-off-by: Karakatiza666 <b****6@g****m> |
Karakatiza666 <b****6@g****m> | 21 days ago | |
| 625fc861 |
[web-console] Add ProductFruits and ConceptualHQ hooks
Signed-off-by: Karakatiza666 <b****6@g****m> |
Karakatiza666 <b****6@g****m> | 21 days ago | |
| 8a81fa7a |
[connectors] broaden Iceberg input type-coverage tests
Signed-off-by: Swanand Mulay <7****x@u****m> |
Swanand Mulay <7****x@u****m> | 21 days ago | |
| 79b56b76 |
adapters: fix argument in tests
Signed-off-by: Swanand Mulay <7****x@u****m> |
Swanand Mulay <7****x@u****m> | 21 days ago | |
| 30e6c25a |
[connectors] read UUID columns from Iceberg input
Signed-off-by: Swanand Mulay <7****x@u****m> |
Swanand Mulay <7****x@u****m> | 21 days ago | |
| be8399ba |
[connectors] at-least-once fault tolerance for Iceberg input
Signed-off-by: Swanand Mulay <7****x@u****m> |
Swanand Mulay <7****x@u****m> | 21 days ago | |
| abae5de5 |
[connectors] Python integration tests for Iceberg input
Signed-off-by: Swanand Mulay <7****x@u****m> |
Swanand Mulay <7****x@u****m> | 21 days ago | |
| 2195333b |
[SQL] GC of tables with keys and LATENESS should never use retain_values, but...
Signed-off-by: Mihai Budiu <m****u@f****m> |
Mihai Budiu <m****u@f****m>
Committed by: Mihai Budiu <m****u@g****m> |
21 days ago | |
| 1f9913b8 |
Bump the npm_and_yarn group across 1 directory with 3 updates
Signed-off-by: dependabot[bot] <s****t@g****m> |
dependabot[bot] <4****]@u****m>
Committed by: Karakatiza666 <b****6@g****m> |
21 days ago | |
| 86763e0b |
[adapters] Refresh ad-hoc snapshot before ending fault-tolerant replay
Signed-off-by: Leonid Ryzhyk <r****k@g****m> |
Leonid Ryzhyk <r****k@g****m> | 22 days ago | |
| 11d7501e |
[docs] Document that Kafka thread count is capped at the partition count.
Signed-off-by: Ben Pfaff <b****p@f****m> |
Ben Pfaff <b****p@f****m>
Committed by: Gerd Zellweger <m****l@g****m> |
22 days ago | |
| 696091b2 |
tests: fix checkpoint sync test regex
Signed-off-by: Swanand Mulay <7****x@u****m> |
Swanand Mulay <7****x@u****m> | 22 days ago | |
| 7c6bc264 |
[web-console] Keep showing the pipeline metrics while the pipeline is stopping
Signed-off-by: Karakatiza666 <b****6@g****m> |
Karakatiza666 <b****6@g****m> | 22 days ago | |
| b384c858 |
[SQL] JSON_* and VARIANT_* functions for filtering and transformations
Signed-off-by: Mihai Budiu <m****u@f****m> |
Mihai Budiu <m****u@f****m>
Committed by: Mihai Budiu <m****u@g****m> |
22 days ago | |
| 0efeb9e0 |
sqllib, sql-to-dbsp: apply FlatVariant review suggestions
Signed-off-by: Gerd Zellweger <m****l@g****m> |
Gerd Zellweger <m****l@g****m> | 22 days ago |