Hi,
the static field will be null after the code has been shipped to the
cluster. You can use a RichMapFunction instead, there you can define an
open() method to initialize such a field. Please see this part of the doc
for rich functions:
https://ci.apache.org/projects/flink/flink-docs-master/apis/
Issue resolved.
Created the uber jar (fat jar) as shown in the flink-quickstart guide.
My bad, I should have checked that first.
However now I am facing NullPointerException , consider the following
example (this is the dummy code , since I cannot share the actual code):
public class App impleme
Also, we may be able to avoid the need for concurrent metrics by
configuring each Finagle source to use a single thread. We'll investigate
the performance implications this week and update you with the results.
Thanks,
Steve
On Friday, June 10, 2016, Steve Cosenza wrote:
> +Chris Hogue who is a
Hi community,
I am using WordCount example in DataStream API. I want to know the memory
usage of each task and operator and possible modify them.
As far as I know, the memory(off-heap or heap) is retrieved through
MemoryManager.
There is, releaseAll(Object owner) method in MemoryManager, that
