[jira] [Commented] (FLINK-6756) Provide RichAsyncFunction to Scala API suite

[ https://issues.apache.org/jira/browse/FLINK-6756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16690520#comment-16690520 ] Shimin Yang commented on FLINK-6756: Well, I can take this over. > Provide RichAsync

[jira] [Updated] (FLINK-10540) Remove legacy FlinkMiniCluster

[ https://issues.apache.org/jira/browse/FLINK-10540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang updated FLINK-10540: Affects Version/s: (was: 1.7.0) 1.8.0 > Remove legacy FlinkMiniCluster

[jira] [Updated] (FLINK-10540) Remove legacy FlinkMiniCluster

[ https://issues.apache.org/jira/browse/FLINK-10540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang updated FLINK-10540: Affects Version/s: (was: 1.8.0) 1.7.0 > Remove legacy FlinkMiniCluster

[jira] [Commented] (FLINK-11002) Trigger.clear() will not be called after purged window

[ https://issues.apache.org/jira/browse/FLINK-11002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16698810#comment-16698810 ] Shimin Yang commented on FLINK-11002: - The Trigger#clear will be finally be called i

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

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 Typ

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

[ https://issues.apache.org/jira/browse/FLINK-11084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16711041#comment-16711041 ] Shimin Yang commented on FLINK-11084: - Currently I am creating a OutputSelectorWrapp

[jira] [Updated] (FLINK-11084) Incorrect ouput after two consecutive split and select

[ https://issues.apache.org/jira/browse/FLINK-11084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang updated FLINK-11084: Summary: Incorrect ouput after two consecutive split and select (was: Incorrect ouput after two s

[jira] [Commented] (FLINK-11084) Incorrect ouput after two consecutive split and select

[ https://issues.apache.org/jira/browse/FLINK-11084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16712255#comment-16712255 ] Shimin Yang commented on FLINK-11084: - Hi [~aljoscha], I don't agree on that. From t

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

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: Bu

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

[ https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang updated FLINK-9567: --- Attachment: jobmanager.log > Flink does not release resource in Yarn Cluster mode > -

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

[ https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang updated FLINK-9567: --- Description: After restart the Job Manager in Yarn Cluster mode, Flink does not release task manager

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

[ https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang updated FLINK-9567: --- Description: After restart the Job Manager in Yarn Cluster mode, Flink does not release task manager

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

[ https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang updated FLINK-9567: --- Attachment: (was: jobmanager.log) > Flink does not release resource in Yarn Cluster mode > --

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

[ https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang updated FLINK-9567: --- Attachment: FlinkYarnProblem > Flink does not release resource in Yarn Cluster mode > ---

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

[ https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang updated FLINK-9567: --- Attachment: fulllog.txt > Flink does not release resource in Yarn Cluster mode >

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

[ https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang updated FLINK-9567: --- Priority: Critical (was: Major) > Flink does not release resource in Yarn Cluster mode > ---

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

[ https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang updated FLINK-9567: --- Description: After restart the Job Manager in Yarn Cluster mode, sometimes Flink does not release ta

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

[ https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang updated FLINK-9567: --- Description: After restart the Job Manager in Yarn Cluster mode, sometimes Flink does not release ta

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

[ https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang updated FLINK-9567: --- Description: After restart the Job Manager in Yarn Cluster mode, sometimes Flink does not release ta

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

[ https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513390#comment-16513390 ] Shimin Yang commented on FLINK-9567: I modified the onContainerCompleted method and r

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

[ https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16515018#comment-16515018 ] Shimin Yang commented on FLINK-9567: I think I can fix the issue but I cannot assign

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

[ https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16516972#comment-16516972 ] Shimin Yang commented on FLINK-9567: Thanks for assigning the issue to me, I will do

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

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 P

[jira] [Commented] (FLINK-10500) Let ExecutionGraphDriver react to fail signal

[ https://issues.apache.org/jira/browse/FLINK-10500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16643038#comment-16643038 ] Shimin Yang commented on FLINK-10500: - Hi [~till.rohrmann], have you started working

[jira] [Assigned] (FLINK-10166) Dependency problems when executing SQL query in sql-client

[ https://issues.apache.org/jira/browse/FLINK-10166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang reassigned FLINK-10166: --- Assignee: (was: Shimin Yang) > Dependency problems when executing SQL query in sql-clie

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

[ https://issues.apache.org/jira/browse/FLINK-10511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16647692#comment-16647692 ] Shimin Yang commented on FLINK-10511: - [~till.rohrmann], good point. We can add an o

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

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] [Commented] (FLINK-10533) job parallelism equals task slots number but not use the same number of the task slots as the parallelism

[ https://issues.apache.org/jira/browse/FLINK-10533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16649879#comment-16649879 ] Shimin Yang commented on FLINK-10533: - Flink uses Slot Sharing Group to optimize the

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

[ https://issues.apache.org/jira/browse/FLINK-10511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang updated FLINK-10511: Issue Type: Improvement (was: Bug) > Code duplication of creating RPC service in ClusterEntrypoin

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

[ https://issues.apache.org/jira/browse/FLINK-10552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang updated FLINK-10552: Issue Type: Improvement (was: Bug) > Provide RichAsyncFunction for scala API > --

[jira] [Commented] (FLINK-10540) Remove legacy FlinkMiniCluster

[ https://issues.apache.org/jira/browse/FLINK-10540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651276#comment-16651276 ] Shimin Yang commented on FLINK-10540: - Hi [~Tison], I would love to take this if you

[jira] [Assigned] (FLINK-10540) Remove legacy FlinkMiniCluster

[ https://issues.apache.org/jira/browse/FLINK-10540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang reassigned FLINK-10540: --- Assignee: Shimin Yang > Remove legacy FlinkMiniCluster > -- > >

[jira] [Commented] (FLINK-10540) Remove legacy FlinkMiniCluster

[ https://issues.apache.org/jira/browse/FLINK-10540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16656235#comment-16656235 ] Shimin Yang commented on FLINK-10540: - Look like it's only used by flink-storm examp

[jira] [Comment Edited] (FLINK-10540) Remove legacy FlinkMiniCluster

[ https://issues.apache.org/jira/browse/FLINK-10540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16656235#comment-16656235 ] Shimin Yang edited comment on FLINK-10540 at 10/19/18 3:37 AM: ---

[jira] [Commented] (FLINK-10618) Introduce catalog for Flink tables

[ https://issues.apache.org/jira/browse/FLINK-10618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16661688#comment-16661688 ] Shimin Yang commented on FLINK-10618: - Sounds good. Do you have a draft of design do

[jira] [Assigned] (FLINK-10500) Let ExecutionGraphDriver react to fail signal

[ https://issues.apache.org/jira/browse/FLINK-10500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang reassigned FLINK-10500: --- Assignee: Shimin Yang > Let ExecutionGraphDriver react to fail signal > ---

[jira] [Assigned] (FLINK-10501) Obtain resource overview of cluster

[ https://issues.apache.org/jira/browse/FLINK-10501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang reassigned FLINK-10501: --- Assignee: Shimin Yang > Obtain resource overview of cluster > -

[jira] [Assigned] (FLINK-10503) Periodically check for new resources

[ https://issues.apache.org/jira/browse/FLINK-10503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang reassigned FLINK-10503: --- Assignee: Shimin Yang > Periodically check for new resources >

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

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] [Closed] (FLINK-10703) Race condition in YarnResourceManager

[ https://issues.apache.org/jira/browse/FLINK-10703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang closed FLINK-10703. --- Resolution: Not A Problem > Race condition in YarnResourceManager >

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

[ https://issues.apache.org/jira/browse/FLINK-10703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16674615#comment-16674615 ] Shimin Yang commented on FLINK-10703: - Thanks [~till.rohrmann]. I didn't notice the

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

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: I

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

[ https://issues.apache.org/jira/browse/FLINK-10815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16678456#comment-16678456 ] Shimin Yang commented on FLINK-10815: - [~till.rohrmann], I would like to hear your o

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

[ https://issues.apache.org/jira/browse/FLINK-10815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16678456#comment-16678456 ] Shimin Yang edited comment on FLINK-10815 at 11/7/18 4:19 PM:

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

[ https://issues.apache.org/jira/browse/FLINK-10815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang closed FLINK-10815. --- Resolution: Workaround > Rethink the rescale operation, can we do it async > ---

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

[ https://issues.apache.org/jira/browse/FLINK-10815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16679185#comment-16679185 ] Shimin Yang commented on FLINK-10815: - Thanks [~dawidwys]. I will close this issue.

[jira] [Assigned] (FLINK-10206) Add hbase stream connector

[ https://issues.apache.org/jira/browse/FLINK-10206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang reassigned FLINK-10206: --- Assignee: Shimin Yang > Add hbase stream connector > -- > >

[jira] [Commented] (FLINK-10206) Add hbase stream connector

[ https://issues.apache.org/jira/browse/FLINK-10206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16592501#comment-16592501 ] Shimin Yang commented on FLINK-10206: - Our streaming job heavily relied on hbase as

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

[ https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang closed FLINK-9567. -- > Flink does not release resource in Yarn Cluster mode > --

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

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 Compon

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

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 Components:

[jira] [Commented] (FLINK-10206) Add hbase sink connector

[ https://issues.apache.org/jira/browse/FLINK-10206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16598750#comment-16598750 ] Shimin Yang commented on FLINK-10206: - Thank you for your advices. I will briefly ta

[jira] [Commented] (FLINK-10206) Add hbase sink connector

[ https://issues.apache.org/jira/browse/FLINK-10206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16598754#comment-16598754 ] Shimin Yang commented on FLINK-10206: - Hi [~hequn8128] , I am planning to implement

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

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 Type:

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

[ https://issues.apache.org/jira/browse/FLINK-10245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang updated FLINK-10245: Description: Design documentation:  [https://docs.google.com/document/d/1of0cYd73CtKGPt-UL3WVFTTBsV

[jira] [Commented] (FLINK-10206) Add hbase sink connector

[ https://issues.apache.org/jira/browse/FLINK-10206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16602287#comment-16602287 ] Shimin Yang commented on FLINK-10206: - [~hequn8128] Thanks for your advice, I have a

[jira] [Commented] (FLINK-10247) Run MetricQueryService in separate thread pool

[ https://issues.apache.org/jira/browse/FLINK-10247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16605338#comment-16605338 ] Shimin Yang commented on FLINK-10247: - Hi [~till.rohrmann], do you mean that we shou

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

[ https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang reopened FLINK-9567: This issue also occurs while using region strategy. In that case the pending slot should also be check

[jira] [Assigned] (FLINK-10247) Run MetricQueryService in separate thread pool

[ https://issues.apache.org/jira/browse/FLINK-10247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang reassigned FLINK-10247: --- Assignee: Shimin Yang > Run MetricQueryService in separate thread pool > --

[jira] [Commented] (FLINK-10247) Run MetricQueryService in separate thread pool

[ https://issues.apache.org/jira/browse/FLINK-10247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16607114#comment-16607114 ] Shimin Yang commented on FLINK-10247: - Hi [~Zentol], sounds good. I am gonna working

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

[ https://issues.apache.org/jira/browse/FLINK-10245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16607989#comment-16607989 ] Shimin Yang commented on FLINK-10245: - Hi [~hequn8128], Thanks for your remind and

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

[ https://issues.apache.org/jira/browse/FLINK-10245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16607989#comment-16607989 ] Shimin Yang edited comment on FLINK-10245 at 9/8/18 9:50 AM: -

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

[ https://issues.apache.org/jira/browse/FLINK-10245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16608642#comment-16608642 ] Shimin Yang commented on FLINK-10245: - Hi [~hequn8128], For the comments you mentio

[jira] [Commented] (FLINK-10247) Run MetricQueryService in separate thread pool

[ https://issues.apache.org/jira/browse/FLINK-10247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16609013#comment-16609013 ] Shimin Yang commented on FLINK-10247: - [~till.rohrmann] It could be a good way to de

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

[ https://issues.apache.org/jira/browse/FLINK-10245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16611487#comment-16611487 ] Shimin Yang commented on FLINK-10245: - Hi [~hequn8128]，I have been thinking about sh

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

[ https://issues.apache.org/jira/browse/FLINK-10245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16611491#comment-16611491 ] Shimin Yang commented on FLINK-10245: - [~hequn8128], we may make the deduplication a

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

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 Issu

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

[ https://issues.apache.org/jira/browse/FLINK-10322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16611714#comment-16611714 ] Shimin Yang commented on FLINK-10322: - Hi [~Tison], do you have any suggestion about

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

[ https://issues.apache.org/jira/browse/FLINK-10322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16612017#comment-16612017 ] Shimin Yang commented on FLINK-10322: - Cool. > Unused instance variable MetricRegis

[jira] [Assigned] (FLINK-10327) Pass processWatermark calls from (Co)ProcessOperator to (Co)ProcessFunction

[ https://issues.apache.org/jira/browse/FLINK-10327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang reassigned FLINK-10327: --- Assignee: Shimin Yang > Pass processWatermark calls from (Co)ProcessOperator to (Co)Process

[jira] [Commented] (FLINK-10327) Pass processWatermark calls from (Co)ProcessOperator to (Co)ProcessFunction

[ https://issues.apache.org/jira/browse/FLINK-10327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16612278#comment-16612278 ] Shimin Yang commented on FLINK-10327: - Sounds good, I ll work on it. > Pass process

[jira] [Assigned] (FLINK-10327) Pass processWatermark calls from (Co)ProcessOperator to (Co)ProcessFunction

[ https://issues.apache.org/jira/browse/FLINK-10327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang reassigned FLINK-10327: --- Assignee: Piotr Nowojski (was: Shimin Yang) > Pass processWatermark calls from (Co)Process

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

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] [Closed] (FLINK-10330) Code Compilation failed in local mode

[ https://issues.apache.org/jira/browse/FLINK-10330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang closed FLINK-10330. --- Resolution: Duplicate > Code Compilation failed in local mode >

[jira] [Commented] (FLINK-10166) Dependency problems when executing SQL query in sql-client

[ https://issues.apache.org/jira/browse/FLINK-10166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16613136#comment-16613136 ] Shimin Yang commented on FLINK-10166: - Hi [~dawidwys] [~StephanEwen], I think a more

[jira] [Assigned] (FLINK-10166) Dependency problems when executing SQL query in sql-client

[ https://issues.apache.org/jira/browse/FLINK-10166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang reassigned FLINK-10166: --- Assignee: Shimin Yang > Dependency problems when executing SQL query in sql-client > --

[jira] [Comment Edited] (FLINK-10166) Dependency problems when executing SQL query in sql-client

[ https://issues.apache.org/jira/browse/FLINK-10166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16613318#comment-16613318 ] Shimin Yang edited comment on FLINK-10166 at 9/13/18 10:55 AM: ---

[jira] [Commented] (FLINK-10166) Dependency problems when executing SQL query in sql-client

[ https://issues.apache.org/jira/browse/FLINK-10166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16613318#comment-16613318 ] Shimin Yang commented on FLINK-10166: - Hi [~twalthr]. Well, not many times. Maybe we

[jira] [Assigned] (FLINK-10337) Use ZooKeeperStateStore in ZooKeeperCompletedCheckpointStore

[ https://issues.apache.org/jira/browse/FLINK-10337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang reassigned FLINK-10337: --- Assignee: Shimin Yang > Use ZooKeeperStateStore in ZooKeeperCompletedCheckpointStore >

[jira] [Assigned] (FLINK-10344) Rethink SubmittedJobGraphListener

[ https://issues.apache.org/jira/browse/FLINK-10344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang reassigned FLINK-10344: --- Assignee: Shimin Yang > Rethink SubmittedJobGraphListener > ---

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

[ https://issues.apache.org/jira/browse/FLINK-10245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16618686#comment-16618686 ] Shimin Yang commented on FLINK-10245: - Hi [~yuanoOo], I think the Increment operatio

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

[ https://issues.apache.org/jira/browse/FLINK-10245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16618688#comment-16618688 ] Shimin Yang commented on FLINK-10245: - [~hequn8128] Sounds good. > Add DataStream H

[jira] [Updated] (FLINK-10206) Add hbase sink connector

[ https://issues.apache.org/jira/browse/FLINK-10206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang updated FLINK-10206: Description: Now, there is a hbase source connector for batch operation.    In some cases, we ne

[jira] [Commented] (FLINK-10206) Add hbase sink connector

[ https://issues.apache.org/jira/browse/FLINK-10206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16620069#comment-16620069 ] Shimin Yang commented on FLINK-10206: - [~hequn8128] [~twalthr] [~till.rohrmann] Hi a

[jira] [Commented] (FLINK-10344) Rethink SubmittedJobGraphListener

[ https://issues.apache.org/jira/browse/FLINK-10344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16620356#comment-16620356 ] Shimin Yang commented on FLINK-10344: - Hi [~SleePy], is there any relation between t

[jira] [Commented] (FLINK-10337) Use ZooKeeperStateStore in ZooKeeperCompletedCheckpointStore

[ https://issues.apache.org/jira/browse/FLINK-10337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16620357#comment-16620357 ] Shimin Yang commented on FLINK-10337: - [~till.rohrmann], sounds reasonable. I will f

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

[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang closed FLINK-1. --- Resolution: Won't Fix > There's a mistake in the comments of CoGroupedStreams.java > ---

[jira] [Commented] (FLINK-10333) Rethink ZooKeeper based stores (SubmittedJobGraph, MesosWorker, CompletedCheckpoints)

[ https://issues.apache.org/jira/browse/FLINK-10333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16620386#comment-16620386 ] Shimin Yang commented on FLINK-10333: - Hi [~till.rohrmann], is there a discussion th

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

[ https://issues.apache.org/jira/browse/FLINK-10245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16621468#comment-16621468 ] Shimin Yang commented on FLINK-10245: - Hi [~hequn8128], I have updated the document,

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

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 Issu

[jira] [Commented] (FLINK-9054) IllegalStateException: Buffer pool is destroyed

[ https://issues.apache.org/jira/browse/FLINK-9054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16582054#comment-16582054 ] Shimin Yang commented on FLINK-9054: Could you please attach more logs? Feels like it

[jira] [Commented] (FLINK-11084) Incorrect ouput after two consecutive split and select

[ https://issues.apache.org/jira/browse/FLINK-11084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16720304#comment-16720304 ] Shimin Yang commented on FLINK-11084: - Hi [~dawidwys], thank you for providing the c

[jira] [Updated] (FLINK-10245) Add HBase Streaming Sink

[ https://issues.apache.org/jira/browse/FLINK-10245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang updated FLINK-10245: Summary: Add HBase Streaming Sink (was: Add DataStream HBase Sink) > Add HBase Streaming Sink > -

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

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] [Assigned] (FLINK-11364) Check and port TaskManagerFailsITCase to new code base if necessary

[ https://issues.apache.org/jira/browse/FLINK-11364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang reassigned FLINK-11364: --- Assignee: Shimin Yang > Check and port TaskManagerFailsITCase to new code base if necessary

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

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] [Commented] (FLINK-14003) Add access to customized state other than built in state types

[ https://issues.apache.org/jira/browse/FLINK-14003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16925116#comment-16925116 ] Shimin Yang commented on FLINK-14003: - [~carp84], what do you think? > Add access t

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

[ https://issues.apache.org/jira/browse/FLINK-14003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16925394#comment-16925394 ] Shimin Yang commented on FLINK-14003: - [~carp84], sounds good. > Add access to cust

[jira] [Commented] (FLINK-9749) Rework Bucketing Sink

[ https://issues.apache.org/jira/browse/FLINK-9749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16934185#comment-16934185 ] Shimin Yang commented on FLINK-9749: Hi [~kkl0u], is there anyone working on DateTime

[jira] [Commented] (FLINK-9749) Rework Bucketing Sink

[ https://issues.apache.org/jira/browse/FLINK-9749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16934266#comment-16934266 ] Shimin Yang commented on FLINK-9749: Hi [~kkl0u], it does seem like a replicating of

  1   2   >