Tags: feldera/feldera
Tags
[adapters]: parallel delta output encoder Use SplitCursor to split the batch and distribute it across tasks, each task retries encoding and writing to delta lake and then returns Add actions which main task retries to commit to delta lake Signed-off-by: Swanand Mulay <[email protected]>
[dbsp] Fix recently introduced bug in pairs seralizer. Commit 99cbbbc ("[dbsp] Optimize how we cache rkyv serialization data structures.") dropped the code that adds offsets to the offsets array in PairsSerializer. This broke multihost pipelines. This fixes the problem. Thanks to Swanand Mulay for reporting the issue. Signed-off-by: Ben Pfaff <[email protected]>
build: quiet on warnings In docker builds we often execute build scripts without a proper .git folder present. In this case the vergen Emitter emits a warning through cargo. This is confusing for users. This make sure the warning disappears. Our code already handles the cases where these env variables are not set. Signed-off-by: Gerd Zellweger <[email protected]>
PreviousNext