[jira] [Created] (FLINK-10039) FlinkKafkaProducer - Serializer Error

2018-08-02 Thread Akshay Nagpal (JIRA)
Akshay Nagpal created FLINK-10039: - Summary: FlinkKafkaProducer - Serializer Error Key: FLINK-10039 URL: https://issues.apache.org/jira/browse/FLINK-10039 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-10038) Parallel the creation of InputSplit if necessary

2018-08-02 Thread JIRA
陈梓立 created FLINK-10038: --- Summary: Parallel the creation of InputSplit if necessary Key: FLINK-10038 URL: https://issues.apache.org/jira/browse/FLINK-10038 Project: Flink Issue Type: Improvement Af

[jira] [Created] (FLINK-10037) Document details event time behavior in a single location

2018-08-02 Thread Elias Levy (JIRA)
Elias Levy created FLINK-10037: -- Summary: Document details event time behavior in a single location Key: FLINK-10037 URL: https://issues.apache.org/jira/browse/FLINK-10037 Project: Flink Issue T

[jira] [Created] (FLINK-10036) Flink's CSV output format is not consistent with the standard.

2018-08-02 Thread Caizhi Weng (JIRA)
Caizhi Weng created FLINK-10036: --- Summary: Flink's CSV output format is not consistent with the standard. Key: FLINK-10036 URL: https://issues.apache.org/jira/browse/FLINK-10036 Project: Flink

[jira] [Created] (FLINK-10035) ConcurrentModificationException with flink-metrics-slf4j

2018-08-02 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-10035: --- Summary: ConcurrentModificationException with flink-metrics-slf4j Key: FLINK-10035 URL: https://issues.apache.org/jira/browse/FLINK-10035 Project: Flink Issue

[jira] [Created] (FLINK-10034) Update community page

2018-08-02 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-10034: Summary: Update community page Key: FLINK-10034 URL: https://issues.apache.org/jira/browse/FLINK-10034 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-10033) Let Task release reference to Invokable on shutdown

2018-08-02 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-10033: Summary: Let Task release reference to Invokable on shutdown Key: FLINK-10033 URL: https://issues.apache.org/jira/browse/FLINK-10033 Project: Flink Issue Typ

[jira] [Created] (FLINK-10032) Flink SQL DATE_FORMAT Function throw Exception in SQL CLI

2018-08-02 Thread Rann Tao (JIRA)
Rann Tao created FLINK-10032: Summary: Flink SQL DATE_FORMAT Function throw Exception in SQL CLI Key: FLINK-10032 URL: https://issues.apache.org/jira/browse/FLINK-10032 Project: Flink Issue Type:

[jira] [Created] (FLINK-10031) Support handling late events in Table API & SQL

2018-08-02 Thread Timo Walther (JIRA)
Timo Walther created FLINK-10031: Summary: Support handling late events in Table API & SQL Key: FLINK-10031 URL: https://issues.apache.org/jira/browse/FLINK-10031 Project: Flink Issue Type: B

[jira] [Created] (FLINK-10030) zookeeper jobgraphs job info cannot be removed when the job is cancelled with zk ha mode

2018-08-02 Thread qiang.li (JIRA)
qiang.li created FLINK-10030: Summary: zookeeper jobgraphs job info cannot be removed when the job is cancelled with zk ha mode Key: FLINK-10030 URL: https://issues.apache.org/jira/browse/FLINK-10030 Proj

[jira] [Created] (FLINK-10029) Refactor the code for better separation of concerns.

2018-08-02 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-10029: -- Summary: Refactor the code for better separation of concerns. Key: FLINK-10029 URL: https://issues.apache.org/jira/browse/FLINK-10029 Project: Flink Issu

[jira] [Created] (FLINK-10028) Introduce ByteArrayData[Input|Output]View

2018-08-02 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-10028: -- Summary: Introduce ByteArrayData[Input|Output]View Key: FLINK-10028 URL: https://issues.apache.org/jira/browse/FLINK-10028 Project: Flink Issue Type: Imp

[jira] [Created] (FLINK-10027) Add logging to the StreamingFileSink

2018-08-02 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-10027: -- Summary: Add logging to the StreamingFileSink Key: FLINK-10027 URL: https://issues.apache.org/jira/browse/FLINK-10027 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-10026) Integrate heap based timers in RocksDB backend with incremental checkpoints

2018-08-02 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-10026: -- Summary: Integrate heap based timers in RocksDB backend with incremental checkpoints Key: FLINK-10026 URL: https://issues.apache.org/jira/browse/FLINK-10026 Proje

[jira] [Created] (FLINK-10025) Add getCheckpointConfig API for PythonStreamExecutionEnvironment

2018-08-02 Thread vinoyang (JIRA)
vinoyang created FLINK-10025: Summary: Add getCheckpointConfig API for PythonStreamExecutionEnvironment Key: FLINK-10025 URL: https://issues.apache.org/jira/browse/FLINK-10025 Project: Flink Iss

[jira] [Created] (FLINK-10024) Test enable_checkpoint python API

2018-08-02 Thread vinoyang (JIRA)
vinoyang created FLINK-10024: Summary: Test enable_checkpoint python API Key: FLINK-10024 URL: https://issues.apache.org/jira/browse/FLINK-10024 Project: Flink Issue Type: Sub-task Comp

[jira] [Created] (FLINK-10023) Enhance Python API for streaming

2018-08-02 Thread vinoyang (JIRA)
vinoyang created FLINK-10023: Summary: Enhance Python API for streaming Key: FLINK-10023 URL: https://issues.apache.org/jira/browse/FLINK-10023 Project: Flink Issue Type: Task Component

[jira] [Created] (FLINK-10022) Add metrics for input/output buffers

2018-08-02 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-10022: --- Summary: Add metrics for input/output buffers Key: FLINK-10022 URL: https://issues.apache.org/jira/browse/FLINK-10022 Project: Flink Issue Type: Improvement

Re: [apache/flink-web] One of your dependencies may have a security vulnerability

2018-08-02 Thread Fabian Hueske
I've filed this under FLINK-10007 [1]. Cheers, Fabian [1] https://issues.apache.org/jira/browse/FLINK-10007 2018-08-02 11:10 GMT+02:00 Ufuk Celebi : > We fixed this for the Flink docs a while back in > https://github.com/apache/flink/pull/5395, but didn't think of the > flink-web repo which use

Re: [apache/flink-web] One of your dependencies may have a security vulnerability

2018-08-02 Thread Ufuk Celebi
We fixed this for the Flink docs a while back in https://github.com/apache/flink/pull/5395, but didn't think of the flink-web repo which uses a similar setup to our docs. If somebody has time to look into this, we can follow the above PR to apply the same changes. – Ufuk On Fri, Jul 27, 2018 at

[jira] [Created] (FLINK-10021) All-round E2E tests query metric with wrong operator name

2018-08-02 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-10021: Summary: All-round E2E tests query metric with wrong operator name Key: FLINK-10021 URL: https://issues.apache.org/jira/browse/FLINK-10021 Project: Flink

Re: [HELP] Bisect

2018-08-02 Thread 陈梓立
I think I find it at https://github.com/apache/flink/commit/4e616a8362744c15a71e0e57ad68fbb52266c837 Thanks, tison 陈梓立 于2018年8月2日周四 下午3:14写道： > Hi devs, > > At tag release-1.5.1, I find LOG contains noise like below. > > ``` > 13:58:40,752 INFO > org.apache.flink.runtime.dispatcher.StandaloneDi

[HELP] Bisect

2018-08-02 Thread 陈梓立
Hi devs, At tag release-1.5.1, I find LOG contains noise like below. ``` 13:58:40,752 INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job a18a72a9c335b5cc964f43075418dedc reached globally terminal state FINISHED. 13:58:40,753 INFO org.apache.flink.runtime.minicluster.MiniClu