[jira] [Work logged] (BEAM-6062) Spark runner do not show Beam metrics in Spark Web Interface

[ https://issues.apache.org/jira/browse/BEAM-6062?focusedWorklogId=166287&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166287 ] ASF GitHub Bot logged work on BEAM-6062: 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=166280&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166280 ] ASF GitHub Bot logged work on BEAM-6056: Author: ASF GitHub Bot

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

[ https://issues.apache.org/jira/browse/BEAM-2939?focusedWorklogId=166283&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166283 ] 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=166281&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166281 ] ASF GitHub Bot logged work on BEAM-2939: 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=166272&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166272 ] 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=166271&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166271 ] ASF GitHub Bot logged work on BEAM-6056: 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=166267&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166267 ] 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=166266&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166266 ] 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=166260&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166260 ] ASF GitHub Bot logged work on BEAM-4524: Author: ASF GitHub Bot

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

[ https://issues.apache.org/jira/browse/BEAM-2939?focusedWorklogId=166259&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166259 ] ASF GitHub Bot logged work on BEAM-2939: 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=166255&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166255 ] ASF GitHub Bot logged work on BEAM-4524: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6067) Dataflow runner should include portable pipeline coder id in CloudObject coder representation

[ https://issues.apache.org/jira/browse/BEAM-6067?focusedWorklogId=166257&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166257 ] ASF GitHub Bot logged work on BEAM-6067: 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=166256&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166256 ] ASF GitHub Bot logged work on BEAM-4215: 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=166254&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166254 ] ASF GitHub Bot logged work on BEAM-4524: Author: ASF GitHub Bot

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

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

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

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

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

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

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

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

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

[ https://issues.apache.org/jira/browse/BEAM-6058?focusedWorklogId=166250&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166250 ] ASF GitHub Bot logged work on BEAM-6058: 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=166245&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166245 ] ASF GitHub Bot logged work on BEAM-5959: 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=166244&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166244 ] ASF GitHub Bot logged work on BEAM-5959: 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=166242&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166242 ] 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=166243&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166243 ] 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=166241&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166241 ] 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=166240&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166240 ] ASF GitHub Bot logged work on BEAM-4524: 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=16687385#comment-16687385 ] Udi Meiri commented on BEAM-6048: - https://github.com/apache/beam/pull/7048 should fix it

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

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

[jira] [Created] (BEAM-6069) Bigquery Tornadoes example fails to run when we pass a custom temp location.

Valentyn Tymofieiev created BEAM-6069: - Summary: Bigquery Tornadoes example fails to run when we pass a custom temp location. Key: BEAM-6069 URL: https://issues.apache.org/jira/browse/BEAM-6069 Pr

[jira] [Work started] (BEAM-6067) Dataflow runner should include portable pipeline coder id in CloudObject coder representation

[ https://issues.apache.org/jira/browse/BEAM-6067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-6067 started by Craig Chambers. > Dataflow runner should include portable pipeline coder id in CloudObject > cod

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

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

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

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

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

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

[jira] [Work logged] (BEAM-3608) Vendor Guava

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

[jira] [Resolved] (BEAM-6068) Wordcount example fails to read from gcs shakespare text file

[ https://issues.apache.org/jira/browse/BEAM-6068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruoyun Huang resolved BEAM-6068. Resolution: Not A Problem Changed to Not a problem.  See the fixing steps in previous comment.  > W

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

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

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

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

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

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

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

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

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

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

[jira] [Commented] (BEAM-6068) Wordcount example fails to read from gcs shakespare text file

[ https://issues.apache.org/jira/browse/BEAM-6068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16687292#comment-16687292 ] Ruoyun Huang commented on BEAM-6068: Now it works on head as well by doing following: 

[jira] [Commented] (BEAM-6068) Wordcount example fails to read from gcs shakespare text file

[ https://issues.apache.org/jira/browse/BEAM-6068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16687280#comment-16687280 ] Ahmet Altay commented on BEAM-6068: --- cc: [~chamikara] - Sounds like a serious issue, pos

[jira] [Updated] (BEAM-6068) Wordcount example fails to read from gcs shakespare text file

[ https://issues.apache.org/jira/browse/BEAM-6068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay updated BEAM-6068: -- Fix Version/s: 2.9.0 > Wordcount example fails to read from gcs shakespare text file > -

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

[ https://issues.apache.org/jira/browse/BEAM-2939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik reassigned BEAM-2939: --- Assignee: Luke Cwik (was: Eugene Kirpichov) > Fn API streaming SDF support > ---

[jira] [Updated] (BEAM-6068) Wordcount example fails to read from gcs shakespare text file

[ https://issues.apache.org/jira/browse/BEAM-6068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruoyun Huang updated BEAM-6068: --- Issue Type: Bug (was: Improvement) > Wordcount example fails to read from gcs shakespare text file >

[jira] [Assigned] (BEAM-6068) Wordcount example fails to read from gcs shakespare text file

[ https://issues.apache.org/jira/browse/BEAM-6068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruoyun Huang reassigned BEAM-6068: -- Assignee: Mark Liu (was: Ahmet Altay) > Wordcount example fails to read from gcs shakespare te

[jira] [Created] (BEAM-6068) Wordcount example fails to read from gcs shakespare text file

Ruoyun Huang created BEAM-6068: -- Summary: Wordcount example fails to read from gcs shakespare text file Key: BEAM-6068 URL: https://issues.apache.org/jira/browse/BEAM-6068 Project: Beam Issue T

[jira] [Assigned] (BEAM-6067) Dataflow runner should include portable pipeline coder id in CloudObject coder representation

[ https://issues.apache.org/jira/browse/BEAM-6067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik reassigned BEAM-6067: --- Assignee: Craig Chambers (was: Kenneth Knowles) > Dataflow runner should include portable pipeline c

[jira] [Work logged] (BEAM-3608) Vendor Guava

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

[jira] [Work logged] (BEAM-6067) Dataflow runner should include portable pipeline coder id in CloudObject coder representation

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

[jira] [Work logged] (BEAM-3608) Vendor Guava

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

[jira] [Work logged] (BEAM-6067) Dataflow runner should include portable pipeline coder id in CloudObject coder representation

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

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

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

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

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

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

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

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

[ https://issues.apache.org/jira/browse/BEAM-5729?focusedWorklogId=166145&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166145 ] ASF GitHub Bot logged work on BEAM-5729: 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=166140&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166140 ] ASF GitHub Bot logged work on BEAM-5320: 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=166143&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166143 ] ASF GitHub Bot logged work on BEAM-5320: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6067) Dataflow runner should include portable pipeline coder id in CloudObject coder representation

[ https://issues.apache.org/jira/browse/BEAM-6067?focusedWorklogId=166141&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166141 ] ASF GitHub Bot logged work on BEAM-6067: 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=166137&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166137 ] ASF GitHub Bot logged work on BEAM-5320: 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=166135&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166135 ] ASF GitHub Bot logged work on BEAM-5320: 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=166136&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166136 ] ASF GitHub Bot logged work on BEAM-5320: Author: ASF GitHub Bot

[jira] [Assigned] (BEAM-5514) BigQueryIO doesn't handle quotaExceeded errors properly

[ https://issues.apache.org/jira/browse/BEAM-5514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Udi Meiri reassigned BEAM-5514: --- Assignee: Heejong Lee (was: Chamikara Jayalath) > BigQueryIO doesn't handle quotaExceeded errors pro

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

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

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

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

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

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

[jira] [Commented] (BEAM-4763) Add postCommit scripts and perfkit dashboards for nexmark on Samza runner

[ https://issues.apache.org/jira/browse/BEAM-4763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16687147#comment-16687147 ] Xinyu Liu commented on BEAM-4763: - [~kenn]: Of course it's interesting to Samza runner! I

[jira] [Work logged] (BEAM-5683) [beam_PostCommit_Py_VR_Dataflow] [test_multiple_empty_outputs] Fails due to pip download flake

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

[jira] [Resolved] (BEAM-6047) hdfsIntegrationTest is failing due to DisallowedDatanodeException

[ https://issues.apache.org/jira/browse/BEAM-6047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Udi Meiri resolved BEAM-6047. - Resolution: Fixed Fix Version/s: Not applicable > hdfsIntegrationTest is failing due to DisallowedD

[jira] [Resolved] (BEAM-6018) Memory leak in GCSUtil.java executeBatches

[ https://issues.apache.org/jira/browse/BEAM-6018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Udi Meiri resolved BEAM-6018. - Resolution: Fixed Fix Version/s: 2.9.0 > Memory leak in GCSUtil.java executeBatches > -

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

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

[jira] [Created] (BEAM-6067) Dataflow runner should include portable pipeline coder id in CloudObject coder representation

Craig Chambers created BEAM-6067: Summary: Dataflow runner should include portable pipeline coder id in CloudObject coder representation Key: BEAM-6067 URL: https://issues.apache.org/jira/browse/BEAM-6067

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

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

[jira] [Created] (BEAM-6066) Tensoflow 150MB input data failed while deserializing having NegativeArraySizeException

Ankur Goenka created BEAM-6066: -- Summary: Tensoflow 150MB input data failed while deserializing having NegativeArraySizeException Key: BEAM-6066 URL: https://issues.apache.org/jira/browse/BEAM-6066 Proje

[jira] [Assigned] (BEAM-5616) Several tests fail on Python 3 with Failed assert: [] == [nan]

[ https://issues.apache.org/jira/browse/BEAM-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Valentyn Tymofieiev reassigned BEAM-5616: - Assignee: (was: Valentyn Tymofieiev) > Several tests fail on Python 3 with F

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

[ https://issues.apache.org/jira/browse/BEAM-5788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Valentyn Tymofieiev reassigned BEAM-5788: - Assignee: Mark Liu (was: Valentyn Tymofieiev) > wordcount_fnapi_it failed on Tes

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

[ https://issues.apache.org/jira/browse/BEAM-6063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16687068#comment-16687068 ] Alexey Romanenko commented on BEAM-6063: Agree, the second option should be better

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

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

[jira] [Work logged] (BEAM-5462) get rid of .options deprecation warnings in tests

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

[jira] [Work logged] (BEAM-5462) get rid of .options deprecation warnings in tests

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

[jira] [Work logged] (BEAM-6028) beam_PreCommit_JavaPortabilityApi_Cron fails due to a timeout

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

[jira] [Work logged] (BEAM-5996) Nexmark postCommits are failing for Dataflow

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

[jira] [Commented] (BEAM-5996) Nexmark postCommits are failing for Dataflow

[ https://issues.apache.org/jira/browse/BEAM-5996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16687026#comment-16687026 ] Andrew Pilloud commented on BEAM-5996: -- Just saw that this was assigned to me. I had

[jira] [Work logged] (BEAM-6028) beam_PreCommit_JavaPortabilityApi_Cron fails due to a timeout

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

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

[ https://issues.apache.org/jira/browse/BEAM-6058?focusedWorklogId=166043&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166043 ] ASF GitHub Bot logged work on BEAM-6058: 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=166041&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166041 ] 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=166040&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166040 ] ASF GitHub Bot logged work on BEAM-5788: Author: ASF GitHub Bot

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

[ https://issues.apache.org/jira/browse/BEAM-6063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16686998#comment-16686998 ] Raghu Angadi commented on BEAM-6063: I was thinking the second option. If you are neut

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

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

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

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

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

[ https://issues.apache.org/jira/browse/BEAM-6058?focusedWorklogId=166019&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166019 ] ASF GitHub Bot logged work on BEAM-6058: 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=166016&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-166016 ] ASF GitHub Bot logged work on BEAM-4681: Author: ASF GitHub Bot

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

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

[jira] [Work logged] (BEAM-6062) Spark runner do not show Beam metrics in Spark Web Interface

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

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

[ https://issues.apache.org/jira/browse/BEAM-6063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16686983#comment-16686983 ] Alexey Romanenko commented on BEAM-6063: Another way - we can keep {{Write}} using

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

[ https://issues.apache.org/jira/browse/BEAM-6058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka updated BEAM-6058: --- Description: Give user option to use flink configuration from a config directory. Earlier we only use

[jira] [Work logged] (BEAM-6062) Spark runner do not show Beam metrics in Spark Web Interface

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

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

[ https://issues.apache.org/jira/browse/BEAM-6063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16686971#comment-16686971 ] Alexey Romanenko commented on BEAM-6063: [~rangadi] What do you think if I will ch

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

[ https://issues.apache.org/jira/browse/BEAM-6063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16686953#comment-16686953 ] Raghu Angadi commented on BEAM-6063: Thanks for filing this. We might keep interface b

[jira] [Work logged] (BEAM-4863) Implement consistentWithEquals/structuralValue on FullWindowedValueCoder

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

[jira] [Work logged] (BEAM-4863) Implement consistentWithEquals/structuralValue on FullWindowedValueCoder

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

  1   2   >