[Dev] Flink 'InputFormat' Interface execution related problem

2017-01-22 Thread Pawan Manishka Gunarathna
Hi, When we are implementing that Flink *InputFormat* Interface, if we have that* input split creation* part in our data analytics server APIs can we directly go to the second phase of the flink InputFormat Interface execution. Basically I need to know that can we read those InputSplits directly,

GlobFilePathFilter NotSerializableException

2017-01-22 Thread Andrew Psaltis
Hi, I am trying to use the GlobFilePathFIlter with Flink 1.2-SNAPSHOT have also tried using the latest 1.3-SNAPSHOT code and get the same error. Basically if using the GlobFilePathFilter there is a serialization exception due to the inner class in sun.nio.fs.UnixFileSystem not being serializable. I

[jira] [Created] (FLINK-5608) Cancel button not always visible

2017-01-22 Thread Shannon Carey (JIRA)
Shannon Carey created FLINK-5608: Summary: Cancel button not always visible Key: FLINK-5608 URL: https://issues.apache.org/jira/browse/FLINK-5608 Project: Flink Issue Type: Bug Comp

Re: Strange segfaults in Flink 1.2 (probably not RocksDB related)

2017-01-22 Thread Stephan Ewen
Hey! I am actually a bit puzzled how these segfaults could come, unless via a native library, or a JVM bug. Can you try how it behaves when not using RocksDB or using a newer JVM version? Stephan On Sun, Jan 22, 2017 at 7:51 PM, Gyula Fóra wrote: > Hey All, > > I am trying to port some of my

Strange segfaults in Flink 1.2 (probably not RocksDB related)

2017-01-22 Thread Gyula Fóra
Hey All, I am trying to port some of my streaming jobs to Flink 1.2 from 1.1.4 and I have noticed some very strange segfaults. (I am running in test environments - with the minicluster) It is a fairly complex job so I wouldnt go into details but the interesting part is that adding/removing a simpl

[jira] [Created] (FLINK-5607) Move location lookup retry out of KvStateLocationLookupService

2017-01-22 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-5607: -- Summary: Move location lookup retry out of KvStateLocationLookupService Key: FLINK-5607 URL: https://issues.apache.org/jira/browse/FLINK-5607 Project: Flink Iss

[jira] [Created] (FLINK-5606) Remove magic number in key and namespace serialization

2017-01-22 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-5606: -- Summary: Remove magic number in key and namespace serialization Key: FLINK-5606 URL: https://issues.apache.org/jira/browse/FLINK-5606 Project: Flink Issue Type:

[jira] [Created] (FLINK-5605) Make KvStateRequestSerializer package private

2017-01-22 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-5605: -- Summary: Make KvStateRequestSerializer package private Key: FLINK-5605 URL: https://issues.apache.org/jira/browse/FLINK-5605 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-5604) Replace QueryableStateClient constructor

2017-01-22 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-5604: -- Summary: Replace QueryableStateClient constructor Key: FLINK-5604 URL: https://issues.apache.org/jira/browse/FLINK-5604 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-5603) Use Flink's futures in QueryableStateClient

2017-01-22 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-5603: -- Summary: Use Flink's futures in QueryableStateClient Key: FLINK-5603 URL: https://issues.apache.org/jira/browse/FLINK-5603 Project: Flink Issue Type: Improvement