[jira] [Commented] (FLINK-25932) Introduce ExecNodeContext.generateUid()

2022-09-09 Thread Wei-Che Wei (Jira)
[ 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

[jira] [Commented] (FLINK-25932) Introduce ExecNodeContext.generateUid()

2022-09-09 Thread Wei-Che Wei (Jira)
[ 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

[jira] [Comment Edited] (FLINK-25048) 在某个option后设置watermark,如果这个option里面有 outputTag,则此outputTag 不会有数据输出,只会在主流输出数据

2021-11-24 Thread Wei-Che Wei (Jira)
[ 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

[jira] [Comment Edited] (FLINK-25048) 在某个option后设置watermark,如果这个option里面有 outputTag,则此outputTag 不会有数据输出,只会在主流输出数据

2021-11-24 Thread Wei-Che Wei (Jira)
[ 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

[jira] [Comment Edited] (FLINK-25048) 在某个option后设置watermark,如果这个option里面有 outputTag,则此outputTag 不会有数据输出,只会在主流输出数据

2021-11-24 Thread Wei-Che Wei (Jira)
[ 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:

[jira] [Comment Edited] (FLINK-25048) 在某个option后设置watermark,如果这个option里面有 outputTag,则此outputTag 不会有数据输出,只会在主流输出数据

2021-11-24 Thread Wei-Che Wei (Jira)
[ 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:

[jira] [Commented] (FLINK-25048) 在某个option后设置watermark,如果这个option里面有 outputTag,则此outputTag 不会有数据输出,只会在主流输出数据

2021-11-24 Thread Wei-Che Wei (Jira)
[ 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里面有

[jira] [Updated] (FLINK-22970) The documentation for `TO_TIMESTAMP` UDF has an incorrect description

2021-06-17 Thread Wei-Che Wei (Jira)
[ 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

[jira] [Commented] (FLINK-22970) The documentation for `TO_TIMESTAMP` UDF has an incorrect description

2021-06-16 Thread Wei-Che Wei (Jira)
[ 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

[jira] [Comment Edited] (FLINK-23012) Add v1.13 docs link in "Pick Docs Version" for master branch

2021-06-16 Thread Wei-Che Wei (Jira)
[ 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]

[jira] [Commented] (FLINK-23012) Add v1.13 docs link in "Pick Docs Version" for master branch

2021-06-16 Thread Wei-Che Wei (Jira)
[ 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

[jira] [Updated] (FLINK-22970) The documentation for `TO_TIMESTAMP` UDF has an incorrect description

2021-06-10 Thread Wei-Che Wei (Jira)
[ 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

[jira] [Created] (FLINK-22970) The documentation for `TO_TIMESTAMP` UDF has an incorrect description

2021-06-10 Thread Wei-Che Wei (Jira)
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

[jira] [Commented] (FLINK-22796) Update mem_setup_tm documentation

2021-05-28 Thread Wei-Che Wei (Jira)
[ 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. >

[jira] [Created] (FLINK-22796) Update mem_setup_tm documentation

2021-05-28 Thread Wei-Che Wei (Jira)
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

[jira] [Updated] (FLINK-22476) Extend the description of the config option `execution.target`

2021-04-27 Thread Wei-Che Wei (Jira)
[ 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` >

[jira] [Updated] (FLINK-22476) Extend the description of the config option `execution.target`

2021-04-26 Thread Wei-Che Wei (Jira)
[ 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`,

[jira] [Created] (FLINK-22476) Extend the description of the config option `execution.target`

2021-04-26 Thread Wei-Che Wei (Jira)
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

[jira] [Commented] (FLINK-19358) when submit job on application mode with HA,the jobid will be 0000000000

2021-04-20 Thread Wei-Che Wei (Jira)
[ 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

[jira] [Comment Edited] (FLINK-14302) FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request if `newPartitionsInTransaction` is empty when enable EoS

2019-10-08 Thread Wei-Che Wei (Jira)
[ 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

[jira] [Commented] (FLINK-14302) FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request if `newPartitionsInTransaction` is empty when enable EoS

2019-10-08 Thread Wei-Che Wei (Jira)
[ 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

[jira] [Comment Edited] (FLINK-14302) FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request if `newPartitionsInTransaction` is empty when enable EoS

2019-10-07 Thread Wei-Che Wei (Jira)
[ 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

[jira] [Commented] (FLINK-14302) FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request if `newPartitionsInTransaction` is empty when enable EoS

2019-10-06 Thread Wei-Che Wei (Jira)
[ 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

[jira] [Commented] (FLINK-14302) FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request if `newPartitionsInTransaction` is empty when enable EoS

2019-10-01 Thread Wei-Che Wei (Jira)
[ 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

[jira] [Created] (FLINK-14302) FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request if `newPartitionsInTransaction` is empty when enable EoS

2019-10-01 Thread Wei-Che Wei (Jira)
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:

[jira] [Created] (FLINK-11251) Incompatible metric name on prometheus reporter

2019-01-02 Thread Wei-Che Wei (JIRA)
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:

[jira] [Created] (FLINK-11034) Provide "rewriting config” to file system factory

2018-11-29 Thread Wei-Che Wei (JIRA)
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:

[jira] [Assigned] (FLINK-4574) Strengthen fetch interval implementation in Kinesis consumer

2018-10-15 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Assigned] (FLINK-4816) Executions failed from "DEPLOYING" should retain restored checkpoint information

2018-10-15 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Commented] (FLINK-9486) Introduce TimerState in keyed state backend

2018-09-11 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Commented] (FLINK-9486) Introduce TimerState in keyed state backend

2018-09-11 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Commented] (FLINK-9486) Introduce TimerState in keyed state backend

2018-09-11 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Commented] (FLINK-4714) Set task state to RUNNING after state has been restored

2018-03-19 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Assigned] (FLINK-4817) Checkpoint Coordinator should be called to restore state with a specific checkpoint ID

2018-03-13 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Closed] (FLINK-5982) Refactor AbstractInvokable and StatefulTask

2018-01-09 Thread Wei-Che Wei (JIRA)
[ 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 >

[jira] [Commented] (FLINK-7935) Metrics with user supplied scope variables

2018-01-03 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Commented] (FLINK-7935) Metrics with user supplied scope variables

2018-01-02 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Assigned] (FLINK-4817) Checkpoint Coordinator should be called to restore state with a specific checkpoint ID

2017-12-28 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Created] (FLINK-8326) CheckpointCoordinatorTest#testRestoreLatestCheckpointedStateScaleOut() didn't use the correct parameter to trigger test function

2017-12-28 Thread Wei-Che Wei (JIRA)
Wei-Che Wei created FLINK-8326: -- Summary: CheckpointCoordinatorTest#testRestoreLatestCheckpointedStateScaleOut() didn't use the correct parameter to trigger test function Key: FLINK-8326 URL:

[jira] [Updated] (FLINK-8324) Expose another offsets metrics by using new metric API to specify user defined variables

2017-12-27 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Updated] (FLINK-8324) Expose another offsets metrics by using new metric API to specify user defined variables

2017-12-27 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Updated] (FLINK-8324) Expose another offsets metrics by using new metric API to specify user defined variables

2017-12-27 Thread Wei-Che Wei (JIRA)
[ 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 >

[jira] [Commented] (FLINK-8324) Expose another offsets metrics by using new metric API to specify user defined variables

2017-12-27 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Created] (FLINK-8324) Expose another offsets metrics by using new metric API to specify user defined variables

2017-12-27 Thread Wei-Che Wei (JIRA)
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

[jira] [Commented] (FLINK-7692) Support user-defined variables in Metrics

2017-11-28 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Comment Edited] (FLINK-7692) Support user-defined variables in Metrics

2017-11-06 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Commented] (FLINK-7692) Support user-defined variables in Metrics

2017-11-01 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Commented] (FLINK-7935) Metrics with user supplied scope variables

2017-10-26 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Assigned] (FLINK-4816) Executions failed from "DEPLOYING" should retain restored checkpoint information

2017-10-16 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Assigned] (FLINK-7692) Support user-defined variables

2017-09-26 Thread Wei-Che Wei (JIRA)
[ 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 > -- > >

[jira] [Updated] (FLINK-7675) LatestCompletedCheckpointExternalPathGauge should check if external path is exist

2017-09-23 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Updated] (FLINK-7675) LatestCompletedCheckpointExternalPathGauge should check if external path is exist

2017-09-23 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Assigned] (FLINK-7675) LatestCompletedCheckpointExternalPathGauge should check if external path is exist

2017-09-23 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Created] (FLINK-7675) LatestCompletedCheckpointExternalPathGauge should check if external path is exist

2017-09-23 Thread Wei-Che Wei (JIRA)
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:

[jira] [Updated] (FLINK-7630) Allow passing a File or an InputStream to ParameterTool.fromPropertiesFile()

2017-09-17 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Closed] (FLINK-7557) Fix typo for s3a config in AWS deployment documentation

2017-09-17 Thread Wei-Che Wei (JIRA)
[ 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 >

[jira] [Commented] (FLINK-7630) Allow passing a File or an InputStream to ParameterTool.fromPropertiesFile()

2017-09-15 Thread Wei-Che Wei (JIRA)
[ 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.

[jira] [Created] (FLINK-7630) Allow passing a File or an InputStream to ParameterTool.fromPropertiesFile()

2017-09-15 Thread Wei-Che Wei (JIRA)
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:

[jira] [Created] (FLINK-7557) Fix typo for s3a config in AWS deployment documentation

2017-08-29 Thread Wei-Che Wei (JIRA)
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

[jira] [Assigned] (FLINK-6653) Avoid directly serializing AWS's Shard class in Kinesis consumer's checkpoints

2017-05-24 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Comment Edited] (FLINK-6653) Avoid directly serializing AWS's Shard class in Kinesis consumer's checkpoints

2017-05-24 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Comment Edited] (FLINK-6653) Avoid directly serializing AWS's Shard class in Kinesis consumer's checkpoints

2017-05-24 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Commented] (FLINK-6653) Avoid directly serializing AWS's Shard class in Kinesis consumer's checkpoints

2017-05-24 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Commented] (FLINK-6653) Avoid directly serializing AWS's Shard class in Kinesis consumer's checkpoints

2017-05-24 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Issue Comment Deleted] (FLINK-6653) Avoid directly serializing AWS's Shard class in Kinesis consumer's checkpoints

2017-05-24 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Commented] (FLINK-6328) Savepoints must not be counted as retained checkpoints

2017-05-18 Thread Wei-Che Wei (JIRA)
[ 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? >

[jira] [Commented] (FLINK-5624) Support tumbling window on streaming tables in the SQL API

2017-03-29 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Assigned] (FLINK-5625) Let Date format for timestamp-based start position in Kinesis consumer be configurable.

2017-03-29 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Assigned] (FLINK-6211) Validation error in Kinesis Consumer when using AT_TIMESTAMP as start position

2017-03-29 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Commented] (FLINK-4523) Allow Kinesis Consumer to start from specific timestamp / Date

2017-03-29 Thread Wei-Che Wei (JIRA)
[ 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.

[jira] [Updated] (FLINK-6211) Validation error in Kinesis Consumer when using AT_TIMESTAMP as start position

2017-03-29 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Updated] (FLINK-6211) Validation error in Kinesis Consumer when using AT_TIMESTAMP as start position

2017-03-29 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Created] (FLINK-6211) Validation error in Kinesis Consumer when using AT_TIMESTAMP as start position

2017-03-29 Thread Wei-Che Wei (JIRA)
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:

[jira] [Commented] (FLINK-5982) Refactor AbstractInvokable and StatefulTask

2017-03-27 Thread Wei-Che Wei (JIRA)
[ 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}}

[jira] [Commented] (FLINK-5982) Refactor AbstractInvokable and StatefulTask

2017-03-27 Thread Wei-Che Wei (JIRA)
[ 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. >

[jira] [Commented] (FLINK-5982) Refactor AbstractInvokable and StatefulTask

2017-03-23 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Commented] (FLINK-5982) Refactor AbstractInvokable and StatefulTask

2017-03-11 Thread Wei-Che Wei (JIRA)
[ 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)}},

[jira] [Commented] (FLINK-5982) Refactor AbstractInvokable and StatefulTask

2017-03-08 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Updated] (FLINK-5982) Refactor AbstractInvokable and StatefulTask

2017-03-08 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Commented] (FLINK-5982) Refactor AbstractInvokable and StatefulTask

2017-03-08 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Updated] (FLINK-5982) Refactor AbstractInvokable and StatefulTask

2017-03-07 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Comment Edited] (FLINK-5982) Refactor AbstractInvokable and StatefulTask

2017-03-07 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Commented] (FLINK-5982) Refactor AbstractInvokable and StatefulTask

2017-03-07 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Created] (FLINK-5982) Refactor AbstractInvokable and StatefulTask

2017-03-07 Thread Wei-Che Wei (JIRA)
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:

[jira] [Assigned] (FLINK-4817) Checkpoint Coordinator should be called to restore state with a specific checkpoint ID

2017-03-05 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Commented] (FLINK-4816) Executions failed from "DEPLOYING" should retain restored checkpoint information

2017-03-05 Thread Wei-Che Wei (JIRA)
[ 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.

[jira] [Commented] (FLINK-4816) Executions failed from "DEPLOYING" should retain restored checkpoint information

2017-03-04 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Assigned] (FLINK-4817) Checkpoint Coordinator should be called to restore state with a specific checkpoint ID

2017-03-04 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Assigned] (FLINK-4816) Executions failed from "DEPLOYING" should retain restored checkpoint information

2017-03-04 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Assigned] (FLINK-4816) Executions failed from "DEPLOYING" should retain restored checkpoint information

2017-03-04 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Commented] (FLINK-4714) Set task state to RUNNING after state has been restored

2017-03-03 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Issue Comment Deleted] (FLINK-4714) Set task state to RUNNING after state has been restored

2017-03-01 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Commented] (FLINK-4815) Automatic fallback to earlier checkpoints when checkpoint restore fails

2017-03-01 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Commented] (FLINK-4714) Set task state to RUNNING after state has been restored

2017-03-01 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Commented] (FLINK-4714) Set task state to RUNNING after state has been restored

2017-03-01 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Comment Edited] (FLINK-4714) Set task state to RUNNING after state has been restored

2017-02-24 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Commented] (FLINK-4714) Set task state to RUNNING after state has been restored

2017-02-24 Thread Wei-Che Wei (JIRA)
[ 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

[jira] [Assigned] (FLINK-4754) Make number of retained checkpoints user configurable

2017-02-20 Thread Wei-Che Wei (JIRA)
[ 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 >

[jira] [Created] (FLINK-5632) Typo in StreamGraph

2017-01-24 Thread Wei-Che Wei (JIRA)
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:

[jira] [Assigned] (FLINK-4821) Implement rescalable non-partitioned state for Kinesis Connector

2016-12-10 Thread Wei-Che Wei (JIRA)
[ 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   2   >