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

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

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

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-7208) Refactor build-in agg(MaxWithRetractAccumulator and MinWithRetractAccumulator) using the DataView

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-7209) Support DataView in Java and Scala Tuples and case classes or as the accumulator of AggregateFunction itself

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-7210) Add TwoPhaseCommitSinkFunction (implementing exactly-once semantic in generic way)

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-7211) Exclude Gelly javadoc jar from release

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

Re: Greetings and question

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-7212) JobManagerLeaderSessionIDITSuite not executed

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

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

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

Flink Connector for AWS SQS

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.

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

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

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

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

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

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

Using native library in Flink

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-7216) ExecutionGraph can perform concurrent global restarts to scheduling

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