[jira] [Created] (FLINK-13418) Avoid InfluxdbReporter to report uncessray tags

Yun Tang created FLINK-13418: Summary: Avoid InfluxdbReporter to report uncessray tags Key: FLINK-13418 URL: https://issues.apache.org/jira/browse/FLINK-13418 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-13417) Bump Zookeeper to 3.5.5

Konstantin Knauf created FLINK-13417: Summary: Bump Zookeeper to 3.5.5 Key: FLINK-13417 URL: https://issues.apache.org/jira/browse/FLINK-13417 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-13416) Refactor documentation of CLI option for yarn cluster mode

vinoyang created FLINK-13416: Summary: Refactor documentation of CLI option for yarn cluster mode Key: FLINK-13416 URL: https://issues.apache.org/jira/browse/FLINK-13416 Project: Flink Issue Type

[jira] [Created] (FLINK-13415) Document how to use hive connector in scala shell

Jeff Zhang created FLINK-13415: -- Summary: Document how to use hive connector in scala shell Key: FLINK-13415 URL: https://issues.apache.org/jira/browse/FLINK-13415 Project: Flink Issue Type: Imp

[jira] [Created] (FLINK-13414) Add support for Scala 2.13

Chaoran Yu created FLINK-13414: -- Summary: Add support for Scala 2.13 Key: FLINK-13414 URL: https://issues.apache.org/jira/browse/FLINK-13414 Project: Flink Issue Type: Task Components:

[jira] [Created] (FLINK-13413) Put flink-table jar under lib folder

Jeff Zhang created FLINK-13413: -- Summary: Put flink-table jar under lib folder Key: FLINK-13413 URL: https://issues.apache.org/jira/browse/FLINK-13413 Project: Flink Issue Type: Improvement

[DISCUSS] FLIP-48: Pluggable Intermediate Result Storage

Hi folks, I would like to start the FLIP discussion thread about the pluggable intermediate result storage. This is phase 2 of FLIP-36: Support Interactive Programming in Flink Skip to end of metadata. While the FLIP-36 provides a default implementation of the intermediate result storage using

[jira] [Created] (FLINK-13412) Test fail on ARM

wangxiyuan created FLINK-13412: -- Summary: Test fail on ARM Key: FLINK-13412 URL: https://issues.apache.org/jira/browse/FLINK-13412 Project: Flink Issue Type: Bug Components: Tests

[jira] [Created] (FLINK-13411) SqlClient swallow the error when fails to submit job

Jeff Zhang created FLINK-13411: -- Summary: SqlClient swallow the error when fails to submit job Key: FLINK-13411 URL: https://issues.apache.org/jira/browse/FLINK-13411 Project: Flink Issue Type:

Re: [ANNOUNCE] Kete Young is now part of the Flink PMC

Thanks everyone! It is really exciting and honored to be part of such a great community. Looking forward to continue to push Flink forward! Best, Kurt On Wed, Jul 24, 2019 at 9:07 AM Becket Qin wrote: > Congrats, Kurt. Well deserved! > > Jiangjie (Becket) Qin > > On Wed, Jul 24, 2019 at 1:11

[jira] [Created] (FLINK-13410) Csv input format does not support LocalDate

Caizhi Weng created FLINK-13410: --- Summary: Csv input format does not support LocalDate Key: FLINK-13410 URL: https://issues.apache.org/jira/browse/FLINK-13410 Project: Flink Issue Type: Test

[jira] [Created] (FLINK-13409) Supported java UDFs in python API

sunjincheng created FLINK-13409: --- Summary: Supported java UDFs in python API Key: FLINK-13409 URL: https://issues.apache.org/jira/browse/FLINK-13409 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-13408) Schedule StandaloneResourceManager.setFailUnfulfillableRequest whenever the leadership is acquired

Andrey Zagrebin created FLINK-13408: --- Summary: Schedule StandaloneResourceManager.setFailUnfulfillableRequest whenever the leadership is acquired Key: FLINK-13408 URL: https://issues.apache.org/jira/browse/FLIN

[ANNOUNCE] The Program of Flink Forward EU 2019 is live

Hi everyone, I'm happy to announce the program of the Flink Forward EU 2019 conference. The conference takes place in the Berlin Congress Center (bcc) from October 7th to 9th. On the first day, we'll have four training sessions [1]: * Apache Flink Developer Training * Apache Flink Operations Trai

[jira] [Created] (FLINK-13407) Fix thread visibility of checked SlotManager.failUnfulfillableRequest in StandaloneResourceManagerTest

Andrey Zagrebin created FLINK-13407: --- Summary: Fix thread visibility of checked SlotManager.failUnfulfillableRequest in StandaloneResourceManagerTest Key: FLINK-13407 URL: https://issues.apache.org/jira/browse/F

[jira] [Created] (FLINK-13406) MetricConfig.getInteger() always returns null

Ori Popowski created FLINK-13406: Summary: MetricConfig.getInteger() always returns null Key: FLINK-13406 URL: https://issues.apache.org/jira/browse/FLINK-13406 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-13405) Translate "Basic API Concepts" page into Chinese

WangHengWei created FLINK-13405: --- Summary: Translate "Basic API Concepts" page into Chinese Key: FLINK-13405 URL: https://issues.apache.org/jira/browse/FLINK-13405 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-13404) Port csv factories & validator from flink-table-planner to flink-csv

godfrey he created FLINK-13404: -- Summary: Port csv factories & validator from flink-table-planner to flink-csv Key: FLINK-13404 URL: https://issues.apache.org/jira/browse/FLINK-13404 Project: Flink

Re: [DISCUSS] Setup a bui...@flink.apache.org mailing list for travis builds

Thanks Robert for helping out that. Best, Jark On Wed, 24 Jul 2019 at 19:16, Robert Metzger wrote: > I've requested the creation of the list, and made Jark, Chesnay and me > moderators of it. > > On Wed, Jul 24, 2019 at 1:12 PM Robert Metzger > wrote: > > > @Jark: Yes, I will request the creat

Re: [DISCUSS] Publish the PyFlink into PyPI

Sorry for chiming in so late. I would be in favor of option #2. I guess that the PMC would need to give the credentials to the release manager for option #1. Hence, the PMC could also add the release manager as a maintainer which makes sure that only the PMC can delete artifacts. Cheers, Till On

Re: [DISCUSS] Setup a bui...@flink.apache.org mailing list for travis builds

I've requested the creation of the list, and made Jark, Chesnay and me moderators of it. On Wed, Jul 24, 2019 at 1:12 PM Robert Metzger wrote: > @Jark: Yes, I will request the creation of a mailing list! > > On Tue, Jul 23, 2019 at 4:48 PM Hugo Louro wrote: > >> +1 >> >> > On Jul 23, 2019, at 6

Re: [DISCUSS] Setup a bui...@flink.apache.org mailing list for travis builds

@Jark: Yes, I will request the creation of a mailing list! On Tue, Jul 23, 2019 at 4:48 PM Hugo Louro wrote: > +1 > > > On Jul 23, 2019, at 6:15 AM, Till Rohrmann wrote: > > > > Good idea Jark. +1 for the proposal. > > > > Cheers, > > Till > > > >> On Tue, Jul 23, 2019 at 1:59 PM Hequn Cheng >

Re: [DISCUSS] Publish the PyFlink into PyPI

Hi all, Thanks for all of your reply! Hi Stephan, thanks for the reply and prove the details we need to pay attention to. such as: Readme and Trademark compliance. Regarding the PyPI account for release, #1 may have some risk that our release package can be deleted by anyone who know the passwor

Re: [DISCUSS] Support temporary tables in SQL API

Hi all, Thank you Xuefu for clarifying your opinion. Now we have 3 votes for both of the options. To conclude this discussion I am willing to change my vote to option 3 as I had only a slight preference towards option 2. Therefore the final results of the poll are as follows: /option #2: 2 votes

[jira] [Created] (FLINK-13403) Correct package name after relocation

godfrey he created FLINK-13403: -- Summary: Correct package name after relocation Key: FLINK-13403 URL: https://issues.apache.org/jira/browse/FLINK-13403 Project: Flink Issue Type: Bug C

Re: Apply for confluence Wiki create and edit permission

Hi Xuannan, I've give you permissions to edit and create wiki pages. Please let me know if it does not work for you. Best, Fabian Am Mi., 24. Juli 2019 um 08:20 Uhr schrieb Xuannan Su : > Hi, > > I’d like to make a FLIP of the pluggable intermediate result storage, > phase 2 of FLIP-36[1]. > >

[jira] [Created] (FLINK-13402) RelOptCluster's constructor can not be accessed when connector dependent both flink-planner and blink-planner

Jingsong Lee created FLINK-13402: Summary: RelOptCluster's constructor can not be accessed when connector dependent both flink-planner and blink-planner Key: FLINK-13402 URL: https://issues.apache.org/jira/browse/

[jira] [Created] (FLINK-13400) Remove Hive and Hadoop dependencies from SQL Client

Timo Walther created FLINK-13400: Summary: Remove Hive and Hadoop dependencies from SQL Client Key: FLINK-13400 URL: https://issues.apache.org/jira/browse/FLINK-13400 Project: Flink Issue Typ

[jira] [Created] (FLINK-13399) Create two separate uber jars for each planner

Jark Wu created FLINK-13399: --- Summary: Create two separate uber jars for each planner Key: FLINK-13399 URL: https://issues.apache.org/jira/browse/FLINK-13399 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-13401) Flink SQL sqlUpdate sql where complex conditional expressions do not take effect

pingle wang created FLINK-13401: --- Summary: Flink SQL sqlUpdate sql where complex conditional expressions do not take effect Key: FLINK-13401 URL: https://issues.apache.org/jira/browse/FLINK-13401 Projec

[jira] [Created] (FLINK-13398) Hive connectory doesn't compile on Java 9

Chesnay Schepler created FLINK-13398: Summary: Hive connectory doesn't compile on Java 9 Key: FLINK-13398 URL: https://issues.apache.org/jira/browse/FLINK-13398 Project: Flink Issue Type:

[jira] [Created] (FLINK-13397) Remove RollingSink

Aljoscha Krettek created FLINK-13397: Summary: Remove RollingSink Key: FLINK-13397 URL: https://issues.apache.org/jira/browse/FLINK-13397 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-13396) Deprecate BucketingSink

Aljoscha Krettek created FLINK-13396: Summary: Deprecate BucketingSink Key: FLINK-13396 URL: https://issues.apache.org/jira/browse/FLINK-13396 Project: Flink Issue Type: Improvement

Re: [DISCUSS] Publish the PyFlink into PyPI

if we ship a binary, we should ship the binary we usually ship, not some highly customized version. On 24/07/2019 05:19, Dian Fu wrote: Hi Stephan & Jeff, Thanks a lot for sharing your thoughts! Regarding the bundled jars, currently only the jars in the flink binary distribution is packaged

Re: [DISCUSS] Support temporary tables in SQL API

Isn’t https://issues.apache.org/jira/browse/FLINK-13279 already a sign that there are surprises for users if we go with option #3? Aljoscha > On 24. Jul 2019, at 00:33, Xuefu Z wrote: > > I favored #3 if that wasn't obvious. > > Usability i

Re: [DISCUSS] Allow at-most-once delivery in case of failures

Hi All, I think using plugins, as Stephan suggested, would be the best way to serve different requirements for difference scenarios, even after they are merged into Flink core. As far as I know, the pluggable shuffle service is ready for use. Failover strategy does not support plugin yet, but it'