RE: aws zeppelin glue table connector

2023-03-09 Thread Katz, David L via user
Hi- Don't see a response for this so taking one last stab. Any reply would be greatly appreciated. Thanks, -Dave David L Katz (he/him/his) why? | Executive Director | Macro Te

aws zeppelin glue table connector

2023-03-03 Thread Katz, David L via user
Hi- Hoping someone can give me more understanding and a sense of timing flink leveraging glue tables. Specifically I would like to leverage a glue table data source via an AWS hosted Zeppelin notebook (instead of referencing a kinesis data stream or s3 bucket directly). Additionally I will ne

RE: [EXTERNAL]Re: aws glue connector

2022-12-20 Thread Katz, David L via user
/github.com/apache/flink/tree/master/flink-formats/flink-json-glue-schema-registry<https://secureweb.jpmchase.net/readonly/https:/github.com/apache/flink/tree/master/flink-formats/flink-json-glue-schema-registry> On Mon, Dec 19, 2022 at 2:31 PM Katz, David L via user mailto:user@flink.apache.org&

aws glue connector

2022-12-19 Thread Katz, David L via user
Hi- Has anyone used a glue table connector (specifically trying to get a streaming glue table that sits on top of a kinesis data stream)? I have been using the kinesis stream connector but want to integrate with lake formation so would like to take advantage of the glue table layer. Thanks, -

RE: [EXTERNAL]multiple s3 sinks

2022-10-19 Thread Katz, David L via user
der-pronous.aspx> | Executive Director | Macro Technology | 545 Washington Blvd, Floor 4 | Jersey City, NJ 07310 From: Katz, David L via user Sent: Wednesday, October 19, 2022 11:46 AM To: user Subject: [EXTERNAL]multiple s3 sinks Hi- I'm getting the following error when trying to write to

multiple s3 sinks

2022-10-19 Thread Katz, David L via user
Hi- I'm getting the following error when trying to write to 3 s3 sinks (in an aws kinesis java app): Caused by: org.apache.flink.util.FlinkRuntimeException: Cannot have more than one execute() or executeAsync() call in a single environment. Code snippet (s3Sum,s3Agg and s3Det are the table cre