[jira] [Created] (FLINK-1973) JobManager log does not contain state change messages on INFO level

Stephan Ewen created FLINK-1973: --- Summary: JobManager log does not contain state change messages on INFO level Key: FLINK-1973 URL: https://issues.apache.org/jira/browse/FLINK-1973 Project: Flink

Re: Error in eclipse

Thanks for all. I only use java. The Stepahan's suggestion works. There is no errors now. ZHOU Yi On 04/05/2015 14:43, Stephan Ewen wrote: I think Vasia and Gyula are actually using Eclipse. The Eclipse setup is tricky. Frequently, it works best to build and install the code with maven on the

[jira] [Created] (FLINK-1972) Remove instanceID in streaming tasks

Stephan Ewen created FLINK-1972: --- Summary: Remove instanceID in streaming tasks Key: FLINK-1972 URL: https://issues.apache.org/jira/browse/FLINK-1972 Project: Flink Issue Type: Bug Co

[jira] [Created] (FLINK-1971) Add user function type to StreamOperator

Aljoscha Krettek created FLINK-1971: --- Summary: Add user function type to StreamOperator Key: FLINK-1971 URL: https://issues.apache.org/jira/browse/FLINK-1971 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-1970) how can implemented subquery in flink

hagersaleh created FLINK-1970: - Summary: how can implemented subquery in flink Key: FLINK-1970 URL: https://issues.apache.org/jira/browse/FLINK-1970 Project: Flink Issue Type: Bug Rep

[jira] [Created] (FLINK-1969) Remove old profile code

Stephan Ewen created FLINK-1969: --- Summary: Remove old profile code Key: FLINK-1969 URL: https://issues.apache.org/jira/browse/FLINK-1969 Project: Flink Issue Type: Bug Components: Dis

[jira] [Created] (FLINK-1968) Make Distributed Cache more robust

Stephan Ewen created FLINK-1968: --- Summary: Make Distributed Cache more robust Key: FLINK-1968 URL: https://issues.apache.org/jira/browse/FLINK-1968 Project: Flink Issue Type: Bug Re

Re: Error in eclipse

I think Vasia and Gyula are actually using Eclipse. The Eclipse setup is tricky. Frequently, it works best to build and install the code with maven on the command line (mvn clean install -DskipTests), and then close in Eclipse all projects except for the ones you are workign with. Robert's guide

[jira] [Created] (FLINK-1967) Introduce (Event)time in Streaming

Aljoscha Krettek created FLINK-1967: --- Summary: Introduce (Event)time in Streaming Key: FLINK-1967 URL: https://issues.apache.org/jira/browse/FLINK-1967 Project: Flink Issue Type: Improvemen

Flink Benchmark: comparing flink's performance in different environments

Hi, I am writing my master thesis about how to orchestrate scalable tasks and services with docker. The idea is to swap a task's environment very fast, I plan to use Flink as the environment. For that I package Apache Flink into container and start one master and X worker nodes plus one task on th

Re: Gzip support

Great. Please file a JIRA and open a pull request for the feature! On Mon, May 4, 2015 at 10:37 AM, Kruse, Sebastian wrote: > Right, I saw the .deflate file support und the unsplittable flag and built > upon that code. I just tried to generalize it and expose it as a hook, so > that unforeseen i

[jira] [Created] (FLINK-1966) Add support for predictive model markup language (PMML)

Till Rohrmann created FLINK-1966: Summary: Add support for predictive model markup language (PMML) Key: FLINK-1966 URL: https://issues.apache.org/jira/browse/FLINK-1966 Project: Flink Issue T

RE: Gzip support

Right, I saw the .deflate file support und the unsplittable flag and built upon that code. I just tried to generalize it and expose it as a hook, so that unforeseen issues like new exotic compression formats or handling custom preambles can be implemented by the users themselves. I can create a

Re: Error in eclipse

Hi, I don't know any Flink committer who is using Eclipse to develop Flink. Setting up Eclipse for Flink is quite hard because we are a mixed Scala/Java project. Check out this page in the documentation: http://ci.apache.org/projects/flink/flink-docs-master/internals/ide_setup.html On Mon, May 4,