Talat UYARER

Initial version of GKE Auth support without gcloud

8

## Description I implement new a TokenRefresher for GKE based on Google documentation. This implementation does not need gcloud. Just need a service account and kubeconfig. Detail explaination you can...

GoogleCloud wagon throw NPE because of keyPath is null

4

I am getting below error when I try to use version 2.3. I did little bit debugging and looks like keypath is not set by anyone and it does not...

Default max Parallelism should not apply all UnBoundedSource.

2

When we have multiple KafkaIO on same job. Beam's Default max parallesim apply for all even though Kafka does not have that much partition on the topic. To prevent that...

Backlog metrics do not showing up in FlinkRunner

2

We have a Flink Job which does not emit backlog metrics. Actually metrics are emitting in KafkaIO. However I could not see them on Flink Metric system. Looks like Beam...

Initial Commit for AvroPayloadSerializer

18

**Please** add a meaningful description for your change here ------------------------ Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily: - [ ]...