Skip to content
Permalink

Comparing changes

Choose two branches to see what’s changed or to start a new pull request. If you need to, you can also or learn more about diff comparisons.

Open a pull request

Create a new pull request by comparing changes across two branches. If you need to, you can also . Learn more about diff comparisons here.
base repository: feldera/feldera
Failed to load repositories. Confirm that selected base ref is valid, then try again.
Loading
base: v0.319.0
Choose a base ref
...
head repository: feldera/feldera
Failed to load repositories. Confirm that selected head ref is valid, then try again.
Loading
compare: v0.320.0
Choose a head ref
  • 7 commits
  • 49 files changed
  • 4 contributors

Commits on Jul 10, 2026

  1. [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>
    ryzhyk committed Jul 10, 2026
    Configuration menu
    Copy the full SHA
    27d31ba View commit details
    Browse the repository at this point in the history
  2. 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>
    anandbraman committed Jul 10, 2026
    Configuration menu
    Copy the full SHA
    b203ac3 View commit details
    Browse the repository at this point in the history
  3. Configuration menu
    Copy the full SHA
    0308242 View commit details
    Browse the repository at this point in the history
  4. [DBSP] Add a 'positive' operator, a variant of 'distinct'

    Signed-off-by: Mihai Budiu <mbudiu@feldera.com>
    mihaibudiu committed Jul 10, 2026
    Configuration menu
    Copy the full SHA
    a7e4fd8 View commit details
    Browse the repository at this point in the history

Commits on Jul 11, 2026

  1. [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>
    ryzhyk committed Jul 11, 2026
    Configuration menu
    Copy the full SHA
    a5d8d17 View commit details
    Browse the repository at this point in the history
  2. [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>
    ryzhyk committed Jul 11, 2026
    Configuration menu
    Copy the full SHA
    4733636 View commit details
    Browse the repository at this point in the history

Commits on Jul 12, 2026

  1. [SQL] Implement INTERSECT/EXCEPT ALL

    Signed-off-by: Mihai Budiu <mbudiu@feldera.com>
    mihaibudiu committed Jul 12, 2026
    Configuration menu
    Copy the full SHA
    9a66270 View commit details
    Browse the repository at this point in the history
Loading