-
Notifications
You must be signed in to change notification settings - Fork 141
Comparing changes
Open a pull request
base repository: feldera/feldera
base: v0.319.0
head repository: feldera/feldera
compare: v0.320.0
- 7 commits
- 49 files changed
- 4 contributors
Commits on Jul 10, 2026
-
[adapters] Increase wait_for_records timeout in tests.
suspend_barrier5 times out waiting for 4000 input records while suspending in CI. The log seems to indicate that the connector is making progress, just slowly under load. We increase the timeout from 10 to 100s and improve progress logging. If the issue occurs again, this means there's a real bug somewhere. Signed-off-by: Leonid Ryzhyk <ryzhyk@gmail.com>
Configuration menu - View commit details
-
Copy full SHA for 27d31ba - Browse repository at this point
Copy the full SHA 27d31baView commit details -
Lakeflow Declarative Pipelines and Feldera Demo
Added configuration for a Lakeflow declarative pipeline. Users can copy the bronze data to their own bucket, see how Feldera works with snapshot_and_follow mode, and contrast with Databricks IVM solution (lakeflow declarative pipelines) Signed-off-by: Anand Raman <anand.raman@feldera.com>
Configuration menu - View commit details
-
Copy full SHA for b203ac3 - Browse repository at this point
Copy the full SHA b203ac3View commit details -
Configuration menu - View commit details
-
Copy full SHA for 0308242 - Browse repository at this point
Copy the full SHA 0308242View commit details -
[DBSP] Add a 'positive' operator, a variant of 'distinct'
Signed-off-by: Mihai Budiu <mbudiu@feldera.com>
Configuration menu - View commit details
-
Copy full SHA for a7e4fd8 - Browse repository at this point
Copy the full SHA a7e4fd8View commit details
Commits on Jul 11, 2026
-
[adapters] Fix a bug + a race in suspend processing.
This commit fixes a severe bug and a less severe race. The bug: when we fail to make a checkpoint while suspending, we log the error, but still set pipeline status to Suspended, making it look like the Suspend succeeded. There are two options for handling this better: (1) go back to the Running state, giving the user a chance to fix the issue and retry (not sure what they can do if the disk runs out of space though...), (2) stop the pipeline and set state to Failed. Like with any other failure, some progress is lost, but at least we don't mask the error. The race: when the checkpoint succeeded, there was a brief window after the checkpoint completes and before we set phase to Suspended when the pipeline's state was Stopped. This caused tests waiting for the Suspended state to fail, since they don't expect the Stopped status. This flaked the cloud `suspend_and_resume_demos` test: a demo reached `Stopped` carrying `PipelineTerminated` instead of suspending cleanly. Signed-off-by: Leonid Ryzhyk <ryzhyk@gmail.com>
Configuration menu - View commit details
-
Copy full SHA for a5d8d17 - Browse repository at this point
Copy the full SHA a5d8d17View commit details -
[py] Add a python test for a failed suspend operation.
Make sure a failed suspend is reported as a pipeline failure. Signed-off-by: Leonid Ryzhyk <ryzhyk@gmail.com>
Configuration menu - View commit details
-
Copy full SHA for 4733636 - Browse repository at this point
Copy the full SHA 4733636View commit details
Commits on Jul 12, 2026
-
[SQL] Implement INTERSECT/EXCEPT ALL
Signed-off-by: Mihai Budiu <mbudiu@feldera.com>
Configuration menu - View commit details
-
Copy full SHA for 9a66270 - Browse repository at this point
Copy the full SHA 9a66270View commit details
This comparison is taking too long to generate.
Unfortunately it looks like we can’t render this comparison for you right now. It might be too big, or there might be something weird with your repository.
You can try running this command locally to see the comparison on your machine:
git diff v0.319.0...v0.320.0