There's another open thread on a similar situation but I'm not quite sure
this is completely related, so I'm opening a new one.
Is there a particular setting that has to be used when logging from an
application that is running in YARN? I quickly put together a simple
application that reads from an
Hello all,
I created KMeans.jar from the source-code and it works fine.
But when I had put the *print* statement before *writeAsCsv, *the result
folder does not get created.
Eg:
clusteredPoints.print();
clusteredPoints.writeAsCsv(outputPath, "\n", " ");
// since file sinks are lazy, we trigger the
Hey Ron,
for accessing keys of a class by their field name (like you did:
.keyBy("accountId",
"agentId", "wideMetricId")), the class needs to be recognized as a POJO by
Flink.
>From the documentation [1] a class is recognized as a POJO when:
-
The class must be public.
-
It must ha
