clear query| facets| time Search criteria: .   Results from 1 to 10 from 1083 (0.0s).
Loading phrases to help you
refine your search...
[expand - 5 more] - Re: - Beam - [mail # user]
...I tried your example and found the same exception on direct runner. I thinkMAP with Row as value types is not well supported in SQL so filehttps://jira.apache.org/jira/browse/BEAM-7623 to im...
   Author: Rui Wang , Vishwas Bm , ... , 2019-06-24, 17:39
[expand - 1 more] - [Python] Accessing the DAG object from my apache beam pipeline? - Beam - [mail # user]
...Probably the easiest thing to do here would be to implement your ownrunner that wraps another runner, and overrideshttps://github.com/apache/beam/blob/master/sdks/python/apache_beam/runners/...
   Author: Robert Bradshaw , Germain TANGUY , ... , 2019-06-24, 08:45
[expand - 2 more] - [Sender Auth Failure]  Re: Question about Parallel execution - Beam - [mail # user]
...Hi Mikhail,Thanks for reply.I believe that Dataflow optimizer assumes that running this pipeline on a single worker is faster and more cost-effective than spinning up 100 workers. Work items...
   Author: Anjana Pydi , Mikhail Gryzykhin , ... , 2019-06-21, 20:42
[expand - 8 more] - [ANNOUNCE] Spark portable runner (batch) now available for Java, Python, Go - Beam - [mail # user]
...This is great news. Can't wait to see more.On Fri, Jun 21, 2019 at 8:56 AM Alexey Romanenko wrote:> Amazing job! Thank you, Kyle!>> On 19 Jun 2019, at 18:10, David Morávek  wro...
   Author: Lukasz Cwik , Alexey Romanenko , ... , 2019-06-21, 15:58
[expand - 2 more] - Beam vs Serverless (Dataflow vs Functions) - Beam - [mail # user]
...In my case, I have the same scenario in production and I am using the *CloudFunction*, and it is working fine now.Even I am doing some lightweight processing for the data, and it is so farso...
   Author: Soliman ElSaber , Lukasz Cwik , ... , 2019-06-21, 03:26
[expand - 7 more] - AvroUtils converting generic record to Beam Row causes class cast exception - Beam - [mail # user]
...PR/8376 is merged and it should be in 2.14.0 release.-RuiOn Mon, Apr 22, 2019 at 10:49 AM Rui Wang  wrote:> I see. I created this PR [1] to ask feedback from the reviewer who knows&g...
   Author: Rui Wang , Vishwas Bm , ... , 2019-06-19, 22:18
[expand - 4 more] - Can we do pardo inside a pardo? - Beam - [mail # user]
...You want Beam.FlataMap(get_response) here so that the output PCollectioncontains all the elements of all the lists returned by get_response ratherthan the lists themselves.On Tue, Jun 18, 20...
   Author: Robert Bradshaw , Chamikara Jayalath , ... , 2019-06-18, 05:41
[expand - 8 more] - Why is my RabbitMq message never acknowledged ? - Beam - [mail # user]
...My test is using the direct runner with the streaming option set to true.As it is the runner that should be used for development (as far as Iunderstand), I suppose it should expose most of t...
   Author: Nicolas Delsaux , Maximilian Michels , ... , 2019-06-17, 07:38
[expand - 1 more] - Why Avro(Generic Record) -> Beam Row -> BigQuery TableRow - Beam - [mail # user]
...These utilities are not a part of Beam public API and can change at anypoint. Beam transform for writing to BigQuery by default expects aPCollection of TableRow objects as input but can also...
   Author: Chamikara Jayalath , Theodore Siu , ... , 2019-06-14, 22:07
[expand - 4 more] - grpc cancelled without enough information - Beam - [mail # user]
...Thanks for the logs.We have seen similar behavior earlier for larger datasets because of missconfiguration in GRPC which was fixed inhttps://github.com/apache/beam/commit/d2543a28e9ce83d46e9...
   Author: Ankur Goenka , 青雉(祁明良) , ... , 2019-06-14, 17:34