clear query| facets| time Search criteria: .   Results from 1 to 10 from 910 (0.0s).
Loading phrases to help you
refine your search...
joining two streams of the same type - Beam - [mail # user]
...Use Flatten to "merge" two PCollections and then GBK to group all therecords by key.On Tue, Oct 16, 2018 at 3:27 PM [EMAIL PROTECTED]  wrote:> I realized I even can't follow that app...
   Author: Lukasz Cwik , 2018-10-16, 22:41
Does anyone have a strong intelliJ setup? - Beam - [mail # dev]
...I also reached out on the Gradle forum asking about how to get Intellij touse a subprojects output jars instead of the output classes:https://discuss.gradle.org/t/how-to-get-intellij-to-use-...
   Author: Lukasz Cwik , 2018-10-16, 18:06
[expand - 4 more] - [BEAM-5442] Store duplicate unknown (runner) options in a list argument - Beam - [mail # dev]
...For all unknown options, the SDK can require that all flag values bespecified explicitly as a valid JSON type.starts with { -> objectstarts with [ -> liststarts with " -> stringis n...
   Author: Lukasz Cwik , 2018-10-16, 17:03
Ingesting from KafkaIO into HDFS, problems with checkpoint and data lost on top of yarn + spark - Beam - [mail # user]
...There has been some discussion in the past about adding a "drain" featureto Apache Beam which would allow this intermediate data to be output so itisn't lost. The caveat is that you'll be ou...
   Author: Lukasz Cwik , 2018-10-16, 16:25
[expand - 1 more] - Why not adding all coders into ModelCoderRegistrar? - Beam - [mail # dev]
...You will want to add your own CoderTranslatorRegistrar for the additionalURNs that you want to support to the runner and make sure the SDK that yourusing submits those coders using those URN...
   Author: Lukasz Cwik , 2018-10-15, 23:36
[expand - 2 more] - Vendoring vulnerable Guava (CVE-2018-10237) - Beam - [mail # dev]
...Nice on the gPRC update to much newer Guava. Once that is out, would beworthwhile to bump up our usage as well.On Mon, Oct 15, 2018 at 2:44 PM Andrew Pilloud  wrote:> gRPC 1.15 was s...
   Author: Lukasz Cwik , 2018-10-15, 22:08
[expand - 4 more] - Rethinking Timers as PCollections - Beam - [mail # dev]
...As Kenn mentioned, the timer is tracking the watermark of the main inputPCollection and not the input watermark of the ParDo which would allow itto fire and thus it couldn't block itself.I d...
   Author: Lukasz Cwik , 2018-10-15, 21:59
[expand - 1 more] - FYI on Slack Channels - Beam - [mail # user]
...I got the slack invite link working again onhttps://beam.apache.org/community/contact-us/ since it requires to berenewed every month.On Mon, Oct 8, 2018 at 7:45 AM Filip Popić  wrote:&g...
   Author: Lukasz Cwik , 2018-10-15, 21:32
Fwd: Slack invitation - Beam - [mail # dev]
...I got the the self service Slack invite link working againhttps://s.apache.org/slack-invite by having it regenerated.On Wed, Oct 10, 2018 at 2:13 PM Filip Popić  wrote:> I got it, th...
   Author: Lukasz Cwik , 2018-10-15, 19:51
Beam Samza Runner status update - Beam - [mail # dev]
...I'm excited to hear about making Samza capable of running non-Javapipelines.On Fri, Oct 12, 2018 at 9:46 AM Xinyu Liu  wrote:> @Max: absolutely we should work together! FlinkRunner h...
   Author: Lukasz Cwik , 2018-10-15, 18:05