[
https://issues.apache.org/jira/browse/FLINK-25932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17602192#comment-17602192
]
Wei-Che Wei commented on FLINK-25932:
-
Hi [~twalthr], got it. I was not aware of this fix. thanks
[
https://issues.apache.org/jira/browse/FLINK-25932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17602168#comment-17602168
]
Wei-Che Wei commented on FLINK-25932:
-
Hi [~slinkydeveloper], [~twalthr],
I found that
[
https://issues.apache.org/jira/browse/FLINK-25048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448904#comment-17448904
]
Wei-Che Wei edited comment on FLINK-25048 at 11/25/21, 2:41 AM:
Hi
[
https://issues.apache.org/jira/browse/FLINK-25048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448904#comment-17448904
]
Wei-Che Wei edited comment on FLINK-25048 at 11/25/21, 2:37 AM:
Hi
[
https://issues.apache.org/jira/browse/FLINK-25048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448904#comment-17448904
]
Wei-Che Wei edited comment on FLINK-25048 at 11/25/21, 2:35 AM:
[
https://issues.apache.org/jira/browse/FLINK-25048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448904#comment-17448904
]
Wei-Che Wei edited comment on FLINK-25048 at 11/25/21, 2:32 AM:
[
https://issues.apache.org/jira/browse/FLINK-25048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448904#comment-17448904
]
Wei-Che Wei commented on FLINK-25048:
-
[~liangxinli] try this
> 在某个option后设置watermark,如果这个option里面有
[
https://issues.apache.org/jira/browse/FLINK-22970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei updated FLINK-22970:
Affects Version/s: 1.14.0
> The documentation for `TO_TIMESTAMP` UDF has an incorrect description
[
https://issues.apache.org/jira/browse/FLINK-22970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364645#comment-17364645
]
Wei-Che Wei commented on FLINK-22970:
-
Hi [~Leonard Xu]
Could you assign this jira to me and help to
[
https://issues.apache.org/jira/browse/FLINK-23012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364644#comment-17364644
]
Wei-Che Wei edited comment on FLINK-23012 at 6/17/21, 2:46 AM:
---
Hi [~jark]
[
https://issues.apache.org/jira/browse/FLINK-23012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364644#comment-17364644
]
Wei-Che Wei commented on FLINK-23012:
-
Hi [~jark]
> Add v1.13 docs link in "Pick Docs Version" for
[
https://issues.apache.org/jira/browse/FLINK-22970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei updated FLINK-22970:
Description:
According to this ML discussion
Wei-Che Wei created FLINK-22970:
---
Summary: The documentation for `TO_TIMESTAMP` UDF has an incorrect
description
Key: FLINK-22970
URL: https://issues.apache.org/jira/browse/FLINK-22970
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-22796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17353014#comment-17353014
]
Wei-Che Wei commented on FLINK-22796:
-
Hi [~jark]
could you assign this issue to me? thanks.
>
Wei-Che Wei created FLINK-22796:
---
Summary: Update mem_setup_tm documentation
Key: FLINK-22796
URL: https://issues.apache.org/jira/browse/FLINK-22796
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-22476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei updated FLINK-22476:
Affects Version/s: 1.13.0
> Extend the description of the config option `execution.target`
>
[
https://issues.apache.org/jira/browse/FLINK-22476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei updated FLINK-22476:
Description:
the current description for `execution.target` only lists `remote`, `local`,
Wei-Che Wei created FLINK-22476:
---
Summary: Extend the description of the config option
`execution.target`
Key: FLINK-22476
URL: https://issues.apache.org/jira/browse/FLINK-22476
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-19358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325611#comment-17325611
]
Wei-Che Wei commented on FLINK-19358:
-
Hi [~trohrmann], [~kkl0u]
I think this issue might also
[
https://issues.apache.org/jira/browse/FLINK-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16947309#comment-16947309
]
Wei-Che Wei edited comment on FLINK-14302 at 10/9/19 1:52 AM:
--
Hi
[
https://issues.apache.org/jira/browse/FLINK-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16947309#comment-16947309
]
Wei-Che Wei commented on FLINK-14302:
-
Hi [~becket_qin]
I think the error was from
[
https://issues.apache.org/jira/browse/FLINK-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16941640#comment-16941640
]
Wei-Che Wei edited comment on FLINK-14302 at 10/7/19 6:59 AM:
--
Sorry for
[
https://issues.apache.org/jira/browse/FLINK-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16945515#comment-16945515
]
Wei-Che Wei commented on FLINK-14302:
-
Hi [~becket_qin]
The root cause of NOT_COORDINATOR is not
[
https://issues.apache.org/jira/browse/FLINK-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16941640#comment-16941640
]
Wei-Che Wei commented on FLINK-14302:
-
Sorry for that I didn't notice that the contribution flow has
Wei-Che Wei created FLINK-14302:
---
Summary: FlinkKafkaInternalProducer should not send
`ADD_PARTITIONS_TO_TXN` request if `newPartitionsInTransaction` is empty when
enable EoS
Key: FLINK-14302
URL:
Wei-Che Wei created FLINK-11251:
---
Summary: Incompatible metric name on prometheus reporter
Key: FLINK-11251
URL: https://issues.apache.org/jira/browse/FLINK-11251
Project: Flink
Issue Type:
Wei-Che Wei created FLINK-11034:
---
Summary: Provide "rewriting config” to file system factory
Key: FLINK-11034
URL: https://issues.apache.org/jira/browse/FLINK-11034
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-4574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei reassigned FLINK-4574:
--
Assignee: (was: Wei-Che Wei)
> Strengthen fetch interval implementation in Kinesis
[
https://issues.apache.org/jira/browse/FLINK-4816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei reassigned FLINK-4816:
--
Assignee: (was: Wei-Che Wei)
> Executions failed from "DEPLOYING" should retain restored
[
https://issues.apache.org/jira/browse/FLINK-9486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16610615#comment-16610615
]
Wei-Che Wei commented on FLINK-9486:
It's clear to me now. Thanks!
> Introduce TimerState in keyed
[
https://issues.apache.org/jira/browse/FLINK-9486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16610597#comment-16610597
]
Wei-Che Wei commented on FLINK-9486:
Hi [~srichter],
If I didn't misunderstand. The timer has been
[
https://issues.apache.org/jira/browse/FLINK-9486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16610365#comment-16610365
]
Wei-Che Wei commented on FLINK-9486:
Hi [~srichter]
Can time service be migrated from heap-based to
[
https://issues.apache.org/jira/browse/FLINK-4714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16404461#comment-16404461
]
Wei-Che Wei commented on FLINK-4714:
Hi [~till.rohrmann]
Since FLINK-5982 has been merged, I would
[
https://issues.apache.org/jira/browse/FLINK-4817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei reassigned FLINK-4817:
--
Assignee: (was: Wei-Che Wei)
> Checkpoint Coordinator should be called to restore state
[
https://issues.apache.org/jira/browse/FLINK-5982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei closed FLINK-5982.
--
Resolution: Done
Fix Version/s: 1.5.0
> Refactor AbstractInvokable and StatefulTask
>
[
https://issues.apache.org/jira/browse/FLINK-7935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16310618#comment-16310618
]
Wei-Che Wei commented on FLINK-7935:
Hi [~elevy]
What you described is almost correct. The FLINK-7692
[
https://issues.apache.org/jira/browse/FLINK-7935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16309048#comment-16309048
]
Wei-Che Wei commented on FLINK-7935:
Hi [~elevy]
Since FLINK-7692 was solved, user can use
[
https://issues.apache.org/jira/browse/FLINK-4817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei reassigned FLINK-4817:
--
Assignee: Wei-Che Wei
> Checkpoint Coordinator should be called to restore state with a
Wei-Che Wei created FLINK-8326:
--
Summary:
CheckpointCoordinatorTest#testRestoreLatestCheckpointedStateScaleOut() didn't
use the correct parameter to trigger test function
Key: FLINK-8326
URL:
[
https://issues.apache.org/jira/browse/FLINK-8324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei updated FLINK-8324:
---
Priority: Trivial (was: Major)
> Expose another offsets metrics by using new metric API to specify
[
https://issues.apache.org/jira/browse/FLINK-8324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei updated FLINK-8324:
---
Affects Version/s: (was: 1.5.0)
> Expose another offsets metrics by using new metric API to
[
https://issues.apache.org/jira/browse/FLINK-8324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei updated FLINK-8324:
---
Fix Version/s: 1.5.0
> Expose another offsets metrics by using new metric API to specify user
>
[
https://issues.apache.org/jira/browse/FLINK-8324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16304988#comment-16304988
]
Wei-Che Wei commented on FLINK-8324:
Hi [~tzulitai]
Looking forward to hearing your comment. Thank
Wei-Che Wei created FLINK-8324:
--
Summary: Expose another offsets metrics by using new metric API to
specify user defined variables
Key: FLINK-8324
URL: https://issues.apache.org/jira/browse/FLINK-8324
[
https://issues.apache.org/jira/browse/FLINK-7692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16269921#comment-16269921
]
Wei-Che Wei commented on FLINK-7692:
[~Zentol]
This idea is much better. I would like to keep working
[
https://issues.apache.org/jira/browse/FLINK-7692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16235098#comment-16235098
]
Wei-Che Wei edited comment on FLINK-7692 at 11/7/17 5:36 AM:
-
Hi [~Zentol]
I
[
https://issues.apache.org/jira/browse/FLINK-7692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16235098#comment-16235098
]
Wei-Che Wei commented on FLINK-7692:
Hi [~Zentol]
I proposed a draft for this issue and want to get
[
https://issues.apache.org/jira/browse/FLINK-7935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16221566#comment-16221566
]
Wei-Che Wei commented on FLINK-7935:
Hi [~elevy]
Is this issue same as FLINK-7692
> Metrics with user
[
https://issues.apache.org/jira/browse/FLINK-4816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei reassigned FLINK-4816:
--
Assignee: Wei-Che Wei
> Executions failed from "DEPLOYING" should retain restored checkpoint
[
https://issues.apache.org/jira/browse/FLINK-7692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei reassigned FLINK-7692:
--
Assignee: Wei-Che Wei
> Support user-defined variables
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-7675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei updated FLINK-7675:
---
Description:
For internal checkpoint, {{CompletedCheckpointStats.getExternalPath()}} could
be
[
https://issues.apache.org/jira/browse/FLINK-7675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei updated FLINK-7675:
---
Description:
For internal checkpoint, {{CompletedCheckpointStats.getExternalPath()}} could
be
[
https://issues.apache.org/jira/browse/FLINK-7675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei reassigned FLINK-7675:
--
Assignee: Wei-Che Wei
> LatestCompletedCheckpointExternalPathGauge should check if external
Wei-Che Wei created FLINK-7675:
--
Summary: LatestCompletedCheckpointExternalPathGauge should check
if external path is exist
Key: FLINK-7675
URL: https://issues.apache.org/jira/browse/FLINK-7675
Project:
[
https://issues.apache.org/jira/browse/FLINK-7630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei updated FLINK-7630:
---
Priority: Minor (was: Major)
Fix Version/s: 1.3.3
1.4.0
> Allow passing
[
https://issues.apache.org/jira/browse/FLINK-7557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei closed FLINK-7557.
--
Resolution: Not A Bug
> Fix typo for s3a config in AWS deployment documentation
>
[
https://issues.apache.org/jira/browse/FLINK-7630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16167955#comment-16167955
]
Wei-Che Wei commented on FLINK-7630:
Hi [~aljoscha]
FYI. If there is any feedback, please let me know.
Wei-Che Wei created FLINK-7630:
--
Summary: Allow passing a File or an InputStream to
ParameterTool.fromPropertiesFile()
Key: FLINK-7630
URL: https://issues.apache.org/jira/browse/FLINK-7630
Project:
Wei-Che Wei created FLINK-7557:
--
Summary: Fix typo for s3a config in AWS deployment documentation
Key: FLINK-7557
URL: https://issues.apache.org/jira/browse/FLINK-7557
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-6653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei reassigned FLINK-6653:
--
Assignee: Wei-Che Wei
> Avoid directly serializing AWS's Shard class in Kinesis consumer's
[
https://issues.apache.org/jira/browse/FLINK-6653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16022800#comment-16022800
]
Wei-Che Wei edited comment on FLINK-6653 at 5/24/17 12:32 PM:
--
Hi
[
https://issues.apache.org/jira/browse/FLINK-6653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16022800#comment-16022800
]
Wei-Che Wei edited comment on FLINK-6653 at 5/24/17 12:33 PM:
--
Hi
[
https://issues.apache.org/jira/browse/FLINK-6653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16022800#comment-16022800
]
Wei-Che Wei commented on FLINK-6653:
Hi [~tzulitai],
I would like to take over this issue and here is
[
https://issues.apache.org/jira/browse/FLINK-6653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16022751#comment-16022751
]
Wei-Che Wei commented on FLINK-6653:
Hi~ [~tzulitai]
I would like to take over this issue and here is
[
https://issues.apache.org/jira/browse/FLINK-6653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei updated FLINK-6653:
---
Comment: was deleted
(was: Hi~ [~tzulitai]
I would like to take over this issue and here is my
[
https://issues.apache.org/jira/browse/FLINK-6328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016776#comment-16016776
]
Wei-Che Wei commented on FLINK-6328:
Hi all,
Are this and FLINK-6071 the similar issues?
>
[
https://issues.apache.org/jira/browse/FLINK-5624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15948326#comment-15948326
]
Wei-Che Wei commented on FLINK-5624:
Sorry for putting the wrong JIRA task id. > <
> Support tumbling
[
https://issues.apache.org/jira/browse/FLINK-5625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei reassigned FLINK-5625:
--
Assignee: Wei-Che Wei
> Let Date format for timestamp-based start position in Kinesis consumer
[
https://issues.apache.org/jira/browse/FLINK-6211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei reassigned FLINK-6211:
--
Assignee: Wei-Che Wei
> Validation error in Kinesis Consumer when using AT_TIMESTAMP as start
[
https://issues.apache.org/jira/browse/FLINK-4523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15946622#comment-15946622
]
Wei-Che Wei commented on FLINK-4523:
[~tsriharsha]
I have opened a task (FLINK-6211) to solve it.
[
https://issues.apache.org/jira/browse/FLINK-6211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei updated FLINK-6211:
---
Fix Version/s: 1.3.0
> Validation error in Kinesis Consumer when using AT_TIMESTAMP as start position
[
https://issues.apache.org/jira/browse/FLINK-6211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei updated FLINK-6211:
---
Component/s: Kinesis Connector
> Validation error in Kinesis Consumer when using AT_TIMESTAMP as
Wei-Che Wei created FLINK-6211:
--
Summary: Validation error in Kinesis Consumer when using
AT_TIMESTAMP as start position
Key: FLINK-6211
URL: https://issues.apache.org/jira/browse/FLINK-6211
Project:
[
https://issues.apache.org/jira/browse/FLINK-5982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15943360#comment-15943360
]
Wei-Che Wei commented on FLINK-5982:
Hi [~till.rohrmann],
I prefer not to pass only {{Environment}}
[
https://issues.apache.org/jira/browse/FLINK-5982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15942972#comment-15942972
]
Wei-Che Wei commented on FLINK-5982:
Hi [~till.rohrmann]
Ok, I see. Thanks for your suggestion.
>
[
https://issues.apache.org/jira/browse/FLINK-5982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15939521#comment-15939521
]
Wei-Che Wei commented on FLINK-5982:
Hi [~till.rohrmann]
Thanks for your replying. For the first
[
https://issues.apache.org/jira/browse/FLINK-5982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15906135#comment-15906135
]
Wei-Che Wei commented on FLINK-5982:
I see. I will just focus on refactoring {{setEnvironment(env)}},
[
https://issues.apache.org/jira/browse/FLINK-5982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901331#comment-15901331
]
Wei-Che Wei commented on FLINK-5982:
[~StephanEwen], [~till.rohrmann]
Have updated the description. Is
[
https://issues.apache.org/jira/browse/FLINK-5982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei updated FLINK-5982:
---
Description:
Currently, running a invokable in {{Task}} needs to call
{{setEnvironment(env)}} and
[
https://issues.apache.org/jira/browse/FLINK-5982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901309#comment-15901309
]
Wei-Che Wei commented on FLINK-5982:
If handling recovery state on {{BatchTask}} is needed in the
[
https://issues.apache.org/jira/browse/FLINK-5982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei updated FLINK-5982:
---
Description:
Currently, running a invokable in {{Task}} needs to call
{{setEnvironment(env)}} and
[
https://issues.apache.org/jira/browse/FLINK-5982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15899368#comment-15899368
]
Wei-Che Wei edited comment on FLINK-5982 at 3/7/17 12:37 PM:
-
FYI
[
https://issues.apache.org/jira/browse/FLINK-5982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15899368#comment-15899368
]
Wei-Che Wei commented on FLINK-5982:
FYI [~StephanEwen], [~till.rohrmann]
Please let me know if you
Wei-Che Wei created FLINK-5982:
--
Summary: Refactor AbstractInvokable and StatefulTask
Key: FLINK-5982
URL: https://issues.apache.org/jira/browse/FLINK-5982
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-4817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei reassigned FLINK-4817:
--
Assignee: (was: Wei-Che Wei)
> Checkpoint Coordinator should be called to restore state
[
https://issues.apache.org/jira/browse/FLINK-4816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15896187#comment-15896187
]
Wei-Che Wei commented on FLINK-4816:
Hi [~ram_krish]
If you have been working on it, just keep going.
[
https://issues.apache.org/jira/browse/FLINK-4816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15895720#comment-15895720
]
Wei-Che Wei commented on FLINK-4816:
Hi [~ram_krish]
How about make the return value in
[
https://issues.apache.org/jira/browse/FLINK-4817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei reassigned FLINK-4817:
--
Assignee: Wei-Che Wei
> Checkpoint Coordinator should be called to restore state with a
[
https://issues.apache.org/jira/browse/FLINK-4816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei reassigned FLINK-4816:
--
Assignee: (was: Wei-Che Wei)
> Executions failed from "DEPLOYING" should retain restored
[
https://issues.apache.org/jira/browse/FLINK-4816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei reassigned FLINK-4816:
--
Assignee: Wei-Che Wei
> Executions failed from "DEPLOYING" should retain restored checkpoint
[
https://issues.apache.org/jira/browse/FLINK-4714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15893937#comment-15893937
]
Wei-Che Wei commented on FLINK-4714:
Hi [~till.rohrmann]
Thanks for your feedback. I will try to
[
https://issues.apache.org/jira/browse/FLINK-4714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei updated FLINK-4714:
---
Comment: was deleted
(was: Hi [~uce]
I saw you implement {{ZooKeeperCompletedCheckpointStore}} in
[
https://issues.apache.org/jira/browse/FLINK-4815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891711#comment-15891711
]
Wei-Che Wei commented on FLINK-4815:
Hi [~uce]
I saw you implement
[
https://issues.apache.org/jira/browse/FLINK-4714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891709#comment-15891709
]
Wei-Che Wei commented on FLINK-4714:
Hi [~uce]
I saw you implement
[
https://issues.apache.org/jira/browse/FLINK-4714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891545#comment-15891545
]
Wei-Che Wei commented on FLINK-4714:
Hi [~till.rohrmann]
I have some ideas about this issue and I
[
https://issues.apache.org/jira/browse/FLINK-4714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15882562#comment-15882562
]
Wei-Che Wei edited comment on FLINK-4714 at 2/25/17 5:10 AM:
-
Hi [~Andrew
[
https://issues.apache.org/jira/browse/FLINK-4714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15882562#comment-15882562
]
Wei-Che Wei commented on FLINK-4714:
Hi Andrew, are you still working on the task? If not, I can also
[
https://issues.apache.org/jira/browse/FLINK-4754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei reassigned FLINK-4754:
--
Assignee: Wei-Che Wei
> Make number of retained checkpoints user configurable
>
Wei-Che Wei created FLINK-5632:
--
Summary: Typo in StreamGraph
Key: FLINK-5632
URL: https://issues.apache.org/jira/browse/FLINK-5632
Project: Flink
Issue Type: Improvement
Components:
[
https://issues.apache.org/jira/browse/FLINK-4821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei reassigned FLINK-4821:
--
Assignee: Wei-Che Wei
> Implement rescalable non-partitioned state for Kinesis Connector
>
1 - 100 of 102 matches
Mail list logo