[jira] [Created] (FLINK-9343) Add Async Example with External Rest API call

2018-05-11 Thread Yazdan Shirvany (JIRA)
Yazdan Shirvany created FLINK-9343: -- Summary: Add Async Example with External Rest API call Key: FLINK-9343 URL: https://issues.apache.org/jira/browse/FLINK-9343 Project: Flink Issue Type: I

[jira] [Created] (FLINK-9342) conflicted url path pattern about SubtaskCurrentAttemptDetailsHeaders and AggregatedSubtaskMetricsHeaders

2018-05-11 Thread vinoyang (JIRA)
vinoyang created FLINK-9342: --- Summary: conflicted url path pattern about SubtaskCurrentAttemptDetailsHeaders and AggregatedSubtaskMetricsHeaders Key: FLINK-9342 URL: https://issues.apache.org/jira/browse/FLINK-9342

[jira] [Created] (FLINK-9341) Oracle: "Type is not supported: Date"

2018-05-11 Thread Ken Geis (JIRA)
Ken Geis created FLINK-9341: --- Summary: Oracle: "Type is not supported: Date" Key: FLINK-9341 URL: https://issues.apache.org/jira/browse/FLINK-9341 Project: Flink Issue Type: Bug Component

[jira] [Created] (FLINK-9340) ScheduleOrUpdateConsumersTest may fail with Address already in use

2018-05-11 Thread Ted Yu (JIRA)
Ted Yu created FLINK-9340: - Summary: ScheduleOrUpdateConsumersTest may fail with Address already in use Key: FLINK-9340 URL: https://issues.apache.org/jira/browse/FLINK-9340 Project: Flink Issue Typ

[DISCUSS] Configuration for local recovery

2018-05-11 Thread Stephan Ewen
Hi! The configuration option (in flink-conf.yaml) for local recovery is currently an enumeration with the values "DISABLED" and "ENABLE_FILE_BASED". I would suggest to change that, for a few reasons: - Having values like "ENABLE_FILE_BASED" breaks with the style of the other config options. Ha

[jira] [Created] (FLINK-9339) Accumulators are not UI accessible running in FLIP-6 mode

2018-05-11 Thread Cliff Resnick (JIRA)
Cliff Resnick created FLINK-9339: Summary: Accumulators are not UI accessible running in FLIP-6 mode Key: FLINK-9339 URL: https://issues.apache.org/jira/browse/FLINK-9339 Project: Flink Issue

Re: [DISCUSS] Service Authorization (redux)

2018-05-11 Thread Stephan Ewen
Hi! Reviving this thread, thank you, Eron, for starting this and for the preparation of the FLIP. I am sharing some thoughts below, and some input based on what has changed with FLIP-6 and the evolution of queryable state. Best, Stephan --- *Internal vs. External Con

Re: KPL in current stable 1.4.2 and below, upcoming problem

2018-05-11 Thread Bowen Li
Thanks, this is a great heads-up! Flink 1.4 is using KPL 0.12.5, *so Flink version 1.4 or below will be effected.* Kinesis sink is in flink-kinesis-connector. Good news is that whoever is using flink-kinesis-connector right now is building it themself, because Flink doesn't publish that jar into

[jira] [Created] (FLINK-9337) Implement AvroDeserializationSchema

2018-05-11 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-9337: --- Summary: Implement AvroDeserializationSchema Key: FLINK-9337 URL: https://issues.apache.org/jira/browse/FLINK-9337 Project: Flink Issue Type: New Featu

[jira] [Created] (FLINK-9338) Implement RegistryAvroDeserializationSchema

2018-05-11 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-9338: --- Summary: Implement RegistryAvroDeserializationSchema Key: FLINK-9338 URL: https://issues.apache.org/jira/browse/FLINK-9338 Project: Flink Issue Type: N

[jira] [Created] (FLINK-9336) Queryable state fails with Exception after task manager restore

2018-05-11 Thread Florian Schmidt (JIRA)
Florian Schmidt created FLINK-9336: -- Summary: Queryable state fails with Exception after task manager restore Key: FLINK-9336 URL: https://issues.apache.org/jira/browse/FLINK-9336 Project: Flink

REMINDER: Apache EU Roadshow 2018 schedule announced!

2018-05-11 Thread sharan
Hello Apache Supporters and Enthusiasts This is a reminder that the schedule for the Apache EU Roadshow 2018 in Berlin has been announced. http://apachecon.com/euroadshow18/schedule.html Please note that we will not be running an ApacheCon in Europe this year which means that this Apache EU

Re: [VOTE] Release 1.5.0, release candidate #2

2018-05-11 Thread Stephan Ewen
@TedYu - looks like a port collision in the testing setup. Will look into that, but I would not consider that a release blocker. On Fri, May 11, 2018 at 5:16 AM, Tzu-Li (Gordon) Tai wrote: > Hi Bowen, > > Thanks for bringing this up! > > Yes, I think we should definitely always test the Kinesis

[jira] [Created] (FLINK-9335) Expose client logs via Flink UI

2018-05-11 Thread Juho Autio (JIRA)
Juho Autio created FLINK-9335: - Summary: Expose client logs via Flink UI Key: FLINK-9335 URL: https://issues.apache.org/jira/browse/FLINK-9335 Project: Flink Issue Type: Improvement R

[jira] [Created] (FLINK-9334) Docs to have a code snippet of Kafka partition discovery

2018-05-11 Thread Juho Autio (JIRA)
Juho Autio created FLINK-9334: - Summary: Docs to have a code snippet of Kafka partition discovery Key: FLINK-9334 URL: https://issues.apache.org/jira/browse/FLINK-9334 Project: Flink Issue Type: