[jira] [Commented] (BEAM-10115) Staging requirements.txt fails but staging setup.py succeeds

[ https://issues.apache.org/jira/browse/BEAM-10115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121391#comment-17121391 ] Kenneth Knowles commented on BEAM-10115: I looked around a bit more and found ht

[jira] [Work logged] (BEAM-10097) Migrate PCollection views to use both iterable and multimap materializations/access patterns

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

[jira] [Work logged] (BEAM-10097) Migrate PCollection views to use both iterable and multimap materializations/access patterns

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

[jira] [Work logged] (BEAM-10097) Migrate PCollection views to use both iterable and multimap materializations/access patterns

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

[jira] [Work logged] (BEAM-10036) More flexible dataframes partitioning.

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

[jira] [Assigned] (BEAM-10068) Modify behavior of Dynamic Destinations

[ https://issues.apache.org/jira/browse/BEAM-10068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pablo Estrada reassigned BEAM-10068: Assignee: Pablo Estrada > Modify behavior of Dynamic Destinations > --

[jira] [Updated] (BEAM-10068) Modify behavior of Dynamic Destinations

[ https://issues.apache.org/jira/browse/BEAM-10068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pablo Estrada updated BEAM-10068: - Issue Type: New Feature (was: Improvement) > Modify behavior of Dynamic Destinations > -

[jira] [Commented] (BEAM-10068) Modify behavior of Dynamic Destinations

[ https://issues.apache.org/jira/browse/BEAM-10068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121408#comment-17121408 ] Pablo Estrada commented on BEAM-10068: -- Made this into a new feature -type issue. [~

[jira] [Assigned] (BEAM-10068) Modify behavior of Dynamic Destinations

[ https://issues.apache.org/jira/browse/BEAM-10068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pablo Estrada reassigned BEAM-10068: Assignee: Reuven Lax (was: Pablo Estrada) > Modify behavior of Dynamic Destinations > ---

[jira] [Work logged] (BEAM-10027) Support for Kotlin-based Beam Katas

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

[jira] [Work logged] (BEAM-9926) Certain code examples for programming guide are not showing

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

[jira] [Work logged] (BEAM-8451) Interactive Beam example failing from stack overflow

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

[jira] [Assigned] (BEAM-10148) Data loaded using ReadAllFromText is not projected properly as side input

[ https://issues.apache.org/jira/browse/BEAM-10148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prathap Kumar Parvathareddy reassigned BEAM-10148: -- Assignee: Prathap Kumar Parvathareddy > Data loaded using Read

[jira] [Assigned] (BEAM-10148) Data loaded using ReadAllFromText is not projected properly as side input

[ https://issues.apache.org/jira/browse/BEAM-10148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prathap Kumar Parvathareddy reassigned BEAM-10148: -- Assignee: (was: Prathap Kumar Parvathareddy) > Data loaded

[jira] [Work logged] (BEAM-9825) Transforms for Intersect, IntersectAll, Except, ExceptAll, Union, UnionAll

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

[jira] [Work logged] (BEAM-9825) Transforms for Intersect, IntersectAll, Except, ExceptAll, Union, UnionAll

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

[jira] [Updated] (BEAM-758) Per-step, per-execution nonce

[ https://issues.apache.org/jira/browse/BEAM-758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-758: - Labels: stale-assigned (was: ) > Per-step, per-execution nonce > - > >

[jira] [Work logged] (BEAM-9825) Transforms for Intersect, IntersectAll, Except, ExceptAll, Union, UnionAll

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

[jira] [Commented] (BEAM-9780) Add a DICOM IO Connector for Google Cloud Healthcare API

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

[jira] [Commented] (BEAM-9709) timezone off by 8 hours

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

[jira] [Updated] (BEAM-9689) Update wordcount webpage with Spark/Flink + Go

[ https://issues.apache.org/jira/browse/BEAM-9689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9689: -- Labels: stale-assigned (was: ) > Update wordcount webpage with Spark/Flink + Go > -

[jira] [Updated] (BEAM-9643) Add user-facing Go SDF documentation.

[ https://issues.apache.org/jira/browse/BEAM-9643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9643: -- Labels: stale-assigned (was: ) > Add user-facing Go SDF documentation. > --

[jira] [Commented] (BEAM-9546) Support for batching a schema-aware PCollection and processing as a Dataframe

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

[jira] [Updated] (BEAM-9839) OnTimerContext should not create a new one when processing each element/timer in FnApiDoFnRunner

[ https://issues.apache.org/jira/browse/BEAM-9839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9839: -- Labels: stale-assigned (was: ) > OnTimerContext should not create a new one when processing eac

[jira] [Updated] (BEAM-9863) AvroUtils is converting incorrectly LogicalType Timestamps from long into Joda DateTimes

[ https://issues.apache.org/jira/browse/BEAM-9863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9863: -- Labels: stale-assigned (was: ) > AvroUtils is converting incorrectly LogicalType Timestamps fro

[jira] [Commented] (BEAM-9863) AvroUtils is converting incorrectly LogicalType Timestamps from long into Joda DateTimes

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

[jira] [Commented] (BEAM-9742) Add ability to pass FluentBackoff to JdbcIo.Write

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

[jira] [Commented] (BEAM-9861) BigQueryStorageStreamSource fails with split fractions of 0.0 or 1.0

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

[jira] [Updated] (BEAM-9322) Python SDK ignores manually set PCollection tags

[ https://issues.apache.org/jira/browse/BEAM-9322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9322: -- Labels: stale-assigned (was: ) > Python SDK ignores manually set PCollection tags > ---

[jira] [Updated] (BEAM-9640) Track PCollection watermark across bundle executions

[ https://issues.apache.org/jira/browse/BEAM-9640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9640: -- Labels: stale-assigned (was: ) > Track PCollection watermark across bundle executions > ---

[jira] [Updated] (BEAM-9787) Send clear error to users trying to use BigQuerySource on FnApi pipelines on Python SDK

[ https://issues.apache.org/jira/browse/BEAM-9787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9787: -- Labels: stale-assigned (was: ) > Send clear error to users trying to use BigQuerySource on FnAp

[jira] [Commented] (BEAM-9850) Key should be available in @OnTimer methods (Spark Runner)

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

[jira] [Commented] (BEAM-9286) Create validation tests for metrics based on MonitoringInfo if applicable

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

[jira] [Commented] (BEAM-9626) pymongo should be an optional requirement

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

[jira] [Updated] (BEAM-9682) Windowing | Go SDK Code Katas

[ https://issues.apache.org/jira/browse/BEAM-9682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9682: -- Labels: stale-assigned (was: ) > Windowing | Go SDK Code Katas > -

[jira] [Updated] (BEAM-9770) Add BigQuery DeadLetter pattern to Patterns Page

[ https://issues.apache.org/jira/browse/BEAM-9770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9770: -- Labels: pipeline-patterns stale-assigned (was: pipeline-patterns) > Add BigQuery DeadLetter pat

[jira] [Commented] (BEAM-9598) _CustomBigQuerySource checks valueprovider when it's not needed

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

[jira] [Commented] (BEAM-9763) Make _ReadFromBigQuery public

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

[jira] [Commented] (BEAM-9781) Cross language test: -v: unary operator expected

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

[jira] [Updated] (BEAM-9777) Support UNNEST(ARRAY[STRUCT()])

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

[jira] [Commented] (BEAM-9680) Common Transforms | Go SDK Code Katas

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

[jira] [Updated] (BEAM-9687) Names of temporary files created by interactive runner include characters invalid on some platforms.

[ https://issues.apache.org/jira/browse/BEAM-9687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9687: -- Labels: stale-assigned (was: ) > Names of temporary files created by interactive runner include

[jira] [Commented] (BEAM-9356) Flink python test logs are too noisy

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

[jira] [Commented] (BEAM-9700) Support ValueProvider for HCatalogIO

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

[jira] [Updated] (BEAM-9785) Add PostCommit suite for Python 3.8

[ https://issues.apache.org/jira/browse/BEAM-9785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9785: -- Labels: stale-assigned (was: ) > Add PostCommit suite for Python 3.8 >

[jira] [Updated] (BEAM-9869) adding self-contained Kafka service jar for testing

[ https://issues.apache.org/jira/browse/BEAM-9869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9869: -- Labels: stale-assigned (was: ) > adding self-contained Kafka service jar for testing >

[jira] [Updated] (BEAM-9709) timezone off by 8 hours

[ https://issues.apache.org/jira/browse/BEAM-9709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9709: -- Labels: stale-assigned zetasql-compliance (was: zetasql-compliance) > timezone off by 8 hours >

[jira] [Updated] (BEAM-9729) Cleanup bundle registration now that SDKs can pull.

[ https://issues.apache.org/jira/browse/BEAM-9729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9729: -- Labels: stale-assigned (was: ) > Cleanup bundle registration now that SDKs can pull. >

[jira] [Updated] (BEAM-9649) beam_python_mongoio_load_test started failing due to mismatched results

[ https://issues.apache.org/jira/browse/BEAM-9649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9649: -- Labels: stale-assigned (was: ) > beam_python_mongoio_load_test started failing due to mismatche

[jira] [Commented] (BEAM-9612) Implement job metrics in Spark uber jar job server

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

[jira] [Updated] (BEAM-9850) Key should be available in @OnTimer methods (Spark Runner)

[ https://issues.apache.org/jira/browse/BEAM-9850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9850: -- Labels: stale-assigned (was: ) > Key should be available in @OnTimer methods (Spark Runner) >

[jira] [Updated] (BEAM-9683) Triggers | Go SDK Code Katas

[ https://issues.apache.org/jira/browse/BEAM-9683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9683: -- Labels: stale-assigned (was: ) > Triggers | Go SDK Code Katas > >

[jira] [Commented] (BEAM-9712) setting default timezone doesn't work

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

[jira] [Commented] (BEAM-9690) Go build failing: undefined: primitives.Reshuffle(KV)

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

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

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

[jira] [Commented] (BEAM-9137) beam_PostCommit_Py_ValCont should run with dataflow_worker_jar

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

[jira] [Updated] (BEAM-9571) Add withMongoClientProvider to MongoDbIO

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

[jira] [Commented] (BEAM-9646) [Java] PTransform that integrates Cloud Vision functionality

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

[jira] [Commented] (BEAM-9527) apache_beam.runners.portability.fn_api_runner_test.FnApiRunnerSplitTest.test_split_crazy_sdf is flaky

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

[jira] [Updated] (BEAM-9830) Flink and Samza pipeline options are incompatible

[ https://issues.apache.org/jira/browse/BEAM-9830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9830: -- Labels: stale-assigned (was: ) > Flink and Samza pipeline options are incompatible > --

[jira] [Updated] (BEAM-9781) Cross language test: -v: unary operator expected

[ https://issues.apache.org/jira/browse/BEAM-9781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9781: -- Labels: stale-assigned (was: ) > Cross language test: -v: unary operator expected > --

[jira] [Commented] (BEAM-9641) Support ZetaSQL DATE functions in BeamSQL

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

[jira] [Commented] (BEAM-9549) Flaky portableWordCountBatch and portableWordCountStreaming tests

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

[jira] [Commented] (BEAM-9674) "Selected fields list too long" error when calling tables.get in BigQueryStorageTableSource

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

[jira] [Commented] (BEAM-9869) adding self-contained Kafka service jar for testing

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

[jira] [Commented] (BEAM-9640) Track PCollection watermark across bundle executions

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

[jira] [Updated] (BEAM-9857) Update Spark runner page to include Docker job server

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

[jira] [Commented] (BEAM-9624) Combine operation should support only converting to accumulators

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

[jira] [Commented] (BEAM-9710) Got current time instead of timestamp value

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

[jira] [Updated] (BEAM-9762) Production-ready BigQuery IOs for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-9762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9762: -- Labels: stale-assigned (was: ) > Production-ready BigQuery IOs for Python SDK > ---

[jira] [Commented] (BEAM-9684) Boss Level | Go SDK Code Katas

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

[jira] [Commented] (BEAM-9723) [Java] PTransform that connects to Cloud DLP deidentification service

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

[jira] [Commented] (BEAM-9750) Streaming Word Count Example Documents is out of date (Python)

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

[jira] [Updated] (BEAM-9776) Beam SQL shell doesn't support creating an external table pointing to GCS, i.e., "gs://..."

[ https://issues.apache.org/jira/browse/BEAM-9776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9776: -- Labels: stale-assigned (was: ) > Beam SQL shell doesn't support creating an external table poin

[jira] [Updated] (BEAM-9198) BeamSQL aggregation analytics functionality

[ https://issues.apache.org/jira/browse/BEAM-9198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9198: -- Labels: gsoc gsoc2020 mentor stale-assigned (was: gsoc gsoc2020 mentor) > BeamSQL aggregation a

[jira] [Updated] (BEAM-9715) annotations_test fails in some environmens

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

[jira] [Updated] (BEAM-9748) Refactor Reparallelize as an alternative Reshuffle implementation

[ https://issues.apache.org/jira/browse/BEAM-9748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9748: -- Labels: stale-assigned (was: ) > Refactor Reparallelize as an alternative Reshuffle implementat

[jira] [Commented] (BEAM-9772) Pipeline validation errors log at WARN level

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

[jira] [Updated] (BEAM-9746) [Go SDK] Empty side inputs causing spurious zero elements

[ https://issues.apache.org/jira/browse/BEAM-9746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9746: -- Labels: stale-assigned (was: ) > [Go SDK] Empty side inputs causing spurious zero elements > --

[jira] [Updated] (BEAM-9700) Support ValueProvider for HCatalogIO

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

[jira] [Commented] (BEAM-9696) UnionCoder IndexOutOfBoundsException in schema-driven join transform

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

[jira] [Commented] (BEAM-9830) Flink and Samza pipeline options are incompatible

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

[jira] [Commented] (BEAM-9829) Restructure test infrastructure for Python SDK

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

[jira] [Updated] (BEAM-9425) explicitly register default environment instead of assuming the first one as a default

[ https://issues.apache.org/jira/browse/BEAM-9425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9425: -- Labels: stale-assigned (was: ) > explicitly register default environment instead of assuming th

[jira] [Updated] (BEAM-9646) [Java] PTransform that integrates Cloud Vision functionality

[ https://issues.apache.org/jira/browse/BEAM-9646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9646: -- Labels: stale-assigned (was: ) > [Java] PTransform that integrates Cloud Vision functionality >

[jira] [Commented] (BEAM-9757) Flake in JavaPortabilityApi precommit

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

[jira] [Commented] (BEAM-9747) Deprecate RedisIO.readAll() and add RedisIO.readKeyPatterns() as a replacement

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

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

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

[jira] [Updated] (BEAM-9625) StateServicer should be owned by FnApiRunnerContextManager

[ https://issues.apache.org/jira/browse/BEAM-9625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9625: -- Labels: stale-assigned (was: ) > StateServicer should be owned by FnApiRunnerContextManager > -

[jira] [Commented] (BEAM-9675) BigQueryStorageStreamSource reader quota issues at split time

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

[jira] [Updated] (BEAM-9615) [Go SDK] Beam Schemas

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

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17121709#comment-17121709 ] Kenneth Knowles commented on BEAM-9185: --- This issue is assigned but has not received

[jira] [Updated] (BEAM-9455) Environment-sensitive provisioning for Dataflow

[ https://issues.apache.org/jira/browse/BEAM-9455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9455: -- Labels: stale-assigned (was: ) > Environment-sensitive provisioning for Dataflow >

[jira] [Commented] (BEAM-9542) Where the BeamModulePlugin's force is needed?

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

[jira] [Commented] (BEAM-9776) Beam SQL shell doesn't support creating an external table pointing to GCS, i.e., "gs://..."

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

[jira] [Updated] (BEAM-9704) BIP-1: Deprecate and remove FieldType metadata

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

[jira] [Updated] (BEAM-9763) Make _ReadFromBigQuery public

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

[jira] [Updated] (BEAM-9861) BigQueryStorageStreamSource fails with split fractions of 0.0 or 1.0

[ https://issues.apache.org/jira/browse/BEAM-9861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9861: -- Labels: stale-assigned (was: ) > BigQueryStorageStreamSource fails with split fractions of 0.0

[jira] [Updated] (BEAM-9712) setting default timezone doesn't work

[ https://issues.apache.org/jira/browse/BEAM-9712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9712: -- Labels: stale-assigned zetasql-compliance (was: zetasql-compliance) > setting default timezone

[jira] [Updated] (BEAM-9681) IO | Go SDK Code Katas

[ https://issues.apache.org/jira/browse/BEAM-9681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9681: -- Labels: stale-assigned (was: ) > IO | Go SDK Code Katas > -- > >

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