ITCases in the Table API

Hi! I want to bring up the discussion again about writing Unit Tests, rather than many ITCases. I looked a bit through the Table API and it looks like there is virtually no unit test, but everything has an ITCase. I would really encourage to write more unit tests. The DataStream API is actually

[jira] [Created] (FLINK-3922) Infinite recursion on TypeExtractor

Flavio Pompermaier created FLINK-3922: - Summary: Infinite recursion on TypeExtractor Key: FLINK-3922 URL: https://issues.apache.org/jira/browse/FLINK-3922 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3923) Unify configuration conventions of the Kinesis producer to the same as the consumer

Robert Metzger created FLINK-3923: - Summary: Unify configuration conventions of the Kinesis producer to the same as the consumer Key: FLINK-3923 URL: https://issues.apache.org/jira/browse/FLINK-3923 P

[jira] [Created] (FLINK-3924) Remove protobuf shading from Kinesis connector

Robert Metzger created FLINK-3924: - Summary: Remove protobuf shading from Kinesis connector Key: FLINK-3924 URL: https://issues.apache.org/jira/browse/FLINK-3924 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-3925) GraphAlgorithm to filter by maximum degree

Greg Hogan created FLINK-3925: - Summary: GraphAlgorithm to filter by maximum degree Key: FLINK-3925 URL: https://issues.apache.org/jira/browse/FLINK-3925 Project: Flink Issue Type: New Feature

Re: Performance and accuracy of Flink iterations

Thanks Vasia for the very clear explanation. saluti, Stefano 2016-05-17 14:53 GMT+02:00 Vasiliki Kalavri : > Hi Greg, > > I think there is confusion between what delta means in the "delta iteration > operator" of Flink and the "delta approximate implementation" of an > algorithm, such as in Page

[jira] [Created] (FLINK-3926) Incorrect implementation of getFieldIndex in TupleTypeInfo

Yijie Shen created FLINK-3926: - Summary: Incorrect implementation of getFieldIndex in TupleTypeInfo Key: FLINK-3926 URL: https://issues.apache.org/jira/browse/FLINK-3926 Project: Flink Issue Ty

[jira] [Created] (FLINK-3927) TaskManager registration may fail if Yarn versions don't match

Maximilian Michels created FLINK-3927: - Summary: TaskManager registration may fail if Yarn versions don't match Key: FLINK-3927 URL: https://issues.apache.org/jira/browse/FLINK-3927 Project: Flink

[jira] [Created] (FLINK-3928) Potential overflow due to 32-bit int arithmetic

Ted Yu created FLINK-3928: - Summary: Potential overflow due to 32-bit int arithmetic Key: FLINK-3928 URL: https://issues.apache.org/jira/browse/FLINK-3928 Project: Flink Issue Type: Bug R

Re: ITCases in the Table API

Hey Stephan, thanks for bringing this up! We discussed this situation with Fabian a while ago and I saw that he has now updated FLINK-3656 regarding this. If nobody picks this up sooner, I can help with reworking the tests next week. Cheers, -V. On 18 May 2016 at 10:23, Stephan Ewen wrote: > H

[jira] [Created] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

Eron Wright created FLINK-3929: --- Summary: Support for Kerberos Authentication with Keytab Credential Key: FLINK-3929 URL: https://issues.apache.org/jira/browse/FLINK-3929 Project: Flink Issue

[jira] [Created] (FLINK-3930) Implement Service-Level Authorization

Eron Wright created FLINK-3930: --- Summary: Implement Service-Level Authorization Key: FLINK-3930 URL: https://issues.apache.org/jira/browse/FLINK-3930 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-3931) Implement Transport Encryption (SSL/TLS)

Eron Wright created FLINK-3931: --- Summary: Implement Transport Encryption (SSL/TLS) Key: FLINK-3931 URL: https://issues.apache.org/jira/browse/FLINK-3931 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-3932) Implement State Backend Security

Eron Wright created FLINK-3932: --- Summary: Implement State Backend Security Key: FLINK-3932 URL: https://issues.apache.org/jira/browse/FLINK-3932 Project: Flink Issue Type: New Feature

Re: Partition problem

Thank you both for your time, we've bumped it to a further version since it was an optimization of what we currently have (a working Mahout-on-flink), and we need to release Mahout 0.12.1. Andy From: Till Rohrmann Sent: Tuesday, May 17, 2016 8:52:51 AM T

Re: [DISCUSS] Secure Flink clusters

Update, the following issues were filed: - [FLINK-3929] Support for Kerberos Authentication with Keytab Credential - [FLINK-3930] Implement Service-Level Authorization - [FLINK-3931] Implement Transport Encryption (SSL/TLS) - [FLINK-3932] Implement State Backend Security > On May 17, 2016, at 11: