Wish to Contribute - 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

Re: Reliable Distributed FS support (HCFS)

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.

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

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

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

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

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

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-5824) Fix String/byte conversion without explicit encodings

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:

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

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-5818) change checkpoint dir permission to 700 for security reason

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:

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

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-5822) Make Checkpoint Coordinator aware of State Backend

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:

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

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

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

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

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

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

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