Multiple Window Streams to same Kinesis Sink

2023-01-27 Thread Curtis Jensen
I'm trying to sink two Window Streams to the same Kinesis Sink. When I do this, no results are making it to the sink (code below). If I remove one of the windows from the Job, results do get published. Adding another stream to the sink seems to void both. How can I have results from both Window

Re: "An illegal reflective access operation has occurred" during KeyedStream process

2022-11-29 Thread Curtis Jensen
legal-access=warn to enable warnings of further illegal reflective access operations WARNING: All illegal access operations will be denied in a future release On Tue, Nov 29, 2022 at 3:25 PM Curtis Jensen wrote: > > Hello, > > Using Flink version 1.15.0, I recieve these warnings when tryi

"An illegal reflective access operation has occurred" during KeyedStream process

2022-11-29 Thread Curtis Jensen
Hello, Using Flink version 1.15.0, I recieve these warnings when trying a small example (code below): WARNING: An illegal reflective access operation has occurred WARNING: Illegal reflective access by org.apache.flink.api.java.ClosureCleaner (file:/Users/cjensen/data/tools/apache-maven-3.3.9/m2/or