[jira] [Created] (FLINK-12782) Show formatted timestamp in Watermark Tab of JM Web UI

2019-06-07 Thread JIRA
Felix Wollschläger created FLINK-12782: -- Summary: Show formatted timestamp in Watermark Tab of JM Web UI Key: FLINK-12782 URL: https://issues.apache.org/jira/browse/FLINK-12782 Project: Flink

[jira] [Created] (FLINK-12781) run job REST api doesn't return complete stack trace for start job failure

2019-06-07 Thread Steven Zhen Wu (JIRA)
Steven Zhen Wu created FLINK-12781: -- Summary: run job REST api doesn't return complete stack trace for start job failure Key: FLINK-12781 URL: https://issues.apache.org/jira/browse/FLINK-12781 Projec

[jira] [Created] (FLINK-12780) use LogicalTypeRoot for type comparison

2019-06-07 Thread Bowen Li (JIRA)
Bowen Li created FLINK-12780: Summary: use LogicalTypeRoot for type comparison Key: FLINK-12780 URL: https://issues.apache.org/jira/browse/FLINK-12780 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-12779) Avoid field conflicts when generate field names for non-composite Typeinformation

2019-06-07 Thread Hequn Cheng (JIRA)
Hequn Cheng created FLINK-12779: --- Summary: Avoid field conflicts when generate field names for non-composite Typeinformation Key: FLINK-12779 URL: https://issues.apache.org/jira/browse/FLINK-12779 Proje

Re: RE: [DISCUSS] Improve Queryable State and introduce a QueryServerProxy component

2019-06-07 Thread yanghua1127
Hi Georgi, Thanks for your feedback. And glad to hear you are using queryable state. I agree that implementation of option 1 is easier than others. However, when we design the new architecture we need to consider more aspects .e.g. scalability. So it seems option 3 is more suitable. Actually, so

[jira] [Created] (FLINK-12778) Fix deriveTableAggRowType bug for non-composite types

2019-06-07 Thread Hequn Cheng (JIRA)
Hequn Cheng created FLINK-12778: --- Summary: Fix deriveTableAggRowType bug for non-composite types Key: FLINK-12778 URL: https://issues.apache.org/jira/browse/FLINK-12778 Project: Flink Issue Typ

Re: HA lock nodes, Checkpoints, and JobGraphs after failure

2019-06-07 Thread dyana . rose
Just wanted to give an update on this. Our ops team and myself independently came to the same conclusion that our ZooKeeper quorum was having syncing issues. After a bit more research, they have updated the initLimit and syncLimit in the quorum configs to: initLimit=10 syncLimit=5 After this c

Re: [DISCUSS] Clean up and reorganize the JIRA components

2019-06-07 Thread Robert Metzger
Hi, Thanks for your explanation. I've added "Benchmarks" and renamed "Runtime / Operators". On Mon, May 20, 2019 at 10:59 AM Piotr Nowojski wrote: > Hi, > > > Concrete operator implementations will then go into the "API / > DataStream"? > > (or "API / DataSet" or Table) > > Afaik, there were som

[jira] [Created] (FLINK-12777) Support CheckpointBarrierHandler in StreamTwoInputSelectableProcessor

2019-06-07 Thread Piotr Nowojski (JIRA)
Piotr Nowojski created FLINK-12777: -- Summary: Support CheckpointBarrierHandler in StreamTwoInputSelectableProcessor Key: FLINK-12777 URL: https://issues.apache.org/jira/browse/FLINK-12777 Project: Fl

RE: [DISCUSS] Improve Queryable State and introduce a QueryServerProxy component

2019-06-07 Thread Georgi Stoyanov
Hi Vino, I was investigating the current architecture and AFAIK the first proposal will be a lot easier to implement, cause currently JM has the information about the states (where, which etc thanks to KvStateLocationRegistry. Correct me if I’m wrong) We are using the feature and it’s indeed no

Re: [DISCUSS] Support Local Aggregation in Flink

2019-06-07 Thread mayo zhang
+ 1 for this feature which is great helpful in product situations and look forward to see it as soon as possible. > 在 2019年6月6日，下午4:58，qianjin Xu 写道： > >> >> hi > > +1 nice work > > best > > forwardxu

[jira] [Created] (FLINK-12776) Ambiguous content in flink-dist NOTICE file

2019-06-07 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-12776: Summary: Ambiguous content in flink-dist NOTICE file Key: FLINK-12776 URL: https://issues.apache.org/jira/browse/FLINK-12776 Project: Flink Issue Typ

[jira] [Created] (FLINK-12775) Bump flink-shaded version to 7.0

2019-06-07 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-12775: Summary: Bump flink-shaded version to 7.0 Key: FLINK-12775 URL: https://issues.apache.org/jira/browse/FLINK-12775 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-12774) Pin version of build-helper-maven plugin

2019-06-07 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-12774: Summary: Pin version of build-helper-maven plugin Key: FLINK-12774 URL: https://issues.apache.org/jira/browse/FLINK-12774 Project: Flink Issue Type: