Discuss about [FLINK-10134] UTF-16 support for TextInputFormat bug fixed

2018-09-27 Thread x1q1j1
dear everyone, I hope to discuss this jira with everyone in order to handle this matter better. Here are some of my thoughts: 1.Where should the BOM be read? I think that when the file is started at the beginning of the file, you still need to increase the logic for

[jira] [Created] (FLINK-10456) Remove org.apache.flink.api.common.time.Deadline

2018-09-27 Thread tison (JIRA)
tison created FLINK-10456: - Summary: Remove org.apache.flink.api.common.time.Deadline Key: FLINK-10456 URL: https://issues.apache.org/jira/browse/FLINK-10456 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-10455) Potential Kafka producer leak in case of failures

2018-09-27 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-10455: --- Summary: Potential Kafka producer leak in case of failures Key: FLINK-10455 URL: https://issues.apache.org/jira/browse/FLINK-10455 Project: Flink Issue Type:

Re: Handling burst I/O when using tumbling/sliding windows

2018-09-27 Thread Rong Rong
HI Piotrek, Yes, to be more clear, 1) the network I/O issue I am referring to is in between Flink and external sink. We did not see issues in between operators. 2) yes we've considered rate limiting sink functions as well which is also mentioned in the doc. along with some of the the pro-con we

[jira] [Created] (FLINK-10454) Travis fails on ScheduleOrUpdateConsumersTest

2018-09-27 Thread tison (JIRA)
tison created FLINK-10454: - Summary: Travis fails on ScheduleOrUpdateConsumersTest Key: FLINK-10454 URL: https://issues.apache.org/jira/browse/FLINK-10454 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-10453) Move hadoop 2.4 travis profile into cron job

2018-09-27 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-10453: Summary: Move hadoop 2.4 travis profile into cron job Key: FLINK-10453 URL: https://issues.apache.org/jira/browse/FLINK-10453 Project: Flink Issue

[jira] [Created] (FLINK-10452) Expose Additional Metrics to Reason about Statesize

2018-09-27 Thread Konstantin Knauf (JIRA)
Konstantin Knauf created FLINK-10452: Summary: Expose Additional Metrics to Reason about Statesize Key: FLINK-10452 URL: https://issues.apache.org/jira/browse/FLINK-10452 Project: Flink

[jira] [Created] (FLINK-10451) TableFunctionCollector should handle the life cycle of ScalarFunction

2018-09-27 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-10451: -- Summary: TableFunctionCollector should handle the life cycle of ScalarFunction Key: FLINK-10451 URL: https://issues.apache.org/jira/browse/FLINK-10451 Project: Flink

[jira] [Created] (FLINK-10450) Broken links in the documentation

2018-09-27 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-10450: Summary: Broken links in the documentation Key: FLINK-10450 URL: https://issues.apache.org/jira/browse/FLINK-10450 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-10449) Docker flink hostname is locked to "cluster"

2018-09-27 Thread Mike Pedersen (JIRA)
Mike Pedersen created FLINK-10449: - Summary: Docker flink hostname is locked to "cluster" Key: FLINK-10449 URL: https://issues.apache.org/jira/browse/FLINK-10449 Project: Flink Issue Type:

Re: Codespeed deployment for Flink

2018-09-27 Thread Till Rohrmann
Great addition Piotr and Nico. This is a really nice tool for the community to monitor performance regressions in Flink. On Tue, Sep 25, 2018 at 8:41 PM Peter Huang wrote: > It is a great tool. Thanks for the contribution. > > On Tue, Sep 25, 2018 at 11:39 AM Jin Sun wrote: > > > Great tool! >

[jira] [Created] (FLINK-10448) VALUES clause is translated into a separate operator per value

2018-09-27 Thread Timo Walther (JIRA)
Timo Walther created FLINK-10448: Summary: VALUES clause is translated into a separate operator per value Key: FLINK-10448 URL: https://issues.apache.org/jira/browse/FLINK-10448 Project: Flink

[jira] [Created] (FLINK-10447) Create Bucketing Table Sink.

2018-09-27 Thread Suxing Lee (JIRA)
Suxing Lee created FLINK-10447: -- Summary: Create Bucketing Table Sink. Key: FLINK-10447 URL: https://issues.apache.org/jira/browse/FLINK-10447 Project: Flink Issue Type: New Feature

Re: Handling burst I/O when using tumbling/sliding windows

2018-09-27 Thread Piotr Nowojski
Hi, Thanks for the proposal. Could you provide more background/explanation/motivation why do you need such feature? What do you mean by “network I/O” degradation? On it’s own burst writes shouldn’t cause problems within Flink. If they do, we might want to fix the original underlying problem