+Chris Hogue who is also working on operationalizing Flink with me
Hi Stephan,
Thanks for the background on your current implementations!
While we don't require a specific implementation for histogram, counter, or
gauge, it just became clear that we'll need threadsafe versions of all
three of th
Hi Robert,
Yes we are using maven for building the jar, I have deployed both jar with
dependencies and without dependencies.
I actually cannot share the pom since it is on the client machine.
But all the dependencies required are there, I have attached a sample pom
file which is similar to the p
Mark Nadelson created FLINK-4058:
Summary: Error uploading JAR with dependencies using flink.bat on
a Windows stand-alone instance
Key: FLINK-4058
URL: https://issues.apache.org/jira/browse/FLINK-4058
Are you using Maven for building your job jar?
If yes, can you post your pom file on the mailing list?
On Fri, Jun 10, 2016 at 7:16 PM, THORMAN, ROBERT D wrote:
> How did you “provide” the dependencies? Did you use the –C
> parameter when you submitted your job?
>
> On 6/10/16, 11:35 AM, "Vina
How did you “provide” the dependencies? Did you use the –C parameter
when you submitted your job?
On 6/10/16, 11:35 AM, "Vinay Patil" wrote:
>Hi Guys,
>
>I have deployed my application on a cluster, however when I try to run the
>application it throws *NoClassDefFoundError for KeyedDeserializ
Hi Guys,
I have deployed my application on a cluster, however when I try to run the
application it throws *NoClassDefFoundError for KeyedDeserializationSchema*,
all the dependencies are provided correctly since I have run it on a
different standalone node.
Please Help
Regards,
Vinay Patil
Hi!
The incremental checkpointing is still being worked upon. Aljoscha, Till
and me have thought through this a lot and have now a pretty good
understanding how we want to do it with respect to coordination,
savepoints, restore, garbage collecting unneeded checkpoints, etc.
We want to put this in
A recent discussion brought up the point of adding a "histogram" metric
type to Flink. This open thread is to gather some more of the requirements
for that metric.
The most important question is whether users need Flink to offer specific
implementations of "Histogram", like for example the "
com.c
Chesnay Schepler created FLINK-4057:
---
Summary: Expose JobManager Metrics
Key: FLINK-4057
URL: https://issues.apache.org/jira/browse/FLINK-4057
Project: Flink
Issue Type: Improvement
Till Rohrmann created FLINK-4056:
Summary: SavepointITCase.testCheckpointHasBeenRemoved failed on
Travis
Key: FLINK-4056
URL: https://issues.apache.org/jira/browse/FLINK-4056
Project: Flink
Till Rohrmann created FLINK-4055:
Summary:
EventTimeWindowCheckpointingITCase.testPreAggregatedSlidingTimeWindow fails on
Travis
Key: FLINK-4055
URL: https://issues.apache.org/jira/browse/FLINK-4055
Chesnay Schepler created FLINK-4054:
---
Summary: Inconsistent Reporter synchronization within report()
Key: FLINK-4054
URL: https://issues.apache.org/jira/browse/FLINK-4054
Project: Flink
Iss
12 matches
Mail list logo
