[
https://issues.apache.org/jira/browse/FLINK-25932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17602192#comment-17602192
]
Wei-Che Wei commented on FLINK-25932:
-
Hi [~twalthr], got it. I was not aware of thi
[
https://issues.apache.org/jira/browse/FLINK-25932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17602168#comment-17602168
]
Wei-Che Wei commented on FLINK-25932:
-
Hi [~slinkydeveloper], [~twalthr],
I found t
[
https://issues.apache.org/jira/browse/FLINK-25048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17448904#comment-17448904
]
Wei-Che Wei edited comment on FLINK-25048 at 11/25/21, 2:41 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-25048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17448904#comment-17448904
]
Wei-Che Wei edited comment on FLINK-25048 at 11/25/21, 2:37 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-25048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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&focusedCommentId=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&focusedCommentId=17448904#comment-17448904
]
Wei-Che Wei commented on FLINK-25048:
-
[~liangxinli] try this
> 在某个option后设置waterma
[
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&focusedCommentId=17364645#comment-17364645
]
Wei-Che Wei commented on FLINK-22970:
-
Hi [~Leonard Xu]
Could you assign this jira t
[
https://issues.apache.org/jira/browse/FLINK-23012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364644#comment-17364644
]
Wei-Che Wei edited comment on FLINK-23012 at 6/17/21, 2:46 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-23012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364644#comment-17364644
]
Wei-Che Wei commented on FLINK-23012:
-
Hi [~jark]
> Add v1.13 docs link in "Pick Do
[
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
[http://apache-flink-user-mailing-list-archive.23360
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&focusedCommentId=17353014#comment-17353014
]
Wei-Che Wei commented on FLINK-22796:
-
Hi [~jark]
could you assign this issue to me?
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`,
`yarn-p
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&focusedCommentId=17325611#comment-17325611
]
Wei-Che Wei commented on FLINK-19358:
-
Hi [~trohrmann], [~kkl0u]
I think this issue
[
https://issues.apache.org/jira/browse/FLINK-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16947309#comment-16947309
]
Wei-Che Wei edited comment on FLINK-14302 at 10/9/19 1:52 AM:
[
https://issues.apache.org/jira/browse/FLINK-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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&focusedCommentId=16941640#comment-16941640
]
Wei-Che Wei edited comment on FLINK-14302 at 10/7/19 6:59 AM:
[
https://issues.apache.org/jira/browse/FLINK-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16945515#comment-16945515
]
Wei-Che Wei commented on FLINK-14302:
-
Hi [~becket_qin]
The root cause of NOT_COOR
[
https://issues.apache.org/jira/browse/FLINK-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16941640#comment-16941640
]
Wei-Che Wei commented on FLINK-14302:
-
Sorry for that I didn't notice that the contr
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: https://issues.ap
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: Bug
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 consume
[
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 c
[
https://issues.apache.org/jira/browse/FLINK-9486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16610615#comment-16610615
]
Wei-Che Wei commented on FLINK-9486:
It's clear to me now. Thanks!
> Introduce Timer
[
https://issues.apache.org/jira/browse/FLINK-9486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16610597#comment-16610597
]
Wei-Che Wei commented on FLINK-9486:
Hi [~srichter],
If I didn't misunderstand. The t
[
https://issues.apache.org/jira/browse/FLINK-9486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16610365#comment-16610365
]
Wei-Che Wei commented on FLINK-9486:
Hi [~srichter]
Can time service be migrated from
[
https://issues.apache.org/jira/browse/FLINK-4714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16404461#comment-16404461
]
Wei-Che Wei edited comment on FLINK-4714 at 3/19/18 2:46 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-4714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16404461#comment-16404461
]
Wei-Che Wei commented on FLINK-4714:
Hi [~till.rohrmann]
Since FLINK-5982 has been mer
[
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 wit
[
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&focusedCommentId=16310618#comment-16310618
]
Wei-Che Wei commented on FLINK-7935:
Hi [~elevy]
What you described is almost correct.
[
https://issues.apache.org/jira/browse/FLINK-7935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16309048#comment-16309048
]
Wei-Che Wei commented on FLINK-7935:
Hi [~elevy]
Since FLINK-7692 was solved, user can
[
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 specifi
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.o
[
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 us
[
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 specif
[
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
> defin
[
https://issues.apache.org/jira/browse/FLINK-8324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16304988#comment-16304988
]
Wei-Che Wei commented on FLINK-8324:
Hi [~tzulitai]
Looking forward to hearing your co
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
Pr
[
https://issues.apache.org/jira/browse/FLINK-7692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16269921#comment-16269921
]
Wei-Che Wei commented on FLINK-7692:
[~Zentol]
This idea is much better. I would like
[
https://issues.apache.org/jira/browse/FLINK-7692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16235098#comment-16235098
]
Wei-Che Wei edited comment on FLINK-7692 at 11/7/17 5:36 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-7692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16235098#comment-16235098
]
Wei-Che Wei commented on FLINK-7692:
Hi [~Zentol]
I proposed a draft for this issue a
[
https://issues.apache.org/jira/browse/FLINK-7935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16221566#comment-16221566
]
Wei-Che Wei commented on FLINK-7935:
Hi [~elevy]
Is this issue same as FLINK-7692
> M
[
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 {{null}
[
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 {{null}
[
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 pat
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 a
[
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&focusedCommentId=16167955#comment-16167955
]
Wei-Che Wei commented on FLINK-7630:
Hi [~aljoscha]
FYI. If there is any feedback, ple
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: Flink
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 Type:
[
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 chec
[
https://issues.apache.org/jira/browse/FLINK-6653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16022800#comment-16022800
]
Wei-Che Wei edited comment on FLINK-6653 at 5/24/17 12:32 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-6653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16022800#comment-16022800
]
Wei-Che Wei edited comment on FLINK-6653 at 5/24/17 12:33 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-6653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16022800#comment-16022800
]
Wei-Che Wei commented on FLINK-6653:
Hi [~tzulitai],
I would like to take over this i
[
https://issues.apache.org/jira/browse/FLINK-6653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16022751#comment-16022751
]
Wei-Che Wei commented on FLINK-6653:
Hi~ [~tzulitai]
I would like to take over this i
[
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 propos
[
https://issues.apache.org/jira/browse/FLINK-6328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16016776#comment-16016776
]
Wei-Che Wei commented on FLINK-6328:
Hi all,
Are this and FLINK-6071 the similar issu
[
https://issues.apache.org/jira/browse/FLINK-5624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948326#comment-15948326
]
Wei-Che Wei commented on FLINK-5624:
Sorry for putting the wrong JIRA task id. > <
>
[
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 p
[
https://issues.apache.org/jira/browse/FLINK-4523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15946622#comment-15946622
]
Wei-Che Wei commented on FLINK-4523:
[~tsriharsha]
I have opened a task (FLINK-6211)
[
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 start
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: Fli
[
https://issues.apache.org/jira/browse/FLINK-5982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15943360#comment-15943360
]
Wei-Che Wei commented on FLINK-5982:
Hi [~till.rohrmann],
I prefer not to pass only {
[
https://issues.apache.org/jira/browse/FLINK-5982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15942972#comment-15942972
]
Wei-Che Wei commented on FLINK-5982:
Hi [~till.rohrmann]
Ok, I see. Thanks for your s
[
https://issues.apache.org/jira/browse/FLINK-5982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15939521#comment-15939521
]
Wei-Che Wei commented on FLINK-5982:
Hi [~till.rohrmann]
Thanks for your replying. Fo
[
https://issues.apache.org/jira/browse/FLINK-5982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15906135#comment-15906135
]
Wei-Che Wei commented on FLINK-5982:
I see. I will just focus on refactoring {{setEnvi
[
https://issues.apache.org/jira/browse/FLINK-5982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15901331#comment-15901331
]
Wei-Che Wei commented on FLINK-5982:
[~StephanEwen], [~till.rohrmann]
Have updated 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 {{i
[
https://issues.apache.org/jira/browse/FLINK-5982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15901309#comment-15901309
]
Wei-Che Wei commented on FLINK-5982:
If handling recovery state on {{BatchTask}} is ne
[
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 {{i
[
https://issues.apache.org/jira/browse/FLINK-5982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15899368#comment-15899368
]
Wei-Che Wei edited comment on FLINK-5982 at 3/7/17 12:37 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-5982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15899368#comment-15899368
]
Wei-Che Wei commented on FLINK-5982:
FYI [~StephanEwen], [~till.rohrmann]
Please let
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: Improvement
[
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 wit
[
https://issues.apache.org/jira/browse/FLINK-4816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15896187#comment-15896187
]
Wei-Che Wei commented on FLINK-4816:
Hi [~ram_krish]
If you have been working on it,
[
https://issues.apache.org/jira/browse/FLINK-4816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15895720#comment-15895720
]
Wei-Che Wei commented on FLINK-4816:
Hi [~ram_krish]
How about make the return value
[
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 specifi
[
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 ch
[
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&focusedCommentId=15893937#comment-15893937
]
Wei-Che Wei commented on FLINK-4714:
Hi [~till.rohrmann]
Thanks for your feedback. I
[
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 FLI
[
https://issues.apache.org/jira/browse/FLINK-4815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891711#comment-15891711
]
Wei-Che Wei commented on FLINK-4815:
Hi [~uce]
I saw you implement {{ZooKeeperComplet
[
https://issues.apache.org/jira/browse/FLINK-4714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891709#comment-15891709
]
Wei-Che Wei commented on FLINK-4714:
Hi [~uce]
I saw you implement {{ZooKeeperComplet
[
https://issues.apache.org/jira/browse/FLINK-4714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891545#comment-15891545
]
Wei-Che Wei commented on FLINK-4714:
Hi [~till.rohrmann]
I have some ideas about this
[
https://issues.apache.org/jira/browse/FLINK-4714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15882562#comment-15882562
]
Wei-Che Wei edited comment on FLINK-4714 at 2/25/17 5:10 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-4714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15882562#comment-15882562
]
Wei-Che Wei commented on FLINK-4714:
Hi Andrew, are you still working on the task? If
[
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: J
1 - 100 of 103 matches
Mail list logo