[PSA] Python: don't forget to close() your gRPC channels

https://github.com/grpc/grpc/issues/12531 I imagine this mostly affects GCP connectors, but perhaps grpcio is used elsewhere? (I haven't checked) Background is that I'm updating the minimum grpcio version to 1.12.1 ( https://github.com/grpc/grpc/releases/tag/v1.12.0). smime.p7s Description:

JobServer JobInvocation for Flink portable runner blocks on job completion

Hello, while launching Flink jobs using the PortableRunner I noticed that jobs are marked by Beam as state RUNNING before actually running on Flink. The issue doesn't seem specific to the Flink Runner though:

Re: Brief of interactive Beam

Hi Pablo, Thanks for reviewing the doc. I think I can grasp some of the concepts, but it is not yet 100% clear to > me why it's necessary to define a new abstraction to have interactivity. > Could you elaborate? > It's not clear to me what the "new abstraction" you are mentioning is. But if it

IllegalStateException: TimestampCombiner moved element from to earlier time in Python

Hi, This is Hai from LinkedIn. I'm looking into a bug I found internally when using Beam portable API (Python) on our own Samza runner. The pipeline looks something like this: (p | 'read' >> ReadFromKafka(cluster="tracking", topic="PageViewEvent") | 'transform' >> beam.Map(lambda