[jira] [Created] (FLINK-12248) Support e2e over window in blink batch

Jingsong Lee created FLINK-12248: Summary: Support e2e over window in blink batch Key: FLINK-12248 URL: https://issues.apache.org/jira/browse/FLINK-12248 Project: Flink Issue Type: New

[jira] [Created] (FLINK-12246) can't get any option from the jobConfiguration of JobGraph

lamber-ken created FLINK-12246: -- Summary: can't get any option from the jobConfiguration of JobGraph Key: FLINK-12246 URL: https://issues.apache.org/jira/browse/FLINK-12246 Project: Flink Issue

[jira] [Created] (FLINK-12247) fix NPE when writing an archive file to a FileSystem

lamber-ken created FLINK-12247: -- Summary: fix NPE when writing an archive file to a FileSystem Key: FLINK-12247 URL: https://issues.apache.org/jira/browse/FLINK-12247 Project: Flink Issue Type:

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

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

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

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:

Re: [DISCUSS] Apache Flink at Season of Docs

Hi Konstantin, 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:

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

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

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

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

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

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:

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

Hi Jeff, I personally like this proposal. From the perspective of programmability, the JobListener can make the third program more appreciable. The scene where I need the listener is the Flink cube engine for Apache Kylin. In the case, the Flink job program is embedded into the Kylin's

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

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-12250) Rewrite assembleNewPartPath to let it return a new PartPath

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

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:

HA lock nodes, Checkpoints, and JobGraphs after failure

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

I want to subscribe Flink mail group

Thanks a lot

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

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

Re: I want to subscribe Flink mail group

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 >

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

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

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

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

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-12259) Improve debuggability of method invocation failures in OptimizerPlanEnvironment

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

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

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,

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

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

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

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

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

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

Apply for contributor permission

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

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

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

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

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

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

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