[jira] [Commented] (BEAM-14558) Data missing when using CassandraIO.Read

[ https://issues.apache.org/jira/browse/BEAM-14558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550154#comment-17550154 ] Danny McCormick commented on BEAM-14558: This issue has been migrated to https://

[jira] [Commented] (BEAM-14364) 404s in BigQueryIO don't get output to Failed Inserts PCollection

[ https://issues.apache.org/jira/browse/BEAM-14364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550152#comment-17550152 ] Danny McCormick commented on BEAM-14364: This issue has been migrated to https://

[jira] [Commented] (BEAM-14269) PulsarIOTest.testReadFromSimpleTopic is very flaky

[ https://issues.apache.org/jira/browse/BEAM-14269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550153#comment-17550153 ] Danny McCormick commented on BEAM-14269: This issue has been migrated to https://

[jira] [Commented] (BEAM-14543) beam_PostCommit_Java_ValidatesRunner_Samza Failing

[ https://issues.apache.org/jira/browse/BEAM-14543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550148#comment-17550148 ] Danny McCormick commented on BEAM-14543: This issue has been migrated to https://

[jira] [Commented] (BEAM-14265) Flink should hold the watermark at the output timestamp for processing time timers

[ https://issues.apache.org/jira/browse/BEAM-14265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550151#comment-17550151 ] Danny McCormick commented on BEAM-14265: This issue has been migrated to https://

[jira] [Commented] (BEAM-14390) Java license check is broken

[ https://issues.apache.org/jira/browse/BEAM-14390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550149#comment-17550149 ] Danny McCormick commented on BEAM-14390: This issue has been migrated to https://

[jira] [Commented] (BEAM-14263) beam_PostCommit_Java_DataflowV2, testBigQueryStorageWrite30MProto failing consistently

[ https://issues.apache.org/jira/browse/BEAM-14263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550147#comment-17550147 ] Danny McCormick commented on BEAM-14263: This issue has been migrated to https://

[jira] [Commented] (BEAM-14146) Python Streaming job failing to drain with BigQueryIO write errors

[ https://issues.apache.org/jira/browse/BEAM-14146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550150#comment-17550150 ] Danny McCormick commented on BEAM-14146: This issue has been migrated to https://

[jira] [Commented] (BEAM-14367) Flaky timeout in github Python unit test action StatefulDoFnOnDirectRunnerTest.test_dynamic_timer_clear_then_set_timer

[ https://issues.apache.org/jira/browse/BEAM-14367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550145#comment-17550145 ] Danny McCormick commented on BEAM-14367: This issue has been migrated to https://

[jira] [Commented] (BEAM-14275) SpannerWriteIT failing in beam PostCommit Java V1

[ https://issues.apache.org/jira/browse/BEAM-14275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550141#comment-17550141 ] Danny McCormick commented on BEAM-14275: This issue has been migrated to https://

[jira] [Commented] (BEAM-14349) GroupByKeyTest BasicTests testLargeKeys100MB flake (on ULR)

[ https://issues.apache.org/jira/browse/BEAM-14349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550146#comment-17550146 ] Danny McCormick commented on BEAM-14349: This issue has been migrated to https://

[jira] [Commented] (BEAM-14277) SpannerChangeStreamIT test failing

[ https://issues.apache.org/jira/browse/BEAM-14277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550144#comment-17550144 ] Danny McCormick commented on BEAM-14277: This issue has been migrated to https://

[jira] [Commented] (BEAM-14459) Docker Snapshots failing to be published since April 14th

[ https://issues.apache.org/jira/browse/BEAM-14459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550137#comment-17550137 ] Danny McCormick commented on BEAM-14459: This issue has been migrated to https://

[jira] [Commented] (BEAM-14252) beam_PostCommit_Java_DataflowV1 failing with a variety of flakes and errors

[ https://issues.apache.org/jira/browse/BEAM-14252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550140#comment-17550140 ] Danny McCormick commented on BEAM-14252: This issue has been migrated to https://

[jira] [Commented] (BEAM-14239) Changing the output timestamp of a timer does not clear the previously set timer

[ https://issues.apache.org/jira/browse/BEAM-14239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550138#comment-17550138 ] Danny McCormick commented on BEAM-14239: This issue has been migrated to https://

[jira] [Commented] (BEAM-14421) --dataflowServiceOptions=use_runner_v2 is broken

[ https://issues.apache.org/jira/browse/BEAM-14421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550139#comment-17550139 ] Danny McCormick commented on BEAM-14421: This issue has been migrated to https://

[jira] [Commented] (BEAM-14276) beam_PostCommit_Java_DataflowV2 failures parent bug

[ https://issues.apache.org/jira/browse/BEAM-14276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550143#comment-17550143 ] Danny McCormick commented on BEAM-14276: This issue has been migrated to https://

[jira] [Commented] (BEAM-14434) beam_LoadTests_Python_GBK_reiterate_Dataflow_Streaming failure

[ https://issues.apache.org/jira/browse/BEAM-14434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550136#comment-17550136 ] Danny McCormick commented on BEAM-14434: This issue has been migrated to https://

[jira] [Commented] (BEAM-14253) pubsublite.ReadWriteIT failing in beam_PostCommit_Java_DataflowV1 and V2

[ https://issues.apache.org/jira/browse/BEAM-14253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550142#comment-17550142 ] Danny McCormick commented on BEAM-14253: This issue has been migrated to https://

[jira] [Commented] (BEAM-14174) Flink Tests failure : java.lang.NoClassDefFoundError: Could not initialize class org.apache.beam.runners.core.construction.SerializablePipelineOptions

[ https://issues.apache.org/jira/browse/BEAM-14174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550134#comment-17550134 ] Danny McCormick commented on BEAM-14174: This issue has been migrated to https://

[jira] [Commented] (BEAM-14135) BigQuery Storage API insert with writeResult retry and write to error table

[ https://issues.apache.org/jira/browse/BEAM-14135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550132#comment-17550132 ] Danny McCormick commented on BEAM-14135: This issue has been migrated to https://

[jira] [Commented] (BEAM-14551) Exception from ElasticSearch Write Module in DataFlow

[ https://issues.apache.org/jira/browse/BEAM-14551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550128#comment-17550128 ] Danny McCormick commented on BEAM-14551: This issue has been migrated to https://

[jira] [Commented] (BEAM-14291) DataflowPipelineResult does not raise exception for unsuccessful states.

[ https://issues.apache.org/jira/browse/BEAM-14291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550133#comment-17550133 ] Danny McCormick commented on BEAM-14291: This issue has been migrated to https://

[jira] [Commented] (BEAM-14534) Add an interface to allow users to compress values being written to shuffle

[ https://issues.apache.org/jira/browse/BEAM-14534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550130#comment-17550130 ] Danny McCormick commented on BEAM-14534: This issue has been migrated to https://

[jira] [Commented] (BEAM-14504) Add support for including addittional parameters to executebundle method in fhirio.

[ https://issues.apache.org/jira/browse/BEAM-14504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550127#comment-17550127 ] Danny McCormick commented on BEAM-14504: This issue has been migrated to https://

[jira] [Commented] (BEAM-14446) Update documentation to point to GitHub issues instead of Jira

[ https://issues.apache.org/jira/browse/BEAM-14446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550124#comment-17550124 ] Danny McCormick commented on BEAM-14446: This issue has been migrated to https://

[jira] [Commented] (BEAM-14529) Beam BQIO not accepting integer values for BQ table fields of type Float64

[ https://issues.apache.org/jira/browse/BEAM-14529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550131#comment-17550131 ] Danny McCormick commented on BEAM-14529: This issue has been migrated to https://

[jira] [Commented] (BEAM-14198) [CdapIO] Implement CDAP IO interface for batch plugins: Read

[ https://issues.apache.org/jira/browse/BEAM-14198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550126#comment-17550126 ] Danny McCormick commented on BEAM-14198: This issue has been migrated to https://

[jira] [Commented] (BEAM-14102) [CdapIO] Adopt CDAP IO for bath plugins: Read PoC using wrappers

[ https://issues.apache.org/jira/browse/BEAM-14102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550125#comment-17550125 ] Danny McCormick commented on BEAM-14102: This issue has been migrated to https://

[jira] [Commented] (BEAM-14553) Dataflow portable job submission translate FileResultCoder only with window coder

[ https://issues.apache.org/jira/browse/BEAM-14553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550129#comment-17550129 ] Danny McCormick commented on BEAM-14553: This issue has been migrated to https://

[jira] [Commented] (BEAM-14116) Fix Pub/Sub Lite IO and SDF performance issues with shuffles

[ https://issues.apache.org/jira/browse/BEAM-14116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550121#comment-17550121 ] Danny McCormick commented on BEAM-14116: This issue has been migrated to https://

[jira] [Commented] (BEAM-14443) Migrate existing Jiras to GitHub

[ https://issues.apache.org/jira/browse/BEAM-14443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550123#comment-17550123 ] Danny McCormick commented on BEAM-14443: This issue has been migrated to https://

[jira] [Commented] (BEAM-14441) Migrate from Jira to GitHub Issues

[ https://issues.apache.org/jira/browse/BEAM-14441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550122#comment-17550122 ] Danny McCormick commented on BEAM-14441: This issue has been migrated to https://

[jira] [Commented] (BEAM-14557) Migrate exclusively to the v1 progress/metrics API

[ https://issues.apache.org/jira/browse/BEAM-14557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550120#comment-17550120 ] Danny McCormick commented on BEAM-14557: This issue has been migrated to https://

[jira] [Commented] (BEAM-14554) Create BigtableIO setting to report external system throttle time to Dataflow

[ https://issues.apache.org/jira/browse/BEAM-14554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550116#comment-17550116 ] Danny McCormick commented on BEAM-14554: This issue has been migrated to https://

[jira] [Commented] (BEAM-14406) Integration testing of Pipeline drain in Go SDK

[ https://issues.apache.org/jira/browse/BEAM-14406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550119#comment-17550119 ] Danny McCormick commented on BEAM-14406: This issue has been migrated to https://

[jira] [Commented] (BEAM-14532) Add integration test for Go FhirIO Read transform

[ https://issues.apache.org/jira/browse/BEAM-14532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550117#comment-17550117 ] Danny McCormick commented on BEAM-14532: This issue has been migrated to https://

[jira] [Commented] (BEAM-14516) Add context support for Python callables

[ https://issues.apache.org/jira/browse/BEAM-14516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550115#comment-17550115 ] Danny McCormick commented on BEAM-14516: This issue has been migrated to https://

[jira] [Commented] (BEAM-14547) Bug in type inference for Python 3.10

[ https://issues.apache.org/jira/browse/BEAM-14547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550109#comment-17550109 ] Danny McCormick commented on BEAM-14547: This issue has been migrated to https://

[jira] [Commented] (BEAM-14315) Update fileio.MatchContinuously to allow reading already read files with a new timestamp

[ https://issues.apache.org/jira/browse/BEAM-14315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550110#comment-17550110 ] Danny McCormick commented on BEAM-14315: This issue has been migrated to https://

[jira] [Commented] (BEAM-14464) Optimize precombining table.

[ https://issues.apache.org/jira/browse/BEAM-14464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550113#comment-17550113 ] Danny McCormick commented on BEAM-14464: This issue has been migrated to https://

[jira] [Commented] (BEAM-14378) [CdapIO] Design and implement SparkReceiverViaSDF component

[ https://issues.apache.org/jira/browse/BEAM-14378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550118#comment-17550118 ] Danny McCormick commented on BEAM-14378: This issue has been migrated to https://

[jira] [Commented] (BEAM-14237) Golang Beam ParDo job not working as expected on Apple M1 chip

[ https://issues.apache.org/jira/browse/BEAM-14237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550105#comment-17550105 ] Danny McCormick commented on BEAM-14237: This issue has been migrated to https://

[jira] [Commented] (BEAM-14101) [CdapIO] Design and implement Spark Receiver Builder

[ https://issues.apache.org/jira/browse/BEAM-14101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550111#comment-17550111 ] Danny McCormick commented on BEAM-14101: This issue has been migrated to https://

[jira] [Commented] (BEAM-14552) Extraneous warning message: "Make sure that locally built Python SDK docker image has Python X.Y interpreter"

[ https://issues.apache.org/jira/browse/BEAM-14552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550114#comment-17550114 ] Danny McCormick commented on BEAM-14552: This issue has been migrated to https://

[jira] [Commented] (BEAM-14422) ReadFromBigQuery with query requires exception handling tests. So does File Loads

[ https://issues.apache.org/jira/browse/BEAM-14422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550106#comment-17550106 ] Danny McCormick commented on BEAM-14422: This issue has been migrated to https://

[jira] [Commented] (BEAM-14510) LocalFileSystem requires exception handling tests

[ https://issues.apache.org/jira/browse/BEAM-14510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550108#comment-17550108 ] Danny McCormick commented on BEAM-14510: This issue has been migrated to https://

[jira] [Commented] (BEAM-14542) TPC-DS: Add user documentation on website

[ https://issues.apache.org/jira/browse/BEAM-14542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550112#comment-17550112 ] Danny McCormick commented on BEAM-14542: This issue has been migrated to https://

[jira] [Commented] (BEAM-14544) Unable to drain pipelines due to seemingly irrelevant timestamp shift validation

[ https://issues.apache.org/jira/browse/BEAM-14544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550107#comment-17550107 ] Danny McCormick commented on BEAM-14544: This issue has been migrated to https://

[jira] [Commented] (BEAM-14524) Add return_row option to RunInference transform

[ https://issues.apache.org/jira/browse/BEAM-14524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550104#comment-17550104 ] Danny McCormick commented on BEAM-14524: This issue has been migrated to https://

[jira] [Commented] (BEAM-14297) Enable null key and value for metadata kafka xlang

[ https://issues.apache.org/jira/browse/BEAM-14297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550103#comment-17550103 ] Danny McCormick commented on BEAM-14297: This issue has been migrated to https://

[jira] [Commented] (BEAM-14513) Add Read transform and initial HealthcareClient in Go SDK

[ https://issues.apache.org/jira/browse/BEAM-14513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550100#comment-17550100 ] Danny McCormick commented on BEAM-14513: This issue has been migrated to https://

[jira] [Commented] (BEAM-14545) Optimize copies in dataflow v1 shuffle reader

[ https://issues.apache.org/jira/browse/BEAM-14545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550102#comment-17550102 ] Danny McCormick commented on BEAM-14545: This issue has been migrated to https://

[jira] [Commented] (BEAM-14481) ScopedState can not be re-entered (regression caused by Batched DoFn worker changes)

[ https://issues.apache.org/jira/browse/BEAM-14481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550101#comment-17550101 ] Danny McCormick commented on BEAM-14481: This issue has been migrated to https://

[jira] [Commented] (BEAM-14431) Handle nulls using SnowflakeIO

[ https://issues.apache.org/jira/browse/BEAM-14431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550097#comment-17550097 ] Danny McCormick commented on BEAM-14431: This issue has been migrated to https://

[jira] [Commented] (BEAM-14541) Timestamp value conversion in Cloud Datastore connector is wrong

[ https://issues.apache.org/jira/browse/BEAM-14541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550098#comment-17550098 ] Danny McCormick commented on BEAM-14541: This issue has been migrated to https://

[jira] [Commented] (BEAM-14540) Native implementation for serialized Rows to/from Arrow

[ https://issues.apache.org/jira/browse/BEAM-14540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550095#comment-17550095 ] Danny McCormick commented on BEAM-14540: This issue has been migrated to https://

[jira] [Commented] (BEAM-14377) Make it easier to run seed job against open PRs

[ https://issues.apache.org/jira/browse/BEAM-14377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550099#comment-17550099 ] Danny McCormick commented on BEAM-14377: This issue has been migrated to https://

[jira] [Commented] (BEAM-14411) TypeCodersTest is never executed

[ https://issues.apache.org/jira/browse/BEAM-14411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550096#comment-17550096 ] Danny McCormick commented on BEAM-14411: This issue has been migrated to https://

[jira] [Commented] (BEAM-14339) More verbose errors when BatchConverter fails to match

[ https://issues.apache.org/jira/browse/BEAM-14339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550092#comment-17550092 ] Danny McCormick commented on BEAM-14339: This issue has been migrated to https://

[jira] [Commented] (BEAM-14293) Add @DoFn.yields_batches and @DoFn.yields_elements decorators to override defaults

[ https://issues.apache.org/jira/browse/BEAM-14293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550094#comment-17550094 ] Danny McCormick commented on BEAM-14293: This issue has been migrated to https://

[jira] [Commented] (BEAM-14408) batch-consuming DoFns should estimate byte size

[ https://issues.apache.org/jira/browse/BEAM-14408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550093#comment-17550093 ] Danny McCormick commented on BEAM-14408: This issue has been migrated to https://

[jira] [Commented] (BEAM-14340) Consider providing a dynamic API for declaring batch input type

[ https://issues.apache.org/jira/browse/BEAM-14340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550090#comment-17550090 ] Danny McCormick commented on BEAM-14340: This issue has been migrated to https://

[jira] [Commented] (BEAM-14214) beam_PostCommit_XVR_GoUsingJava_Dataflow fails on some test transforms

[ https://issues.apache.org/jira/browse/BEAM-14214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550083#comment-17550083 ] Danny McCormick commented on BEAM-14214: This issue has been migrated to https://

[jira] [Commented] (BEAM-14527) Implement "Beam Summit 2022" banner

[ https://issues.apache.org/jira/browse/BEAM-14527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550086#comment-17550086 ] Danny McCormick commented on BEAM-14527: This issue has been migrated to https://

[jira] [Commented] (BEAM-14420) Mongo DB Upgrade to 5.0 having compatibitlity issue with Apache Beam included mongo-java-driver.

[ https://issues.apache.org/jira/browse/BEAM-14420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550084#comment-17550084 ] Danny McCormick commented on BEAM-14420: This issue has been migrated to https://

[jira] [Commented] (BEAM-14352) Add a TimestampedBatch analogue for TimestampedValue

[ https://issues.apache.org/jira/browse/BEAM-14352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550089#comment-17550089 ] Danny McCormick commented on BEAM-14352: This issue has been migrated to https://

[jira] [Commented] (BEAM-14537) Create a cross-language registrar for SchemaTransform

[ https://issues.apache.org/jira/browse/BEAM-14537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550082#comment-17550082 ] Danny McCormick commented on BEAM-14537: This issue has been migrated to https://

[jira] [Commented] (BEAM-14409) Support per-key DoFn params in process_batch

[ https://issues.apache.org/jira/browse/BEAM-14409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550091#comment-17550091 ] Danny McCormick commented on BEAM-14409: This issue has been migrated to https://

[jira] [Commented] (BEAM-14538) Support Flink Operator on Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-14538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550085#comment-17550085 ] Danny McCormick commented on BEAM-14538: This issue has been migrated to https://

[jira] [Commented] (BEAM-14213) Add support for Batched DoFns in the Python SDK

[ https://issues.apache.org/jira/browse/BEAM-14213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550088#comment-17550088 ] Danny McCormick commented on BEAM-14213: This issue has been migrated to https://

[jira] [Commented] (BEAM-14410) FnRunnerTest with non-trivial (order 1000 elements) numpy input flakes in non-cython environment

[ https://issues.apache.org/jira/browse/BEAM-14410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550081#comment-17550081 ] Danny McCormick commented on BEAM-14410: This issue has been migrated to https://

[jira] [Commented] (BEAM-14451) Add Export to BQ to FhirIO.Export

[ https://issues.apache.org/jira/browse/BEAM-14451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550087#comment-17550087 ] Danny McCormick commented on BEAM-14451: This issue has been migrated to https://

[jira] [Commented] (BEAM-14360) DropFields PTransform automatically unnesting remaining fields

[ https://issues.apache.org/jira/browse/BEAM-14360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550078#comment-17550078 ] Danny McCormick commented on BEAM-14360: This issue has been migrated to https://

[jira] [Commented] (BEAM-14387) DirectRunner does not update reference to currentRestriction when running in SDF

[ https://issues.apache.org/jira/browse/BEAM-14387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550075#comment-17550075 ] Danny McCormick commented on BEAM-14387: This issue has been migrated to https://

[jira] [Commented] (BEAM-14475) Add exception test cases to GcsFileSystem

[ https://issues.apache.org/jira/browse/BEAM-14475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550080#comment-17550080 ] Danny McCormick commented on BEAM-14475: This issue has been migrated to https://

[jira] [Commented] (BEAM-14118) beam-vendor-grpc-1_43_2 shades vulnerable Netty version

[ https://issues.apache.org/jira/browse/BEAM-14118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550077#comment-17550077 ] Danny McCormick commented on BEAM-14118: This issue has been migrated to https://

[jira] [Commented] (BEAM-14211) Add "interactive" DataFrame operations that eagerly trigger execution

[ https://issues.apache.org/jira/browse/BEAM-14211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550076#comment-17550076 ] Danny McCormick commented on BEAM-14211: This issue has been migrated to https://

[jira] [Commented] (BEAM-14533) Bump clouldpilckle to 2.1.0

[ https://issues.apache.org/jira/browse/BEAM-14533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550079#comment-17550079 ] Danny McCormick commented on BEAM-14533: This issue has been migrated to https://

[jira] [Commented] (BEAM-14531) Adds Testcontainers with SSL config for SSL-specific testing

[ https://issues.apache.org/jira/browse/BEAM-14531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550074#comment-17550074 ] Danny McCormick commented on BEAM-14531: This issue has been migrated to https://

[jira] [Commented] (BEAM-14075) Unknown Coder URN beam:coder:pickled_python:v1 in SnowflakeIO for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-14075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550062#comment-17550062 ] Danny McCormick commented on BEAM-14075: This issue has been migrated to https://

[jira] [Commented] (BEAM-14215) Incomplete argument validation in SnowflakeIO

[ https://issues.apache.org/jira/browse/BEAM-14215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550063#comment-17550063 ] Danny McCormick commented on BEAM-14215: This issue has been migrated to https://

[jira] [Commented] (BEAM-14121) Incorrect Spanner IO Request Count metrics

[ https://issues.apache.org/jira/browse/BEAM-14121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550065#comment-17550065 ] Danny McCormick commented on BEAM-14121: This issue has been migrated to https://

[jira] [Commented] (BEAM-14216) Multiple XVR Suites having similar flakes simultaneously

[ https://issues.apache.org/jira/browse/BEAM-14216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550059#comment-17550059 ] Danny McCormick commented on BEAM-14216: This issue has been migrated to https://

[jira] [Commented] (BEAM-14166) Improvements to RowWithGetter

[ https://issues.apache.org/jira/browse/BEAM-14166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550064#comment-17550064 ] Danny McCormick commented on BEAM-14166: This issue has been migrated to https://

[jira] [Commented] (BEAM-14333) Supports JSON in SnowflakeIO

[ https://issues.apache.org/jira/browse/BEAM-14333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550061#comment-17550061 ] Danny McCormick commented on BEAM-14333: This issue has been migrated to https://

[jira] [Commented] (BEAM-14111) Legacy (SDF wrapper-based) KafkaIO reader degrades when Kafka poll latency is hign

[ https://issues.apache.org/jira/browse/BEAM-14111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550060#comment-17550060 ] Danny McCormick commented on BEAM-14111: This issue has been migrated to https://

[jira] [Commented] (BEAM-14525) Unable to find Proto getters in certain cases

[ https://issues.apache.org/jira/browse/BEAM-14525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550056#comment-17550056 ] Danny McCormick commented on BEAM-14525: This issue has been migrated to https://

[jira] [Commented] (BEAM-14373) Support using FlinkRunner with the beam_sql magic

[ https://issues.apache.org/jira/browse/BEAM-14373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550057#comment-17550057 ] Danny McCormick commented on BEAM-14373: This issue has been migrated to https://

[jira] [Commented] (BEAM-14523) Update beam to not retry on insertAll parseError

[ https://issues.apache.org/jira/browse/BEAM-14523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550051#comment-17550051 ] Danny McCormick commented on BEAM-14523: This issue has been migrated to https://

[jira] [Commented] (BEAM-14379) Add Runner API pipeline and jobInfo in SamzaRunner configs

[ https://issues.apache.org/jira/browse/BEAM-14379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550058#comment-17550058 ] Danny McCormick commented on BEAM-14379: This issue has been migrated to https://

[jira] [Commented] (BEAM-14528) Data type and conversions are stricter for BQ sinks

[ https://issues.apache.org/jira/browse/BEAM-14528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550055#comment-17550055 ] Danny McCormick commented on BEAM-14528: This issue has been migrated to https://

[jira] [Commented] (BEAM-14502) Create separate BigtableIO reader that splits large scans into smaller segments

[ https://issues.apache.org/jira/browse/BEAM-14502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550054#comment-17550054 ] Danny McCormick commented on BEAM-14502: This issue has been migrated to https://

[jira] [Commented] (BEAM-14331) Make InteractiveRunner work without runner api roundtrip

[ https://issues.apache.org/jira/browse/BEAM-14331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550052#comment-17550052 ] Danny McCormick commented on BEAM-14331: This issue has been migrated to https://

[jira] [Commented] (BEAM-14191) CrossLanguageJdbcIOTest broken with "Cannot load JDBC driver class 'com.mysql.cj.jdbc.Driver'"

[ https://issues.apache.org/jira/browse/BEAM-14191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550053#comment-17550053 ] Danny McCormick commented on BEAM-14191: This issue has been migrated to https://

[jira] [Commented] (BEAM-14508) Parquetio should produce a schema'd PCollection

[ https://issues.apache.org/jira/browse/BEAM-14508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550044#comment-17550044 ] Danny McCormick commented on BEAM-14508: This issue has been migrated to https://

[jira] [Commented] (BEAM-14478) Fix 'RuntimeValueProvider' object has no attribute 'projectId' error in _CustomBigQuerySource.split

[ https://issues.apache.org/jira/browse/BEAM-14478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550047#comment-17550047 ] Danny McCormick commented on BEAM-14478: This issue has been migrated to https://

[jira] [Commented] (BEAM-14452) Support Hadoop 4mc file format

[ https://issues.apache.org/jira/browse/BEAM-14452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550049#comment-17550049 ] Danny McCormick commented on BEAM-14452: This issue has been migrated to https://

[jira] [Commented] (BEAM-14514) Beam python SDK ignores pickle_library option in pipeline.run()

[ https://issues.apache.org/jira/browse/BEAM-14514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550045#comment-17550045 ] Danny McCormick commented on BEAM-14514: This issue has been migrated to https://

[jira] [Commented] (BEAM-14419) Remove invalid mod type from DataChangeRecord

[ https://issues.apache.org/jira/browse/BEAM-14419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550048#comment-17550048 ] Danny McCormick commented on BEAM-14419: This issue has been migrated to https://

  1   2   3   4   5   6   7   8   9   10   >