[
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
[
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
[
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
[
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
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
[
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
[
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
[
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
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
[
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
> -
[
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
[
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
[
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
> --
[
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
> ---
[
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
>
[
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
> ---
[
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
[
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
[
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
[
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
[
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
[
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
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
[
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
[
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
[
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
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
[
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
[
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
[
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
> --
[
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
[
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
> --
>
>
[
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
[
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:
---
[
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
[
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
> ---
[
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
> -
[
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
>
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
[
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
>
[
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
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
[
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
[
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:
[
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
> ---
[
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.
[
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
> --
>
>
[
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
[
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
> --
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
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:
[
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
[
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
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:
[
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
[
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
[
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
[
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
[
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
> --
[
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
[
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
[
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:
-
[
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
[
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
[
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
[
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
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
[
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
[
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
[
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
[
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
[
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
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
[
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
>
[
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
[
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
> --
[
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:
---
[
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
[
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
>
[
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
> ---
[
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
[
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
[
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
[
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
[
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
[
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
[
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
> ---
[
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
[
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,
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
[
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
[
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
[
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
> -
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
[
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
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
[
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
[
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
[
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
[
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 - 100 of 111 matches
Mail list logo