Re: [Question] AWS Credentials Serializability

2023-09-23 Thread deepak kumar
It seems there is problem with the fat/Uber jar . It might have multiple
versions of the classs being overwritten with duplicates .
Check this link :

https://stackoverflow.com/questions/57039951/beam-failed-to-serialize-and-deserialize-property-awscredentialsprovider


On Sat, 23 Sep 2023 at 9:55 PM, Ramya Prasad via user 
wrote:

> Hello,
>
> I am a developer trying to use Apache Beam, and I'm running into an issue
> with trying to provide multiple AWS credentials to the AwsOptions class
> within the PipelineOptions class. My use case requires multi-account reads,
> and I've tried using the AwsCredentialsProviderChain class within the
> options.as(AwsOptions.class).setAwsCredentialsProvider() method, but I
> keep getting the error
>
> Caused by: com.fasterxml.jackson.databind.JsonMappingException: Unexpected
> IOException (of type java.io.IOException): Failed to serialize and
> deserialize property 'awsCredentialsProvider' with value
> 'AwsCredentialsProviderChain.
>
> Is there anything I'm doing wrong? Any help would be appreciated!
>
> Thanks and sincerely,
> Ramya
> --
>
> The information contained in this e-mail is confidential and/or
> proprietary to Capital One and/or its affiliates and may only be used
> solely in performance of work or services for Capital One. The information
> transmitted herewith is intended only for use by the individual or entity
> to which it is addressed. If the reader of this message is not the intended
> recipient, you are hereby notified that any review, retransmission,
> dissemination, distribution, copying or other use of, or taking of any
> action in reliance upon this information is strictly prohibited. If you
> have received this communication in error, please contact the sender and
> delete the material from your computer.
>
>
>
>
>


Re: Firing a dataflow job using REST API

2022-02-14 Thread deepak kumar
Hi Rajnil,
Did you look at the gcloud documentation?

https://cloud.google.com/dataflow/docs/reference/rest

Thanks
Deepak

On Mon, Feb 14, 2022 at 3:53 PM Rajnil Guha  wrote:

> Hi Beam Community,
>
> I am trying to run a Dataflow pipeline using the REST API. Currently I see
> an example for doing the same for Dataflow templates[1].
> My query is can we run a dataflow job using REST API but not create
> templates. As per the docs the projects.jobs.create method allows to do so,
> but if anyone have tried this before would be very helpful if you could
> provide a snippet of your code.
>
> [1]
> https://cloud.google.com/dataflow/docs/guides/templates/running-templates
>
> Thanks & Regards
> Rajnil
>
>
>


Re: Allyship workshops for open source contributors

2021-06-14 Thread deepak kumar
+1

On Tue, Jun 15, 2021 at 12:31 AM Aizhamal Nurmamat kyzy 
wrote:

> Thank you all! Based on the feedback, I will set up a session for a couple
> open source groups. Will share more details soon. Stay tuned.
>
> On Mon, Jun 7, 2021 at 4:42 PM Kenneth Knowles  wrote:
>
>> Yes please!
>>
>> On Thu, Jun 3, 2021, 18:32 Ratnakar Malla  wrote:
>>
>>> +1
>>>
>>>
>>> --
>>> *From:* Austin Bennett 
>>> *Sent:* Thursday, June 3, 2021 6:20:25 PM
>>> *To:* user@beam.apache.org 
>>> *Cc:* dev 
>>> *Subject:* Re: Allyship workshops for open source contributors
>>>
>>> +1, assuming timing can work.
>>>
>>> On Wed, Jun 2, 2021 at 2:07 PM Aizhamal Nurmamat kyzy <
>>> aizha...@apache.org> wrote:
>>>
>>> If we have a good number of people who express interest in this thread,
>>> I will set up training for the Airflow community.
>>>
>>>
>>> I meant Beam ^^' I am organizing it for the Airflow community as well.
>>>
>>>


Freelancing work

2020-12-09 Thread deepak kumar
Hi All,
Sorry for spamming.
If anyone is looking or knows someone who might be looking for freelancers
in Apache Beam,please let me know.

Thanks.


Ways to learn Beam in detail

2020-05-07 Thread deepak kumar
Hi There,
Can anyone suggest the best way to get started on Beam APIs , so i can
start contributing to the codebase?

Thanks
Deepak


Re: Scheduling dataflow pipelines

2020-04-06 Thread deepak kumar
We have used composer (airlfow) successfully to schedule Dataflow jobs.
Please let me know if you would need details around it.

Thanks
Deepak

On Sun, Apr 5, 2020 at 7:56 PM Joshua B. Harrison 
wrote:

> Hi Marco,
>
> I've ended using a VM running Luigi to schedule jobs. I use the data flow
> Python API to execute stored templates.
>
> I can give you more details if you’re interested.
>
> Best,
> Joshua
>
> On Sun, Apr 5, 2020 at 5:02 AM Marco Mistroni  wrote:
>
>> HI all
>>  sorry for this partially OT but has anyone been successful in scheduling
>> dataflow job on GCP?
>> I have tried the CloudFunction approach (following few eamples on the
>> web) but it didnt work out for me - the cloud function keep on giving me an
>> INVALID ARGUMENT - which i could not debug
>>
>> So i was wondering if anyone has  been successful and can provide me an
>> example
>>
>> kind regards
>>  Marco
>>
>> --
> Joshua Harrison |  Software Engineer |  joshharri...@gmail.com
>  |  404-433-0242
>


Design patterns while using Beam

2019-09-21 Thread deepak kumar
Hi All
I guess we need to put some examples in the documentation around best
coding practises , concurrency , non blocking IO and design patterns while
writing Apache Beam pipelines.
Is there any such guide available ?
E.g. when there are lot of options to be used in the pipeline ,
BuilderPattern should be used.
Another use case can be when anyone wants to run complex transformation on
incoming objects , visitor pattern should be used.
This guide can come from people already running beam in production and
written it with all best practices in mind.
It will help in greater and wider adaoption.

Just a thought.
Please let me know if anyone wants to contribute and i can lead this
initiative.

Thanks
Deepak


How to debug dataflow locally

2019-09-12 Thread deepak kumar
Hi All,
I am trying to come up with a framework that would help debugging dataflow
job end to end locally.
Dataflow can work with 100s of source and sinks.
Is there a framework already to setup these sources and sinks locally e.g.
if my dataflow reads from BQ and inserts to Bigtable.
Please let me know if someone is already doing this.
If ues then how.

Thanks
Deepak


Advanced Java 1.8+ and Beam mentors

2019-09-08 Thread deepak kumar
Hi
I am looking for some advanced level of mentoring in Beam using Java 1.8+.
Are there any resources available or if someone does it on
professional development level?
Please let me know.

Thanks
Deepak


Is there any job board for Beam with Java?

2019-09-05 Thread deepak kumar
Hi All,
Sorry to spam.
I am writing to check if there is any job board where we can post or look
for open positions/  jobs in Apache Beam?

Thanks
Deepak