Re: Flink using Yarn on MapR

2016-11-24 Thread Maximilian Michels
Hi Naveen, The new Kerberos authentication code in Flink assumes that we're running against vanilla Hadoop. The unmodified Hadoop's behavior is to skip a secure login if security is not configured. This is different for the MapR Hadoop version. Thus, we need to make sure we don't perform any logi

[jira] [Created] (FLINK-5158) Handle ZooKeeperCompletedCheckpointStore exceptions in CheckpointCoordinator

2016-11-24 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-5158: Summary: Handle ZooKeeperCompletedCheckpointStore exceptions in CheckpointCoordinator Key: FLINK-5158 URL: https://issues.apache.org/jira/browse/FLINK-5158 Project: F

Move Row, RowInputFormat to core package

2016-11-24 Thread Anton Solovev
Hello, In Scala case classes can store huge count of fields, it's really helpful for reading wide csv files, but It uses only in table api. what about this issue (https://issues.apache.org/jira/browse/FLINK-2186), should we use table api in machine learning library? To solve the issue #readC

Re: [DISCUSS] @Public libraries

2016-11-24 Thread Robert Metzger
In the initial discussion / proposal for interface annotations we decided to annotate only the very core APIs with @Public and give the libraries more freedom to evolve over time. I think we should not have a general rule for the libraries and decide this case-by-case. If you feel that Gelly is mat

[jira] [Created] (FLINK-5157) Extending AllWindow Function Metadata

2016-11-24 Thread Ventura Del Monte (JIRA)
Ventura Del Monte created FLINK-5157: Summary: Extending AllWindow Function Metadata Key: FLINK-5157 URL: https://issues.apache.org/jira/browse/FLINK-5157 Project: Flink Issue Type: New F

Re: [DISCUSS] Make FieldAccessor logic consistent with remaining API

2016-11-24 Thread Márton Balassi
Just a friendly reminder that PR 2094 resolved some of the issue mentioned here, but a bit remains in terms of fully consolidating the semantics. Merging the PR as soon as Travis comes in green. The reminder is documented in [1]. [1] https://issues.apache.org/jira/browse/FLINK-5156 On Thu, Nov 3

[jira] [Created] (FLINK-5156) Consolidate streaming FieldAccessor functionality

2016-11-24 Thread JIRA
Márton Balassi created FLINK-5156: - Summary: Consolidate streaming FieldAccessor functionality Key: FLINK-5156 URL: https://issues.apache.org/jira/browse/FLINK-5156 Project: Flink Issue Type:

[jira] [Created] (FLINK-5155) Deprecate ValueStateDescriptor constructors with default value

2016-11-24 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5155: --- Summary: Deprecate ValueStateDescriptor constructors with default value Key: FLINK-5155 URL: https://issues.apache.org/jira/browse/FLINK-5155 Project: Flink

[jira] [Created] (FLINK-5154) Duplicate TypeSerializer when writing RocksDB Snapshot

2016-11-24 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5154: --- Summary: Duplicate TypeSerializer when writing RocksDB Snapshot Key: FLINK-5154 URL: https://issues.apache.org/jira/browse/FLINK-5154 Project: Flink Is

[jira] [Created] (FLINK-5153) Allow setting custom application tags for Flink on YARN

2016-11-24 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5153: - Summary: Allow setting custom application tags for Flink on YARN Key: FLINK-5153 URL: https://issues.apache.org/jira/browse/FLINK-5153 Project: Flink Issue

[jira] [Created] (FLINK-5152) accepting NullValue for EV in Gelly examples

2016-11-24 Thread wouter ligtenberg (JIRA)
wouter ligtenberg created FLINK-5152: Summary: accepting NullValue for EV in Gelly examples Key: FLINK-5152 URL: https://issues.apache.org/jira/browse/FLINK-5152 Project: Flink Issue Type