[jira] [Created] (FLINK-8829) Flink in EMR(YARN) is down due to Akka communication issue

Aleksandr Filichkin created FLINK-8829: -- Summary: Flink in EMR(YARN) is down due to Akka communication issue Key: FLINK-8829 URL: https://issues.apache.org/jira/browse/FLINK-8829 Project: Flink

[jira] [Created] (FLINK-8827) When FLINK_CONF_DIR contains spaces, execute zookeeper related scripts failed

Donghui Xu created FLINK-8827: - Summary: When FLINK_CONF_DIR contains spaces, execute zookeeper related scripts failed Key: FLINK-8827 URL: https://issues.apache.org/jira/browse/FLINK-8827 Project: Flink

[DISCUSS] Convert main Table API classes into traits

Hi everyone, I'm currently thinking about how to implement FLINK-8606. The reason behind it is that Java users are able to see all variables and methods that are declared 'private[flink]' or even 'protected' in Scala. Classes such as TableEnvironment look very messy from the outside in Java.

[jira] [Created] (FLINK-8826) In Flip6 mode, when starting yarn cluster, configured taskmanager.heap.mb is ignored

Piotr Nowojski created FLINK-8826: - Summary: In Flip6 mode, when starting yarn cluster, configured taskmanager.heap.mb is ignored Key: FLINK-8826 URL: https://issues.apache.org/jira/browse/FLINK-8826

[jira] [Created] (FLINK-8825) Disallow new String() without charset in checkstyle

Aljoscha Krettek created FLINK-8825: --- Summary: Disallow new String() without charset in checkstyle Key: FLINK-8825 URL: https://issues.apache.org/jira/browse/FLINK-8825 Project: Flink

[jira] [Created] (FLINK-8824) In Kafka Consumers, replace 'getCanonicalClassName()' with 'getClassName()'

Stephan Ewen created FLINK-8824: --- Summary: In Kafka Consumers, replace 'getCanonicalClassName()' with 'getClassName()' Key: FLINK-8824 URL: https://issues.apache.org/jira/browse/FLINK-8824 Project:

[jira] [Created] (FLINK-8823) Add network profiling/diagnosing metrics.

Piotr Nowojski created FLINK-8823: - Summary: Add network profiling/diagnosing metrics. Key: FLINK-8823 URL: https://issues.apache.org/jira/browse/FLINK-8823 Project: Flink Issue Type:

[jira] [Created] (FLINK-8822) RotateLogFile may not work well when sed version is below 4.2

Xin Liu created FLINK-8822: -- Summary: RotateLogFile may not work well when sed version is below 4.2 Key: FLINK-8822 URL: https://issues.apache.org/jira/browse/FLINK-8822 Project: Flink Issue Type:

[jira] [Created] (FLINK-8821) Fix BigDecimal divide in AvgAggFunction

Ruidong Li created FLINK-8821: - Summary: Fix BigDecimal divide in AvgAggFunction Key: FLINK-8821 URL: https://issues.apache.org/jira/browse/FLINK-8821 Project: Flink Issue Type: Bug

Re: [DISCUS] Flink SQL Client dependency management

I agree, option (2) would be the easiest approach for the users. 2018-03-01 0:00 GMT+01:00 Rong Rong : > Hi Timo, > > Thanks for the initiating the SQL client effort. I agree with Xingcan's > points, adding to it (1) most of the user for SQL client would very likely > to

[jira] [Created] (FLINK-8820) FlinkKafkaConsumer010 reads too many bytes

Fabian Hueske created FLINK-8820: Summary: FlinkKafkaConsumer010 reads too many bytes Key: FLINK-8820 URL: https://issues.apache.org/jira/browse/FLINK-8820 Project: Flink Issue Type: Bug

Re: [DISCUSS] Releasing Flink 1.5.0

Thanks for bringing this issue up Shashank. I think Aljoscha is taking a look at the issue. It looks like a serious bug which we should definitely fix. What I've heard so far is that it's not so trivial. Cheers, Till On Thu, Mar 1, 2018 at 9:56 AM, shashank734 wrote: >

Re: [DISCUSS] Releasing Flink 1.5.0

Can we have https://issues.apache.org/jira/browse/FLINK-7756 solved in this version. Cause unable to use checkpointing with CEP and RocksDB backend. -- Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/

[jira] [Created] (FLINK-8819) Rework travis script to use build stages

Chesnay Schepler created FLINK-8819: --- Summary: Rework travis script to use build stages Key: FLINK-8819 URL: https://issues.apache.org/jira/browse/FLINK-8819 Project: Flink Issue Type: