[jira] [Commented] (BEAM-6036) How to periodically refresh side inputs

[ https://issues.apache.org/jira/browse/BEAM-6036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16689096#comment-16689096 ] Evgeny commented on BEAM-6036: -- [~kenn] Thank you, I'll post a question on Stack Overflow.

[jira] [Updated] (BEAM-6036) How to periodically refresh side inputs

[ https://issues.apache.org/jira/browse/BEAM-6036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Evgeny updated BEAM-6036: - Description: * I have followed the example provided here [https://cloud.google.com/blog/products/gcp/guide-to-com

[jira] [Updated] (BEAM-6036) How to periodically refresh side inputs

[ https://issues.apache.org/jira/browse/BEAM-6036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Evgeny updated BEAM-6036: - Description: I have followed the example provided here [https://cloud.google.com/blog/products/gcp/guide-to-commo

[jira] [Work logged] (BEAM-5788) wordcount_fnapi_it failed on TestDataflowRunner because of JSON string decoding error

[ https://issues.apache.org/jira/browse/BEAM-5788?focusedWorklogId=166761&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166761 ] ASF GitHub Bot logged work on BEAM-5788: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5788) wordcount_fnapi_it failed on TestDataflowRunner because of JSON string decoding error

[ https://issues.apache.org/jira/browse/BEAM-5788?focusedWorklogId=166763&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166763 ] ASF GitHub Bot logged work on BEAM-5788: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5788) wordcount_fnapi_it failed on TestDataflowRunner because of JSON string decoding error

[ https://issues.apache.org/jira/browse/BEAM-5788?focusedWorklogId=166762&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166762 ] ASF GitHub Bot logged work on BEAM-5788: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-4850) Remove dependency on google-apitools package in Python SDK.

[ https://issues.apache.org/jira/browse/BEAM-4850?focusedWorklogId=166760&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166760 ] ASF GitHub Bot logged work on BEAM-4850: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-5873) Python test failure: "ImportError: No module named pip._internal"

[ https://issues.apache.org/jira/browse/BEAM-5873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16689019#comment-16689019 ] Valentyn Tymofieiev commented on BEAM-5873: --- Thanks, [~markflyhigh]! I tried st

[jira] [Created] (BEAM-6075) Dataflow insufficient quota

Ankur Goenka created BEAM-6075: -- Summary: Dataflow insufficient quota Key: BEAM-6075 URL: https://issues.apache.org/jira/browse/BEAM-6075 Project: Beam Issue Type: Bug Components: test

[jira] [Work logged] (BEAM-6063) KafkaIO: add writing support with ProducerRecord

[ https://issues.apache.org/jira/browse/BEAM-6063?focusedWorklogId=166755&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166755 ] ASF GitHub Bot logged work on BEAM-6063: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6063) KafkaIO: add writing support with ProducerRecord

[ https://issues.apache.org/jira/browse/BEAM-6063?focusedWorklogId=166757&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166757 ] ASF GitHub Bot logged work on BEAM-6063: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6063) KafkaIO: add writing support with ProducerRecord

[ https://issues.apache.org/jira/browse/BEAM-6063?focusedWorklogId=166753&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166753 ] ASF GitHub Bot logged work on BEAM-6063: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6063) KafkaIO: add writing support with ProducerRecord

[ https://issues.apache.org/jira/browse/BEAM-6063?focusedWorklogId=166752&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166752 ] ASF GitHub Bot logged work on BEAM-6063: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6063) KafkaIO: add writing support with ProducerRecord

[ https://issues.apache.org/jira/browse/BEAM-6063?focusedWorklogId=166754&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166754 ] ASF GitHub Bot logged work on BEAM-6063: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6063) KafkaIO: add writing support with ProducerRecord

[ https://issues.apache.org/jira/browse/BEAM-6063?focusedWorklogId=166756&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166756 ] ASF GitHub Bot logged work on BEAM-6063: Author: ASF GitHub Bot

[jira] [Created] (BEAM-6074) Artifact staging proto changes are causing python post commit to fail

Ankur Goenka created BEAM-6074: -- Summary: Artifact staging proto changes are causing python post commit to fail Key: BEAM-6074 URL: https://issues.apache.org/jira/browse/BEAM-6074 Project: Beam

[jira] [Work logged] (BEAM-6056) Migrate gRPC to use vendoring library and vendoring format

[ https://issues.apache.org/jira/browse/BEAM-6056?focusedWorklogId=166742&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166742 ] ASF GitHub Bot logged work on BEAM-6056: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5357) Go check for IsWorkerCompatibleBinary is wrong

[ https://issues.apache.org/jira/browse/BEAM-5357?focusedWorklogId=166736&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166736 ] ASF GitHub Bot logged work on BEAM-5357: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6056) Migrate gRPC to use vendoring library and vendoring format

[ https://issues.apache.org/jira/browse/BEAM-6056?focusedWorklogId=166724&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166724 ] ASF GitHub Bot logged work on BEAM-6056: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6056) Migrate gRPC to use vendoring library and vendoring format

[ https://issues.apache.org/jira/browse/BEAM-6056?focusedWorklogId=166723&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166723 ] ASF GitHub Bot logged work on BEAM-6056: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6049) Support Job / Graph upload to GCS in Dataflow Runner

[ https://issues.apache.org/jira/browse/BEAM-6049?focusedWorklogId=166721&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166721 ] ASF GitHub Bot logged work on BEAM-6049: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6049) Support Job / Graph upload to GCS in Dataflow Runner

[ https://issues.apache.org/jira/browse/BEAM-6049?focusedWorklogId=166710&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166710 ] ASF GitHub Bot logged work on BEAM-6049: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6073) Go PostCommit Broken -> gogradle needs "github.com/stretchr/testify/assert" dep.

[ https://issues.apache.org/jira/browse/BEAM-6073?focusedWorklogId=166717&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166717 ] ASF GitHub Bot logged work on BEAM-6073: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6011) Enable Phrase triggering in Nexmark jobs

[ https://issues.apache.org/jira/browse/BEAM-6011?focusedWorklogId=166714&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166714 ] ASF GitHub Bot logged work on BEAM-6011: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6049) Support Job / Graph upload to GCS in Dataflow Runner

[ https://issues.apache.org/jira/browse/BEAM-6049?focusedWorklogId=166713&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166713 ] ASF GitHub Bot logged work on BEAM-6049: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6049) Support Job / Graph upload to GCS in Dataflow Runner

[ https://issues.apache.org/jira/browse/BEAM-6049?focusedWorklogId=166712&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166712 ] ASF GitHub Bot logged work on BEAM-6049: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6049) Support Job / Graph upload to GCS in Dataflow Runner

[ https://issues.apache.org/jira/browse/BEAM-6049?focusedWorklogId=166711&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166711 ] ASF GitHub Bot logged work on BEAM-6049: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6049) Support Job / Graph upload to GCS in Dataflow Runner

[ https://issues.apache.org/jira/browse/BEAM-6049?focusedWorklogId=166709&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166709 ] ASF GitHub Bot logged work on BEAM-6049: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-5456) Update google-api-client libraries to 1.25

[ https://issues.apache.org/jira/browse/BEAM-5456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16688822#comment-16688822 ] Chamikara Jayalath commented on BEAM-5456: -- Assigning to Huyaga who has [https://

[jira] [Assigned] (BEAM-5456) Update google-api-client libraries to 1.25

[ https://issues.apache.org/jira/browse/BEAM-5456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Jayalath reassigned BEAM-5456: Assignee: Batkhuyag Batsaikhan (was: Chamikara Jayalath) > Update google-api-clien

[jira] [Work logged] (BEAM-6017) Support nanosecond precision for DATETIME in Schema

[ https://issues.apache.org/jira/browse/BEAM-6017?focusedWorklogId=166700&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166700 ] ASF GitHub Bot logged work on BEAM-6017: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6017) Support nanosecond precision for DATETIME in Schema

[ https://issues.apache.org/jira/browse/BEAM-6017?focusedWorklogId=166701&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166701 ] ASF GitHub Bot logged work on BEAM-6017: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5299) Define max global window as a shared value in protos like URN enums.

[ https://issues.apache.org/jira/browse/BEAM-5299?focusedWorklogId=166690&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166690 ] ASF GitHub Bot logged work on BEAM-5299: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5959) Add Cloud KMS support to GCS copies

[ https://issues.apache.org/jira/browse/BEAM-5959?focusedWorklogId=166673&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166673 ] ASF GitHub Bot logged work on BEAM-5959: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5817) Nexmark test of joining stream to files

[ https://issues.apache.org/jira/browse/BEAM-5817?focusedWorklogId=17&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-17 ] ASF GitHub Bot logged work on BEAM-5817: Author: ASF GitHub Bot

[jira] [Resolved] (BEAM-6036) How to periodically refresh side inputs

[ https://issues.apache.org/jira/browse/BEAM-6036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles resolved BEAM-6036. --- Resolution: Not A Problem Fix Version/s: Not applicable > How to periodically refresh s

[jira] [Commented] (BEAM-6036) How to periodically refresh side inputs

[ https://issues.apache.org/jira/browse/BEAM-6036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16688739#comment-16688739 ] Kenneth Knowles commented on BEAM-6036: --- This is a good question for StackOverflow.

[jira] [Work logged] (BEAM-5939) Deduplicate constants

[ https://issues.apache.org/jira/browse/BEAM-5939?focusedWorklogId=166657&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166657 ] ASF GitHub Bot logged work on BEAM-5939: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5939) Deduplicate constants

[ https://issues.apache.org/jira/browse/BEAM-5939?focusedWorklogId=166656&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166656 ] ASF GitHub Bot logged work on BEAM-5939: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5299) Define max global window as a shared value in protos like URN enums.

[ https://issues.apache.org/jira/browse/BEAM-5299?focusedWorklogId=166647&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166647 ] ASF GitHub Bot logged work on BEAM-5299: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6073) Go PostCommit Broken -> gogradle needs "github.com/stretchr/testify/assert" dep.

[ https://issues.apache.org/jira/browse/BEAM-6073?focusedWorklogId=166644&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166644 ] ASF GitHub Bot logged work on BEAM-6073: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5299) Define max global window as a shared value in protos like URN enums.

[ https://issues.apache.org/jira/browse/BEAM-5299?focusedWorklogId=166646&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166646 ] ASF GitHub Bot logged work on BEAM-5299: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6073) Go PostCommit Broken -> gogradle needs "github.com/stretchr/testify/assert" dep.

[ https://issues.apache.org/jira/browse/BEAM-6073?focusedWorklogId=166645&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166645 ] ASF GitHub Bot logged work on BEAM-6073: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-6058) Support flink config directory for flink runner.

[ https://issues.apache.org/jira/browse/BEAM-6058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16688638#comment-16688638 ] Ankur Goenka commented on BEAM-6058: Also, from the code I observed that the jar based

[jira] [Commented] (BEAM-6058) Support flink config directory for flink runner.

[ https://issues.apache.org/jira/browse/BEAM-6058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16688618#comment-16688618 ] Ankur Goenka commented on BEAM-6058: I agree, that runtime properties should be manage

[jira] [Work logged] (BEAM-6058) Support flink config directory for flink runner.

[ https://issues.apache.org/jira/browse/BEAM-6058?focusedWorklogId=166639&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166639 ] ASF GitHub Bot logged work on BEAM-6058: Author: ASF GitHub Bot

[jira] [Resolved] (BEAM-5729) Create ability to read/write database implementing database/sql contract

[ https://issues.apache.org/jira/browse/BEAM-5729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Burke resolved BEAM-5729. Resolution: Fixed Fix Version/s: Not applicable > Create ability to read/write database imple

[jira] [Work logged] (BEAM-4524) We should not be using md5 to validate artifact integrity.

[ https://issues.apache.org/jira/browse/BEAM-4524?focusedWorklogId=166635&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166635 ] ASF GitHub Bot logged work on BEAM-4524: Author: ASF GitHub Bot

[jira] [Updated] (BEAM-6073) Go PostCommit Broken -> gogradle needs "github.com/stretchr/testify/assert" dep.

[ https://issues.apache.org/jira/browse/BEAM-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Burke updated BEAM-6073: --- Description: [https://builds.apache.org/job/beam_PostCommit_Go_GradleBuild/1676/] 16:41:13 ok github

[jira] [Created] (BEAM-6073) Go PostCommit Broken -> gogradle needs "github.com/stretchr/testify/assert" dep.

Robert Burke created BEAM-6073: -- Summary: Go PostCommit Broken -> gogradle needs "github.com/stretchr/testify/assert" dep. Key: BEAM-6073 URL: https://issues.apache.org/jira/browse/BEAM-6073 Project: Bea

[jira] [Work logged] (BEAM-4681) Integrate support for timers using the portability APIs into Flink

[ https://issues.apache.org/jira/browse/BEAM-4681?focusedWorklogId=166629&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166629 ] ASF GitHub Bot logged work on BEAM-4681: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-4681) Integrate support for timers using the portability APIs into Flink

[ https://issues.apache.org/jira/browse/BEAM-4681?focusedWorklogId=166630&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166630 ] ASF GitHub Bot logged work on BEAM-4681: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-4850) Remove dependency on google-apitools package in Python SDK.

[ https://issues.apache.org/jira/browse/BEAM-4850?focusedWorklogId=166628&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166628 ] ASF GitHub Bot logged work on BEAM-4850: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-4524) We should not be using md5 to validate artifact integrity.

[ https://issues.apache.org/jira/browse/BEAM-4524?focusedWorklogId=166626&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166626 ] ASF GitHub Bot logged work on BEAM-4524: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-4524) We should not be using md5 to validate artifact integrity.

[ https://issues.apache.org/jira/browse/BEAM-4524?focusedWorklogId=166625&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166625 ] ASF GitHub Bot logged work on BEAM-4524: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-4524) We should not be using md5 to validate artifact integrity.

[ https://issues.apache.org/jira/browse/BEAM-4524?focusedWorklogId=166624&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166624 ] ASF GitHub Bot logged work on BEAM-4524: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5969) Update website with the new query

[ https://issues.apache.org/jira/browse/BEAM-5969?focusedWorklogId=166615&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166615 ] ASF GitHub Bot logged work on BEAM-5969: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5969) Update website with the new query

[ https://issues.apache.org/jira/browse/BEAM-5969?focusedWorklogId=166613&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166613 ] ASF GitHub Bot logged work on BEAM-5969: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5969) Update website with the new query

[ https://issues.apache.org/jira/browse/BEAM-5969?focusedWorklogId=166614&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166614 ] ASF GitHub Bot logged work on BEAM-5969: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-2939) Fn API streaming SDF support

[ https://issues.apache.org/jira/browse/BEAM-2939?focusedWorklogId=166575&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166575 ] ASF GitHub Bot logged work on BEAM-2939: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5674) DataflowRunner.Deduplicate/WithKeys cannot infer Coder for K when running with experiment "enable_custom_pubsub_source"

[ https://issues.apache.org/jira/browse/BEAM-5674?focusedWorklogId=166607&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166607 ] ASF GitHub Bot logged work on BEAM-5674: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-1251) Python 3 Support

[ https://issues.apache.org/jira/browse/BEAM-1251?focusedWorklogId=166601&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166601 ] ASF GitHub Bot logged work on BEAM-1251: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-4850) Remove dependency on google-apitools package in Python SDK.

[ https://issues.apache.org/jira/browse/BEAM-4850?focusedWorklogId=166600&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166600 ] ASF GitHub Bot logged work on BEAM-4850: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5203) expose PaneInfo and BoundedWindow as UDF

[ https://issues.apache.org/jira/browse/BEAM-5203?focusedWorklogId=166597&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166597 ] ASF GitHub Bot logged work on BEAM-5203: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-6058) Support flink config directory for flink runner.

[ https://issues.apache.org/jira/browse/BEAM-6058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16688521#comment-16688521 ] Maximilian Michels commented on BEAM-6058: -- I agree, if at all, the file should b

[jira] [Work logged] (BEAM-2939) Fn API streaming SDF support

[ https://issues.apache.org/jira/browse/BEAM-2939?focusedWorklogId=166585&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166585 ] ASF GitHub Bot logged work on BEAM-2939: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-2939) Fn API streaming SDF support

[ https://issues.apache.org/jira/browse/BEAM-2939?focusedWorklogId=166574&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166574 ] ASF GitHub Bot logged work on BEAM-2939: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-2939) Fn API streaming SDF support

[ https://issues.apache.org/jira/browse/BEAM-2939?focusedWorklogId=166583&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166583 ] ASF GitHub Bot logged work on BEAM-2939: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-2939) Fn API streaming SDF support

[ https://issues.apache.org/jira/browse/BEAM-2939?focusedWorklogId=166584&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166584 ] ASF GitHub Bot logged work on BEAM-2939: Author: ASF GitHub Bot

[jira] [Closed] (BEAM-5999) Proto error when running test_pardo_timers of Python PortableValidatesRunner

[ https://issues.apache.org/jira/browse/BEAM-5999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed BEAM-5999. Resolution: Fixed Assignee: Robert Bradshaw > Proto error when running test_pardo_time

[jira] [Work logged] (BEAM-2939) Fn API streaming SDF support

[ https://issues.apache.org/jira/browse/BEAM-2939?focusedWorklogId=166578&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166578 ] ASF GitHub Bot logged work on BEAM-2939: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-2939) Fn API streaming SDF support

[ https://issues.apache.org/jira/browse/BEAM-2939?focusedWorklogId=166582&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166582 ] ASF GitHub Bot logged work on BEAM-2939: Author: ASF GitHub Bot

[jira] [Updated] (BEAM-6063) KafkaIO: add writing support with ProducerRecord

[ https://issues.apache.org/jira/browse/BEAM-6063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-6063: --- Summary: KafkaIO: add writing support with ProducerRecord (was: KafkaIO: add writing support

[jira] [Work logged] (BEAM-2939) Fn API streaming SDF support

[ https://issues.apache.org/jira/browse/BEAM-2939?focusedWorklogId=166573&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166573 ] ASF GitHub Bot logged work on BEAM-2939: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-2939) Fn API streaming SDF support

[ https://issues.apache.org/jira/browse/BEAM-2939?focusedWorklogId=166580&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166580 ] ASF GitHub Bot logged work on BEAM-2939: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-2939) Fn API streaming SDF support

[ https://issues.apache.org/jira/browse/BEAM-2939?focusedWorklogId=166577&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166577 ] ASF GitHub Bot logged work on BEAM-2939: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-2939) Fn API streaming SDF support

[ https://issues.apache.org/jira/browse/BEAM-2939?focusedWorklogId=166579&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166579 ] ASF GitHub Bot logged work on BEAM-2939: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-2939) Fn API streaming SDF support

[ https://issues.apache.org/jira/browse/BEAM-2939?focusedWorklogId=166576&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166576 ] ASF GitHub Bot logged work on BEAM-2939: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-2939) Fn API streaming SDF support

[ https://issues.apache.org/jira/browse/BEAM-2939?focusedWorklogId=166581&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166581 ] ASF GitHub Bot logged work on BEAM-2939: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-2939) Fn API streaming SDF support

[ https://issues.apache.org/jira/browse/BEAM-2939?focusedWorklogId=166586&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166586 ] ASF GitHub Bot logged work on BEAM-2939: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6049) Support Job / Graph upload to GCS in Dataflow Runner

[ https://issues.apache.org/jira/browse/BEAM-6049?focusedWorklogId=166569&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166569 ] ASF GitHub Bot logged work on BEAM-6049: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5959) Add Cloud KMS support to GCS copies

[ https://issues.apache.org/jira/browse/BEAM-5959?focusedWorklogId=166564&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166564 ] ASF GitHub Bot logged work on BEAM-5959: Author: ASF GitHub Bot

[jira] [Work started] (BEAM-6063) KafkaIO: add writing support for ProducerRecord

[ https://issues.apache.org/jira/browse/BEAM-6063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-6063 started by Alexey Romanenko. -- > KafkaIO: add writing support for ProducerRecord > -

[jira] [Work logged] (BEAM-6063) KafkaIO: add writing support for ProducerRecord

[ https://issues.apache.org/jira/browse/BEAM-6063?focusedWorklogId=166560&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166560 ] ASF GitHub Bot logged work on BEAM-6063: Author: ASF GitHub Bot

[jira] [Assigned] (BEAM-6048) pylint-27 failed but not caught in Pre/PostCommit

[ https://issues.apache.org/jira/browse/BEAM-6048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay reassigned BEAM-6048: - Assignee: Yueyang Qiu (was: Mark Liu) > pylint-27 failed but not caught in Pre/PostCommit >

[jira] [Work logged] (BEAM-6063) KafkaIO: add writing support for ProducerRecord

[ https://issues.apache.org/jira/browse/BEAM-6063?focusedWorklogId=166559&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166559 ] ASF GitHub Bot logged work on BEAM-6063: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6049) Support Job / Graph upload to GCS in Dataflow Runner

[ https://issues.apache.org/jira/browse/BEAM-6049?focusedWorklogId=166556&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166556 ] ASF GitHub Bot logged work on BEAM-6049: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-4215) Update Python SDK dependencies for next release

[ https://issues.apache.org/jira/browse/BEAM-4215?focusedWorklogId=166557&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166557 ] ASF GitHub Bot logged work on BEAM-4215: Author: ASF GitHub Bot

[jira] [Created] (BEAM-6072) add encrypt/decrypt permissions for Cloud KMS key testing

Udi Meiri created BEAM-6072: --- Summary: add encrypt/decrypt permissions for Cloud KMS key testing Key: BEAM-6072 URL: https://issues.apache.org/jira/browse/BEAM-6072 Project: Beam Issue Type: Task

[jira] [Commented] (BEAM-6048) pylint-27 failed but not caught in Pre/PostCommit

[ https://issues.apache.org/jira/browse/BEAM-6048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16688463#comment-16688463 ] Ahmet Altay commented on BEAM-6048: --- Assigned to Robin to: - fix the doc bug introduce d

[jira] [Work logged] (BEAM-5959) Add Cloud KMS support to GCS copies

[ https://issues.apache.org/jira/browse/BEAM-5959?focusedWorklogId=166549&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166549 ] ASF GitHub Bot logged work on BEAM-5959: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-6048) pylint-27 failed but not caught in Pre/PostCommit

[ https://issues.apache.org/jira/browse/BEAM-6048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16688443#comment-16688443 ] Mark Liu commented on BEAM-6048: [https://github.com/apache/beam/pull/7048] is merged. Can

[jira] [Comment Edited] (BEAM-6048) pylint-27 failed but not caught in Pre/PostCommit

[ https://issues.apache.org/jira/browse/BEAM-6048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16688443#comment-16688443 ] Mark Liu edited comment on BEAM-6048 at 11/15/18 5:55 PM: -- Thanks

[jira] [Work logged] (BEAM-5203) expose PaneInfo and BoundedWindow as UDF

[ https://issues.apache.org/jira/browse/BEAM-5203?focusedWorklogId=166548&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166548 ] ASF GitHub Bot logged work on BEAM-5203: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5203) expose PaneInfo and BoundedWindow as UDF

[ https://issues.apache.org/jira/browse/BEAM-5203?focusedWorklogId=166545&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166545 ] ASF GitHub Bot logged work on BEAM-5203: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6049) Support Job / Graph upload to GCS in Dataflow Runner

[ https://issues.apache.org/jira/browse/BEAM-6049?focusedWorklogId=166544&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166544 ] ASF GitHub Bot logged work on BEAM-6049: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-588) All runners should support ProfilingOptions

[ https://issues.apache.org/jira/browse/BEAM-588?focusedWorklogId=166536&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166536 ] ASF GitHub Bot logged work on BEAM-588: --- Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-4524) We should not be using md5 to validate artifact integrity.

[ https://issues.apache.org/jira/browse/BEAM-4524?focusedWorklogId=166535&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166535 ] ASF GitHub Bot logged work on BEAM-4524: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5320) Finish Python 3 porting for testing module

[ https://issues.apache.org/jira/browse/BEAM-5320?focusedWorklogId=166533&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166533 ] ASF GitHub Bot logged work on BEAM-5320: Author: ASF GitHub Bot

[jira] [Resolved] (BEAM-5812) Timeout in Python ITs: WordCountIT (fn api and legacy), HourlyTeamScoreIT, FastavroIT

[ https://issues.apache.org/jira/browse/BEAM-5812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mark Liu resolved BEAM-5812. Resolution: Fixed Fix Version/s: Not applicable > Timeout in Python ITs: WordCountIT (fn api and lega

  1   2   >