Side outputs from sinks

with is to implement the sink functionality inside a ProcessFunction or just call the sink.invoke() method from inside a process function but we hope there is a better/cleaner way to do it. We are working with the DataStream API in java. Thanks in advance, Aian -- ----

Custom Restart Strategy for controlled Exceptions in Flink 1.20

ontrolled exceptions across the pipeline without duplicating logic in every operator? Any insights or experience would be greatly appreciated. Thanks in advance! Best regards, Aian -- --------- Aian Cantabrana ZYLK.net :: consultoría.openSource