[jira] [Created] (FLINK-2516) Remove unwanted log.isInfoEnabled check

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 C

[jira](FLINK-2493) Simplify names of example program JARs

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 examples/flink-java-examples-0.10-SNAPSHOT-ConnectedCompone

Re: Builds Problems on Travis

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 < mj...@informatik.

Re: 答复: 答复: Some problems about Flink applications

How about something like this: DataStream> sink = user .join(area) .onWindow(15, TimeUnit.MINUTES) .where(0) .equalTo(0) .flatMap(new FlatMapFunction,Tuple2>, Tuple2>() { @Override public void flatMap(Tuple2,Tuple2> value, Co

答复: 答复: Some problems about Flink applications

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: > >>> > >>> DataStream> user = env.addSource(new > >>

Builds Problems on Travis

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] > /home/travis/build/mjsax/flink/flink-contrib/flink-storm-compatibility/flin

[jira] [Created] (FLINK-2515) CheckpointCoordinator triggers checkpoints even if not all sources are running any more

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 P

Test about Improve performance of call system.currentTimeMillis()

Hello! I have a test about cost of System.currentTimeMillis() and my CLOCK.currentTimeMillis() .( My clock will be a JVM singleton) Call currentTimeMillis function 1 times, System.currentTimeMillis() need about 1902ms and my CLOCK.currentTimeMillis() only need 119ms. The function perfor

[jira] [Created] (FLINK-2514) Local and Remote environment behave differently when re-triggering execution.

Stephan Ewen created FLINK-2514: --- Summary: Local and Remote environment behave differently when re-triggering execution. Key: FLINK-2514 URL: https://issues.apache.org/jira/browse/FLINK-2514 Project: Fl

[jira] [Created] (FLINK-2513) Extend state handle provider interface to list all state handles

Ufuk Celebi created FLINK-2513: -- Summary: Extend state handle provider interface to list all state handles Key: FLINK-2513 URL: https://issues.apache.org/jira/browse/FLINK-2513 Project: Flink I