Fabian, Jorn:
Yes, that was indeed it.
When I added the env.execute("MyApp") it worked.
Thank you for your help.
-Chris
On Mon, May 28, 2018 at 5:03 AM, Fabian Hueske wrote:
> Hi,
>
> Jörn is probably right.
>
> In contrast to print(), which immediately triggers an execution,
> writeToSink()
Hi,
Jörn is probably right.
In contrast to print(), which immediately triggers an execution,
writeToSink() just appends a sink operator and requires to explicitly
trigger the execution.
The INFO messages of the TypeExtractor are "just" telling you, that Row
cannot be used as a POJO type, but tha
Do you have the complete source?
I am missing a env.execute at the end
> On 27. May 2018, at 18:55, chrisr123 wrote:
>
> I'm using Flink 1.4.0
>
> I'm trying to save the results of a Table API query to a CSV file, but I'm
> getting an error.
> Here are the details:
>
> My Input file looks lik
I'm using Flink 1.4.0
I'm trying to save the results of a Table API query to a CSV file, but I'm
getting an error.
Here are the details:
My Input file looks like this:
id,species,color,weight,name
311,canine,golden,75,dog1
312,canine,brown,22,dog2
313,feline,gray,8,cat1
I run a query on this to
