[
https://issues.apache.org/jira/browse/FLINK-7611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
aitozi updated FLINK-7611:
--
Affects Version/s: 1.3.0
> add metrics to measure the data drop by watermark
>
[
https://issues.apache.org/jira/browse/FLINK-7611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
aitozi updated FLINK-7611:
--
Affects Version/s: 1.2.0
> add metrics to measure the data drop by watermark
>
[
https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16168852#comment-16168852
]
aitozi commented on FLINK-7608:
---
i am doubt that why it need to access the value of p50,p95,p99. i think
aitozi created FLINK-7611:
-
Summary: add metrics to measure the data drop by watermark
Key: FLINK-7611
URL: https://issues.apache.org/jira/browse/FLINK-7611
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-7611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16164008#comment-16164008
]
aitozi commented on FLINK-7611:
---
i have add the pr, https://github.com/apache/flink/pull/4665 , anyone
[
https://issues.apache.org/jira/browse/FLINK-7945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
aitozi updated FLINK-7945:
--
Summary: Per partition-lag metric lost in kafka connector (was:
kafka-connector11 use kafkaConsumer0.9 caused
[
https://issues.apache.org/jira/browse/FLINK-7945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16234932#comment-16234932
]
aitozi commented on FLINK-7945:
---
Before I think the losed metric is caused by the kafka client is used
[
https://issues.apache.org/jira/browse/FLINK-7945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
aitozi updated FLINK-7945:
--
Affects Version/s: 1.3.2
> kafka-connector11 use kafkaConsumer0.9 caused it lost the important metric in
>
[
https://issues.apache.org/jira/browse/FLINK-6109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
aitozi reassigned FLINK-6109:
-
Assignee: aitozi
> Add "consumer lag" report metric to FlinkKafkaConsumer
>
[
https://issues.apache.org/jira/browse/FLINK-6109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
aitozi reassigned FLINK-6109:
-
Assignee: aitozi
> Add "consumer lag" report metric to FlinkKafkaConsumer
>
[
https://issues.apache.org/jira/browse/FLINK-6109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
aitozi reassigned FLINK-6109:
-
Assignee: (was: aitozi)
> Add "consumer lag" report metric to FlinkKafkaConsumer
>
[
https://issues.apache.org/jira/browse/FLINK-6109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16224395#comment-16224395
]
aitozi commented on FLINK-6109:
---
Is anyone working on this issue, Now in version 1.3.2 we can only see that
aitozi created FLINK-7945:
-
Summary: kafka-connector10 use kafkaConsumer0.9 caused it lost the
important metric in kafka clients10
Key: FLINK-7945
URL: https://issues.apache.org/jira/browse/FLINK-7945
[
https://issues.apache.org/jira/browse/FLINK-7945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16224782#comment-16224782
]
aitozi edited comment on FLINK-7945 at 10/30/17 11:55 AM:
--
This may be can partly
[
https://issues.apache.org/jira/browse/FLINK-7945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16224796#comment-16224796
]
aitozi commented on FLINK-7945:
---
This may be can partly address
[
https://issues.apache.org/jira/browse/FLINK-7945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
aitozi updated FLINK-7945:
--
Comment: was deleted
(was: This may be can partly address
https://issues.apache.org/jira/browse/FLINK-6109# )
[
https://issues.apache.org/jira/browse/FLINK-7945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16224782#comment-16224782
]
aitozi commented on FLINK-7945:
---
This may be can address https://issues.apache.org/jira/browse/FLINK-6109#
aitozi created FLINK-7895:
-
Summary: Error in the example in SideOutput usage example that
show how to get late message of window
Key: FLINK-7895
URL: https://issues.apache.org/jira/browse/FLINK-7895
[
https://issues.apache.org/jira/browse/FLINK-7945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
aitozi updated FLINK-7945:
--
Affects Version/s: (was: 1.3.2)
(was: 1.2.1)
1.4.0
[
https://issues.apache.org/jira/browse/FLINK-9418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488660#comment-16488660
]
aitozi commented on FLINK-9418:
---
Hi, can you share some detail about how to reach this "so that only the
aitozi created FLINK-9431:
-
Summary: Introduce TimeEnd State to flink cep
Key: FLINK-9431
URL: https://issues.apache.org/jira/browse/FLINK-9431
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-9431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488734#comment-16488734
]
aitozi commented on FLINK-9431:
---
[~dawidwys]two thing:
# 1. if i use
[
https://issues.apache.org/jira/browse/FLINK-9431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488734#comment-16488734
]
aitozi edited comment on FLINK-9431 at 5/24/18 9:57 AM:
[~dawidwys] Three thing:
[
https://issues.apache.org/jira/browse/FLINK-9431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488734#comment-16488734
]
aitozi edited comment on FLINK-9431 at 5/24/18 9:56 AM:
[~dawidwys] Three thing:
[
https://issues.apache.org/jira/browse/FLINK-9431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488734#comment-16488734
]
aitozi edited comment on FLINK-9431 at 5/24/18 9:56 AM:
[~dawidwys] Three thing:
[
https://issues.apache.org/jira/browse/FLINK-9431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488734#comment-16488734
]
aitozi edited comment on FLINK-9431 at 5/24/18 10:00 AM:
-
[~dawidwys] Three thing:
aitozi created FLINK-9443:
-
Summary: Remove unused parameter in StreamGraphHasherV2
Key: FLINK-9443
URL: https://issues.apache.org/jira/browse/FLINK-9443
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-9561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16507250#comment-16507250
]
aitozi commented on FLINK-9561:
---
Get it, thanks. i will close this issue.
> Lack of the api to set
[
https://issues.apache.org/jira/browse/FLINK-9561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
aitozi closed FLINK-9561.
-
Resolution: Not A Problem
> Lack of the api to set RocksDB Option by flink config
>
aitozi created FLINK-9561:
-
Summary: Lack of the api to set RocksDB Option by flink config
Key: FLINK-9561
URL: https://issues.apache.org/jira/browse/FLINK-9561
Project: Flink
Issue Type:
aitozi created FLINK-9579:
-
Summary: Remove unnecessary check with cep elementQueue
Key: FLINK-9579
URL: https://issues.apache.org/jira/browse/FLINK-9579
Project: Flink
Issue Type: Improvement
aitozi created FLINK-9588:
-
Summary: Reuse the same conditionContext with in a same
computationState
Key: FLINK-9588
URL: https://issues.apache.org/jira/browse/FLINK-9588
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-9579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
aitozi updated FLINK-9579:
--
Summary: Remove unnecessary clear with cep elementQueue (was: Remove
unnecessary check with cep elementQueue)
aitozi created FLINK-9476:
-
Summary: Lost sideOutPut Late Elements in CEP Operator
Key: FLINK-9476
URL: https://issues.apache.org/jira/browse/FLINK-9476
Project: Flink
Issue Type: Improvement
aitozi created FLINK-9507:
-
Summary: Introduce ReduceFunction to CEP to minor the cost for
IterativeCondition
Key: FLINK-9507
URL: https://issues.apache.org/jira/browse/FLINK-9507
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
aitozi updated FLINK-9507:
--
Description:
When we use the cep to describe a condition about the events that has been
matched, we have to
[
https://issues.apache.org/jira/browse/FLINK-9507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16499467#comment-16499467
]
aitozi commented on FLINK-9507:
---
Hi [~kkl0u]
Thanks for your quick answer, I have apply the patch
aitozi created FLINK-9504:
-
Summary: Change checkpoint duration log level to debug to avoid
too much log
Key: FLINK-9504
URL: https://issues.apache.org/jira/browse/FLINK-9504
Project: Flink
Issue
aitozi created FLINK-9533:
-
Summary: CEP
Key: FLINK-9533
URL: https://issues.apache.org/jira/browse/FLINK-9533
Project: Flink
Issue Type: Bug
Reporter: aitozi
--
This message was
aitozi created FLINK-9534:
-
Summary: CEP
Key: FLINK-9534
URL: https://issues.apache.org/jira/browse/FLINK-9534
Project: Flink
Issue Type: Bug
Reporter: aitozi
--
This message was
[
https://issues.apache.org/jira/browse/FLINK-9533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
aitozi reassigned FLINK-9533:
-
Assignee: aitozi
Affects Version/s: 1.4.2
Description:
As described in the
[
https://issues.apache.org/jira/browse/FLINK-9534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
aitozi closed FLINK-9534.
-
Resolution: Invalid
uncarefully opened twice, and don't know how to delete = =, so just closed it ,
sorry.
>
[
https://issues.apache.org/jira/browse/FLINK-9533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
aitozi updated FLINK-9533:
--
Description:
As described in the
[
https://issues.apache.org/jira/browse/FLINK-9533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
aitozi updated FLINK-9533:
--
Description:
As described in the [link
[
https://issues.apache.org/jira/browse/FLINK-6759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16521377#comment-16521377
]
aitozi commented on FLINK-6759:
---
Can i ask how to skip this error? I encountered the same error when maven
aitozi created FLINK-9620:
-
Summary: Add an alternative option to choose when deal with
eventtime cep
Key: FLINK-9620
URL: https://issues.apache.org/jira/browse/FLINK-9620
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-6109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16350468#comment-16350468
]
aitozi commented on FLINK-6109:
---
[~tzulitai] you mentioned that the calculate of the lag is overwhelming,
[
https://issues.apache.org/jira/browse/FLINK-8477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16350403#comment-16350403
]
aitozi commented on FLINK-8477:
---
[~aljoscha]In production, some application like monitor type , it need the
[
https://issues.apache.org/jira/browse/FLINK-6109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16350437#comment-16350437
]
aitozi commented on FLINK-6109:
---
OK， i will see the pr later .
> Add "consumer lag" report metric to
aitozi created FLINK-9642:
-
Summary: Reduce the count to deal with state during a CEP process
Key: FLINK-9642
URL: https://issues.apache.org/jira/browse/FLINK-9642
Project: Flink
Issue Type:
aitozi created FLINK-10158:
--
Summary: The DataOutputSerializer may consume excessive memory
Key: FLINK-10158
URL: https://issues.apache.org/jira/browse/FLINK-10158
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-9054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16582220#comment-16582220
]
aitozi commented on FLINK-9054:
---
It may be caused by the timerService not shutdown correctly, Is it
[
https://issues.apache.org/jira/browse/FLINK-10158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16582349#comment-16582349
]
aitozi commented on FLINK-10158:
Thanks for your remind [~zjwang], I will take a look at your PR later,
[
https://issues.apache.org/jira/browse/FLINK-9054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16587165#comment-16587165
]
aitozi commented on FLINK-9054:
---
I think it has been solved by
[
https://issues.apache.org/jira/browse/FLINK-10158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
aitozi closed FLINK-10158.
--
Resolution: Duplicate
> The DataOutputSerializer may consume excessive memory
>
[
https://issues.apache.org/jira/browse/FLINK-9054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
aitozi updated FLINK-9054:
--
Comment: was deleted
(was: I think it has been solved by
[
https://issues.apache.org/jira/browse/FLINK-9054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16582220#comment-16582220
]
aitozi edited comment on FLINK-9054 at 8/21/18 8:56 AM:
Is it reproducible ? Is
[
https://issues.apache.org/jira/browse/FLINK-10223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
aitozi reassigned FLINK-10223:
--
Assignee: aitozi
> TaskManagers should log their ResourceID during startup
>
aitozi created FLINK-10254:
--
Summary: Fix check in stateBackend
Key: FLINK-10254
URL: https://issues.apache.org/jira/browse/FLINK-10254
Project: Flink
Issue Type: Improvement
Components:
aitozi created FLINK-9883:
-
Summary: Filter the target window to calculate when deal with
slidewindow
Key: FLINK-9883
URL: https://issues.apache.org/jira/browse/FLINK-9883
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-9883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16547521#comment-16547521
]
aitozi edited comment on FLINK-9883 at 7/18/18 8:08 AM:
IMO, it can be used like
[
https://issues.apache.org/jira/browse/FLINK-9883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16547521#comment-16547521
]
aitozi commented on FLINK-9883:
---
IMO, it can be used like this
{code:java}
.keyBy()
[
https://issues.apache.org/jira/browse/FLINK-9883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16547528#comment-16547528
]
aitozi commented on FLINK-9883:
---
user can calculate whether this window belong to the current day or
[
https://issues.apache.org/jira/browse/FLINK-9883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
aitozi closed FLINK-9883.
-
Resolution: Won't Fix
> Filter the target window to calculate when deal with slidewindow
>
[
https://issues.apache.org/jira/browse/FLINK-9883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16549069#comment-16549069
]
aitozi commented on FLINK-9883:
---
I think it over again, maybe it can be done by user custom trigger. Do you
[
https://issues.apache.org/jira/browse/FLINK-9938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16555190#comment-16555190
]
aitozi commented on FLINK-9938:
---
Can it be done by checking periodic ? so that the clean up of state is not
[
https://issues.apache.org/jira/browse/FLINK-10254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
aitozi updated FLINK-10254:
---
Summary: Fix inappropriate checkNotNull in stateBackend (was: Fix check in
stateBackend)
> Fix
[
https://issues.apache.org/jira/browse/FLINK-10223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16609935#comment-16609935
]
aitozi commented on FLINK-10223:
[~gjy]I have pushed the PR, could help take a look please, thx
>
[
https://issues.apache.org/jira/browse/FLINK-7129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16336981#comment-16336981
]
aitozi commented on FLINK-7129:
---
Hi，can i ask the progress of this feature ?
> Dynamically changing
aitozi created FLINK-8477:
-
Summary: Add api to support for user to skip the first incomplete
window data
Key: FLINK-8477
URL: https://issues.apache.org/jira/browse/FLINK-8477
Project: Flink
Issue
aitozi created FLINK-8893:
-
Summary: NPE when netty try to allocate directBuffer
Key: FLINK-8893
URL: https://issues.apache.org/jira/browse/FLINK-8893
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-8914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16396500#comment-16396500
]
aitozi commented on FLINK-8914:
---
Yes, i run into this bug too, greedy only works when it has a ending flag.
[
https://issues.apache.org/jira/browse/FLINK-9122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423762#comment-16423762
]
aitozi commented on FLINK-9122:
---
thanks [~aljoscha] ，still have two question
1. Why the exception appear in
[
https://issues.apache.org/jira/browse/FLINK-8914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
aitozi reassigned FLINK-8914:
-
Assignee: aitozi
> CEP's greedy() modifier doesn't work
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-8914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16421652#comment-16421652
]
aitozi commented on FLINK-8914:
---
I am woking with issue, can i take over this issue?
> CEP's greedy()
aitozi created FLINK-9122:
-
Summary: NFASerialize deserailze failed and cause other exception
Key: FLINK-9122
URL: https://issues.apache.org/jira/browse/FLINK-9122
Project: Flink
Issue Type: Bug
aitozi created FLINK-8869:
-
Summary: Kafka restore from checkpoint without react to the new
add partition to kafka server
Key: FLINK-8869
URL: https://issues.apache.org/jira/browse/FLINK-8869
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526330#comment-16526330
]
aitozi commented on FLINK-9687:
---
Hi, [~kkl0u]
I have added my thought/description on this issue, can you
[
https://issues.apache.org/jira/browse/FLINK-9687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
aitozi updated FLINK-9687:
--
Description: When the window operator is fired by the event timer or
processing timer, it fetch the state
aitozi created FLINK-9687:
-
Summary: Delay the state fetch only when the triggerResult is fire
Key: FLINK-9687
URL: https://issues.apache.org/jira/browse/FLINK-9687
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-10095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16649655#comment-16649655
]
aitozi commented on FLINK-10095:
Hi, [~azagrebin]
I have a little question here:
If we use the order
[
https://issues.apache.org/jira/browse/FLINK-10596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16658778#comment-16658778
]
aitozi commented on FLINK-10596:
Hi, [~dawidwys]
I want to deal with this PR, can i work on this ?
aitozi created FLINK-10567:
--
Summary: Lost serialize fields when ttl state store with the
mutable serializer
Key: FLINK-10567
URL: https://issues.apache.org/jira/browse/FLINK-10567
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-10095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660309#comment-16660309
]
aitozi commented on FLINK-10095:
Ok, I get it , thanks [~azagrebin]
> Change the serialisation order in
[
https://issues.apache.org/jira/browse/FLINK-8914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16601943#comment-16601943
]
aitozi commented on FLINK-8914:
---
Hi,[~alpinegizmo] & [~GuoLJ]
Now It can be solved like this
{code:java}
[
https://issues.apache.org/jira/browse/FLINK-11077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
aitozi updated FLINK-11077:
---
Description: Now checkpoint coordinator will cancel the checkpoint when
checkpoint timeout. But the subtask
aitozi created FLINK-11077:
--
Summary: Make subtask aware of the timeout of checkpoint and abort
the current ongoing asynccheckpoint
Key: FLINK-11077
URL: https://issues.apache.org/jira/browse/FLINK-11077
[
https://issues.apache.org/jira/browse/FLINK-10996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16706685#comment-16706685
]
aitozi commented on FLINK-10996:
Hi, [~StephanEwen]
I think it can be resolved by supporting the api to
aitozi created FLINK-10996:
--
Summary: Enable state ttl in cep
Key: FLINK-10996
URL: https://issues.apache.org/jira/browse/FLINK-10996
Project: Flink
Issue Type: Improvement
Components:
aitozi created FLINK-10990:
--
Summary: Pre-check timespan in meterview to avoid NAN
Key: FLINK-10990
URL: https://issues.apache.org/jira/browse/FLINK-10990
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-10343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
aitozi closed FLINK-10343.
--
Resolution: Won't Fix
> Expose setCurrentKey method to streamRuntimeContext
>
[
https://issues.apache.org/jira/browse/FLINK-8477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
aitozi closed FLINK-8477.
-
Resolution: Won't Fix
> Add api to support for user to skip the first incomplete window data
>
[
https://issues.apache.org/jira/browse/FLINK-10343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16614932#comment-16614932
]
aitozi commented on FLINK-10343:
Hi, [~kkl0u]
I think the approach implementing specific operator by
[
https://issues.apache.org/jira/browse/FLINK-10343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16614932#comment-16614932
]
aitozi edited comment on FLINK-10343 at 9/14/18 2:54 PM:
-
Hi, [~kkl0u]
I think
[
https://issues.apache.org/jira/browse/FLINK-10343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16614951#comment-16614951
]
aitozi commented on FLINK-10343:
[~kkl0u]
Yes, I agree with that it's not good to break the
[
https://issues.apache.org/jira/browse/FLINK-10343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16615034#comment-16615034
]
aitozi commented on FLINK-10343:
Thanks for [~kkl0u] [~aljoscha] [~azagrebin]'s suggestion which makes
[
https://issues.apache.org/jira/browse/FLINK-9761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16617710#comment-16617710
]
aitozi commented on FLINK-9761:
---
Hi，[~NicoK]
why does the stagedMessagesHandler still should work when the
[
https://issues.apache.org/jira/browse/FLINK-10343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
aitozi updated FLINK-10343:
---
Description:
when we use reducing state / aggregating keyed state and so on , we have to
read value from
aitozi created FLINK-10343:
--
Summary: Expose setCurrentKey method to streamRuntimeContext
Key: FLINK-10343
URL: https://issues.apache.org/jira/browse/FLINK-10343
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-11077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
aitozi closed FLINK-11077.
--
Resolution: Won't Fix
> Make subtask aware of the timeout of checkpoint and abort the current ongoing
>
1 - 100 of 803 matches
Mail list logo
