Stephan Ewen created FLINK-2515:
---
Summary: CheckpointCoordinator triggers checkpoints even if not
all sources are running any more
Key: FLINK-2515
URL: https://issues.apache.org/jira/browse/FLINK-2515
Hi,
I encountered a strange build problem in one of my branches. I have no
idea what the problem might be. Did I break anything? The current master
does not seem to have this problem.
The Error is as follows:
ERROR]
That is a shading problem.
Are you including Guava in your dependencies, or are you only
transitively referring to it?
Have a look here:
https://cwiki.apache.org/confluence/display/FLINK/Hadoop+Versions+and+Dependency+Shading
On Thu, Aug 13, 2015 at 2:19 PM, Matthias J. Sax
Summary:Simplify names of example program JARs
Key:FLINK-2493, URL:https://issues.apache.org/jira/browse/FLINK-2493
Issue Type: Improvement
Components:Examples
Propose to simplify the name to examples/ConnectedComponents.jar rather
than
fangfengbin created FLINK-2516:
--
Summary: Remove unwanted log.isInfoEnabled check
Key: FLINK-2516
URL: https://issues.apache.org/jira/browse/FLINK-2516
Project: Flink
Issue Type: Bug
How about something like this:
DataStreamTuple2String, Integer sink = user
.join(area)
.onWindow(15, TimeUnit.MINUTES)
.where(0)
.equalTo(0)
.flatMap(new FlatMapFunctionTuple2Tuple3String, Integer, Long,Tuple2String,
Integer, Tuple2String, Integer() {
Hi Stephan,
Thank you for the information about the
https://github.com/apache/flink/pull/1008.
I`ll try again.
Otherwise, is there any suggestion about the original second problem:
2.
There is a case following using operator join:
DataStreamTuple3String, Integer, Long user =
