I figured what was the issue: I shall assign `assi...
# troubleshooting
a
I figured what was the issue: I shall assign
assignTimestampsAndWatermarks(IngestionTimeWatermarkStrategy._create_());
to both streams!