Hi,
This is Yu Watanabe from Creationline.
I would like to contribute issues related to elasticsearch and kafka.
Can someone add me as a contributor for Beam's Jira issue
tracker? I would like to create/assign tickets for my work.
My username in JIRA is "y-watanabe"
Thanks,
Yu
--
Yu Watanabe
OK, I've reordered and tweaked it a bit based on your suggestions, but I'm
going to stop here. I'm spending far more time on this than the
implementation.
I did add an open issues section though that people can add issues too that
can be discussed and voted on. Those that make sense?
_/
_/ Alex
done
On Sun, Feb 16, 2020 at 9:02 AM Yu Watanabe wrote:
> Hi,
>
> This is Yu Watanabe from Creationline.
> I would like to contribute issues related to elasticsearch and kafka.
> Can someone add me as a contributor for Beam's Jira issue
> tracker? I would like to create/assign tickets for my wor
Hey Maria,
Great work!! This provides a nice overview of all the channels and how they
contribute to the overall project.
I will comment on the sections I am most familiar with:
- Website / blog: +1 for reducing the number of outlets to 1. The Beam
Summit website repository could use a clean-up a
Hey,
I'm testing my own PR's against Dataflow, something I've done in the past
with success seem to fail now. I get this error:
java.lang.NoClassDefFoundError: Could not initialize class
org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.construction.WindowingStrategy
Ismael,
I'm also putting together training exercises for O'Reilly (ex:
https://conferences.oreilly.com/strata-data-ai/stai-ca/public/schedule/detail/83505),
and to offer online versions and extensions as well. My criteria for
involvement with them has been ability to reuse and share produced
mate
Digging further in the traces, it seems like a result of changes to the
model:
Caused by: java.lang.ClassNotFoundException:
org.apache.beam.model.pipeline.v1.StandardWindowFns$SessionsPayload$Enum
I see changes by Lukasz Cwik. Will this be a problem for the release?
_/
_/ Alex Van Boxel
On Su
Are you running things manually? This probably means you are using an
out-of-date Dataflow worker. I believe that all tests on Jenkins will build
the Dataflow worker from head to prevent exactly this problem.
On Sun, Feb 16, 2020 at 11:10 PM Alex Van Boxel wrote:
> Digging further in the traces,
Yes, running it manually with the normal parameters as I do for production
Dataflow. I'm probably a bit ignorant on that, and I probably need to
provide my own worker.
Thanks for the hint... I'll dive into that.
_/
_/ Alex Van Boxel
On Mon, Feb 17, 2020 at 8:16 AM Reuven Lax wrote:
> Are you