Re: Limitations on grouped ReduceFunction

For now, I think it is worth documenting and leaving it as it is. A while back we thought about adding a Static Code Analysis rule to find such cases and create a warning. For Reduce, that is quite straightforward, for GrouReduce quite tricky... Am 02.02.2016 21:55 schrieb "Greg Hogan"

Re: Connector Documentation missing

Most of the flume code is commented out IIRC? Sent from my iPhone > On Feb 3, 2016, at 8:24 AM, Matthias J. Sax wrote: > > Hi, > > I just observed that there are 7 flink-streaming-connectors available > but only 5 are documented on the web page. > > Flume and Nifi are not

Re: Connector Documentation missing

There is currently only a FlumeSink. The FlumeSource is a dummy file (copied from the AvroSource) and needs to be removed. On Wed, Feb 3, 2016 at 3:11 PM, Matthias J. Sax wrote: > FlumeSink is there. FlumeSource and FlumeTopology is all put in > comments... Not sure about it.

[jira] [Created] (FLINK-3326) Kafka Consumer doesn't retrieve messages after killing flink job which was using the same topic

Farouk Salem created FLINK-3326: --- Summary: Kafka Consumer doesn't retrieve messages after killing flink job which was using the same topic Key: FLINK-3326 URL: https://issues.apache.org/jira/browse/FLINK-3326

Re: Connector Documentation missing

Sorry, I don't think it was purposely not documented :) It needs to be added. Could you file JIRAs and perhaps link them with the Flume/Nifi JIRAs? You could also reopen those.. On Wed, Feb 3, 2016 at 3:21 PM, Matthias J. Sax wrote: > Thanks for clarification! What about the

[jira] [Created] (FLINK-3323) Nifi connector not documented

Matthias J. Sax created FLINK-3323: -- Summary: Nifi connector not documented Key: FLINK-3323 URL: https://issues.apache.org/jira/browse/FLINK-3323 Project: Flink Issue Type: Improvement

Re: Connector Documentation missing

FlumeSink is there. FlumeSource and FlumeTopology is all put in comments... Not sure about it. There is no JIRA for a Flume connector... Does anyone know the status of Flume connector? On 02/03/2016 02:45 PM, Suneel Marthi wrote: > Most of the flume code is commented out IIRC? > > Sent from my

[jira] [Created] (FLINK-3325) Unclosed InputStream in CEPPatternOperator#restoreState()

Ted Yu created FLINK-3325: - Summary: Unclosed InputStream in CEPPatternOperator#restoreState() Key: FLINK-3325 URL: https://issues.apache.org/jira/browse/FLINK-3325 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3329) Unclosed BackupEngine in AbstractRocksDBState#snapshot()

Ted Yu created FLINK-3329: - Summary: Unclosed BackupEngine in AbstractRocksDBState#snapshot() Key: FLINK-3329 URL: https://issues.apache.org/jira/browse/FLINK-3329 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3330) Add SparseVector support to BLAS library in FlinkML

Chiwan Park created FLINK-3330: -- Summary: Add SparseVector support to BLAS library in FlinkML Key: FLINK-3330 URL: https://issues.apache.org/jira/browse/FLINK-3330 Project: Flink Issue Type:

Connector Documentation missing

Hi, I just observed that there are 7 flink-streaming-connectors available but only 5 are documented on the web page. Flume and Nifi are not documented. Did we miss to extend the documentation for both (which should have been part of the commit of the code) or was this left out on purpose?

[jira] [Created] (FLINK-3327) Attach the ExecutionConfig to the JobGraph and make it accessible to the AbstractInvocable.

Kostas created FLINK-3327: - Summary: Attach the ExecutionConfig to the JobGraph and make it accessible to the AbstractInvocable. Key: FLINK-3327 URL: https://issues.apache.org/jira/browse/FLINK-3327 Project:

Re: [DISCUSS] Release 0.10.2

> On 02 Feb 2016, at 17:30, Robert Metzger wrote: > > Thank you for taking care of this. +1 > > I'd like to include this in to the 0.10.2 release: > https://github.com/apache/flink/pull/1576 OK (merged to master and release-10)

[jira] [Created] (FLINK-3328) Incorrectly shaded dependencies in flink-runtime

Stephan Ewen created FLINK-3328: --- Summary: Incorrectly shaded dependencies in flink-runtime Key: FLINK-3328 URL: https://issues.apache.org/jira/browse/FLINK-3328 Project: Flink Issue Type: Bug