Re: Flink sink never executes

2021-01-04 Thread Ben Beasley
Yes, it did. Thanks for checking, Kostas. Also, thanks again for helping me 
with the other issue. What a great community Flink has.

From: Kostas Kloudas 
Date: Monday, January 4, 2021 at 6:21 AM
To: Ben Beasley 
Cc: user@flink.apache.org 
Subject: Re: Flink sink never executes
Hi Ben,

Sorry for the late reply but I guess that your question was answered
in StackOverflow, right?
Did that answer solve your problem?

Cheers,
Kostas

On Mon, Dec 21, 2020 at 9:09 AM Ben Beasley  wrote:
>
> First off I want to thank the folks in this email list for their help thus 
> far.
>
>
>
> I’m facing another strange issue where if I add a window to my stream, the 
> sink no longer executes. However the sink executes without the windowing. I 
> described my problem on stackoverflow so that the code is easy to read.
>
>
>
> I wonder if anyone can help me once more, I believe the solution could be 
> simple for someone familiar with the code. I believe I’ve followed the 
> tutorials and articles on the flink website correctly.


Flink sink never executes

2020-12-21 Thread Ben Beasley
First off I want to thank the folks in this email list for their help thus far.

I’m facing another strange issue where if I add a window to my stream, the sink 
no longer executes. However the sink executes without the windowing. I 
described my problem on 
stackoverflow
 so that the code is easy to read.

I wonder if anyone can help me once more, I believe the solution could be 
simple for someone familiar with the code. I believe I’ve followed the 
tutorials and articles on the flink website correctly.


Re: No execution.target specified in your configuration file

2020-12-20 Thread Ben Beasley
That worked. Thankyou, Kostas.

From: Kostas Kloudas 
Date: Sunday, December 20, 2020 at 7:21 AM
To: Ben Beasley 
Cc: user@flink.apache.org 
Subject: Re: No execution.target specified in your configuration file
Hi Ben,

You can try using StreamExecutionEnvironment
streamExecutionEnvironment =
StreamExecutionEnvironment.getExecutionEnvironment();
instead of directly creating a new one. This will allow to pick up the
configuration parameters you pass through the command line.

I hope this helps,
Kostas

On Sun, Dec 20, 2020 at 7:46 AM Ben Beasley  wrote:
>
> I was wondering if I could get help with the issue described in this 
> stackoverflow post.


No execution.target specified in your configuration file

2020-12-19 Thread Ben Beasley
I was wondering if I could get help with the issue described in this 
stackoverflow 
post.