[jira] [Created] (FLINK-7407) Assumption of partition id strict contiguity is too naive in Kafka consumer's AbstractPartitionDiscoverer

2017-08-09 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-7407: -- Summary: Assumption of partition id strict contiguity is too naive in Kafka consumer's AbstractPartitionDiscoverer Key: FLINK-7407 URL: https://issues.apache.org/jira/

[jira] [Created] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based

2017-08-09 Thread zhijiang (JIRA)
zhijiang created FLINK-7406: --- Summary: Implement Netty receiver incoming pipeline for credit-based Key: FLINK-7406 URL: https://issues.apache.org/jira/browse/FLINK-7406 Project: Flink Issue Type:

Re: Behaviour when a task in a running job fails

2017-08-09 Thread Luis Alves
Hi Till, Awesome! Thanks a lot for your answer!  Currently I don’t have much free time to help with the implementation/contribute to Flink, but for sure I will in a near future! Thanks again,  Luís Alves On Wed, 09 Aug 2017 at 10:29 Till Rohrmann < mailto:Till Rohrmann > wrote: a, pre, cod

[jira] [Created] (FLINK-7405) Reduce excessive warning logging from DatadogHttpReporter

2017-08-09 Thread Bowen Li (JIRA)
Bowen Li created FLINK-7405: --- Summary: Reduce excessive warning logging from DatadogHttpReporter Key: FLINK-7405 URL: https://issues.apache.org/jira/browse/FLINK-7405 Project: Flink Issue Type: Imp

[jira] [Created] (FLINK-7404) Table API batch join code-gen's equi-join conditions

2017-08-09 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-7404: Summary: Table API batch join code-gen's equi-join conditions Key: FLINK-7404 URL: https://issues.apache.org/jira/browse/FLINK-7404 Project: Flink Issue Type

[jira] [Created] (FLINK-7403) Remove expandLocalRef() before code generation

2017-08-09 Thread Timo Walther (JIRA)
Timo Walther created FLINK-7403: --- Summary: Remove expandLocalRef() before code generation Key: FLINK-7403 URL: https://issues.apache.org/jira/browse/FLINK-7403 Project: Flink Issue Type: Improv

[jira] [Created] (FLINK-7402) Ineffective null check in NettyMessage#write()

2017-08-09 Thread Ted Yu (JIRA)
Ted Yu created FLINK-7402: - Summary: Ineffective null check in NettyMessage#write() Key: FLINK-7402 URL: https://issues.apache.org/jira/browse/FLINK-7402 Project: Flink Issue Type: Bug Re

[jira] [Created] (FLINK-7401) EnvironmentInformation.getMaxJvmHeapMemory does not return the value given via -Xmx

2017-08-09 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-7401: -- Summary: EnvironmentInformation.getMaxJvmHeapMemory does not return the value given via -Xmx Key: FLINK-7401 URL: https://issues.apache.org/jira/browse/FLINK-7401 Project

[jira] [Created] (FLINK-7400) off-heap limits set to conservatively in yarn

2017-08-09 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-7400: -- Summary: off-heap limits set to conservatively in yarn Key: FLINK-7400 URL: https://issues.apache.org/jira/browse/FLINK-7400 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-7399) Add checkstyle rule to forbid codehaus jackson imports

2017-08-09 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-7399: --- Summary: Add checkstyle rule to forbid codehaus jackson imports Key: FLINK-7399 URL: https://issues.apache.org/jira/browse/FLINK-7399 Project: Flink Is

[jira] [Created] (FLINK-7398) Table API operators/UDFs must not store Logger

2017-08-09 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-7398: --- Summary: Table API operators/UDFs must not store Logger Key: FLINK-7398 URL: https://issues.apache.org/jira/browse/FLINK-7398 Project: Flink Issue Type

[jira] [Created] (FLINK-7397) Which scheduling mechanism and algorithm used for scheduling Jobs

2017-08-09 Thread saif.aljumaili (JIRA)
saif.aljumaili created FLINK-7397: - Summary: Which scheduling mechanism and algorithm used for scheduling Jobs Key: FLINK-7397 URL: https://issues.apache.org/jira/browse/FLINK-7397 Project: Flink

[jira] [Created] (FLINK-7396) Don't put multiple directories in HADOOP_CONF_DIR in config.sh

2017-08-09 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-7396: --- Summary: Don't put multiple directories in HADOOP_CONF_DIR in config.sh Key: FLINK-7396 URL: https://issues.apache.org/jira/browse/FLINK-7396 Project: Flink

Re: Behaviour when a task in a running job fails

2017-08-09 Thread Till Rohrmann
Hi Luis, Flink's default behaviour is to fail all tasks and then redeploying the tasks with a possible different task to slot mapping. However, we recently introduced the infrastructure for a more fine-grained recovery mechanism. With this infrastructure it will be possible to only restart depend

[jira] [Created] (FLINK-7395) NumBytesOut metric in RecordWriter call synchronized method

2017-08-09 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-7395: --- Summary: NumBytesOut metric in RecordWriter call synchronized method Key: FLINK-7395 URL: https://issues.apache.org/jira/browse/FLINK-7395 Project: Flink