[jira] [Created] (BEAM-6746) Support DoFn.setup and DoFn.teardown in Python

2019-02-25 Thread Yifan Mai (JIRA)
Yifan Mai created BEAM-6746: --- Summary: Support DoFn.setup and DoFn.teardown in Python Key: BEAM-6746 URL: https://issues.apache.org/jira/browse/BEAM-6746 Project: Beam Issue Type: Bug

[jira] [Closed] (BEAM-6746) Support DoFn.setup and DoFn.teardown in Python

2019-03-04 Thread Yifan Mai (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yifan Mai closed BEAM-6746. --- Resolution: Duplicate Fix Version/s: Not applicable Looks like this was already filed as BEAM-562 >

[jira] [Updated] (BEAM-6746) Support DoFn.setup and DoFn.teardown in Python

2019-02-26 Thread Yifan Mai (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-6746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yifan Mai updated BEAM-6746: Issue Type: Improvement (was: Bug) > Support DoFn.setup and DoFn.teardown in Python >

[jira] [Created] (BEAM-7340) DoFn.teardown metrics are lost in Python SDK

2019-05-16 Thread Yifan Mai (JIRA)
Yifan Mai created BEAM-7340: --- Summary: DoFn.teardown metrics are lost in Python SDK Key: BEAM-7340 URL: https://issues.apache.org/jira/browse/BEAM-7340 Project: Beam Issue Type: Bug

[jira] [Commented] (BEAM-529) Check immutability violations in DirectPipelineRunner

2019-06-04 Thread Yifan Mai (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16856227#comment-16856227 ] Yifan Mai commented on BEAM-529: No, not planning to work on this in the near future. As discussed

[jira] [Comment Edited] (BEAM-529) Check immutability violations in DirectPipelineRunner

2019-06-05 Thread Yifan Mai (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16856777#comment-16856777 ] Yifan Mai edited comment on BEAM-529 at 6/5/19 3:06 PM: Sorry, I haven't captured

[jira] [Commented] (BEAM-529) Check immutability violations in DirectPipelineRunner

2019-06-05 Thread Yifan Mai (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16856777#comment-16856777 ] Yifan Mai commented on BEAM-529: Sorry, I haven't captured the proposal on JIRA yet. The general idea to

[jira] [Closed] (BEAM-563) DoFn Reuse: Update DirectRunner

2019-05-16 Thread Yifan Mai (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yifan Mai closed BEAM-563. -- Resolution: Done Fix Version/s: Not applicable This was also done in

[jira] [Closed] (BEAM-7121) Provide deterministic version of Python's ProtoCoder

2019-05-16 Thread Yifan Mai (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-7121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yifan Mai closed BEAM-7121. --- Resolution: Done Fix Version/s: Not applicable > Provide deterministic version of Python's ProtoCoder

[jira] [Resolved] (BEAM-562) DoFn Reuse: Add new methods to DoFn

2019-05-16 Thread Yifan Mai (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yifan Mai resolved BEAM-562. Resolution: Done Fix Version/s: Not applicable > DoFn Reuse: Add new methods to DoFn >

[jira] [Updated] (BEAM-7121) Provide deterministic version of Python's ProtoCoder

2019-04-19 Thread Yifan Mai (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-7121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yifan Mai updated BEAM-7121: Description: Passing deterministic=true to proto's

[jira] [Updated] (BEAM-7121) Provide deterministic version of Python's ProtoCoder

2019-04-19 Thread Yifan Mai (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-7121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yifan Mai updated BEAM-7121: Description: Passing deterministic=true to proto's

[jira] [Created] (BEAM-7121) Provide deterministic version of Python's ProtoCoder

2019-04-19 Thread Yifan Mai (JIRA)
Yifan Mai created BEAM-7121: --- Summary: Provide deterministic version of Python's ProtoCoder Key: BEAM-7121 URL: https://issues.apache.org/jira/browse/BEAM-7121 Project: Beam Issue Type:

[jira] [Updated] (BEAM-7121) Provide deterministic version of Python's ProtoCoder

2019-04-22 Thread Yifan Mai (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-7121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yifan Mai updated BEAM-7121: Description: Passing deterministic=true to proto's

[jira] [Comment Edited] (BEAM-3645) Support multi-process execution on the FnApiRunner

2019-09-06 Thread Yifan Mai (Jira)
[ https://issues.apache.org/jira/browse/BEAM-3645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16924585#comment-16924585 ] Yifan Mai edited comment on BEAM-3645 at 9/6/19 8:54 PM: - While testing this I

[jira] [Updated] (BEAM-8149) [FnApiRunner]multi-process runner does not terminate cleanly upon receiving SIGINT

2019-09-06 Thread Yifan Mai (Jira)
[ https://issues.apache.org/jira/browse/BEAM-8149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yifan Mai updated BEAM-8149: Description: The multi-process runner does not handle SIGINT gracefully. To reproduce, run wordcount.py

[jira] [Updated] (BEAM-8149) [FnApiRunner]multi-process runner does not terminate cleanly upon receiving SIGINT

2019-09-06 Thread Yifan Mai (Jira)
[ https://issues.apache.org/jira/browse/BEAM-8149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yifan Mai updated BEAM-8149: Description: The multi-process runner does not handle SIGINT gracefully. To reproduce, run wordcount.py

[jira] [Commented] (BEAM-3645) Support multi-process execution on the FnApiRunner

2019-09-06 Thread Yifan Mai (Jira)
[ https://issues.apache.org/jira/browse/BEAM-3645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16924585#comment-16924585 ] Yifan Mai commented on BEAM-3645: - While testing this I noticed that the multi-process runner does not

[jira] [Created] (BEAM-8519) Typehint for Python CombineFn Accumulator

2019-10-30 Thread Yifan Mai (Jira)
Yifan Mai created BEAM-8519: --- Summary: Typehint for Python CombineFn Accumulator Key: BEAM-8519 URL: https://issues.apache.org/jira/browse/BEAM-8519 Project: Beam Issue Type: New Feature

[jira] [Created] (BEAM-8520) Expansion of _CombinePerKeyWithHotKeyFanout has no typehints

2019-10-30 Thread Yifan Mai (Jira)
Yifan Mai created BEAM-8520: --- Summary: Expansion of _CombinePerKeyWithHotKeyFanout has no typehints Key: BEAM-8520 URL: https://issues.apache.org/jira/browse/BEAM-8520 Project: Beam Issue Type:

[jira] [Updated] (BEAM-8381) Typehints on DoFn subclass are incorrectly set on superclass

2019-10-30 Thread Yifan Mai (Jira)
[ https://issues.apache.org/jira/browse/BEAM-8381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yifan Mai updated BEAM-8381: Summary: Typehints on DoFn subclass are incorrectly set on superclass (was: Typehints on DoFn subclass are

[jira] [Updated] (BEAM-8519) Typehint for Python CombineFn Accumulator

2019-10-30 Thread Yifan Mai (Jira)
[ https://issues.apache.org/jira/browse/BEAM-8519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yifan Mai updated BEAM-8519: Description: Feature request: Allow users to specify a typehint for the accumulator type of CombineFn,

[jira] [Created] (BEAM-8381) Typehints on DoFn subclass are incorrect set on superclass

2019-10-10 Thread Yifan Mai (Jira)
Yifan Mai created BEAM-8381: --- Summary: Typehints on DoFn subclass are incorrect set on superclass Key: BEAM-8381 URL: https://issues.apache.org/jira/browse/BEAM-8381 Project: Beam Issue Type: Bug