Hi, I am trying to join inputs from Unbounded Sources then write to Bounded Sink. The pipeline I'm trying is: Kafka Sources -> SqlTransform -> HCatalogIO Sink And, a FixedWindow of 1 minute duration is applied.
I'm expecting the inputs from unbounded sources joined within the current window to be written to the HCatalogIO Sink after every 1 min i.e after each window interval. Can someone please tell if this is a valid scenario and what is the expected behaviour from this kind of scenario? Regards, Shanta
