[jira] [Commented] (BEAM-6855) Side inputs are not supported when using the state API

[ https://issues.apache.org/jira/browse/BEAM-6855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17122090#comment-17122090 ] Kenneth Knowles commented on BEAM-6855: --- This issue is assigned but has not received

[jira] [Commented] (BEAM-8460) Portable Flink runner ignores UsesStrictTimerOrdering category tests

[ https://issues.apache.org/jira/browse/BEAM-8460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121840#comment-17121840 ] Kenneth Knowles commented on BEAM-8460: --- This issue is assigned but has not received

[jira] [Updated] (BEAM-9118) apache_beam.runners.portability.portable_runner_test.PortableRunnerTestWithSubprocesses is flaky

[ https://issues.apache.org/jira/browse/BEAM-9118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9118: -- Labels: stale-assigned (was: ) > apache_beam.runners.portability.portable_runner_test.PortableR

[jira] [Updated] (BEAM-9547) Raise NotImplementedError for remaining pandas methods

[ https://issues.apache.org/jira/browse/BEAM-9547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9547: -- Labels: stale-assigned (was: ) > Raise NotImplementedError for remaining pandas methods > -

[jira] [Updated] (BEAM-9559) Remove smoke load test for Java and Python dsk

[ https://issues.apache.org/jira/browse/BEAM-9559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9559: -- Labels: stale-assigned (was: ) > Remove smoke load test for Java and Python dsk > -

[jira] [Updated] (BEAM-8090) Add test for Self Setting Timers close to GC TImer

[ https://issues.apache.org/jira/browse/BEAM-8090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8090: -- Labels: stale-assigned (was: ) > Add test for Self Setting Timers close to GC TImer > -

[jira] [Commented] (BEAM-9118) apache_beam.runners.portability.portable_runner_test.PortableRunnerTestWithSubprocesses is flaky

[ https://issues.apache.org/jira/browse/BEAM-9118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121726#comment-17121726 ] Kenneth Knowles commented on BEAM-9118: --- This issue is assigned but has not received

[jira] [Commented] (BEAM-6286) Add SamzaRunner profile to mvn archetype

[ https://issues.apache.org/jira/browse/BEAM-6286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17122179#comment-17122179 ] Kenneth Knowles commented on BEAM-6286: --- This issue is assigned but has not received

[jira] [Updated] (BEAM-8979) protoc-gen-mypy: program not found or is not executable

[ https://issues.apache.org/jira/browse/BEAM-8979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8979: -- Labels: stale-assigned (was: ) > protoc-gen-mypy: program not found or is not executable >

[jira] [Commented] (BEAM-9256) Use SortedMapState for optimization of @RequiresTimeSortedInput

[ https://issues.apache.org/jira/browse/BEAM-9256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121697#comment-17121697 ] Kenneth Knowles commented on BEAM-9256: --- This issue is assigned but has not received

[jira] [Updated] (BEAM-8572) tox environment: assert on Cython source file presence

[ https://issues.apache.org/jira/browse/BEAM-8572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8572: -- Labels: stale-assigned (was: ) > tox environment: assert on Cython source file presence > -

[jira] [Commented] (BEAM-7559) Add an Integration Test for DynamoDBIO

[ https://issues.apache.org/jira/browse/BEAM-7559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121998#comment-17121998 ] Kenneth Knowles commented on BEAM-7559: --- This issue is assigned but has not received

[jira] [Commented] (BEAM-9179) Simplify types in Beam ZetaSQL

[ https://issues.apache.org/jira/browse/BEAM-9179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121713#comment-17121713 ] Kenneth Knowles commented on BEAM-9179: --- This issue is assigned but has not received

[jira] [Commented] (BEAM-6839) User reports protobuf ClassChangeError running against 2.6.0 or above

[ https://issues.apache.org/jira/browse/BEAM-6839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17122091#comment-17122091 ] Kenneth Knowles commented on BEAM-6839: --- This issue is assigned but has not received

[jira] [Commented] (BEAM-7921) Add Schema support for Tensorflow

[ https://issues.apache.org/jira/browse/BEAM-7921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121943#comment-17121943 ] Kenneth Knowles commented on BEAM-7921: --- This issue is assigned but has not received

[jira] [Commented] (BEAM-7944) Improvements of portability framework to make it usable in other projects

[ https://issues.apache.org/jira/browse/BEAM-7944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121946#comment-17121946 ] Kenneth Knowles commented on BEAM-7944: --- This issue is assigned but has not received

[jira] [Commented] (BEAM-6007) Create ClassLoadingStrategy with Java 11 compatible way

[ https://issues.apache.org/jira/browse/BEAM-6007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17122207#comment-17122207 ] Kenneth Knowles commented on BEAM-6007: --- This issue is assigned but has not received

[jira] [Commented] (BEAM-8878) Possible flake in PortableRunnerTest.test_error_traceback_includes_user_code

[ https://issues.apache.org/jira/browse/BEAM-8878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121783#comment-17121783 ] Kenneth Knowles commented on BEAM-8878: --- This issue is assigned but has not received

[jira] [Updated] (BEAM-8035) [beam_PreCommit_Java_Phrase] [WatchTest.testMultiplePollsWithManyResults] Flake: Outputs must be in timestamp order

[ https://issues.apache.org/jira/browse/BEAM-8035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8035: -- Labels: flake stale-assigned (was: flake) > [beam_PreCommit_Java_Phrase] [WatchTest.testMultipl

[jira] [Commented] (BEAM-6701) Create LogicalType for Schema fields

[ https://issues.apache.org/jira/browse/BEAM-6701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17122108#comment-17122108 ] Kenneth Knowles commented on BEAM-6701: --- This issue is assigned but has not received

[jira] [Updated] (BEAM-7851) PubsubIO.readStrings() and DataflowRunner

[ https://issues.apache.org/jira/browse/BEAM-7851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-7851: -- Labels: stale-assigned (was: ) > PubsubIO.readStrings() and DataflowRunner > --

[jira] [Commented] (BEAM-7350) Update Python Datastore example to use v1new Datastore IO

[ https://issues.apache.org/jira/browse/BEAM-7350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17122036#comment-17122036 ] Kenneth Knowles commented on BEAM-7350: --- This issue is assigned but has not received

[jira] [Commented] (BEAM-9676) Go SDK Code Katas

[ https://issues.apache.org/jira/browse/BEAM-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121591#comment-17121591 ] Kenneth Knowles commented on BEAM-9676: --- This issue is assigned but has not received

[jira] [Commented] (BEAM-9611) Add a test for Iter/ReIter parameters in ParDos (such as after a GBK).

[ https://issues.apache.org/jira/browse/BEAM-9611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121608#comment-17121608 ] Kenneth Knowles commented on BEAM-9611: --- This issue is assigned but has not received

[jira] [Updated] (BEAM-8970) Spark portable runner supports Yarn

[ https://issues.apache.org/jira/browse/BEAM-8970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8970: -- Labels: portability-spark stale-assigned (was: portability-spark) > Spark portable runner suppo

[jira] [Commented] (BEAM-7540) deadlock using save_main_session and logging caused by threading.RLock pickling

[ https://issues.apache.org/jira/browse/BEAM-7540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17122001#comment-17122001 ] Kenneth Knowles commented on BEAM-7540: --- This issue is assigned but has not received

[jira] [Updated] (BEAM-8541) Beam directRunner documentation java tab has python information

[ https://issues.apache.org/jira/browse/BEAM-8541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8541: -- Labels: stale-assigned (was: ) > Beam directRunner documentation java tab has python informatio

[jira] [Commented] (BEAM-6004) DirectRunner doesn't trigger deserialization of coders.

[ https://issues.apache.org/jira/browse/BEAM-6004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17122210#comment-17122210 ] Kenneth Knowles commented on BEAM-6004: --- This issue is assigned but has not received

[jira] [Updated] (BEAM-9182) Support NULL parameter in BeamZetaSqlCalcRel

[ https://issues.apache.org/jira/browse/BEAM-9182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9182: -- Labels: stale-assigned (was: ) > Support NULL parameter in BeamZetaSqlCalcRel > ---

[jira] [Commented] (BEAM-7246) Add Google Spanner IO on Python SDK

[ https://issues.apache.org/jira/browse/BEAM-7246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17122056#comment-17122056 ] Kenneth Knowles commented on BEAM-7246: --- This issue is assigned but has not received

[jira] [Commented] (BEAM-8879) IOError flake in PortableRunnerTest

[ https://issues.apache.org/jira/browse/BEAM-8879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121781#comment-17121781 ] Kenneth Knowles commented on BEAM-8879: --- This issue is assigned but has not received

[jira] [Updated] (BEAM-7189) Remove FieldType metadata

[ https://issues.apache.org/jira/browse/BEAM-7189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-7189: -- Labels: stale-assigned (was: ) > Remove FieldType metadata > - > >

[jira] [Commented] (BEAM-9048) Matching compile-time and run-time type information in Java external transforms

[ https://issues.apache.org/jira/browse/BEAM-9048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121742#comment-17121742 ] Kenneth Knowles commented on BEAM-9048: --- This issue is assigned but has not received

[jira] [Updated] (BEAM-8467) Enable reading compressed files with Python fileio

[ https://issues.apache.org/jira/browse/BEAM-8467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8467: -- Labels: stale-assigned (was: ) > Enable reading compressed files with Python fileio > -

[jira] [Updated] (BEAM-8344) Add infer schema support in ParquetIO and refactor ParquetTableProvider

[ https://issues.apache.org/jira/browse/BEAM-8344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8344: -- Labels: stale-assigned (was: ) > Add infer schema support in ParquetIO and refactor ParquetTabl

[jira] [Updated] (BEAM-9631) Flink 1.10 test execution is broken due to premature test cluster shutdown

[ https://issues.apache.org/jira/browse/BEAM-9631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9631: -- Labels: stale-assigned (was: ) > Flink 1.10 test execution is broken due to premature test clus

[jira] [Updated] (BEAM-9190) Remove duplicate content in BeamBigQuerySqlDialect after updating Calcite version

[ https://issues.apache.org/jira/browse/BEAM-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9190: -- Labels: stale-assigned (was: ) > Remove duplicate content in BeamBigQuerySqlDialect after updat

[jira] [Updated] (BEAM-7059) SamzaRunner: fix the job.id inconsistency in the new Samza version

[ https://issues.apache.org/jira/browse/BEAM-7059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-7059: -- Labels: stale-assigned (was: ) > SamzaRunner: fix the job.id inconsistency in the new Samza ver

[jira] [Commented] (BEAM-8954) tox: use isolated builds (PEP 517 and 518)

[ https://issues.apache.org/jira/browse/BEAM-8954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121762#comment-17121762 ] Kenneth Knowles commented on BEAM-8954: --- This issue is assigned but has not received

[jira] [Commented] (BEAM-6315) UnboundedSourceWrapper checkpoints before starting Readers

[ https://issues.apache.org/jira/browse/BEAM-6315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17122174#comment-17122174 ] Kenneth Knowles commented on BEAM-6315: --- This issue is assigned but has not received

[jira] [Commented] (BEAM-9500) Refactor load tests

[ https://issues.apache.org/jira/browse/BEAM-9500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121635#comment-17121635 ] Kenneth Knowles commented on BEAM-9500: --- This issue is assigned but has not received

[jira] [Commented] (BEAM-7250) Use annotation based parameters for SDF on Java

[ https://issues.apache.org/jira/browse/BEAM-7250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17122041#comment-17122041 ] Kenneth Knowles commented on BEAM-7250: --- This issue is assigned but has not received

[jira] [Updated] (BEAM-8174) BigQueryIO clustering documentation is incorrect and lacking

[ https://issues.apache.org/jira/browse/BEAM-8174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8174: -- Labels: documentation stale-assigned (was: documentation) > BigQueryIO clustering documentation

[jira] [Commented] (BEAM-9045) Implement an Ignite runner using Apache Ignite compute grid

[ https://issues.apache.org/jira/browse/BEAM-9045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121743#comment-17121743 ] Kenneth Knowles commented on BEAM-9045: --- This issue is assigned but has not received

[jira] [Commented] (BEAM-8596) Add SplunkIO transform to write messages to Splunk

[ https://issues.apache.org/jira/browse/BEAM-8596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121813#comment-17121813 ] Kenneth Knowles commented on BEAM-8596: --- This issue is assigned but has not received

[jira] [Commented] (BEAM-8546) Moving Java external transform from core-construction-java to sdks-java-core

[ https://issues.apache.org/jira/browse/BEAM-8546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121826#comment-17121826 ] Kenneth Knowles commented on BEAM-8546: --- This issue is assigned but has not received

[jira] [Updated] (BEAM-8873) Add support for splitting at fractions > 0 to org.apache.beam.sdk.transforms.Watch.GrowthTracker

[ https://issues.apache.org/jira/browse/BEAM-8873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8873: -- Labels: stale-assigned (was: ) > Add support for splitting at fractions > 0 to > org.apache.be

[jira] [Commented] (BEAM-9466) SnowflakeIO in python

[ https://issues.apache.org/jira/browse/BEAM-9466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121643#comment-17121643 ] Kenneth Knowles commented on BEAM-9466: --- This issue is assigned but has not received

[jira] [Updated] (BEAM-6700) isSubType isSuperType methods do not belong in Schema.FieldType

[ https://issues.apache.org/jira/browse/BEAM-6700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-6700: -- Labels: stale-assigned (was: ) > isSubType isSuperType methods do not belong in Schema.FieldTyp

[jira] [Updated] (BEAM-9257) Enable custom UDF for sorting criterion in @RequiresTimeSortedInput

[ https://issues.apache.org/jira/browse/BEAM-9257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9257: -- Labels: stale-assigned (was: ) > Enable custom UDF for sorting criterion in @RequiresTimeSorted

[jira] [Updated] (BEAM-9150) beam_PostRelease_Python_Candidate fails

[ https://issues.apache.org/jira/browse/BEAM-9150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9150: -- Labels: stale-assigned (was: ) > beam_PostRelease_Python_Candidate fails >

[jira] [Commented] (BEAM-6804) [beam_PostCommit_Java] [PubsubReadIT.testReadPublicData] Timeout waiting on Sub

[ https://issues.apache.org/jira/browse/BEAM-6804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17122095#comment-17122095 ] Kenneth Knowles commented on BEAM-6804: --- This issue is assigned but has not received

[jira] [Updated] (BEAM-8593) Define expected behavior of running ZetaSQL query on tables with unsupported field types

[ https://issues.apache.org/jira/browse/BEAM-8593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8593: -- Labels: stale-assigned (was: ) > Define expected behavior of running ZetaSQL query on tables wi

[jira] [Updated] (BEAM-9621) Python SqlTransform follow-ups

[ https://issues.apache.org/jira/browse/BEAM-9621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9621: -- Labels: stale-assigned (was: ) > Python SqlTransform follow-ups > -

[jira] [Commented] (BEAM-6733) Use Flink 1.6/1.7 prepareSnapshotPreBarrier to replace BufferedOutputManager

[ https://issues.apache.org/jira/browse/BEAM-6733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17122106#comment-17122106 ] Kenneth Knowles commented on BEAM-6733: --- This issue is assigned but has not received

[jira] [Commented] (BEAM-9406) Convert KuduIO away from BoundedSource

[ https://issues.apache.org/jira/browse/BEAM-9406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121660#comment-17121660 ] Kenneth Knowles commented on BEAM-9406: --- This issue is assigned but has not received

[jira] [Updated] (BEAM-8739) Consistently use with Pipeline(...) syntax

[ https://issues.apache.org/jira/browse/BEAM-8739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8739: -- Labels: stale-assigned (was: ) > Consistently use with Pipeline(...) syntax > -

[jira] [Commented] (BEAM-8364) SchemaCoder inconsistent equality behavior for POJO

[ https://issues.apache.org/jira/browse/BEAM-8364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121858#comment-17121858 ] Kenneth Knowles commented on BEAM-8364: --- This issue is assigned but has not received

[jira] [Commented] (BEAM-9385) Vendoring validation is not detecting module-info.class pattern

[ https://issues.apache.org/jira/browse/BEAM-9385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121669#comment-17121669 ] Kenneth Knowles commented on BEAM-9385: --- This issue is assigned but has not received

[jira] [Updated] (BEAM-8954) tox: use isolated builds (PEP 517 and 518)

[ https://issues.apache.org/jira/browse/BEAM-8954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8954: -- Labels: stale-assigned (was: ) > tox: use isolated builds (PEP 517 and 518) > -

[jira] [Updated] (BEAM-9483) PubsubIO.readMessagesWithMessageId does not work with streaming dataflow pipeline

[ https://issues.apache.org/jira/browse/BEAM-9483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9483: -- Labels: stale-assigned (was: ) > PubsubIO.readMessagesWithMessageId does not work with streamin

[jira] [Updated] (BEAM-7633) Remove experimental annotation from stable transforms in Java HBaseIO connector

[ https://issues.apache.org/jira/browse/BEAM-7633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-7633: -- Labels: stale-assigned (was: ) > Remove experimental annotation from stable transforms in Java

[jira] [Commented] (BEAM-7482) Update Documentations for issue BEAM-7439

[ https://issues.apache.org/jira/browse/BEAM-7482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17122009#comment-17122009 ] Kenneth Knowles commented on BEAM-7482: --- This issue is assigned but has not received

[jira] [Commented] (BEAM-8906) Long BigQuery dry runs cause avalanche delay

[ https://issues.apache.org/jira/browse/BEAM-8906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121776#comment-17121776 ] Kenneth Knowles commented on BEAM-8906: --- This issue is assigned but has not received

[jira] [Commented] (BEAM-9206) Easy way to run checkJavaLinkage?

[ https://issues.apache.org/jira/browse/BEAM-9206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121705#comment-17121705 ] Kenneth Knowles commented on BEAM-9206: --- This issue is assigned but has not received

[jira] [Updated] (BEAM-9185) Publish pre-release python artifacts (RCs) to PyPI

[ https://issues.apache.org/jira/browse/BEAM-9185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9185: -- Labels: stale-assigned (was: ) > Publish pre-release python artifacts (RCs) to PyPI > -

[jira] [Updated] (BEAM-8216) GCS IO fails with uninformative 'Broken pipe' errors while attempting to write to a GCS bucket without proper permissions.

[ https://issues.apache.org/jira/browse/BEAM-8216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8216: -- Labels: stale-assigned (was: ) > GCS IO fails with uninformative 'Broken pipe' errors while att

[jira] [Commented] (BEAM-8388) Update Avro to 1.9.1 from 1.8.2

[ https://issues.apache.org/jira/browse/BEAM-8388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121853#comment-17121853 ] Kenneth Knowles commented on BEAM-8388: --- This issue is assigned but has not received

[jira] [Commented] (BEAM-9015) Make py37-cloud test suite for TOX instead of separate py37-gcp, and py37-aws

[ https://issues.apache.org/jira/browse/BEAM-9015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121745#comment-17121745 ] Kenneth Knowles commented on BEAM-9015: --- This issue is assigned but has not received

[jira] [Commented] (BEAM-8344) Add infer schema support in ParquetIO and refactor ParquetTableProvider

[ https://issues.apache.org/jira/browse/BEAM-8344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121867#comment-17121867 ] Kenneth Knowles commented on BEAM-8344: --- This issue is assigned but has not received

[jira] [Commented] (BEAM-7739) Add ValueState in Python sdk

[ https://issues.apache.org/jira/browse/BEAM-7739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121970#comment-17121970 ] Kenneth Knowles commented on BEAM-7739: --- This issue is assigned but has not received

[jira] [Updated] (BEAM-9348) Enable CrossLanguageValidatesRunner test for direct runner

[ https://issues.apache.org/jira/browse/BEAM-9348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9348: -- Labels: stale-assigned (was: ) > Enable CrossLanguageValidatesRunner test for direct runner > -

[jira] [Updated] (BEAM-9376) Delete python DirectRunner after FnApiRunner fully supports Batch & Streaming

[ https://issues.apache.org/jira/browse/BEAM-9376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9376: -- Labels: stale-assigned (was: ) > Delete python DirectRunner after FnApiRunner fully supports Ba

[jira] [Updated] (BEAM-8602) Always use shadow configuration for direct runner dependencies

[ https://issues.apache.org/jira/browse/BEAM-8602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8602: -- Labels: stale-assigned (was: ) > Always use shadow configuration for direct runner dependencies

[jira] [Updated] (BEAM-8992) ./gradlew :sdks:go:examples:goVet fails

[ https://issues.apache.org/jira/browse/BEAM-8992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8992: -- Labels: stale-assigned (was: ) > ./gradlew :sdks:go:examples:goVet fails >

[jira] [Updated] (BEAM-5287) Support ReduceByKey - sorted values

[ https://issues.apache.org/jira/browse/BEAM-5287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-5287: -- Labels: stale-assigned (was: ) > Support ReduceByKey - sorted values >

[jira] [Commented] (BEAM-8823) Make FnApiRunner work by executing ready elements instead of stages

[ https://issues.apache.org/jira/browse/BEAM-8823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121791#comment-17121791 ] Kenneth Knowles commented on BEAM-8823: --- This issue is assigned but has not received

[jira] [Updated] (BEAM-9629) JdbcIO seems to run out of connections in the connection pool and freezes pipeline

[ https://issues.apache.org/jira/browse/BEAM-9629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9629: -- Labels: performance stale-assigned (was: performance) > JdbcIO seems to run out of connections

[jira] [Commented] (BEAM-6511) AbstractGlobalCombineFn hierarchy is inconsistent

[ https://issues.apache.org/jira/browse/BEAM-6511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17122132#comment-17122132 ] Kenneth Knowles commented on BEAM-6511: --- This issue is assigned but has not received

[jira] [Updated] (BEAM-8325) SdkWorker should be stopped in SdkHarness

[ https://issues.apache.org/jira/browse/BEAM-8325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8325: -- Labels: stale-assigned (was: ) > SdkWorker should be stopped in SdkHarness > --

[jira] [Updated] (BEAM-8389) Code Velocity dashboard lists closed PR as open

[ https://issues.apache.org/jira/browse/BEAM-8389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8389: -- Labels: stale-assigned (was: ) > Code Velocity dashboard lists closed PR as open >

[jira] [Updated] (BEAM-8790) Provide Kubernetes deployment for InfluxDB/Kapacitor

[ https://issues.apache.org/jira/browse/BEAM-8790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8790: -- Labels: stale-assigned (was: ) > Provide Kubernetes deployment for InfluxDB/Kapacitor > ---

[jira] [Updated] (BEAM-8756) Beam Dependency Update Request: com.google.cloud:google-cloud-core

[ https://issues.apache.org/jira/browse/BEAM-8756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8756: -- Labels: stale-assigned (was: ) > Beam Dependency Update Request: com.google.cloud:google-cloud-

[jira] [Updated] (BEAM-7555) Migrate AWS IOs to AWS SDK for Java 2

[ https://issues.apache.org/jira/browse/BEAM-7555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-7555: -- Labels: stale-assigned (was: ) > Migrate AWS IOs to AWS SDK for Java 2 > --

[jira] [Updated] (BEAM-7410) Explore possibilities to lower in-use IP address quota footprint.

[ https://issues.apache.org/jira/browse/BEAM-7410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-7410: -- Labels: stale-assigned (was: ) > Explore possibilities to lower in-use IP address quota footpri

[jira] [Updated] (BEAM-8511) Support for enhanced fan-out in KinesisIO.Read

[ https://issues.apache.org/jira/browse/BEAM-8511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8511: -- Labels: stale-assigned (was: ) > Support for enhanced fan-out in KinesisIO.Read > -

[jira] [Updated] (BEAM-9436) Improve performance of GBK

[ https://issues.apache.org/jira/browse/BEAM-9436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9436: -- Labels: stale-assigned structured-streaming (was: structured-streaming) > Improve performance o

[jira] [Updated] (BEAM-9390) [PostCommit_Java_PortabilityApi] [BigQuery related ITs] UnsupportedOperationException: BigQuery source must be split before being read

[ https://issues.apache.org/jira/browse/BEAM-9390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9390: -- Labels: currently-failing stale-assigned (was: currently-failing) > [PostCommit_Java_Portabilit

[jira] [Updated] (BEAM-7992) Unhandled type_constraint in apache_beam.io.gcp.bigquery_write_it_test.BigQueryWriteIntegrationTests.test_big_query_write_new_types

[ https://issues.apache.org/jira/browse/BEAM-7992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-7992: -- Labels: stale-assigned (was: ) > Unhandled type_constraint in > apache_beam.io.gcp.bigquery_wr

[jira] [Commented] (BEAM-9180) [ZetaSQL] Support 4-byte unicode in literal string unparsing

[ https://issues.apache.org/jira/browse/BEAM-9180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121712#comment-17121712 ] Kenneth Knowles commented on BEAM-9180: --- This issue is assigned but has not received

[jira] [Updated] (BEAM-6652) Handle map encoding better.

[ https://issues.apache.org/jira/browse/BEAM-6652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-6652: -- Labels: stale-assigned (was: ) > Handle map encoding better. > --- > >

[jira] [Updated] (BEAM-7374) Add usage documentation for vet runner

[ https://issues.apache.org/jira/browse/BEAM-7374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-7374: -- Labels: stale-assigned (was: ) > Add usage documentation for vet runner > -

[jira] [Updated] (BEAM-7261) Add support for BasicSessionCredentials for aws credentials.

[ https://issues.apache.org/jira/browse/BEAM-7261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-7261: -- Labels: stale-assigned (was: ) > Add support for BasicSessionCredentials for aws credentials. >

[jira] [Commented] (BEAM-6585) Docker builds are repeatedly timing out when executing on beam7

[ https://issues.apache.org/jira/browse/BEAM-6585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17122117#comment-17122117 ] Kenneth Knowles commented on BEAM-6585: --- This issue is assigned but has not received

[jira] [Commented] (BEAM-4459) Schemas across pipeline modifications

[ https://issues.apache.org/jira/browse/BEAM-4459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17122325#comment-17122325 ] Kenneth Knowles commented on BEAM-4459: --- This issue is assigned but has not received

[jira] [Updated] (BEAM-8963) Apache Beam Java GCP dependencies to catch up with GCP libraries-bom

[ https://issues.apache.org/jira/browse/BEAM-8963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8963: -- Labels: stale-assigned (was: ) > Apache Beam Java GCP dependencies to catch up with GCP librari

[jira] [Commented] (BEAM-8386) Java Dependencies out of date

[ https://issues.apache.org/jira/browse/BEAM-8386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121851#comment-17121851 ] Kenneth Knowles commented on BEAM-8386: --- This issue is assigned but has not received

[jira] [Updated] (BEAM-7250) Use annotation based parameters for SDF on Java

[ https://issues.apache.org/jira/browse/BEAM-7250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-7250: -- Labels: outreachy19dec stale-assigned (was: outreachy19dec) > Use annotation based parameters f

[jira] [Commented] (BEAM-5464) Portable beam hangs while running TFX preprocessing step on a distributed cluster

[ https://issues.apache.org/jira/browse/BEAM-5464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17122244#comment-17122244 ] Kenneth Knowles commented on BEAM-5464: --- This issue is assigned but has not received

[jira] [Updated] (BEAM-5051) Cleanup pubsub subscriptions

[ https://issues.apache.org/jira/browse/BEAM-5051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-5051: -- Labels: stale-assigned (was: ) > Cleanup pubsub subscriptions > >

<    2   3   4   5   6   7   8   9   10   11   >