[jira] [Created] (FLINK-10702) Yarn app is not killed when scala shell is terminated

Jeff Zhang created FLINK-10702: -- Summary: Yarn app is not killed when scala shell is terminated Key: FLINK-10702 URL: https://issues.apache.org/jira/browse/FLINK-10702 Project: Flink Issue Type:

[jira] [Created] (FLINK-10701) Move modern kafka connector module into connector profile

vinoyang created FLINK-10701: Summary: Move modern kafka connector module into connector profile Key: FLINK-10701 URL: https://issues.apache.org/jira/browse/FLINK-10701 Project: Flink Issue Type

[jira] [Created] (FLINK-10700) Remove LegacyStandaloneClusterDescriptor

TisonKun created FLINK-10700: Summary: Remove LegacyStandaloneClusterDescriptor Key: FLINK-10700 URL: https://issues.apache.org/jira/browse/FLINK-10700 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-10699) Create a catalog implementation for persistent Flink meta objects using Hive metastore as a registry

Xuefu Zhang created FLINK-10699: --- Summary: Create a catalog implementation for persistent Flink meta objects using Hive metastore as a registry Key: FLINK-10699 URL: https://issues.apache.org/jira/browse/FLINK-10699

[jira] [Created] (FLINK-10698) Create CatalogManager class manages all external catalogs and temporary meta objects

Xuefu Zhang created FLINK-10698: --- Summary: Create CatalogManager class manages all external catalogs and temporary meta objects Key: FLINK-10698 URL: https://issues.apache.org/jira/browse/FLINK-10698 Pr

[jira] [Created] (FLINK-10697) Create an in-memory catalog that stores Flink's meta objects

Xuefu Zhang created FLINK-10697: --- Summary: Create an in-memory catalog that stores Flink's meta objects Key: FLINK-10697 URL: https://issues.apache.org/jira/browse/FLINK-10697 Project: Flink I

[jira] [Created] (FLINK-10696) Add APIs to ExternalCatalog for views and UDFs

Xuefu Zhang created FLINK-10696: --- Summary: Add APIs to ExternalCatalog for views and UDFs Key: FLINK-10696 URL: https://issues.apache.org/jira/browse/FLINK-10696 Project: Flink Issue Type: Sub-

[jira] [Created] (FLINK-10695) "Cannot load user class" errors should set the underlying ClassNotFoundException as their cause

Max Feng created FLINK-10695: Summary: "Cannot load user class" errors should set the underlying ClassNotFoundException as their cause Key: FLINK-10695 URL: https://issues.apache.org/jira/browse/FLINK-10695

[jira] [Created] (FLINK-10694) ZooKeeperRunningJobsRegistry Cleanup

Mikhail Pryakhin created FLINK-10694: Summary: ZooKeeperRunningJobsRegistry Cleanup Key: FLINK-10694 URL: https://issues.apache.org/jira/browse/FLINK-10694 Project: Flink Issue Type: Bug

Re: [VOTE] Release 1.6.2, release candidate #1

+1 (binding) - Built Flink 1.6.2 from sources and ran all tests - Ran all end-to-end tests - Executed the Jepsen test suite with the Hadoop 2.8 binaries Cheers, Till On Fri, Oct 26, 2018 at 8:12 AM Tzu-Li (Gordon) Tai wrote: > +1 > > - Verified signature and hashes > - Built locally, with Scal

Re: [VOTE] Release 1.5.5, release candidate #1

+1 (binding) - Built Flink 1.5.5 with Scala 2.11.11 and Hadoop 2.8.5 and ran all tests - Ran all end-to-end tests - Executed the Jepsen test suite with the Hadoop 2.8 binaries Cheers, Till On Fri, Oct 26, 2018 at 8:18 AM Tzu-Li (Gordon) Tai wrote: > +1 > > - Built locally, with Scala 2.11, Had

[jira] [Created] (FLINK-10693) Fix Scala EitherSerializer duplication

Stephan Ewen created FLINK-10693: Summary: Fix Scala EitherSerializer duplication Key: FLINK-10693 URL: https://issues.apache.org/jira/browse/FLINK-10693 Project: Flink Issue Type: Bug

Flink POJO type in forAvroRecordClass function of Kafka010AvroTableSource

Hi Team , I am using Flink 1.5.0 and tried to use below code for Kafka consumer in Flink. I need some information for Flink POJO type . KafkaTableSource kf_source = Kafka010AvroTableSource.builder() .forTopic("test-topic") .withKafkaP

[jira] [Created] (FLINK-10692) Harden Confluent schema E2E test

Till Rohrmann created FLINK-10692: - Summary: Harden Confluent schema E2E test Key: FLINK-10692 URL: https://issues.apache.org/jira/browse/FLINK-10692 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-10691) StreamSQL E2E test relies on hadoop

Chesnay Schepler created FLINK-10691: Summary: StreamSQL E2E test relies on hadoop Key: FLINK-10691 URL: https://issues.apache.org/jira/browse/FLINK-10691 Project: Flink Issue Type: Impro

[jira] [Created] (FLINK-10690) Tests leak resources via Files.list

Chesnay Schepler created FLINK-10690: Summary: Tests leak resources via Files.list Key: FLINK-10690 URL: https://issues.apache.org/jira/browse/FLINK-10690 Project: Flink Issue Type: Bug

Re: [DISCUSS] Breaking the Scala API for Scala 2.12 Support

I was wondering about the outcome of this discussion on what it means for our users. In particular: Does this API break only apply to 2.12 users, or also for people using 2.11? On 04.10.2018 17:10, Aljoscha Krettek wrote: Hi, I'm currently working on https://issues.apache.org/jira/browse/FL

[jira] [Created] (FLINK-10689) Port Table API extension points to flink-table-common

Timo Walther created FLINK-10689: Summary: Port Table API extension points to flink-table-common Key: FLINK-10689 URL: https://issues.apache.org/jira/browse/FLINK-10689 Project: Flink Issue T

[jira] [Created] (FLINK-10688) Remove flink-table dependencies from flink-connectors

Timo Walther created FLINK-10688: Summary: Remove flink-table dependencies from flink-connectors Key: FLINK-10688 URL: https://issues.apache.org/jira/browse/FLINK-10688 Project: Flink Issue

[jira] [Created] (FLINK-10687) Make flink-formats Scala-free

Timo Walther created FLINK-10687: Summary: Make flink-formats Scala-free Key: FLINK-10687 URL: https://issues.apache.org/jira/browse/FLINK-10687 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-10686) Introduce a flink-table-common module

Timo Walther created FLINK-10686: Summary: Introduce a flink-table-common module Key: FLINK-10686 URL: https://issues.apache.org/jira/browse/FLINK-10686 Project: Flink Issue Type: Improvement