[jira] [Created] (FLINK-2560) Flink-Avro Plugin cannot be handled by Eclipse

2015-08-21 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created FLINK-2560: -- Summary: Flink-Avro Plugin cannot be handled by Eclipse Key: FLINK-2560 URL: https://issues.apache.org/jira/browse/FLINK-2560 Project: Flink Issue Type:

Graph.fromDataSet function calls: flink-gelly

2015-08-21 Thread Sachin Goel
Hi I was going through the two files VertexCentricIteration and GatherSumApplyIteration, and noticed that when the graph is constructed from the edge and vertex data set, a new execution environment is passed. As in, Graph graph = Graph.fromDataSet(vertexDataSet, edgeDataSet, ExecutionEnviro

Re: a problem about flink cluster

2015-08-21 Thread Stephan Ewen
Hi! Usually, TaskManagers should automatically choose a network interface from which they can communicate to the JobManager. They also use that network interface to talk to each other, then. If I understand correctly, what happened is that the TaskManager that ran on the same machine as the JobMa

a problem about flink cluster

2015-08-21 Thread ????
Hi, There is a problem occured during I was running the flink on cluster. I stared the cluster with 3 nodes(one of them as master node ran the jobmanager and taskmanager while others as worker nodes ran taskmanager). First, I didn`t notice that one of the worker nodes also started Docker and Dock

Re: Bug fix release 0.9.1

2015-08-21 Thread Robert Metzger
I would like to release Flink 0.9.1 soon. There were some annoying bugs discovered recently, that should be addressed in a bug fix release. I have the following bugs in my mind: https://issues.apache.org/jira/browse/FLINK-2555 (Hadoop Input/Output Formats are unable to access secured HDFS cluster

[jira] [Created] (FLINK-2559) Fix Javadoc Code Examples

2015-08-21 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2559: --- Summary: Fix Javadoc Code Examples Key: FLINK-2559 URL: https://issues.apache.org/jira/browse/FLINK-2559 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-2558) Add Streaming Connector for Elasticsearch

2015-08-21 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2558: --- Summary: Add Streaming Connector for Elasticsearch Key: FLINK-2558 URL: https://issues.apache.org/jira/browse/FLINK-2558 Project: Flink Issue Type: Imp

[jira] [Created] (FLINK-2557) Manal type information via "returns" fails in DataSet API

2015-08-21 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created FLINK-2557: -- Summary: Manal type information via "returns" fails in DataSet API Key: FLINK-2557 URL: https://issues.apache.org/jira/browse/FLINK-2557 Project: Flink I

Re: Question about TypeInformation in DataSet

2015-08-21 Thread Stephan Ewen
Seems fair. This should not immediately fail, but also only give a "MissingTypeInfo" so that type hints would work. The error message is also wrong, btw: It should state that raw types are not supported. On Fri, Aug 21, 2015 at 1:02 PM, Matthias J. Sax < mj...@informatik.hu-berlin.de> wrote: > H

Question about TypeInformation in DataSet

2015-08-21 Thread Matthias J. Sax
Hi, I changed the WordCount example as below and I am wondering, why this does not work. Looking at the Flink internal implemenation, it make sense that it fails. However, from an API point of view it should work. Is this a bug or do I miss understand the semantic of .returns(...)? The change is

Re: [FAILING TEST] StateCheckpoinedITCase

2015-08-21 Thread Matthias J. Sax
I like the idea with the special label. Otherwise, it will be difficult to find the correct tickets. -Matthias On 08/21/2015 12:15 PM, Till Rohrmann wrote: > I'm also in favor of JIRA, because I fear that nobody will keep the wiki > page in sync. Maybe we can assign a special label for test stabi

Re: [ANNOUNCE] New Committer Chesnay Schepler

2015-08-21 Thread Stephan Ewen
Welcome! On Fri, Aug 21, 2015 at 10:42 AM, Fabian Hueske wrote: > Welcome on board Chesnay! > > > 2015-08-20 21:25 GMT+02:00 Andra Lungu : > > > Congrats Chesnay! :) > > > > On Thu, Aug 20, 2015 at 8:51 PM, Márton Balassi < > balassi.mar...@gmail.com> > > wrote: > > > > > Welcome Chesnay! > > >

Re: [FAILING TEST] StateCheckpoinedITCase

2015-08-21 Thread Till Rohrmann
I'm also in favor of JIRA, because I fear that nobody will keep the wiki page in sync. Maybe we can assign a special label for test stability to these JIRA issues. Then we can quickly find all currently instable test cases. On Fri, Aug 21, 2015 at 11:02 AM, Robert Metzger wrote: > I agree that w

Re: [FAILING TEST] StateCheckpoinedITCase

2015-08-21 Thread Robert Metzger
I agree that we should look for a solution other than opening a lot of small discussion threads on the mailing list. When I have a test failure, I usually search my gmail inbox to see whether somebody else wrote something about the error already. Creating a JIRA for each failing test might be a be

Re: [ANNOUNCE] New Committer Chesnay Schepler

2015-08-21 Thread Fabian Hueske
Welcome on board Chesnay! 2015-08-20 21:25 GMT+02:00 Andra Lungu : > Congrats Chesnay! :) > > On Thu, Aug 20, 2015 at 8:51 PM, Márton Balassi > wrote: > > > Welcome Chesnay! > > > > On Thu, Aug 20, 2015 at 7:29 PM, Henry Saputra > > wrote: > > > > > Welcome Chesnay! > > > > > > On Thu, Aug 20,