[jira] [Created] (FLINK-7216) ExecutionGraph can perform concurrent global restarts to scheduling

2017-07-17 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-7216: --- Summary: ExecutionGraph can perform concurrent global restarts to scheduling Key: FLINK-7216 URL: https://issues.apache.org/jira/browse/FLINK-7216 Project: Flink

Using native library in Flink

2017-07-17 Thread Mike Accola
I am new Flink user just trying to learn a little bit. I am trying to incorporate an existing C++ library into a new Flink application. I am seeing some strange behavior when trying to link in the native (C++) library using java via JNI. I am running this on Linux (RHEL6) I can run my appl

[jira] [Created] (FLINK-7215) Typo in FAQ page

2017-07-17 Thread Bowen Li (JIRA)
Bowen Li created FLINK-7215: --- Summary: Typo in FAQ page Key: FLINK-7215 URL: https://issues.apache.org/jira/browse/FLINK-7215 Project: Flink Issue Type: Bug Components: Documentation

[jira] [Created] (FLINK-7214) Add a sink that writes to ORCFile on HDFS

2017-07-17 Thread Robert Rapplean (JIRA)
Robert Rapplean created FLINK-7214: -- Summary: Add a sink that writes to ORCFile on HDFS Key: FLINK-7214 URL: https://issues.apache.org/jira/browse/FLINK-7214 Project: Flink Issue Type: New F

[DISCUSS] A more thorough Pull Request check list and template

2017-07-17 Thread Stephan Ewen
Hi all! I have reflected a bit on the pull requests and on some of the recent changes to Flink and some of the introduced bugs / regressions that we have fixed. One thing that I think would have helped is to have more explicit information about what the pull request does and how the contributor w

Flink Connector for AWS SQS

2017-07-17 Thread Ray Ruvinskiy
I’m interested in writing a connector for AWS SQS (https://aws.amazon.com/sqs/). I’ve looked, and I don’t believe one is available. Flink does have a Kinesis collector, and there is some overlap in terms of basic AWS configuration handling (I believe mostly limited to what’s in https://github.

[jira] [Created] (FLINK-7213) Introduce state management by OperatorID in TaskManager

2017-07-17 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-7213: - Summary: Introduce state management by OperatorID in TaskManager Key: FLINK-7213 URL: https://issues.apache.org/jira/browse/FLINK-7213 Project: Flink Issue

[jira] [Created] (FLINK-7212) JobManagerLeaderSessionIDITSuite not executed

2017-07-17 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-7212: -- Summary: JobManagerLeaderSessionIDITSuite not executed Key: FLINK-7212 URL: https://issues.apache.org/jira/browse/FLINK-7212 Project: Flink Issue Type: Bug

Re: Greetings and question

2017-07-17 Thread Fabian Hueske
Hi Robert, I don't think anybody is working on a ORC file sink. Are you interested in a sink for data streams or a batch sink? Implementing a batch sink shouldn't be very hard. You can either implement an OutputFormat the internally uses the ORC Java API or you try to use Flink's HadoopOutputForm

[jira] [Created] (FLINK-7211) Exclude Gelly javadoc jar from release

2017-07-17 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-7211: - Summary: Exclude Gelly javadoc jar from release Key: FLINK-7211 URL: https://issues.apache.org/jira/browse/FLINK-7211 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-7210) Add TwoPhaseCommitSinkFunction (implementing exactly-once semantic in generic way)

2017-07-17 Thread Piotr Nowojski (JIRA)
Piotr Nowojski created FLINK-7210: - Summary: Add TwoPhaseCommitSinkFunction (implementing exactly-once semantic in generic way) Key: FLINK-7210 URL: https://issues.apache.org/jira/browse/FLINK-7210 Pr

[jira] [Created] (FLINK-7209) Support DataView in Java and Scala Tuples and case classes or as the accumulator of AggregateFunction itself

2017-07-17 Thread Kaibo Zhou (JIRA)
Kaibo Zhou created FLINK-7209: - Summary: Support DataView in Java and Scala Tuples and case classes or as the accumulator of AggregateFunction itself Key: FLINK-7209 URL: https://issues.apache.org/jira/browse/FLINK-72

[jira] [Created] (FLINK-7208) Refactor build-in agg(MaxWithRetractAccumulator and MinWithRetractAccumulator) using the DataView

2017-07-17 Thread Kaibo Zhou (JIRA)
Kaibo Zhou created FLINK-7208: - Summary: Refactor build-in agg(MaxWithRetractAccumulator and MinWithRetractAccumulator) using the DataView Key: FLINK-7208 URL: https://issues.apache.org/jira/browse/FLINK-7208

[jira] [Created] (FLINK-7207) Support getAccumulatorType when use DataView

2017-07-17 Thread Kaibo Zhou (JIRA)
Kaibo Zhou created FLINK-7207: - Summary: Support getAccumulatorType when use DataView Key: FLINK-7207 URL: https://issues.apache.org/jira/browse/FLINK-7207 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-7206) Implementation of DataView to support state access for UDAGG

2017-07-17 Thread Kaibo Zhou (JIRA)
Kaibo Zhou created FLINK-7206: - Summary: Implementation of DataView to support state access for UDAGG Key: FLINK-7206 URL: https://issues.apache.org/jira/browse/FLINK-7206 Project: Flink Issue T