[jira] [Commented] (BEAM-7642) (Dataflow) Python AfterProcessingTime fires before defined time

2019-06-26 Thread Daniel Mills (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-7642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16873721#comment-16873721 ] Daniel Mills commented on BEAM-7642: Looks like the issue is a seconds/milliseconds mixup when

[jira] [Commented] (BEAM-7642) (Dataflow) Python AfterProcessingTime fires before defined time

2019-06-26 Thread Daniel Mills (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-7642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16873723#comment-16873723 ] Daniel Mills commented on BEAM-7642: There's at least one example pipeline in the beam repo that

[jira] [Created] (BEAM-7932) GcsFileSystem should validate directories and file names for \n chars

2019-08-08 Thread Daniel Mills (JIRA)
Daniel Mills created BEAM-7932: -- Summary: GcsFileSystem should validate directories and file names for \n chars Key: BEAM-7932 URL: https://issues.apache.org/jira/browse/BEAM-7932 Project: Beam

[jira] [Created] (BEAM-9320) Add an annotation to State to indicate it should always be fetched

2020-02-14 Thread Daniel Mills (Jira)
Daniel Mills created BEAM-9320: -- Summary: Add an annotation to State to indicate it should always be fetched Key: BEAM-9320 URL: https://issues.apache.org/jira/browse/BEAM-9320 Project: Beam

[jira] [Assigned] (BEAM-9320) Add an annotation to State to indicate it should always be fetched

2020-02-14 Thread Daniel Mills (Jira)
[ https://issues.apache.org/jira/browse/BEAM-9320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Mills reassigned BEAM-9320: -- Assignee: Reuven Lax > Add an annotation to State to indicate it should always be fetched >

[jira] [Created] (BEAM-9627) KafkaIO needs better support for SSL

2020-03-27 Thread Daniel Mills (Jira)
Daniel Mills created BEAM-9627: -- Summary: KafkaIO needs better support for SSL Key: BEAM-9627 URL: https://issues.apache.org/jira/browse/BEAM-9627 Project: Beam Issue Type: Improvement