[jira] [Created] (FLINK-11709) Bump jline version

2019-02-20 Thread xueyu (JIRA)
xueyu created FLINK-11709: - Summary: Bump jline version Key: FLINK-11709 URL: https://issues.apache.org/jira/browse/FLINK-11709 Project: Flink Issue Type: Improvement Components: SQL

Re: Contributor Request

2019-02-20 Thread Fabian Hueske
Hi, Welcome to the Flink community. I've given you contributor permissions for Jira. Best, Fabian Am Mi., 20. Feb. 2019 um 17:14 Uhr schrieb Kenny Deng < denggeng2...@gmail.com>: > Hi, > > I want to contribute to Apache Flink. > Would you please give me the contributor permission? > My JIRA ID

Re: [DISCUSS] Improve the flinkbot

2019-02-20 Thread jincheng sun
Hi @Robert Metzger the colors of the emojis is not very important. I think is enough if we can express the intentions clear. +1 for alternative2, but for the corresponding pictures, if need I can look for visual design classmates to help. what do you think? Best, Jincheng Robert Metzger

[jira] [Created] (FLINK-11708) There is a big chance that a taskExecutor starts another RegistrationTimeout after successfully registered at RM

2019-02-20 Thread Kai Chen (JIRA)
Kai Chen created FLINK-11708: Summary: There is a big chance that a taskExecutor starts another RegistrationTimeout after successfully registered at RM Key: FLINK-11708 URL:

[jira] [Created] (FLINK-11707) Make InputGate interface extend AutoCloseable

2019-02-20 Thread zhijiang (JIRA)
zhijiang created FLINK-11707: Summary: Make InputGate interface extend AutoCloseable Key: FLINK-11707 URL: https://issues.apache.org/jira/browse/FLINK-11707 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-11706) Add the SumFunction to support KeyedStream.sum with field which is array

2019-02-20 Thread wangpeibin (JIRA)
wangpeibin created FLINK-11706: -- Summary: Add the SumFunction to support KeyedStream.sum with field which is array Key: FLINK-11706 URL: https://issues.apache.org/jira/browse/FLINK-11706 Project: Flink

[jira] [Created] (FLINK-11705) remove org.apache.flink.runtime.testingUtils.TestingUtils

2019-02-20 Thread Shimin Yang (JIRA)
Shimin Yang created FLINK-11705: --- Summary: remove org.apache.flink.runtime.testingUtils.TestingUtils Key: FLINK-11705 URL: https://issues.apache.org/jira/browse/FLINK-11705 Project: Flink

[jira] [Created] (FLINK-11704) Improve AbstractCheckpointStateOutputStreamTestBase with Parameterized

2019-02-20 Thread Congxian Qiu(klion26) (JIRA)
Congxian Qiu(klion26) created FLINK-11704: - Summary: Improve AbstractCheckpointStateOutputStreamTestBase with Parameterized Key: FLINK-11704 URL: https://issues.apache.org/jira/browse/FLINK-11704

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

2019-02-20 Thread shengjk1
+1 for the vote Also agree with Chesnay Schepler. There area few minor things I just noticed, except as mentioned in the Chesnay Schepler email: * "Scala Shell" is to be renamed to "Scala Shell", but it should say keep Best, Shengjk1 On 02/20/2019 18:31,Chesnay Schepler wrote: There

[jira] [Created] (FLINK-11703) Add a basic framework for Blink SQL

2019-02-20 Thread Jark Wu (JIRA)
Jark Wu created FLINK-11703: --- Summary: Add a basic framework for Blink SQL Key: FLINK-11703 URL: https://issues.apache.org/jira/browse/FLINK-11703 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-11702) Introduce a new table type system: InternalType

2019-02-20 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-11702: Summary: Introduce a new table type system: InternalType Key: FLINK-11702 URL: https://issues.apache.org/jira/browse/FLINK-11702 Project: Flink Issue Type:

[jira] [Created] (FLINK-11701) Introduce an abstract set of data formats

2019-02-20 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-11701: Summary: Introduce an abstract set of data formats Key: FLINK-11701 URL: https://issues.apache.org/jira/browse/FLINK-11701 Project: Flink Issue Type: New

[jira] [Created] (FLINK-11700) mvn package field

2019-02-20 Thread suyuan19 (JIRA)
suyuan19 created FLINK-11700: Summary: mvn package field Key: FLINK-11700 URL: https://issues.apache.org/jira/browse/FLINK-11700 Project: Flink Issue Type: Bug Components: Build System

[jira] [Created] (FLINK-11699) Should use `String.equals()` instead of `==` for String compares in AbstractDispatcherResourceManagerComponentFactory.getHostname()

2019-02-20 Thread Benchao Li (JIRA)
Benchao Li created FLINK-11699: -- Summary: Should use `String.equals()` instead of `==` for String compares in AbstractDispatcherResourceManagerComponentFactory.getHostname() Key: FLINK-11699 URL:

[jira] [Created] (FLINK-11697) Add readMapReduceTextFile API for HadoopInputs

2019-02-20 Thread vinoyang (JIRA)
vinoyang created FLINK-11697: Summary: Add readMapReduceTextFile API for HadoopInputs Key: FLINK-11697 URL: https://issues.apache.org/jira/browse/FLINK-11697 Project: Flink Issue Type:

[jira] [Created] (FLINK-11698) Add readMapRedTextFile API for HadoopInputs

2019-02-20 Thread vinoyang (JIRA)
vinoyang created FLINK-11698: Summary: Add readMapRedTextFile API for HadoopInputs Key: FLINK-11698 URL: https://issues.apache.org/jira/browse/FLINK-11698 Project: Flink Issue Type: Improvement

Re: [DISCUSS] FLIP-33: Standardize connector metrics

2019-02-20 Thread Becket Qin
Bump. If there is no objections to the proposed metrics. I'll start a voting thread later toady. Thanks, Jiangjie (Becket) Qin On Mon, Feb 11, 2019 at 8:17 PM Becket Qin wrote: > Hi folks, > > I would like to start the FLIP discussion thread about standardize the > connector metrics. > > In

Re: [DISCUSS] Improve the flinkbot

2019-02-20 Thread Jark Wu
I also prefer alternative 2. Instead of using an emoji ( ❓) , can we just use the "?" character ? For example: review=description? IMO, this will be more clear that the description has not been approved than "review=description". Thanks, Jark On Wed, 20 Feb 2019 at 22:15, Chesnay Schepler

[jira] [Created] (FLINK-11696) [checkpoint] Avoid to send mkdir requests to DFS from task side

2019-02-20 Thread Yun Tang (JIRA)
Yun Tang created FLINK-11696: Summary: [checkpoint] Avoid to send mkdir requests to DFS from task side Key: FLINK-11696 URL: https://issues.apache.org/jira/browse/FLINK-11696 Project: Flink

[jira] [Created] (FLINK-11695) [checkpoint] Make sharedStateDir could create sub-directories to avoid MaxDirectoryItemsExceededException

2019-02-20 Thread Yun Tang (JIRA)
Yun Tang created FLINK-11695: Summary: [checkpoint] Make sharedStateDir could create sub-directories to avoid MaxDirectoryItemsExceededException Key: FLINK-11695 URL: https://issues.apache.org/jira/browse/FLINK-11695

Contributor Request

2019-02-20 Thread Kenny Deng
Hi, I want to contribute to Apache Flink. Would you please give me the contributor permission? My JIRA ID is denggeng.

[jira] [Created] (FLINK-11694) Enforce space before left curly brace

2019-02-20 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-11694: Summary: Enforce space before left curly brace Key: FLINK-11694 URL: https://issues.apache.org/jira/browse/FLINK-11694 Project: Flink Issue Type:

[jira] [Created] (FLINK-11693) Add KafkaSerializationSchema that directly uses ProducerRecord

2019-02-20 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-11693: Summary: Add KafkaSerializationSchema that directly uses ProducerRecord Key: FLINK-11693 URL: https://issues.apache.org/jira/browse/FLINK-11693 Project:

[jira] [Created] (FLINK-11692) Add Proxy for DataDog Metric Reporter

2019-02-20 Thread Scott Mitchell (JIRA)
Scott Mitchell created FLINK-11692: -- Summary: Add Proxy for DataDog Metric Reporter Key: FLINK-11692 URL: https://issues.apache.org/jira/browse/FLINK-11692 Project: Flink Issue Type:

[jira] [Created] (FLINK-11691) Introduce ClassLoader in the methods of StateBackendFactory and ConfigurableStateBackend

2019-02-20 Thread Yun Tang (JIRA)
Yun Tang created FLINK-11691: Summary: Introduce ClassLoader in the methods of StateBackendFactory and ConfigurableStateBackend Key: FLINK-11691 URL: https://issues.apache.org/jira/browse/FLINK-11691

Re: [DISCUSS] Improve the flinkbot

2019-02-20 Thread Chesnay Schepler
I prefer alternative 2 as the first is rather ambiguous. The emojis seem unnecessary, the approved label could be shorted to "Approved"; the review prefix isn't necessary here imo. I would stick the green checkmarks as this is consistent with Travis. As another request, we may want to ignore

[jira] [Created] (FLINK-11690) Use configured RPC timeout in MiniCluster

2019-02-20 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-11690: Summary: Use configured RPC timeout in MiniCluster Key: FLINK-11690 URL: https://issues.apache.org/jira/browse/FLINK-11690 Project: Flink Issue

[jira] [Created] (FLINK-11689) Code clean for StreamingJobGraphGenerator

2019-02-20 Thread shiwuliang (JIRA)
shiwuliang created FLINK-11689: -- Summary: Code clean for StreamingJobGraphGenerator Key: FLINK-11689 URL: https://issues.apache.org/jira/browse/FLINK-11689 Project: Flink Issue Type:

[jira] [Created] (FLINK-11688) Enforce whitespace around TYPE_EXTENSION_AND

2019-02-20 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-11688: Summary: Enforce whitespace around TYPE_EXTENSION_AND Key: FLINK-11688 URL: https://issues.apache.org/jira/browse/FLINK-11688 Project: Flink Issue

[jira] [Created] (FLINK-11687) Remove useless code in StreamingJobGraphGenerator

2019-02-20 Thread wangsan (JIRA)
wangsan created FLINK-11687: --- Summary: Remove useless code in StreamingJobGraphGenerator Key: FLINK-11687 URL: https://issues.apache.org/jira/browse/FLINK-11687 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-11686) Enforce spaces around lambdas

2019-02-20 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-11686: Summary: Enforce spaces around lambdas Key: FLINK-11686 URL: https://issues.apache.org/jira/browse/FLINK-11686 Project: Flink Issue Type:

[jira] [Created] (FLINK-11685) Add plan test infrastructure

2019-02-20 Thread godfrey he (JIRA)
godfrey he created FLINK-11685: -- Summary: Add plan test infrastructure Key: FLINK-11685 URL: https://issues.apache.org/jira/browse/FLINK-11685 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-11684) Checkstyle allows multiple empty lines around static imports

2019-02-20 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-11684: Summary: Checkstyle allows multiple empty lines around static imports Key: FLINK-11684 URL: https://issues.apache.org/jira/browse/FLINK-11684 Project: Flink

[jira] [Created] (FLINK-11682) Add abstract source and sink metric classes.

2019-02-20 Thread Jiangjie Qin (JIRA)
Jiangjie Qin created FLINK-11682: Summary: Add abstract source and sink metric classes. Key: FLINK-11682 URL: https://issues.apache.org/jira/browse/FLINK-11682 Project: Flink Issue Type:

[jira] [Created] (FLINK-11683) Implement standard metrics in Kafka connectors.

2019-02-20 Thread Jiangjie Qin (JIRA)
Jiangjie Qin created FLINK-11683: Summary: Implement standard metrics in Kafka connectors. Key: FLINK-11683 URL: https://issues.apache.org/jira/browse/FLINK-11683 Project: Flink Issue Type:

[jira] [Created] (FLINK-11681) Add an AbstractMetric to combine the metric definition and metric management.

2019-02-20 Thread Jiangjie Qin (JIRA)
Jiangjie Qin created FLINK-11681: Summary: Add an AbstractMetric to combine the metric definition and metric management. Key: FLINK-11681 URL: https://issues.apache.org/jira/browse/FLINK-11681

[jira] [Created] (FLINK-11680) make query plan easier to read

2019-02-20 Thread godfrey he (JIRA)
godfrey he created FLINK-11680: -- Summary: make query plan easier to read Key: FLINK-11680 URL: https://issues.apache.org/jira/browse/FLINK-11680 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-11679) Create Blink SQL planner and runtime modules

2019-02-20 Thread Timo Walther (JIRA)
Timo Walther created FLINK-11679: Summary: Create Blink SQL planner and runtime modules Key: FLINK-11679 URL: https://issues.apache.org/jira/browse/FLINK-11679 Project: Flink Issue Type: New

[jira] [Created] (FLINK-11678) Remove suspend logic from ExecutionGraphCache

2019-02-20 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-11678: - Summary: Remove suspend logic from ExecutionGraphCache Key: FLINK-11678 URL: https://issues.apache.org/jira/browse/FLINK-11678 Project: Flink Issue Type:

[jira] [Created] (FLINK-11677) Remove ResourceManagerRunner

2019-02-20 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-11677: - Summary: Remove ResourceManagerRunner Key: FLINK-11677 URL: https://issues.apache.org/jira/browse/FLINK-11677 Project: Flink Issue Type: Improvement

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

2019-02-20 Thread Chesnay Schepler
There area few minor things I just noticed: * "Job-Submission" is to be merged into "Command Line Client", but I'm certain that there are issue in that category that also/only apply to REST. The same applies to Web Client I suppose, which should be primarily about the WebFrontend /

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

2019-02-20 Thread jincheng sun
+1(non-binding) for the proposal. Best, JIncheng Timo Walther 于2019年2月20日周三 下午6:04写道: > +1 > > Thanks for the proposal. > > Timo > > Am 20.02.19 um 10:53 schrieb Robert Metzger: > > Hey all, > > > > As discussed in the last days, I'm proposing to clean up and reorganize > our > > JIRA tickets.

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

2019-02-20 Thread Robert Metzger
+1 Thanks Timo! On Wed, Feb 20, 2019 at 11:04 AM Timo Walther wrote: > +1 > > Thanks for the proposal. > > Timo > > Am 20.02.19 um 10:53 schrieb Robert Metzger: > > Hey all, > > > > As discussed in the last days, I'm proposing to clean up and reorganize > our > > JIRA tickets. > > Chesnay

[jira] [Created] (FLINK-11676) Make ResultPartitionWriter extend AutoCloseable

2019-02-20 Thread zhijiang (JIRA)
zhijiang created FLINK-11676: Summary: Make ResultPartitionWriter extend AutoCloseable Key: FLINK-11676 URL: https://issues.apache.org/jira/browse/FLINK-11676 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-11674) Add an initial Blink SQL code generator

2019-02-20 Thread Kurt Young (JIRA)
Kurt Young created FLINK-11674: -- Summary: Add an initial Blink SQL code generator Key: FLINK-11674 URL: https://issues.apache.org/jira/browse/FLINK-11674 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-11675) Add an initial support for running batch jobs with streaming runtime

2019-02-20 Thread Kurt Young (JIRA)
Kurt Young created FLINK-11675: -- Summary: Add an initial support for running batch jobs with streaming runtime Key: FLINK-11675 URL: https://issues.apache.org/jira/browse/FLINK-11675 Project: Flink

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

2019-02-20 Thread Timo Walther
+1 Thanks for the proposal. Timo Am 20.02.19 um 10:53 schrieb Robert Metzger: Hey all, As discussed in the last days, I'm proposing to clean up and reorganize our JIRA tickets. Chesnay proposed to approve the final proposal through a VOTE. Here is the proposal:

[VOTE] Clean up and reorganize the JIRA components

2019-02-20 Thread Robert Metzger
Hey all, As discussed in the last days, I'm proposing to clean up and reorganize our JIRA tickets. Chesnay proposed to approve the final proposal through a VOTE. Here is the proposal: https://cwiki.apache.org/confluence/display/FLINK/Proposal+for+new+JIRA+Components Please vote with: [ ] +1

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

2019-02-20 Thread Robert Metzger
Thanks a lot Timo! I will start a vote Chesnay! On Wed, Feb 20, 2019 at 10:11 AM Timo Walther wrote: > +1 for the vote. Btw I can help cleaning up the "Table API & SQL" > component. It seems to be the biggest with 1229 Issues. > > Thanks, > Timo > > Am 20.02.19 um 10:09 schrieb Chesnay

Starting contribution, choosing problem

2019-02-20 Thread Александр
Hello everyone! I would like to start contributing, but I have some problems with it. There are small number of tasks with label "newbie/starter" and so on. The most of tasks are just proposals, not a task in general sense. Can anyone help with finding some bugs/improvements with start level in

[jira] [Created] (FLINK-11673) add example for streaming operators's broadcast

2019-02-20 Thread shengjk1 (JIRA)
shengjk1 created FLINK-11673: Summary: add example for streaming operators's broadcast Key: FLINK-11673 URL: https://issues.apache.org/jira/browse/FLINK-11673 Project: Flink Issue Type:

[jira] [Created] (FLINK-11672) Add example for streaming operator connect

2019-02-20 Thread shengjk1 (JIRA)
shengjk1 created FLINK-11672: Summary: Add example for streaming operator connect Key: FLINK-11672 URL: https://issues.apache.org/jira/browse/FLINK-11672 Project: Flink Issue Type: Improvement

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

2019-02-20 Thread Timo Walther
+1 for the vote. Btw I can help cleaning up the "Table API & SQL" component. It seems to be the biggest with 1229 Issues. Thanks, Timo Am 20.02.19 um 10:09 schrieb Chesnay Schepler: I would prefer if you'd start a vote with a new cleaned up proposal. On 18.02.2019 15:23, Robert Metzger

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

2019-02-20 Thread Chesnay Schepler
I would prefer if you'd start a vote with a new cleaned up proposal. On 18.02.2019 15:23, Robert Metzger wrote: I added "Runtime / Configuration" to the proposal: https://cwiki.apache.org/confluence/display/FLINK/Proposal+for+new+JIRA+Components Since this discussion has been open for 10 days,

[jira] [Created] (FLINK-11670) Add SUSPEND/TERMINATE calls to REST API

2019-02-20 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-11670: -- Summary: Add SUSPEND/TERMINATE calls to REST API Key: FLINK-11670 URL: https://issues.apache.org/jira/browse/FLINK-11670 Project: Flink Issue Type:

[jira] [Created] (FLINK-11671) Expose SUSPEND/TERMINATE to CLI

2019-02-20 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-11671: -- Summary: Expose SUSPEND/TERMINATE to CLI Key: FLINK-11671 URL: https://issues.apache.org/jira/browse/FLINK-11671 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-11669) Add Synchronous Checkpoint Triggering RPCs.

2019-02-20 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-11669: -- Summary: Add Synchronous Checkpoint Triggering RPCs. Key: FLINK-11669 URL: https://issues.apache.org/jira/browse/FLINK-11669 Project: Flink Issue Type:

[jira] [Created] (FLINK-11668) Allow sources to advance time to max watermark on checkpoint.

2019-02-20 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-11668: -- Summary: Allow sources to advance time to max watermark on checkpoint. Key: FLINK-11668 URL: https://issues.apache.org/jira/browse/FLINK-11668 Project: Flink

[jira] [Created] (FLINK-11667) Add Synchronous Checkpoint handling in StreamTask

2019-02-20 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-11667: -- Summary: Add Synchronous Checkpoint handling in StreamTask Key: FLINK-11667 URL: https://issues.apache.org/jira/browse/FLINK-11667 Project: Flink Issue