[jira] [Created] (FLINK-5826) UDF/UDTF should support variable types and variable arguments

2017-02-16 Thread Zhuoluo Yang (JIRA)
Zhuoluo Yang created FLINK-5826: --- Summary: UDF/UDTF should support variable types and variable arguments Key: FLINK-5826 URL: https://issues.apache.org/jira/browse/FLINK-5826 Project: Flink Is

[jira] [Created] (FLINK-5825) In yarn mode, a small pic can not be loaded

2017-02-16 Thread Tao Wang (JIRA)
Tao Wang created FLINK-5825: --- Summary: In yarn mode, a small pic can not be loaded Key: FLINK-5825 URL: https://issues.apache.org/jira/browse/FLINK-5825 Project: Flink Issue Type: Bug Com

Re: Wish to Contribute - Andrea Spina

2017-02-16 Thread Tzu-Li (Gordon) Tai
Hi Andrea! Welcome to the Flink community! Very happy to see that you’re interested in contributing. Just let us know when you’ve came across an issue on JIRA you’d like to start working on, and also your JIRA id. We can assign you contributor permissions on JIRA so that you can assign issues

Re: Reliable Distributed FS support (HCFS)

2017-02-16 Thread Vijay Srinivasaraghavan
Following up on my question regarding backed Filesystem (HCFS) requirements. Appreciate any inputs. ---Regarding the Filesystem abstraction support, we are planning to use a distributed file system which complies with Hadoop Compatible File System (HCFS) standard in place of standard HDFS. Accor

Wish to Contribute - Andrea Spina

2017-02-16 Thread Andrea Spina
Dear Flink People! My name is Andrea and I'm software engineer. I love Scala and I'm strongly interested on Big Data and Machine Learning topics. I'm working with Apache Flink since almost one year and the relationship is getting deep :). So my wish is to contribute somehow to the project (I was

[jira] [Created] (FLINK-5824) Fix String/byte conversion without explicit encodings

2017-02-16 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-5824: -- Summary: Fix String/byte conversion without explicit encodings Key: FLINK-5824 URL: https://issues.apache.org/jira/browse/FLINK-5824 Project: Flink Issue Type: B

[jira] [Created] (FLINK-5823) Store Checkpoint Root Metadata in StateBackend (not in HA custom store)

2017-02-16 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-5823: --- Summary: Store Checkpoint Root Metadata in StateBackend (not in HA custom store) Key: FLINK-5823 URL: https://issues.apache.org/jira/browse/FLINK-5823 Project: Flink

[jira] [Created] (FLINK-5822) Make Checkpoint Coordinator aware of State Backend

2017-02-16 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-5822: --- Summary: Make Checkpoint Coordinator aware of State Backend Key: FLINK-5822 URL: https://issues.apache.org/jira/browse/FLINK-5822 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-5821) Create StateBackend root interface

2017-02-16 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-5821: --- Summary: Create StateBackend root interface Key: FLINK-5821 URL: https://issues.apache.org/jira/browse/FLINK-5821 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-5820) Extend State Backend Abstraction to support Global Cleanup Hooks

2017-02-16 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-5820: --- Summary: Extend State Backend Abstraction to support Global Cleanup Hooks Key: FLINK-5820 URL: https://issues.apache.org/jira/browse/FLINK-5820 Project: Flink

[jira] [Created] (FLINK-5819) Improve metrics reporting

2017-02-16 Thread Paul Nelligan (JIRA)
Paul Nelligan created FLINK-5819: Summary: Improve metrics reporting Key: FLINK-5819 URL: https://issues.apache.org/jira/browse/FLINK-5819 Project: Flink Issue Type: Improvement Com

[jira] [Created] (FLINK-5818) change checkpoint dir permission to 700 for security reason

2017-02-16 Thread Tao Wang (JIRA)
Tao Wang created FLINK-5818: --- Summary: change checkpoint dir permission to 700 for security reason Key: FLINK-5818 URL: https://issues.apache.org/jira/browse/FLINK-5818 Project: Flink Issue Type:

Re: Flink Job Exception

2017-02-16 Thread Aljoscha Krettek
Hi Govindarajan, the Jira issue that you linked to and which Till is currently fixing will only fix the obvious type mismatch in the Akka messages. There is also an underlying problem that causes this message to be sent in the first place. In the case of the user who originally created the Jira iss

[jira] [Created] (FLINK-5817) Fix test concurrent execution failure by test dir conflicts.

2017-02-16 Thread Wenlong Lyu (JIRA)
Wenlong Lyu created FLINK-5817: -- Summary: Fix test concurrent execution failure by test dir conflicts. Key: FLINK-5817 URL: https://issues.apache.org/jira/browse/FLINK-5817 Project: Flink Issue

[jira] [Created] (FLINK-5816) I would like to stream data from MongoDB using Flink's source function. Is this possible? Thank you.

2017-02-16 Thread Pedro Lima Monteiro (JIRA)
Pedro Lima Monteiro created FLINK-5816: -- Summary: I would like to stream data from MongoDB using Flink's source function. Is this possible? Thank you. Key: FLINK-5816 URL: https://issues.apache.org/jira/brows

[jira] [Created] (FLINK-5815) Add resource files configuration for Yarn Mode

2017-02-16 Thread Wenlong Lyu (JIRA)
Wenlong Lyu created FLINK-5815: -- Summary: Add resource files configuration for Yarn Mode Key: FLINK-5815 URL: https://issues.apache.org/jira/browse/FLINK-5815 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-5814) flink-dist creates wrong symlink when not used with cleaned before

2017-02-16 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-5814: -- Summary: flink-dist creates wrong symlink when not used with cleaned before Key: FLINK-5814 URL: https://issues.apache.org/jira/browse/FLINK-5814 Project: Flink

Re: Flink Job Exception

2017-02-16 Thread Till Rohrmann
Hi Govindarajan, there is a pending PR for this issue. I think I can merge it today. Cheers, Till On Thu, Feb 16, 2017 at 12:50 AM, Govindarajan Srinivasaraghavan < govindragh...@gmail.com> wrote: > Hi All, > > I'm trying to run a streaming job with flink 1.2 version and there are 3 > task mana