[jira] [Created] (FLINK-16279) Per job Yarn application leak in normal execution mode.

Wenlong Lyu created FLINK-16279: --- Summary: Per job Yarn application leak in normal execution mode. Key: FLINK-16279 URL: https://issues.apache.org/jira/browse/FLINK-16279 Project: Flink Issue T

[jira] [Created] (FLINK-16864) Add idle metrics for Task

Wenlong Lyu created FLINK-16864: --- Summary: Add idle metrics for Task Key: FLINK-16864 URL: https://issues.apache.org/jira/browse/FLINK-16864 Project: Flink Issue Type: Improvement Com

[jira] [Created] (FLINK-17012) Expose cost of task initialization

Wenlong Lyu created FLINK-17012: --- Summary: Expose cost of task initialization Key: FLINK-17012 URL: https://issues.apache.org/jira/browse/FLINK-17012 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-17040) SavepointWriterITCase broken

Wenlong Lyu created FLINK-17040: --- Summary: SavepointWriterITCase broken Key: FLINK-17040 URL: https://issues.apache.org/jira/browse/FLINK-17040 Project: Flink Issue Type: Bug Report

[jira] [Created] (FLINK-17109) FlinkPipelineTranslationUtil#getJobGraph doesn't consider Jars and Classpaths in configuration.

Wenlong Lyu created FLINK-17109: --- Summary: FlinkPipelineTranslationUtil#getJobGraph doesn't consider Jars and Classpaths in configuration. Key: FLINK-17109 URL: https://issues.apache.org/jira/browse/FLINK-17109

[jira] [Created] (FLINK-17110) Make StreamExecutionEnvironment#configure also affects configuration

Wenlong Lyu created FLINK-17110: --- Summary: Make StreamExecutionEnvironment#configure also affects configuration Key: FLINK-17110 URL: https://issues.apache.org/jira/browse/FLINK-17110 Project: Flink

[jira] [Created] (FLINK-17141) Name of SQL Operator is too long

Wenlong Lyu created FLINK-17141: --- Summary: Name of SQL Operator is too long Key: FLINK-17141 URL: https://issues.apache.org/jira/browse/FLINK-17141 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-17386) Exception in HadoopSecurityContextFactory.createContext while no shaded-hadoop-lib provided.

Wenlong Lyu created FLINK-17386: --- Summary: Exception in HadoopSecurityContextFactory.createContext while no shaded-hadoop-lib provided. Key: FLINK-17386 URL: https://issues.apache.org/jira/browse/FLINK-17386

[jira] [Created] (FLINK-4271) There is no way to set parallelism of operators such as map and window produced by

Wenlong Lyu created FLINK-4271: -- Summary: There is no way to set parallelism of operators such as map and window produced by Key: FLINK-4271 URL: https://issues.apache.org/jira/browse/FLINK-4271 Project

[jira] [Created] (FLINK-4375) defined rpc protocols provided by job manager

Wenlong Lyu created FLINK-4375: -- Summary: defined rpc protocols provided by job manager Key: FLINK-4375 URL: https://issues.apache.org/jira/browse/FLINK-4375 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-4376) implement job manager init procedure

Wenlong Lyu created FLINK-4376: -- Summary: implement job manager init procedure Key: FLINK-4376 URL: https://issues.apache.org/jira/browse/FLINK-4376 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-4378) Enable RollingSink to custom HDFS client configuration

Wenlong Lyu created FLINK-4378: -- Summary: Enable RollingSink to custom HDFS client configuration Key: FLINK-4378 URL: https://issues.apache.org/jira/browse/FLINK-4378 Project: Flink Issue Type:

[jira] [Created] (FLINK-4406) Implement job master registration at resource manager

Wenlong Lyu created FLINK-4406: -- Summary: Implement job master registration at resource manager Key: FLINK-4406 URL: https://issues.apache.org/jira/browse/FLINK-4406 Project: Flink Issue Type: S

[jira] [Created] (FLINK-4414) Remove restriction on RpcService.getAddress

Wenlong Lyu created FLINK-4414: -- Summary: Remove restriction on RpcService.getAddress Key: FLINK-4414 URL: https://issues.apache.org/jira/browse/FLINK-4414 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-4443) Add support in RpcCompletenessTest for inheritance of RpcGateway and RpcEndpoint

Wenlong Lyu created FLINK-4443: -- Summary: Add support in RpcCompletenessTest for inheritance of RpcGateway and RpcEndpoint Key: FLINK-4443 URL: https://issues.apache.org/jira/browse/FLINK-4443 Project: F

[jira] [Created] (FLINK-5284) Make output of bucketing sink compatible with other processing framework like mapreduce

Wenlong Lyu created FLINK-5284: -- Summary: Make output of bucketing sink compatible with other processing framework like mapreduce Key: FLINK-5284 URL: https://issues.apache.org/jira/browse/FLINK-5284 Pro

[jira] [Created] (FLINK-5749) Unset HADOOP_HOME and HADOOP_CONF_DIR from system environment when building flink

Wenlong Lyu created FLINK-5749: -- Summary: Unset HADOOP_HOME and HADOOP_CONF_DIR from system environment when building flink Key: FLINK-5749 URL: https://issues.apache.org/jira/browse/FLINK-5749 Project:

[jira] [Created] (FLINK-5815) Add resource files configuration for Yarn Mode

Wenlong Lyu created FLINK-5815: -- Summary: Add resource files configuration for Yarn Mode Key: FLINK-5815 URL: https://issues.apache.org/jira/browse/FLINK-5815 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-5817) Fix test concurrent execution failure by test dir conflicts.

Wenlong Lyu created FLINK-5817: -- Summary: Fix test concurrent execution failure by test dir conflicts. Key: FLINK-5817 URL: https://issues.apache.org/jira/browse/FLINK-5817 Project: Flink Issue

[jira] [Created] (FLINK-5989) Protobuf in akka needs to be shaded

Wenlong Lyu created FLINK-5989: -- Summary: Protobuf in akka needs to be shaded Key: FLINK-5989 URL: https://issues.apache.org/jira/browse/FLINK-5989 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-6162) Fix bug in ByteArrayOutputStreamWithPos#setPosition

Wenlong Lyu created FLINK-6162: -- Summary: Fix bug in ByteArrayOutputStreamWithPos#setPosition Key: FLINK-6162 URL: https://issues.apache.org/jira/browse/FLINK-6162 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20736) Separate the implementation of BatchExecLimit and StreamExecLimit

Wenlong Lyu created FLINK-20736: --- Summary: Separate the implementation of BatchExecLimit and StreamExecLimit Key: FLINK-20736 URL: https://issues.apache.org/jira/browse/FLINK-20736 Project: Flink

[jira] [Created] (FLINK-20766) Separate the implementation of stream sort nodes

Wenlong Lyu created FLINK-20766: --- Summary: Separate the implementation of stream sort nodes Key: FLINK-20766 URL: https://issues.apache.org/jira/browse/FLINK-20766 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-20782) Separate the implementation of BatchExecRank

Wenlong Lyu created FLINK-20782: --- Summary: Separate the implementation of BatchExecRank Key: FLINK-20782 URL: https://issues.apache.org/jira/browse/FLINK-20782 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-20783) Separate the implementation of BatchExec nodes for Join

Wenlong Lyu created FLINK-20783: --- Summary: Separate the implementation of BatchExec nodes for Join Key: FLINK-20783 URL: https://issues.apache.org/jira/browse/FLINK-20783 Project: Flink Issue T

[jira] [Created] (FLINK-20876) Separate the implementation of StreamExecTemporalJoin

Wenlong Lyu created FLINK-20876: --- Summary: Separate the implementation of StreamExecTemporalJoin Key: FLINK-20876 URL: https://issues.apache.org/jira/browse/FLINK-20876 Project: Flink Issue Typ

[jira] [Created] (FLINK-20925) Separate the implementation of StreamExecLookup and BatchExecLookup

Wenlong Lyu created FLINK-20925: --- Summary: Separate the implementation of StreamExecLookup and BatchExecLookup Key: FLINK-20925 URL: https://issues.apache.org/jira/browse/FLINK-20925 Project: Flink

[jira] [Created] (FLINK-26770) Nullable ArrayData should not be Object[]

Wenlong Lyu created FLINK-26770: --- Summary: Nullable ArrayData should not be Object[] Key: FLINK-26770 URL: https://issues.apache.org/jira/browse/FLINK-26770 Project: Flink Issue Type: Bug A

[jira] [Created] (FLINK-25070) FLIP-195: Improve the name and structure of vertex and operator name for job

Wenlong Lyu created FLINK-25070: --- Summary: FLIP-195: Improve the name and structure of vertex and operator name for job Key: FLINK-25070 URL: https://issues.apache.org/jira/browse/FLINK-25070 Project: F

[jira] [Created] (FLINK-25072) Introduce description for operator

Wenlong Lyu created FLINK-25072: --- Summary: Introduce description for operator Key: FLINK-25072 URL: https://issues.apache.org/jira/browse/FLINK-25072 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-25073) Introduce Tree Mode

Wenlong Lyu created FLINK-25073: --- Summary: Introduce Tree Mode Key: FLINK-25073 URL: https://issues.apache.org/jira/browse/FLINK-25073 Project: Flink Issue Type: Sub-task Reporter:

[jira] [Created] (FLINK-25074) Simplify name of window operators in DS by moving details to description

Wenlong Lyu created FLINK-25074: --- Summary: Simplify name of window operators in DS by moving details to description Key: FLINK-25074 URL: https://issues.apache.org/jira/browse/FLINK-25074 Project: Flink

[jira] [Created] (FLINK-25076) Simplify name of SQL operators

Wenlong Lyu created FLINK-25076: --- Summary: Simplify name of SQL operators Key: FLINK-25076 URL: https://issues.apache.org/jira/browse/FLINK-25076 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-25118) Add vertex index as prefix in vertex name

Wenlong Lyu created FLINK-25118: --- Summary: Add vertex index as prefix in vertex name Key: FLINK-25118 URL: https://issues.apache.org/jira/browse/FLINK-25118 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-25123) Improve expression description in SQL operator

Wenlong Lyu created FLINK-25123: --- Summary: Improve expression description in SQL operator Key: FLINK-25123 URL: https://issues.apache.org/jira/browse/FLINK-25123 Project: Flink Issue Type: Sub-

[jira] [Created] (FLINK-25198) add document about how to debug with the name and description

Wenlong Lyu created FLINK-25198: --- Summary: add document about how to debug with the name and description Key: FLINK-25198 URL: https://issues.apache.org/jira/browse/FLINK-25198 Project: Flink

[jira] [Created] (FLINK-25600) Support new statement set syntax in sql client and update docs

Wenlong Lyu created FLINK-25600: --- Summary: Support new statement set syntax in sql client and update docs Key: FLINK-25600 URL: https://issues.apache.org/jira/browse/FLINK-25600 Project: Flink

[jira] [Created] (FLINK-21010) Separete the implementation of StreamExecJoin

Wenlong Lyu created FLINK-21010: --- Summary: Separete the implementation of StreamExecJoin Key: FLINK-21010 URL: https://issues.apache.org/jira/browse/FLINK-21010 Project: Flink Issue Type: Sub-t

[jira] [Created] (FLINK-21011) Separete the implementation of StreamExecJoin

Wenlong Lyu created FLINK-21011: --- Summary: Separete the implementation of StreamExecJoin Key: FLINK-21011 URL: https://issues.apache.org/jira/browse/FLINK-21011 Project: Flink Issue Type: Sub-t

[jira] [Created] (FLINK-21704) Support StreamExecChangelogNormalize json serde

Wenlong Lyu created FLINK-21704: --- Summary: Support StreamExecChangelogNormalize json serde Key: FLINK-21704 URL: https://issues.apache.org/jira/browse/FLINK-21704 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-21785) Support StreamExecCorrelate json serde

Wenlong Lyu created FLINK-21785: --- Summary: Support StreamExecCorrelate json serde Key: FLINK-21785 URL: https://issues.apache.org/jira/browse/FLINK-21785 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-21805) Support StreamExecRank and StreamExecSortLimit Json ser/de

Wenlong Lyu created FLINK-21805: --- Summary: Support StreamExecRank and StreamExecSortLimit Json ser/de Key: FLINK-21805 URL: https://issues.apache.org/jira/browse/FLINK-21805 Project: Flink Issu

[jira] [Created] (FLINK-21813) Support StreamExecOverAggregate json ser/de

Wenlong Lyu created FLINK-21813: --- Summary: Support StreamExecOverAggregate json ser/de Key: FLINK-21813 URL: https://issues.apache.org/jira/browse/FLINK-21813 Project: Flink Issue Type: Sub-tas

[jira] [Created] (FLINK-21815) Support StreamExecUnion json ser/de

Wenlong Lyu created FLINK-21815: --- Summary: Support StreamExecUnion json ser/de Key: FLINK-21815 URL: https://issues.apache.org/jira/browse/FLINK-21815 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-21816) Support StreamExecGroupTableAggregate json ser/de

Wenlong Lyu created FLINK-21816: --- Summary: Support StreamExecGroupTableAggregate json ser/de Key: FLINK-21816 URL: https://issues.apache.org/jira/browse/FLINK-21816 Project: Flink Issue Type: S

[jira] [Created] (FLINK-21843) Support StreamExecGroupWindowAggregate json ser/de

Wenlong Lyu created FLINK-21843: --- Summary: Support StreamExecGroupWindowAggregate json ser/de Key: FLINK-21843 URL: https://issues.apache.org/jira/browse/FLINK-21843 Project: Flink Issue Type:

[jira] [Created] (FLINK-21870) RelDataType of TableFunction different in local and CI

Wenlong Lyu created FLINK-21870: --- Summary: RelDataType of TableFunction different in local and CI Key: FLINK-21870 URL: https://issues.apache.org/jira/browse/FLINK-21870 Project: Flink Issue Ty

[jira] [Created] (FLINK-22020) Reflections ClassNotFound when trying to deserialize a json plan in deployment envrionment

Wenlong Lyu created FLINK-22020: --- Summary: Reflections ClassNotFound when trying to deserialize a json plan in deployment envrionment Key: FLINK-22020 URL: https://issues.apache.org/jira/browse/FLINK-22020

[jira] [Created] (FLINK-8200) RocksDBAsyncSnapshotTest should use temp fold instead of fold with fixed name

Wenlong Lyu created FLINK-8200: -- Summary: RocksDBAsyncSnapshotTest should use temp fold instead of fold with fixed name Key: FLINK-8200 URL: https://issues.apache.org/jira/browse/FLINK-8200 Project: Flin

[jira] [Created] (FLINK-8201) YarnResourceManagerTest causes license checking failure

Wenlong Lyu created FLINK-8201: -- Summary: YarnResourceManagerTest causes license checking failure Key: FLINK-8201 URL: https://issues.apache.org/jira/browse/FLINK-8201 Project: Flink Issue Type: