[jira] [Created] (FLINK-21778) Use heap memory instead of direct memory as index entry cache for sort-merge shuffle

2021-03-13 Thread Yingjie Cao (Jira)
Yingjie Cao created FLINK-21778: --- Summary: Use heap memory instead of direct memory as index entry cache for sort-merge shuffle Key: FLINK-21778 URL: https://issues.apache.org/jira/browse/FLINK-21778

[jira] [Created] (FLINK-21777) Replace the 4M data writing cache of sort-merge shuffle with writev system call

2021-03-13 Thread Yingjie Cao (Jira)
Yingjie Cao created FLINK-21777: --- Summary: Replace the 4M data writing cache of sort-merge shuffle with writev system call Key: FLINK-21777 URL: https://issues.apache.org/jira/browse/FLINK-21777

flink 1.11 class loading question

2021-03-13 Thread Chen Qin
Hi there, We were using flink 1.11.2 in production with a large setting. The job runs fine for a couple of days and ends up with a restart loop caused by YARN container memory kill. This is not observed while running against 1.9.1 with the same setting. Here is JVM environment passed to 1.11 as

[jira] [Created] (FLINK-21776) Migrate all JobManagerJobMG instantiations to factory method

2021-03-13 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-21776: Summary: Migrate all JobManagerJobMG instantiations to factory method Key: FLINK-21776 URL: https://issues.apache.org/jira/browse/FLINK-21776 Project: Flink

[jira] [Created] (FLINK-21775) Migrate all JobManagerMG instantiations to factory method

2021-03-13 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-21775: Summary: Migrate all JobManagerMG instantiations to factory method Key: FLINK-21775 URL: https://issues.apache.org/jira/browse/FLINK-21775 Project: Flink

[jira] [Created] (FLINK-21774) Do not display column names when retrun set is emtpy in SQL Client

2021-03-13 Thread Jark Wu (Jira)
Jark Wu created FLINK-21774: --- Summary: Do not display column names when retrun set is emtpy in SQL Client Key: FLINK-21774 URL: https://issues.apache.org/jira/browse/FLINK-21774 Project: Flink

[jira] [Created] (FLINK-21773) Remove dependency from flink-metrics-statsd

2021-03-13 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-21773: Summary: Remove dependency from flink-metrics-statsd Key: FLINK-21773 URL: https://issues.apache.org/jira/browse/FLINK-21773 Project: Flink Issue

[jira] [Created] (FLINK-21772) Remove dependency from flink-metrics-slf4j

2021-03-13 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-21772: Summary: Remove dependency from flink-metrics-slf4j Key: FLINK-21772 URL: https://issues.apache.org/jira/browse/FLINK-21772 Project: Flink Issue

[jira] [Created] (FLINK-21771) Replace StreamTaskTestHarness#TestTaskMetricGroup

2021-03-13 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-21771: Summary: Replace StreamTaskTestHarness#TestTaskMetricGroup Key: FLINK-21771 URL: https://issues.apache.org/jira/browse/FLINK-21771 Project: Flink

[jira] [Created] (FLINK-21770) JobManagerMG should not accept JobGraph

2021-03-13 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-21770: Summary: JobManagerMG should not accept JobGraph Key: FLINK-21770 URL: https://issues.apache.org/jira/browse/FLINK-21770 Project: Flink Issue Type:

[jira] [Created] (FLINK-21769) Encapsulate component meta data

2021-03-13 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-21769: Summary: Encapsulate component meta data Key: FLINK-21769 URL: https://issues.apache.org/jira/browse/FLINK-21769 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-21768) Optimize system.exit() logic of CliFrontend

2021-03-13 Thread Junfan Zhang (Jira)
Junfan Zhang created FLINK-21768: Summary: Optimize system.exit() logic of CliFrontend Key: FLINK-21768 URL: https://issues.apache.org/jira/browse/FLINK-21768 Project: Flink Issue Type:

[jira] [Created] (FLINK-21767) ComponentMetricGroups should return plain QueryScopeInfos

2021-03-13 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-21767: Summary: ComponentMetricGroups should return plain QueryScopeInfos Key: FLINK-21767 URL: https://issues.apache.org/jira/browse/FLINK-21767 Project: Flink

[jira] [Created] (FLINK-21766) Remove OperatorMetricGroup#parent

2021-03-13 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-21766: Summary: Remove OperatorMetricGroup#parent Key: FLINK-21766 URL: https://issues.apache.org/jira/browse/FLINK-21766 Project: Flink Issue Type:

[jira] [Created] (FLINK-21765) Remove implementation-specific MetricGroup parents

2021-03-13 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-21765: Summary: Remove implementation-specific MetricGroup parents Key: FLINK-21765 URL: https://issues.apache.org/jira/browse/FLINK-21765 Project: Flink

[jira] [Created] (FLINK-21763) Extend Data Stream's batch mode to handle partitioning/grouping/ordering

2021-03-13 Thread Alexis Sarda-Espinosa (Jira)
Alexis Sarda-Espinosa created FLINK-21763: - Summary: Extend Data Stream's batch mode to handle partitioning/grouping/ordering Key: FLINK-21763 URL: https://issues.apache.org/jira/browse/FLINK-21763

[jira] [Created] (FLINK-21761) Remove dependency from flink-metrics-influxdb

2021-03-13 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-21761: Summary: Remove dependency from flink-metrics-influxdb Key: FLINK-21761 URL: https://issues.apache.org/jira/browse/FLINK-21761 Project: Flink Issue

[jira] [Created] (FLINK-21762) Remove dependency from flink-metrics-prometheus

2021-03-13 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-21762: Summary: Remove dependency from flink-metrics-prometheus Key: FLINK-21762 URL: https://issues.apache.org/jira/browse/FLINK-21762 Project: Flink

[jira] [Created] (FLINK-21760) Remove dependency from flink-metrics-jmx

2021-03-13 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-21760: Summary: Remove dependency from flink-metrics-jmx Key: FLINK-21760 URL: https://issues.apache.org/jira/browse/FLINK-21760 Project: Flink Issue Type:

[jira] [Created] (FLINK-21759) Add TestMetricGroup

2021-03-13 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-21759: Summary: Add TestMetricGroup Key: FLINK-21759 URL: https://issues.apache.org/jira/browse/FLINK-21759 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-21758) Add default implementations for all MetricGroup methods accepting ints

2021-03-13 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-21758: Summary: Add default implementations for all MetricGroup methods accepting ints Key: FLINK-21758 URL: https://issues.apache.org/jira/browse/FLINK-21758

[jira] [Created] (FLINK-21757) Extract LogicalScopeProvider interface from FrontMetricGroup

2021-03-13 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-21757: Summary: Extract LogicalScopeProvider interface from FrontMetricGroup Key: FLINK-21757 URL: https://issues.apache.org/jira/browse/FLINK-21757 Project: Flink

[jira] [Created] (FLINK-21756) Move JMXServer to flink-core

2021-03-13 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-21756: Summary: Move JMXServer to flink-core Key: FLINK-21756 URL: https://issues.apache.org/jira/browse/FLINK-21756 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-21755) Remove flink-runtime dependency from metric reporters

2021-03-13 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-21755: Summary: Remove flink-runtime dependency from metric reporters Key: FLINK-21755 URL: https://issues.apache.org/jira/browse/FLINK-21755 Project: Flink

[jira] [Created] (FLINK-21754) Exception message does not point to the right path.

2021-03-13 Thread ZhangWei (Jira)
ZhangWei created FLINK-21754: Summary: Exception message does not point to the right path. Key: FLINK-21754 URL: https://issues.apache.org/jira/browse/FLINK-21754 Project: Flink Issue Type: Bug