Hello Beam Dev,
I am having a hard time to get checkpoint work with FlinkRunner. I setup two
simple pipelines, one read from unboundedsource Kinesis, and other read from
text file (and test with/without `--streaming=true` config). But both are
failed to save a checkpoint. The checkpoint are
Hello everyone,
I am an software engineer at Godaddy. Our team is working with and supporting
Beam. I just opened a Jira ticket to build a new component, which DynamoSink.
Here is the ticket: https://issues.apache.org/jira/browse/BEAM-7043
I would love to become a contributor in this repo, or
