[jira] [Created] (FLINK-14003) Add access to customized state other than built in state types

2019-09-08 Thread Shimin Yang (Jira)
Shimin Yang created FLINK-14003: --- Summary: Add access to customized state other than built in state types Key: FLINK-14003 URL: https://issues.apache.org/jira/browse/FLINK-14003 Project: Flink

[jira] [Created] (FLINK-11705) remove org.apache.flink.runtime.testingUtils.TestingUtils

2019-02-20 Thread Shimin Yang (JIRA)
Shimin Yang created FLINK-11705: --- Summary: remove org.apache.flink.runtime.testingUtils.TestingUtils Key: FLINK-11705 URL: https://issues.apache.org/jira/browse/FLINK-11705 Project: Flink

[jira] [Created] (FLINK-11486) Remove RecoveryITCase for jobmanager

2019-01-31 Thread Shimin Yang (JIRA)
Shimin Yang created FLINK-11486: --- Summary: Remove RecoveryITCase for jobmanager Key: FLINK-11486 URL: https://issues.apache.org/jira/browse/FLINK-11486 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-11084) Incorrect ouput after two successive split and select

2018-12-05 Thread Shimin Yang (JIRA)
Shimin Yang created FLINK-11084: --- Summary: Incorrect ouput after two successive split and select Key: FLINK-11084 URL: https://issues.apache.org/jira/browse/FLINK-11084 Project: Flink Issue

[jira] [Created] (FLINK-10815) Rethink the rescale operation, can we do it async

2018-11-07 Thread Shimin Yang (JIRA)
Shimin Yang created FLINK-10815: --- Summary: Rethink the rescale operation, can we do it async Key: FLINK-10815 URL: https://issues.apache.org/jira/browse/FLINK-10815 Project: Flink Issue Type:

[jira] [Created] (FLINK-10703) Race condition in YarnResourceManager

2018-10-28 Thread Shimin Yang (JIRA)
Shimin Yang created FLINK-10703: --- Summary: Race condition in YarnResourceManager Key: FLINK-10703 URL: https://issues.apache.org/jira/browse/FLINK-10703 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-10552) Provide RichAsyncFunction for scala API

2018-10-15 Thread Shimin Yang (JIRA)
Shimin Yang created FLINK-10552: --- Summary: Provide RichAsyncFunction for scala API Key: FLINK-10552 URL: https://issues.apache.org/jira/browse/FLINK-10552 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-10511) Code duplication of creating RPC service in ClusterEntrypoint and AkkaRpcServiceUtils

2018-10-08 Thread Shimin Yang (JIRA)
Shimin Yang created FLINK-10511: --- Summary: Code duplication of creating RPC service in ClusterEntrypoint and AkkaRpcServiceUtils Key: FLINK-10511 URL: https://issues.apache.org/jira/browse/FLINK-10511

[jira] [Created] (FLINK-10330) Code Compilation failed in local mode

2018-09-13 Thread Shimin Yang (JIRA)
Shimin Yang created FLINK-10330: --- Summary: Code Compilation failed in local mode Key: FLINK-10330 URL: https://issues.apache.org/jira/browse/FLINK-10330 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-10322) Unused instance variable MetricRegistry in ResourceManager

2018-09-12 Thread Shimin Yang (JIRA)
Shimin Yang created FLINK-10322: --- Summary: Unused instance variable MetricRegistry in ResourceManager Key: FLINK-10322 URL: https://issues.apache.org/jira/browse/FLINK-10322 Project: Flink

[jira] [Created] (FLINK-10277) Add AppendStreamTableSink and UpsertStreamTableSink

2018-09-02 Thread Shimin Yang (JIRA)
Shimin Yang created FLINK-10277: --- Summary: Add AppendStreamTableSink and UpsertStreamTableSink Key: FLINK-10277 URL: https://issues.apache.org/jira/browse/FLINK-10277 Project: Flink Issue

[jira] [Created] (FLINK-10248) Add HBase Table Sink

2018-08-29 Thread Shimin Yang (JIRA)
Shimin Yang created FLINK-10248: --- Summary: Add HBase Table Sink Key: FLINK-10248 URL: https://issues.apache.org/jira/browse/FLINK-10248 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-10245) Add DataStream HBase Sink

2018-08-29 Thread Shimin Yang (JIRA)
Shimin Yang created FLINK-10245: --- Summary: Add DataStream HBase Sink Key: FLINK-10245 URL: https://issues.apache.org/jira/browse/FLINK-10245 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-10000) There's a mistake in the comments of CoGroupedStreams.java

2018-07-31 Thread Shimin Yang (JIRA)
Shimin Yang created FLINK-1: --- Summary: There's a mistake in the comments of CoGroupedStreams.java Key: FLINK-1 URL: https://issues.apache.org/jira/browse/FLINK-1 Project: Flink

[jira] [Created] (FLINK-9567) Flink does not release resource in Yarn Cluster mode

2018-06-11 Thread Shimin Yang (JIRA)
Shimin Yang created FLINK-9567: -- Summary: Flink does not release resource in Yarn Cluster mode Key: FLINK-9567 URL: https://issues.apache.org/jira/browse/FLINK-9567 Project: Flink Issue Type: