[jira] [Commented] (BEAM-9479) Provide option to run pylint in local git pre-commit

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

[jira] [Updated] (BEAM-9307) Put windows inside the key to avoid having all values for the same key in memory

[ https://issues.apache.org/jira/browse/BEAM-9307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9307: -- Labels: stale-assigned structured-streaming (was: structured-streaming) > Put windows inside th

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

[jira] [Updated] (BEAM-8937) Add a Jenkins job running GroupByKey load test on Java with Flink in Portability mode

[ https://issues.apache.org/jira/browse/BEAM-8937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8937: -- Labels: stale-assigned (was: ) > Add a Jenkins job running GroupByKey load test on Java with Fl

[jira] [Commented] (BEAM-9510) Dependencies in base_image_requirements.txt are not compatible with each other

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

[jira] [Commented] (BEAM-9648) DirectRunner waitUntilFinish does not return null on timeout

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

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

[jira] [Commented] (BEAM-9091) build_release_candidate.sh never runs hub command

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

[jira] [Updated] (BEAM-9445) Preoptimize causes error with environment setup

[ https://issues.apache.org/jira/browse/BEAM-9445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9445: -- Labels: stale-assigned (was: ) > Preoptimize causes error with environment setup >

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

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

[jira] [Updated] (BEAM-9008) Add readAll() method to CassandraIO

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

[jira] [Updated] (BEAM-8681) Beam Dependency Update Request: com.google.api.grpc:proto-google-cloud-pubsub-v1

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

[jira] [Updated] (BEAM-9397) new DoFn should allow injecting all parameters in StartBundleContext/FinishBundleContext

[ https://issues.apache.org/jira/browse/BEAM-9397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9397: -- Labels: stale-assigned (was: ) > new DoFn should allow injecting all parameters in > StartBund

[jira] [Updated] (BEAM-9650) Add consistent slowly changing side inputs support

[ https://issues.apache.org/jira/browse/BEAM-9650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9650: -- Labels: stale-assigned (was: ) > Add consistent slowly changing side inputs support > -

[jira] [Updated] (BEAM-8587) Add TestStream support for Dataflow runner

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

[jira] [Updated] (BEAM-9449) Consider passing pipeline options for expansion service.

[ https://issues.apache.org/jira/browse/BEAM-9449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9449: -- Labels: stale-assigned (was: ) > Consider passing pipeline options for expansion service. > ---

[jira] [Commented] (BEAM-9120) Deprecate onSuccessMatcher, onCreateMatcher

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

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

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

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

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

[jira] [Updated] (BEAM-8045) Publish custom windows pattern

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

[jira] [Updated] (BEAM-9064) Add pytype to lint checks

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

[jira] [Updated] (BEAM-9575) beam_PostCommit_PortableJar_Flink and beam_PostCommit_PortableJar_Spark failing

[ https://issues.apache.org/jira/browse/BEAM-9575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9575: -- Labels: currently-failing portability-flink portability-spark stale-assigned (was: currently-fa

[jira] [Updated] (BEAM-7703) Colab examples for aggregation transforms (Java)

[ https://issues.apache.org/jira/browse/BEAM-7703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-7703: -- Labels: stale-assigned (was: ) > Colab examples for aggregation transforms (Java) > ---

[jira] [Updated] (BEAM-7923) Interactive Beam

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

[jira] [Updated] (BEAM-9486) Python 2 PostCommit Failures due to time-out in 2.20.0 release branch

[ https://issues.apache.org/jira/browse/BEAM-9486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9486: -- Labels: stale-assigned (was: ) > Python 2 PostCommit Failures due to time-out in 2.20.0 release

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

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

[jira] [Commented] (BEAM-9424) Grouping By LogicalTypes is not supported

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

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

[ https://issues.apache.org/jira/browse/BEAM-9356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9356: -- Labels: portability-flink stale-assigned testing (was: portability-flink testing) > Flink pyth

[jira] [Commented] (BEAM-9429) Python PostCommit: wordcount_xlang.py hangs

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

[jira] [Updated] (BEAM-9668) Java PortabilityApi PreCommit failing due to LegacyArtifactRetrievalService Unimplemented

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

[jira] [Commented] (BEAM-8931) [beam_PostCommit_Java_Nexmark_Dataflow] Several queries are failing

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

[jira] [Updated] (BEAM-9444) Shall we use GCP Libraries BOM to specify Google-related library versions?

[ https://issues.apache.org/jira/browse/BEAM-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9444: -- Labels: stale-assigned (was: ) > Shall we use GCP Libraries BOM to specify Google-related libra

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

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

[ https://issues.apache.org/jira/browse/BEAM-8386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8386: -- Labels: stale-assigned (was: ) > Java Dependencies out of date > -

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

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

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

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

[jira] [Commented] (BEAM-9666) UNION ALL with double IllegalStateException

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

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

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

[jira] [Updated] (BEAM-8366) Need a DynamicDestinations implementation for BigtableIO

[ https://issues.apache.org/jira/browse/BEAM-8366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8366: -- Labels: stale-assigned (was: ) > Need a DynamicDestinations implementation for BigtableIO > ---

[jira] [Updated] (BEAM-7605) Provide a way for user code to read dataflow runner stats

[ https://issues.apache.org/jira/browse/BEAM-7605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-7605: -- Labels: stale-assigned (was: ) > Provide a way for user code to read dataflow runner stats > --

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

[ https://issues.apache.org/jira/browse/BEAM-9206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9206: -- Labels: stale-assigned (was: ) > Easy way to run checkJavaLinkage? > --

[jira] [Commented] (BEAM-9134) RedisIO.ReadAll incorrectly alters windowing behavior

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

[jira] [Updated] (BEAM-9502) SchemaCoder assigns random UUID, causes Dataflow's compatibility check to fail

[ https://issues.apache.org/jira/browse/BEAM-9502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9502: -- Labels: stale-assigned (was: ) > SchemaCoder assigns random UUID, causes Dataflow's compatibili

[jira] [Commented] (BEAM-8571) Use SDK version in default Go container tag

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

[jira] [Commented] (BEAM-9250) Improve beam release script based on 2.19.0 release experience

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

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

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

[jira] [Commented] (BEAM-9449) Consider passing pipeline options for expansion service.

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

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

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

[jira] [Commented] (BEAM-9403) Make RedisIO readAll consistent with other Beam readAll methods

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

[jira] [Updated] (BEAM-9073) PipelineVisitor is topologically-order dependent

[ https://issues.apache.org/jira/browse/BEAM-9073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9073: -- Labels: stale-assigned (was: ) > PipelineVisitor is topologically-order dependent > ---

[jira] [Updated] (BEAM-9499) test_multi_triggered_gbk_side_input is failing on head

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

[jira] [Commented] (BEAM-9564) Remove insecure ssl options from MongoDBIO

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

[jira] [Updated] (BEAM-8915) Run flink_runner_test and spark_runner_test using tox

[ https://issues.apache.org/jira/browse/BEAM-8915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8915: -- Labels: portability-flink portability-spark stale-assigned (was: portability-flink portability-

[jira] [Updated] (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:all-tabpanel ] Kenneth Knowles updated BEAM-9598: -- Labels: stale-assigned (was: ) > _CustomBigQuerySource checks valueprovider when it's not neede

[jira] [Commented] (BEAM-9238) Cross-language pipeline dependency management

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

[jira] [Commented] (BEAM-9445) Preoptimize causes error with environment setup

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

[jira] [Commented] (BEAM-8958) Use default credentials provider with BasicKinesisProvider

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

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

[ https://issues.apache.org/jira/browse/BEAM-9710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9710: -- Labels: stale-assigned zetasql-compliance (was: zetasql-compliance) > Got current time instead

[jira] [Updated] (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:all-tabpanel ] Kenneth Knowles updated BEAM-9624: -- Labels: stale-assigned (was: ) > Combine operation should support only converting to accumulato

[jira] [Commented] (BEAM-9318) Py 2 Precommit Flake: PortableRunnerTestWithLocalDocker test flaky

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

[jira] [Commented] (BEAM-8474) A microbenchmark that exercises the FnAPI runner functionality

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

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

[jira] [Commented] (BEAM-9561) Run pandas tests with Beam Dataframe API

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

[jira] [Commented] (BEAM-8149) [FnApiRunner]multi-process runner does not terminate cleanly upon receiving SIGINT

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

[jira] [Commented] (BEAM-8941) Create a common place for Load Tests configuration

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

[jira] [Updated] (BEAM-8452) TriggerLoadJobs.process in bigquery_file_loads schema is type str

[ https://issues.apache.org/jira/browse/BEAM-8452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8452: -- Labels: stale-assigned (was: ) > TriggerLoadJobs.process in bigquery_file_loads schema is type

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

[jira] [Updated] (BEAM-8965) WriteToBigQuery failed in BundleBasedDirectRunner

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

[jira] [Commented] (BEAM-9191) CAST does not work in some cases due to bugs in Calcite unparsing

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

[jira] [Commented] (BEAM-7505) Create SideInput Python Load Test Jenkins Job

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

[jira] [Updated] (BEAM-9131) cleanup bug in run_rc_validation.sh

[ https://issues.apache.org/jira/browse/BEAM-9131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9131: -- Labels: stale-assigned (was: ) > cleanup bug in run_rc_validation.sh >

[jira] [Commented] (BEAM-8924) Beam Dependency Update Request: org.apache.tika

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

[jira] [Updated] (BEAM-9291) upload_graph support in Dataflow Python SDK

[ https://issues.apache.org/jira/browse/BEAM-9291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9291: -- Labels: stale-assigned (was: ) > upload_graph support in Dataflow Python SDK >

[jira] [Updated] (BEAM-9623) Add support for configuring TableProviders in Python SqlTransform

[ https://issues.apache.org/jira/browse/BEAM-9623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9623: -- Labels: stale-assigned (was: ) > Add support for configuring TableProviders in Python SqlTransf

[jira] [Updated] (BEAM-9238) Cross-language pipeline dependency management

[ https://issues.apache.org/jira/browse/BEAM-9238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9238: -- Labels: stale-assigned (was: ) > Cross-language pipeline dependency management > --

[jira] [Commented] (BEAM-7560) Python local filesystem match does not work without directory separator.

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

[jira] [Commented] (BEAM-8000) Add Delete method to gRPC JobService

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

[jira] [Commented] (BEAM-9049) MemoryMonitor thrashing detection is too aggressive for batch workers

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

[jira] [Updated] (BEAM-7516) Add a watermark manager for the fn_api_runner

[ https://issues.apache.org/jira/browse/BEAM-7516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-7516: -- Labels: stale-assigned (was: ) > Add a watermark manager for the fn_api_runner > --

[jira] [Commented] (BEAM-7968) UDF case insensitive

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

[jira] [Updated] (BEAM-6136) Shade conscrypt within the Dataflow legacy worker jar

[ https://issues.apache.org/jira/browse/BEAM-6136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-6136: -- Labels: stale-assigned (was: ) > Shade conscrypt within the Dataflow legacy worker jar > --

[jira] [Commented] (BEAM-9232) BigQueryWriteIntegrationTests.test_big_query_write_new_types is flaky

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

[jira] [Commented] (BEAM-9117) Clustering coder does not get used for BQ multi-partitioned tables

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

[jira] [Updated] (BEAM-7663) Create SideInput Python Load Test Jenkins Job [Flink]

[ https://issues.apache.org/jira/browse/BEAM-7663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-7663: -- Labels: stale-assigned (was: ) > Create SideInput Python Load Test Jenkins Job [Flink] > --

[jira] [Updated] (BEAM-9354) How long does PubSubIO message deduplication last?

[ https://issues.apache.org/jira/browse/BEAM-9354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9354: -- Labels: gcp pubsubio stale-assigned (was: gcp pubsubio) > How long does PubSubIO message dedupl

[jira] [Commented] (BEAM-6338) Python streaming test failed because cannot cancel the job

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

[jira] [Commented] (BEAM-8331) Vendored calcite breaks if another calcite is on the class path

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

[jira] [Commented] (BEAM-5188) Need a set of tests that exercise SyntheticSource / SyntheticStep functionality

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

[jira] [Updated] (BEAM-9382) TestStreamTranscriptTest relies on non-deterministic behavior

[ https://issues.apache.org/jira/browse/BEAM-9382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-9382: -- Labels: stale-assigned (was: ) > TestStreamTranscriptTest relies on non-deterministic behavior

[jira] [Commented] (BEAM-9147) [Java] PTransform that integrates Video Intelligence functionality

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

[jira] [Commented] (BEAM-7120) Turn `WindowedValue` into `T` for all the interfaces of Data Plane

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

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

[jira] [Updated] (BEAM-7363) Make HCatalogIOIT running on Jenkins

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

[jira] [Updated] (BEAM-8924) Beam Dependency Update Request: org.apache.tika

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

[jira] [Updated] (BEAM-8295) Python streaming doc changes

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

[jira] [Commented] (BEAM-7596) List is not parallel: Make it parallel

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

[jira] [Updated] (BEAM-7977) DataflowRunner writes to System.out instead of logging

[ https://issues.apache.org/jira/browse/BEAM-7977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-7977: -- Labels: stale-assigned (was: ) > DataflowRunner writes to System.out instead of logging > -

[jira] [Commented] (BEAM-8620) Tear down unused DoFns periodically in Java SDK harness

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

[jira] [Commented] (BEAM-7889) Make release scripts less interactive

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

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