[jira] [Created] (FLINK-12249) Type equivalence check fails for Window Aggregates

2019-04-18 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-12249: Summary: Type equivalence check fails for Window Aggregates Key: FLINK-12249 URL: https://issues.apache.org/jira/browse/FLINK-12249 Project: Flink Is

Re: [DISCUSS] [FLINK SQL] External catalog for Confluent Kafka

2019-04-18 Thread Timo Walther
Hi Artsem, having a catalog support for Confluent Schema Registry would be a great addition. Although the implementation of FLIP-30 is still ongoing, we merged the stable interfaces today [0]. This should unblock people from contributing new catalog implementations. So you could already start

Re: [DISCUSS] FLIP-37: Rework of the Table API Type System (Part 1)

2019-04-18 Thread Timo Walther
Hi everyone, thanks for the valuable feedback I got so far. I updated the design document at different positions due to the comments I got online and offline. In general, the feedback was very positive. It seems there is consensus to perform a big rework of the type system with a better long

[jira] [Created] (FLINK-12250) Rewrite assembleNewPartPath to let it return a new PartPath

2019-04-18 Thread Fokko Driesprong (JIRA)
Fokko Driesprong created FLINK-12250: Summary: Rewrite assembleNewPartPath to let it return a new PartPath Key: FLINK-12250 URL: https://issues.apache.org/jira/browse/FLINK-12250 Project: Flink

[jira] [Created] (FLINK-12251) Rework the Table API & SQL type system

2019-04-18 Thread Timo Walther (JIRA)
Timo Walther created FLINK-12251: Summary: Rework the Table API & SQL type system Key: FLINK-12251 URL: https://issues.apache.org/jira/browse/FLINK-12251 Project: Flink Issue Type: Improvemen

[jira] [Created] (FLINK-12252) Support not escaped table name for External Catalogs in INSERT SQL statement

2019-04-18 Thread Artsem Semianenka (JIRA)
Artsem Semianenka created FLINK-12252: - Summary: Support not escaped table name for External Catalogs in INSERT SQL statement Key: FLINK-12252 URL: https://issues.apache.org/jira/browse/FLINK-12252

[jira] [Created] (FLINK-12253) Setup a class hierarchy for the new type system

2019-04-18 Thread Timo Walther (JIRA)
Timo Walther created FLINK-12253: Summary: Setup a class hierarchy for the new type system Key: FLINK-12253 URL: https://issues.apache.org/jira/browse/FLINK-12253 Project: Flink Issue Type: S

[jira] [Created] (FLINK-12254) Expose the new type system through the API

2019-04-18 Thread Timo Walther (JIRA)
Timo Walther created FLINK-12254: Summary: Expose the new type system through the API Key: FLINK-12254 URL: https://issues.apache.org/jira/browse/FLINK-12254 Project: Flink Issue Type: Sub-ta

Re: [DISCUSS] Apache Flink at Season of Docs

2019-04-18 Thread jincheng sun
Hi Konstantin&all, The blog post is released, please see https://flink.apache.org/news/2019/04/17/sod.html And I think is better to spread the word by https://twitter.com/ApacheFlink, but I found that only PMC can manage and publish messages. Help spread the word here: https://twitter.com/sunji

I want to subscribe Flink mail group

2019-04-18 Thread Armstrong
Thanks a lot

Re: I want to subscribe Flink mail group

2019-04-18 Thread Fan Liya
If you only want to subscribe to the mail group, send a message to dev-subscr...@flink.apache.org If you want to be a flink contributor, please provide your apache account. Best, Liya Fan On Thu, Apr 18, 2019 at 7:50 PM Armstrong wrote: > Thanks a lot >

Re: [Discuss] Add JobListener (hook) in flink job lifecycle

2019-04-18 Thread Till Rohrmann
Thanks for starting this discussion Jeff. I can see the need for additional hooks for third party integrations. The thing I'm wondering is whether we really need/want to expose a JobListener via the ExecutionEnvironment. The ExecutionEnvironment is usually used by the user who writes the code and

HA lock nodes, Checkpoints, and JobGraphs after failure

2019-04-18 Thread dyana . rose
Flink v1.7.1 After a Flink reboot we've been seeing some unexpected issues with excess retained checkpoints not being able to be removed from ZooKeeper after a new checkpoint is created. I believe I've got my head around the role of ZK and lockNodes in Checkpointing after going through the cod

[jira] [Created] (FLINK-12255) Rename a few exception class names that were migrated from scala

2019-04-18 Thread Xuefu Zhang (JIRA)
Xuefu Zhang created FLINK-12255: --- Summary: Rename a few exception class names that were migrated from scala Key: FLINK-12255 URL: https://issues.apache.org/jira/browse/FLINK-12255 Project: Flink

Apply for contributor permission

2019-04-18 Thread peng2251
Hi, I want to contribute to Apache Flink. Would you please give me the contributor permission? My JIRA ID is TonySu. Thanks.

[jira] [Created] (FLINK-12256) Implement KafkaReadableCatalog

2019-04-18 Thread Artsem Semianenka (JIRA)
Artsem Semianenka created FLINK-12256: - Summary: Implement KafkaReadableCatalog Key: FLINK-12256 URL: https://issues.apache.org/jira/browse/FLINK-12256 Project: Flink Issue Type: New Feat

Re: [DISCUSS] [FLINK SQL] External catalog for Confluent Kafka

2019-04-18 Thread Artsem Semianenka
Thank you guys so much! You provided me a lot of helpful information. I've created the Jira ticket[1] and added to it an initial description only with the main purpose of the new feature. More detailed implementation description will be added further. Hi Rong, to tell the truth, my first idea was

Re: [DISCUSS] [FLINK SQL] External catalog for Confluent Kafka

2019-04-18 Thread Artsem Semianenka
Sorry guys I've attached the wrong link for Jira ticket in the previous email. This is the correct link : https://issues.apache.org/jira/browse/FLINK-12256 On Thu, 18 Apr 2019 at 18:29, Artsem Semianenka wrote: > Thank you guys so much! > > You provided me a lot of helpful information. > I've cr

[jira] [Created] (FLINK-12257) Convert CatalogBaseTable to org.apache.calcite.schema.Table so that planner can use unified catalog APIs

2019-04-18 Thread Bowen Li (JIRA)
Bowen Li created FLINK-12257: Summary: Convert CatalogBaseTable to org.apache.calcite.schema.Table so that planner can use unified catalog APIs Key: FLINK-12257 URL: https://issues.apache.org/jira/browse/FLINK-12257

[jira] [Created] (FLINK-12258) Decouple CatalogManager with Calcite

2019-04-18 Thread Bowen Li (JIRA)
Bowen Li created FLINK-12258: Summary: Decouple CatalogManager with Calcite Key: FLINK-12258 URL: https://issues.apache.org/jira/browse/FLINK-12258 Project: Flink Issue Type: Sub-task C

Re: [DISCUSS] [FLINK SQL] External catalog for Confluent Kafka

2019-04-18 Thread Bowen Li
Great! I linked that JIRA to FLINK-11275 , and put it along with JIRAs for HiveCatalog and GenericHiveMetastoreCatalog. I have some initial thoughts on the solution you described, but I'll wait till a more complete google design doc comes up, sin

[jira] [Created] (FLINK-12259) Improve debuggability of method invocation failures in OptimizerPlanEnvironment

2019-04-18 Thread Gaurav (JIRA)
Gaurav created FLINK-12259: -- Summary: Improve debuggability of method invocation failures in OptimizerPlanEnvironment Key: FLINK-12259 URL: https://issues.apache.org/jira/browse/FLINK-12259 Project: Flink

[jira] [Created] (FLINK-12260) Slot allocation failure by taskmanager registration timeout and race

2019-04-18 Thread Hwanju Kim (JIRA)
Hwanju Kim created FLINK-12260: -- Summary: Slot allocation failure by taskmanager registration timeout and race Key: FLINK-12260 URL: https://issues.apache.org/jira/browse/FLINK-12260 Project: Flink

[jira] [Created] (FLINK-12261) Support e2e group window in blink batch

2019-04-18 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-12261: Summary: Support e2e group window in blink batch Key: FLINK-12261 URL: https://issues.apache.org/jira/browse/FLINK-12261 Project: Flink Issue Type: New Featu

[jira] [Created] (FLINK-12262) Benefit of Watching TV Shows on the YesMovies Website

2019-04-18 Thread Sansa Stark (JIRA)
Sansa Stark created FLINK-12262: --- Summary: Benefit of Watching TV Shows on the YesMovies Website Key: FLINK-12262 URL: https://issues.apache.org/jira/browse/FLINK-12262 Project: Flink Issue Typ

[jira] [Created] (FLINK-12263) Remove SINGLE_VALUE aggregate function from physical plan

2019-04-18 Thread Jark Wu (JIRA)
Jark Wu created FLINK-12263: --- Summary: Remove SINGLE_VALUE aggregate function from physical plan Key: FLINK-12263 URL: https://issues.apache.org/jira/browse/FLINK-12263 Project: Flink Issue Type: N