[jira] [Updated] (BEAM-8735) tox: yes or no

[ https://issues.apache.org/jira/browse/BEAM-8735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8735: -- Status: Open (was: Triage Needed) > tox: yes or no > -- > > Key: BE

[jira] [Commented] (BEAM-8735) Beam site says to install tox, but GitHub README does not

[ https://issues.apache.org/jira/browse/BEAM-8735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17108775#comment-17108775 ] Kenneth Knowles commented on BEAM-8735: --- Ideally we'd just have one set of instructi

[jira] [Updated] (BEAM-8735) Beam site says to install tox, but GitHub README does not

[ https://issues.apache.org/jira/browse/BEAM-8735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8735: -- Summary: Beam site says to install tox, but GitHub README does not (was: tox: yes or no) > Bea

[jira] [Updated] (BEAM-9894) Add batch SnowflakeIO.Write to Java SDK

[ https://issues.apache.org/jira/browse/BEAM-9894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9894: -- Status: Open (was: Triage Needed) > Add batch SnowflakeIO.Write to Java SDK > -

[jira] [Updated] (BEAM-9898) Add cross-language support to SnowflakeIO.Write

[ https://issues.apache.org/jira/browse/BEAM-9898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9898: -- Status: Open (was: Triage Needed) > Add cross-language support to SnowflakeIO.Write > -

[jira] [Updated] (BEAM-9896) Add streaming for SnowflakeIO.Write to Java SDK

[ https://issues.apache.org/jira/browse/BEAM-9896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9896: -- Status: Open (was: Triage Needed) > Add streaming for SnowflakeIO.Write to Java SDK > -

[jira] [Updated] (BEAM-9897) Add cross-language support to SnowflakeIO.Read

[ https://issues.apache.org/jira/browse/BEAM-9897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9897: -- Status: Open (was: Triage Needed) > Add cross-language support to SnowflakeIO.Read > --

[jira] [Updated] (BEAM-10024) Spark runner failing testOutputTimestampDefault

[ https://issues.apache.org/jira/browse/BEAM-10024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10024: --- Status: Open (was: Triage Needed) > Spark runner failing testOutputTimestampDefault > --

[jira] [Updated] (BEAM-10025) Samza runner failing testOutputTimestampDefault

[ https://issues.apache.org/jira/browse/BEAM-10025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10025: --- Status: Open (was: Triage Needed) > Samza runner failing testOutputTimestampDefault > --

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

[ https://issues.apache.org/jira/browse/BEAM-10027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10027: --- Status: Open (was: Triage Needed) > Support for Kotlin-based Beam Katas > --

[jira] [Assigned] (BEAM-9961) Python MongoDBIO does not apply projection

[ https://issues.apache.org/jira/browse/BEAM-9961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-9961: - Assignee: Corvin Deboeser > Python MongoDBIO does not apply projection >

[jira] [Comment Edited] (BEAM-9961) Python MongoDBIO does not apply projection

[ https://issues.apache.org/jira/browse/BEAM-9961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17108875#comment-17108875 ] Kenneth Knowles edited comment on BEAM-9961 at 5/18/20, 9:05 PM: ---

[jira] [Assigned] (BEAM-9960) Python MongoDBIO fails when response of split vector command is larger than 16mb

[ https://issues.apache.org/jira/browse/BEAM-9960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-9960: - Assignee: Corvin Deboeser > Python MongoDBIO fails when response of split vector command

[jira] [Assigned] (BEAM-10004) ZeroDivisionError if source bundle smaller than 1mb

[ https://issues.apache.org/jira/browse/BEAM-10004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-10004: -- Assignee: Corvin Deboeser > ZeroDivisionError if source bundle smaller than 1mb >

[jira] [Assigned] (BEAM-10002) Mongo cursor timeout leads to CursorNotFound error

[ https://issues.apache.org/jira/browse/BEAM-10002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-10002: -- Assignee: Corvin Deboeser > Mongo cursor timeout leads to CursorNotFound error > -

[jira] [Commented] (BEAM-9961) Python MongoDBIO does not apply projection

[ https://issues.apache.org/jira/browse/BEAM-9961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110618#comment-17110618 ] Kenneth Knowles commented on BEAM-9961: --- Great! > Python MongoDBIO does not apply p

[jira] [Commented] (BEAM-9745) [beam_PostCommit_Java_PortabilityApi] Various GCP IO tests failing, unable to deserialize Custom DoFns and Custom Coders.

[ https://issues.apache.org/jira/browse/BEAM-9745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110619#comment-17110619 ] Kenneth Knowles commented on BEAM-9745: --- Yea it was disabled because it has been per

[jira] [Updated] (BEAM-9745) [beam_PostCommit_Java_PortabilityApi] Various GCP IO tests failing, unable to deserialize Custom DoFns and Custom Coders.

[ https://issues.apache.org/jira/browse/BEAM-9745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9745: -- Priority: P1 (was: P0) > [beam_PostCommit_Java_PortabilityApi] Various GCP IO tests failing, un

[jira] [Commented] (BEAM-9745) [beam_PostCommit_Java_PortabilityApi] Various GCP IO tests failing, unable to deserialize Custom DoFns and Custom Coders.

[ https://issues.apache.org/jira/browse/BEAM-9745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110621#comment-17110621 ] Kenneth Knowles commented on BEAM-9745: --- BEAM-9868 indicates that the test that shou

[jira] [Commented] (BEAM-9239) Dependency conflict with Spark using aws io

[ https://issues.apache.org/jira/browse/BEAM-9239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110625#comment-17110625 ] Kenneth Knowles commented on BEAM-9239: --- That sounds familiar to me as well. > Depe

[jira] [Updated] (BEAM-10028) [Java SDK] Support state backed iterables within the SDK harness

[ https://issues.apache.org/jira/browse/BEAM-10028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10028: --- Status: Open (was: Triage Needed) > [Java SDK] Support state backed iterables within the SDK

[jira] [Resolved] (BEAM-2762) Coverage report for Python code

[ https://issues.apache.org/jira/browse/BEAM-2762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles resolved BEAM-2762. --- Fix Version/s: Not applicable Resolution: Fixed > Coverage report for Python code > ---

[jira] [Reopened] (BEAM-2762) Coverage report for Python code

[ https://issues.apache.org/jira/browse/BEAM-2762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reopened BEAM-2762: --- Assignee: (was: Mark Liu) Actually I'm reopening this because done & done here would mea

[jira] [Comment Edited] (BEAM-2762) Coverage report for Python code

[ https://issues.apache.org/jira/browse/BEAM-2762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111288#comment-17111288 ] Kenneth Knowles edited comment on BEAM-2762 at 5/19/20, 3:48 PM: ---

[jira] [Updated] (BEAM-2318) Flake in HBaseIOTest

[ https://issues.apache.org/jira/browse/BEAM-2318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-2318: -- Labels: flake (was: ) > Flake in HBaseIOTest > > > Key: BE

[jira] [Updated] (BEAM-891) Flake in Spark metrics library?

[ https://issues.apache.org/jira/browse/BEAM-891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-891: - Labels: flake (was: ) > Flake in Spark metrics library? > --- > >

[jira] [Updated] (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:all-tabpanel ] Kenneth Knowles updated BEAM-8878: -- Labels: flake (was: ) > Possible flake in PortableRunnerTest.test_error_traceback_includes_user

[jira] [Updated] (BEAM-5925) Test flake in ElasticsearchIOTest.testWriteFullAddressing

[ https://issues.apache.org/jira/browse/BEAM-5925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-5925: -- Labels: flake (was: ) > Test flake in ElasticsearchIOTest.testWriteFullAddressing > ---

[jira] [Updated] (BEAM-10034) ZetaSQLCalcRel should assert types match

[ https://issues.apache.org/jira/browse/BEAM-10034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10034: --- Status: Open (was: Triage Needed) > ZetaSQLCalcRel should assert types match > -

[jira] [Updated] (BEAM-10035) Pandas Dataframes API

[ https://issues.apache.org/jira/browse/BEAM-10035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10035: --- Status: Open (was: Triage Needed) > Pandas Dataframes API > - > >

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

[ https://issues.apache.org/jira/browse/BEAM-10036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10036: --- Status: Open (was: Triage Needed) > More flexible dataframes partitioning. > ---

[jira] [Updated] (BEAM-10037) BeamSqlExample.java fails to build when running ./gradlew command

[ https://issues.apache.org/jira/browse/BEAM-10037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10037: --- Status: Open (was: Triage Needed) > BeamSqlExample.java fails to build when running ./gradle

[jira] [Updated] (BEAM-10038) Add script to mass-comment Jenkins triggers on PR

[ https://issues.apache.org/jira/browse/BEAM-10038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10038: --- Status: Open (was: Triage Needed) > Add script to mass-comment Jenkins triggers on PR >

[jira] [Updated] (BEAM-10048) Remove "manual steps" from release guide.

[ https://issues.apache.org/jira/browse/BEAM-10048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10048: --- Status: Open (was: Triage Needed) > Remove "manual steps" from release guide. >

[jira] [Updated] (BEAM-10054) Direct Runner execution stalls with test pipeline

[ https://issues.apache.org/jira/browse/BEAM-10054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10054: --- Status: Open (was: Triage Needed) > Direct Runner execution stalls with test pipeline >

[jira] [Updated] (BEAM-10056) Side Input Validation too tight, doesn't allow CoGBK

[ https://issues.apache.org/jira/browse/BEAM-10056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10056: --- Status: Open (was: Triage Needed) > Side Input Validation too tight, doesn't allow CoGBK > -

[jira] [Commented] (BEAM-10015) output timestamp not properly propagated through the Dataflow runner

[ https://issues.apache.org/jira/browse/BEAM-10015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17114517#comment-17114517 ] Kenneth Knowles commented on BEAM-10015: [~reuvenlax] the typical protocol I use

[jira] [Updated] (BEAM-10072) RequiesTimeSortedInput not working for DnFs without state

[ https://issues.apache.org/jira/browse/BEAM-10072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10072: --- Status: Open (was: Triage Needed) > RequiesTimeSortedInput not working for DnFs without stat

[jira] [Updated] (BEAM-10073) Add dashboard for pubsub performance tests to grafana

[ https://issues.apache.org/jira/browse/BEAM-10073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10073: --- Status: Open (was: Triage Needed) > Add dashboard for pubsub performance tests to grafana >

[jira] [Updated] (BEAM-10074) Hash Functions in BeamSQL

[ https://issues.apache.org/jira/browse/BEAM-10074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10074: --- Status: Open (was: Triage Needed) > Hash Functions in BeamSQL > - >

[jira] [Updated] (BEAM-10075) Allow users to tune the grouping table size in batch dataflow pipelines

[ https://issues.apache.org/jira/browse/BEAM-10075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10075: --- Status: Open (was: Triage Needed) > Allow users to tune the grouping table size in batch dat

[jira] [Updated] (BEAM-10076) Dataflow worker status page incorrectly displays work item statuses

[ https://issues.apache.org/jira/browse/BEAM-10076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10076: --- Status: Open (was: Triage Needed) > Dataflow worker status page incorrectly displays work it

[jira] [Updated] (BEAM-10077) using filename + hash instead of UUID for staging name

[ https://issues.apache.org/jira/browse/BEAM-10077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10077: --- Status: Open (was: Triage Needed) > using filename + hash instead of UUID for staging name >

[jira] [Commented] (BEAM-10005) Unable to use ApproximateQuantiles.globally/ApproximateUnique.globally when inputs not windowed by GlobalWindows

[ https://issues.apache.org/jira/browse/BEAM-10005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17116890#comment-17116890 ] Kenneth Knowles commented on BEAM-10005: Thanks for checking. I think the simple

[jira] [Updated] (BEAM-10093) Add ZetaSQL Nexmark variant

[ https://issues.apache.org/jira/browse/BEAM-10093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10093: --- Status: Open (was: Triage Needed) > Add ZetaSQL Nexmark variant > --

[jira] [Created] (BEAM-10093) Add ZetaSQL Nexmark variant

Kenneth Knowles created BEAM-10093: -- Summary: Add ZetaSQL Nexmark variant Key: BEAM-10093 URL: https://issues.apache.org/jira/browse/BEAM-10093 Project: Beam Issue Type: New Feature

[jira] [Updated] (BEAM-10095) Add hyperlinks to the beam-overview page.

[ https://issues.apache.org/jira/browse/BEAM-10095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10095: --- Status: Open (was: Triage Needed) > Add hyperlinks to the beam-overview page. >

[jira] [Updated] (BEAM-10096) Spark runners are numbered 1,2,2

[ https://issues.apache.org/jira/browse/BEAM-10096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10096: --- Status: Open (was: Triage Needed) > Spark runners are numbered 1,2,2 > -

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

[ https://issues.apache.org/jira/browse/BEAM-10097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10097: --- Status: Open (was: Triage Needed) > Migrate PCollection views to use both iterable and multi

[jira] [Updated] (BEAM-10102) Fix query in python pubsub IO streaming performance tests dashboards

[ https://issues.apache.org/jira/browse/BEAM-10102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10102: --- Status: Open (was: Triage Needed) > Fix query in python pubsub IO streaming performance test

[jira] [Updated] (BEAM-10106) Script the deployment of artifacts to pypi

[ https://issues.apache.org/jira/browse/BEAM-10106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10106: --- Status: Open (was: Triage Needed) > Script the deployment of artifacts to pypi > ---

[jira] [Updated] (BEAM-10107) beam website PR listed twice in release guide with contradictory instructions

[ https://issues.apache.org/jira/browse/BEAM-10107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10107: --- Status: Open (was: Triage Needed) > beam website PR listed twice in release guide with contr

[jira] [Updated] (BEAM-10108) publish_docker_images.sh has out of date Flink versions

[ https://issues.apache.org/jira/browse/BEAM-10108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10108: --- Status: Open (was: Triage Needed) > publish_docker_images.sh has out of date Flink versions

[jira] [Updated] (BEAM-10109) Fix context classloader in Spark portable runner

[ https://issues.apache.org/jira/browse/BEAM-10109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10109: --- Status: Open (was: Triage Needed) > Fix context classloader in Spark portable runner > -

[jira] [Updated] (BEAM-10110) Populate pipeline_proto_coder_id field for dataflow.

[ https://issues.apache.org/jira/browse/BEAM-10110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10110: --- Status: Open (was: Triage Needed) > Populate pipeline_proto_coder_id field for dataflow. > -

[jira] [Updated] (BEAM-10111) Create methods in fileio to read from / write to archive files

[ https://issues.apache.org/jira/browse/BEAM-10111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10111: --- Status: Open (was: Triage Needed) > Create methods in fileio to read from / write to archive

[jira] [Updated] (BEAM-10089) Apex Runner tests failing [Java 11]

[ https://issues.apache.org/jira/browse/BEAM-10089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10089: --- Status: Open (was: Triage Needed) > Apex Runner tests failing [Java 11] > --

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

Kenneth Knowles created BEAM-10115: -- Summary: Staging requirements.txt fails but staging setup.py succeeds Key: BEAM-10115 URL: https://issues.apache.org/jira/browse/BEAM-10115 Project: Beam

[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=17117955#comment-17117955 ] Kenneth Knowles commented on BEAM-10115: The code paths are different. See https

[jira] [Updated] (BEAM-10116) Implement grouping on non-merging unknown windowing strategies.

[ https://issues.apache.org/jira/browse/BEAM-10116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10116: --- Status: Open (was: Triage Needed) > Implement grouping on non-merging unknown windowing stra

[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=17117959#comment-17117959 ] Kenneth Knowles commented on BEAM-10115: [~heejong] [~goenka] do either of you ha

[jira] [Updated] (BEAM-10118) Unconditionally use safe coders for data channels in FnAPI runner.

[ https://issues.apache.org/jira/browse/BEAM-10118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10118: --- Status: Open (was: Triage Needed) > Unconditionally use safe coders for data channels in FnA

[jira] [Updated] (BEAM-10121) Python RowCoder doesn't support nested structs

[ https://issues.apache.org/jira/browse/BEAM-10121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10121: --- Status: Open (was: Triage Needed) > Python RowCoder doesn't support nested structs > ---

[jira] [Updated] (BEAM-10122) Python RowCoder throws NotImplementedError in DataflowRunner

[ https://issues.apache.org/jira/browse/BEAM-10122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10122: --- Status: Open (was: Triage Needed) > Python RowCoder throws NotImplementedError in DataflowRu

[jira] [Updated] (BEAM-10132) Remove reference to apachebeam/*

[ https://issues.apache.org/jira/browse/BEAM-10132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10132: --- Status: Open (was: Triage Needed) > Remove reference to apachebeam/* > -

[jira] [Updated] (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:all-tabpanel ] Kenneth Knowles updated BEAM-10115: --- Status: Open (was: Triage Needed) > Staging requirements.txt fails but staging setup.py succ

[jira] [Updated] (BEAM-10158) [Python] Reuse a shared unbounded thread pool

[ https://issues.apache.org/jira/browse/BEAM-10158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10158: --- Status: Open (was: Triage Needed) > [Python] Reuse a shared unbounded thread pool >

[jira] [Commented] (BEAM-9843) Flink UnboundedSourceWrapperTest flaky due to a timeout

[ https://issues.apache.org/jira/browse/BEAM-9843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17120064#comment-17120064 ] Kenneth Knowles commented on BEAM-9843: --- [~mxm] timed out in https://builds.apache.

[jira] [Reopened] (BEAM-9843) Flink UnboundedSourceWrapperTest flaky due to a timeout

[ https://issues.apache.org/jira/browse/BEAM-9843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reopened BEAM-9843: --- Assignee: Maximilian Michels > Flink UnboundedSourceWrapperTest flaky due to a timeout > ---

[jira] [Updated] (BEAM-9843) Flink UnboundedSourceWrapperTest flaky due to a timeout

[ https://issues.apache.org/jira/browse/BEAM-9843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9843: -- Priority: P1 (was: P2) > Flink UnboundedSourceWrapperTest flaky due to a timeout >

[jira] [Commented] (BEAM-9843) Flink UnboundedSourceWrapperTest flaky due to a timeout

[ https://issues.apache.org/jira/browse/BEAM-9843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17120079#comment-17120079 ] Kenneth Knowles commented on BEAM-9843: --- I'm reopening just because it is recent eno

[jira] [Updated] (BEAM-9843) Flink UnboundedSourceWrapperTest flaky due to a timeout

[ https://issues.apache.org/jira/browse/BEAM-9843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9843: -- Labels: flake (was: ) > Flink UnboundedSourceWrapperTest flaky due to a timeout > -

[jira] [Commented] (BEAM-9843) Flink UnboundedSourceWrapperTest flaky due to a timeout

[ https://issues.apache.org/jira/browse/BEAM-9843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17120081#comment-17120081 ] Kenneth Knowles commented on BEAM-9843: --- And marking P1 due to flaky test policy. >

[jira] [Commented] (BEAM-9239) Dependency conflict with Spark using aws io

[ https://issues.apache.org/jira/browse/BEAM-9239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17120088#comment-17120088 ] Kenneth Knowles commented on BEAM-9239: --- Yea the spark experimental configs for user

[jira] [Comment Edited] (BEAM-3288) Guard against unsafe triggers at construction time

[ https://issues.apache.org/jira/browse/BEAM-3288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963195#comment-16963195 ] Kenneth Knowles edited comment on BEAM-3288 at 5/30/20, 4:35 AM: ---

[jira] [Updated] (BEAM-10162) Add python pubsubIO performance tests to readme

[ https://issues.apache.org/jira/browse/BEAM-10162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10162: --- Status: Open (was: Triage Needed) > Add python pubsubIO performance tests to readme > --

[jira] [Updated] (BEAM-10163) Change pubsub and bq performance tests jobs name

[ https://issues.apache.org/jira/browse/BEAM-10163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10163: --- Status: Open (was: Triage Needed) > Change pubsub and bq performance tests jobs name > -

[jira] [Updated] (BEAM-10164) Flink: Memory efficient combine implementation for batch runner

[ https://issues.apache.org/jira/browse/BEAM-10164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10164: --- Status: Open (was: Triage Needed) > Flink: Memory efficient combine implementation for batch

[jira] [Updated] (BEAM-10167) Fix 2.21.0 downloads link in blog post

[ https://issues.apache.org/jira/browse/BEAM-10167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10167: --- Status: Open (was: Triage Needed) > Fix 2.21.0 downloads link in blog post > ---

[jira] [Updated] (BEAM-10168) Add Github "publish release" to release guide

[ https://issues.apache.org/jira/browse/BEAM-10168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-10168: --- Status: Open (was: Triage Needed) > Add Github "publish release" to release guide >

[jira] [Comment Edited] (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 edited comment on BEAM-10115 at 6/1/20, 11:05 PM: -

[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] [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] [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 > -

<    5   6   7   8   9   10   11   12   13   14   >