Steve Niemitz created BEAM-11057:
Summary: Make BigQueryIO.Read::withTestServices publicly accessible
Key: BEAM-11057
URL: https://issues.apache.org/jira/browse/BEAM-11057
Project: Beam
Issue
Steve Niemitz created BEAM-10523:
Summary: Add support for custom DatumWriters to AvroIO.Write
Key: BEAM-10523
URL: https://issues.apache.org/jira/browse/BEAM-10523
Project: Beam
Issue Type:
Steve Niemitz created BEAM-10395:
Summary: Dataflow runner should deduplicate files to stage by
destination
Key: BEAM-10395
URL: https://issues.apache.org/jira/browse/BEAM-10395
Project: Beam
[
https://issues.apache.org/jira/browse/BEAM-8809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steve Niemitz resolved BEAM-8809.
-
Fix Version/s: 2.17.0
Resolution: Fixed
> AvroWriteRequest should have a public constructor
[
https://issues.apache.org/jira/browse/BEAM-14072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503717#comment-17503717
]
Steve Niemitz commented on BEAM-14072:
--
Yeah I saw this last night, do you have any
[
https://issues.apache.org/jira/browse/BEAM-14072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503724#comment-17503724
]
Steve Niemitz commented on BEAM-14072:
--
Or I guess alternatively how can I run this
Steve Niemitz created BEAM-14134:
Summary: Many coders cause significant unnecessary allocations
Key: BEAM-14134
URL: https://issues.apache.org/jira/browse/BEAM-14134
Project: Beam
Issue Type
Steve Niemitz created BEAM-14144:
Summary: Record JFR profiles when GC thrashing is detected
Key: BEAM-14144
URL: https://issues.apache.org/jira/browse/BEAM-14144
Project: Beam
Issue Type: Im
Steve Niemitz created BEAM-13993:
Summary: Python portable SDK harness does not import beam_plugins
at startup
Key: BEAM-13993
URL: https://issues.apache.org/jira/browse/BEAM-13993
Project: Beam
Steve Niemitz created BEAM-14175:
Summary: "Read loop was aborted" errors are very noisy when large
jobs fail
Key: BEAM-14175
URL: https://issues.apache.org/jira/browse/BEAM-14175
Project: Beam
[
https://issues.apache.org/jira/browse/BEAM-14239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516840#comment-17516840
]
Steve Niemitz commented on BEAM-14239:
--
Here's an example of GroupIntoBatches with 3
Steve Niemitz created BEAM-14239:
Summary: Changing the output timestamp of a timer does not clear
the previously set timer
Key: BEAM-14239
URL: https://issues.apache.org/jira/browse/BEAM-14239
Projec
[
https://issues.apache.org/jira/browse/BEAM-14239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steve Niemitz updated BEAM-14239:
-
Attachment: image-2022-04-04-09-57-29-583.png
> Changing the output timestamp of a timer does not
[
https://issues.apache.org/jira/browse/BEAM-14244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steve Niemitz reassigned BEAM-14244:
Assignee: Steve Niemitz
> Processing time timers should use outputTimestamp rather than in
Steve Niemitz created BEAM-14244:
Summary: Processing time timers should use outputTimestamp rather
than input watermark for their timestamp
Key: BEAM-14244
URL: https://issues.apache.org/jira/browse/BEAM-14244
[
https://issues.apache.org/jira/browse/BEAM-14244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steve Niemitz updated BEAM-14244:
-
Status: Open (was: Triage Needed)
> Processing time timers should use outputTimestamp rather tha
[
https://issues.apache.org/jira/browse/BEAM-14244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on BEAM-14244 started by Steve Niemitz.
> Processing time timers should use outputTimestamp rather than input watermark
Steve Niemitz created BEAM-14265:
Summary: Flink should hold the watermark at the output timestamp
for processing time timers
Key: BEAM-14265
URL: https://issues.apache.org/jira/browse/BEAM-14265
Proj
Steve Niemitz created BEAM-14269:
Summary: PulsarIOTest.testReadFromSimpleTopic is very flaky
Key: BEAM-14269
URL: https://issues.apache.org/jira/browse/BEAM-14269
Project: Beam
Issue Type: B
[
https://issues.apache.org/jira/browse/BEAM-14144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17518990#comment-17518990
]
Steve Niemitz commented on BEAM-14144:
--
Oh interesting I didn't realize it was backp
[
https://issues.apache.org/jira/browse/BEAM-14239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17530100#comment-17530100
]
Steve Niemitz commented on BEAM-14239:
--
> is it that the previously set timer does f
[
https://issues.apache.org/jira/browse/BEAM-14239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17530132#comment-17530132
]
Steve Niemitz commented on BEAM-14239:
--
#1 doesn't work if you have multiple timers
[
https://issues.apache.org/jira/browse/BEAM-14239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17530138#comment-17530138
]
Steve Niemitz commented on BEAM-14239:
--
agreed they'll both fire, my point was they'
[
https://issues.apache.org/jira/browse/BEAM-11017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17531900#comment-17531900
]
Steve Niemitz commented on BEAM-11017:
--
I'd bet this is caused by https://issues.apa
[
https://issues.apache.org/jira/browse/BEAM-11017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17531900#comment-17531900
]
Steve Niemitz edited comment on BEAM-11017 at 5/4/22 7:06 PM:
-
Steve Niemitz created BEAM-14534:
Summary: Add an interface to allow users to compress values being
written to shuffle
Key: BEAM-14534
URL: https://issues.apache.org/jira/browse/BEAM-14534
Project: Be
[
https://issues.apache.org/jira/browse/BEAM-14534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on BEAM-14534 started by Steve Niemitz.
> Add an interface to allow users to compress values being written to shuffle
>
Steve Niemitz created BEAM-14545:
Summary: Optimize copies in dataflow v1 shuffle reader
Key: BEAM-14545
URL: https://issues.apache.org/jira/browse/BEAM-14545
Project: Beam
Issue Type: Improv
[
https://issues.apache.org/jira/browse/BEAM-14244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steve Niemitz updated BEAM-14244:
-
Fix Version/s: 2.39.0
Resolution: Fixed
Status: Resolved (was: In Progress)
>
[
https://issues.apache.org/jira/browse/BEAM-14269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17519067#comment-17519067
]
Steve Niemitz commented on BEAM-14269:
--
I'm not working on it right now, I had just
[
https://issues.apache.org/jira/browse/BEAM-14265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17525916#comment-17525916
]
Steve Niemitz commented on BEAM-14265:
--
The output timestamp is ignored yes. I was
Steve Niemitz created BEAM-12229:
Summary: WindmillStateCache has a 0% hit rate in 2.29
Key: BEAM-12229
URL: https://issues.apache.org/jira/browse/BEAM-12229
Project: Beam
Issue Type: Bug
[
https://issues.apache.org/jira/browse/BEAM-12229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17332791#comment-17332791
]
Steve Niemitz commented on BEAM-12229:
--
I was working on bisecting now actually, the
[
https://issues.apache.org/jira/browse/BEAM-12229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17332832#comment-17332832
]
Steve Niemitz commented on BEAM-12229:
--
Can confirm that [https://github.com/apache/
[
https://issues.apache.org/jira/browse/BEAM-12229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17332835#comment-17332835
]
Steve Niemitz commented on BEAM-12229:
--
So perhaps even more concerning, looking at
[
https://issues.apache.org/jira/browse/BEAM-12229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17333216#comment-17333216
]
Steve Niemitz commented on BEAM-12229:
--
Oh interesting, I'll apply that patch and tr
[
https://issues.apache.org/jira/browse/BEAM-12229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17333285#comment-17333285
]
Steve Niemitz commented on BEAM-12229:
--
I can confirm that PR fixed it also, thank y
[
https://issues.apache.org/jira/browse/BEAM-10670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17334808#comment-17334808
]
Steve Niemitz commented on BEAM-10670:
--
I'd be a big +1 on changing the default back
[
https://issues.apache.org/jira/browse/BEAM-10670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17340929#comment-17340929
]
Steve Niemitz commented on BEAM-10670:
--
Yeah my issues were with the usability of th
Steve Niemitz created BEAM-12451:
Summary: BigQueryIO leaks gRPC channels
Key: BEAM-12451
URL: https://issues.apache.org/jira/browse/BEAM-12451
Project: Beam
Issue Type: Bug
Compone
Steve Niemitz created BEAM-12754:
Summary: RowCoderGenerator calls getValue multiple times
Key: BEAM-12754
URL: https://issues.apache.org/jira/browse/BEAM-12754
Project: Beam
Issue Type: Impr
[
https://issues.apache.org/jira/browse/BEAM-6855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17382315#comment-17382315
]
Steve Niemitz commented on BEAM-6855:
-
Just ran into this again today trying to use a
Steve Niemitz created BEAM-12767:
Summary: Improve UX of PipelineOptions parsing
Key: BEAM-12767
URL: https://issues.apache.org/jira/browse/BEAM-12767
Project: Beam
Issue Type: Improvement
Steve Niemitz created BEAM-10991:
Summary: Timers don't release watermark holds in dataflow on 2.24
Key: BEAM-10991
URL: https://issues.apache.org/jira/browse/BEAM-10991
Project: Beam
Issue T
Steve Niemitz created BEAM-11728:
Summary: BigQueryIO should should output records on successful
inserts
Key: BEAM-11728
URL: https://issues.apache.org/jira/browse/BEAM-11728
Project: Beam
I
Steve Niemitz created BEAM-11801:
Summary: BigtableIO should not set useCachedDataPool when using an
emulator
Key: BEAM-11801
URL: https://issues.apache.org/jira/browse/BEAM-11801
Project: Beam
[
https://issues.apache.org/jira/browse/BEAM-11801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on BEAM-11801 started by Steve Niemitz.
> BigtableIO should not set useCachedDataPool when using an emulator
> -
[
https://issues.apache.org/jira/browse/BEAM-7716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302830#comment-17302830
]
Steve Niemitz commented on BEAM-7716:
-
Yes correct. The experiment flag is "enable_cu
[
https://issues.apache.org/jira/browse/BEAM-7716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302847#comment-17302847
]
Steve Niemitz commented on BEAM-7716:
-
I was using it to try to debug pubsub read perf
Steve Niemitz created BEAM-12126:
Summary: DirectRunner doesn't respect use_deprecated_reads
experiment
Key: BEAM-12126
URL: https://issues.apache.org/jira/browse/BEAM-12126
Project: Beam
Is
[
https://issues.apache.org/jira/browse/BEAM-10670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17316858#comment-17316858
]
Steve Niemitz commented on BEAM-10670:
--
This ticket seems possibly out of date now,
[
https://issues.apache.org/jira/browse/BEAM-7717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17301955#comment-17301955
]
Steve Niemitz commented on BEAM-7717:
-
yeah it still seems broken. No one probably no
[
https://issues.apache.org/jira/browse/BEAM-7716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17301957#comment-17301957
]
Steve Niemitz commented on BEAM-7716:
-
it's only reproducible if you don't use windmil
Steve Niemitz created BEAM-10075:
Summary: Allow users to tune the grouping table size in batch
dataflow pipelines
Key: BEAM-10075
URL: https://issues.apache.org/jira/browse/BEAM-10075
Project: Beam
[
https://issues.apache.org/jira/browse/BEAM-9383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17116181#comment-17116181
]
Steve Niemitz commented on BEAM-9383:
-
I was just validating the 2.22 branch and this
[
https://issues.apache.org/jira/browse/BEAM-9383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17116185#comment-17116185
]
Steve Niemitz commented on BEAM-9383:
-
There's actually another much more serious bug
Steve Niemitz created BEAM-10076:
Summary: Dataflow worker status page incorrectly displays work
item statuses
Key: BEAM-10076
URL: https://issues.apache.org/jira/browse/BEAM-10076
Project: Beam
[
https://issues.apache.org/jira/browse/BEAM-10076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steve Niemitz updated BEAM-10076:
-
Description:
The work item status page incorrectly renders its table due to an incorrectly
place
[
https://issues.apache.org/jira/browse/BEAM-10076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steve Niemitz updated BEAM-10076:
-
Attachment: image-2020-05-25-17-13-49-465.png
> Dataflow worker status page incorrectly displays
[
https://issues.apache.org/jira/browse/BEAM-10076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steve Niemitz updated BEAM-10076:
-
Description:
The work item status page incorrectly renders its table due to an incorrectly
place
[
https://issues.apache.org/jira/browse/BEAM-9383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17116879#comment-17116879
]
Steve Niemitz commented on BEAM-9383:
-
{quote}Steve, why would two workers jars be sta
[
https://issues.apache.org/jira/browse/BEAM-7568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steve Niemitz reassigned BEAM-7568:
---
Assignee: Steve Niemitz
> Java dataflow harness re-encodes value state cells even if they hav
Steve Niemitz created BEAM-13081:
Summary: Portable representation of "packed bitset indicating null
fields" in beam Row format is not compatible with jvm representations
Key: BEAM-13081
URL: https://issues.apache
Steve Niemitz created BEAM-13459:
Summary: Dataflow python runner should cache uploaded artifacts
across job runs
Key: BEAM-13459
URL: https://issues.apache.org/jira/browse/BEAM-13459
Project: Beam
Steve Niemitz created BEAM-13488:
Summary: ClassGraph scanner is nondeterministic/incomplete when
using parallel scans
Key: BEAM-13488
URL: https://issues.apache.org/jira/browse/BEAM-13488
Project: Be
Steve Niemitz created BEAM-13672:
Summary: Window.into() without a windowFn not correctly translated
to portable representation
Key: BEAM-13672
URL: https://issues.apache.org/jira/browse/BEAM-13672
Pr
Steve Niemitz created BEAM-13689:
Summary: BigQueryIO batch writes should output "void" elements
when successful
Key: BEAM-13689
URL: https://issues.apache.org/jira/browse/BEAM-13689
Project: Beam
[
https://issues.apache.org/jira/browse/BEAM-13672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479562#comment-17479562
]
Steve Niemitz commented on BEAM-13672:
--
ah ok. it's possible this was just a side-e
[
https://issues.apache.org/jira/browse/BEAM-13672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479562#comment-17479562
]
Steve Niemitz edited comment on BEAM-13672 at 1/20/22, 6:32 PM:
---
[
https://issues.apache.org/jira/browse/BEAM-13672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steve Niemitz updated BEAM-13672:
-
Resolution: Not A Bug
Status: Resolved (was: Open)
> Window.into() without a windowFn no
[
https://issues.apache.org/jira/browse/BEAM-13488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steve Niemitz updated BEAM-13488:
-
Fix Version/s: 2.36.0
Resolution: Fixed
Status: Resolved (was: Open)
> ClassGr
[
https://issues.apache.org/jira/browse/BEAM-13488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steve Niemitz updated BEAM-13488:
-
Status: Resolved (was: Resolved)
> ClassGraph scanner is nondeterministic/incomplete when using
[
https://issues.apache.org/jira/browse/BEAM-13459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steve Niemitz updated BEAM-13459:
-
Fix Version/s: 2.36.0
Resolution: Fixed
Status: Resolved (was: Triage Needed)
[
https://issues.apache.org/jira/browse/BEAM-9308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17474592#comment-17474592
]
Steve Niemitz commented on BEAM-9308:
-
The attached PR is closed, we could never reach
[
https://issues.apache.org/jira/browse/BEAM-12126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steve Niemitz updated BEAM-12126:
-
Resolution: Fixed
Status: Resolved (was: Open)
> DirectRunner doesn't respect use_deprec
[
https://issues.apache.org/jira/browse/BEAM-12754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steve Niemitz updated BEAM-12754:
-
Resolution: Fixed
Status: Resolved (was: Open)
> RowCoderGenerator calls getValue multip
[
https://issues.apache.org/jira/browse/BEAM-11057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steve Niemitz updated BEAM-11057:
-
Resolution: Fixed
Status: Resolved (was: Open)
> Make BigQueryIO.Read::withTestServices
[
https://issues.apache.org/jira/browse/BEAM-7605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17474595#comment-17474595
]
Steve Niemitz commented on BEAM-7605:
-
This is not resolved, the attached PR was never
[
https://issues.apache.org/jira/browse/BEAM-6855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17474597#comment-17474597
]
Steve Niemitz commented on BEAM-6855:
-
this is not resolved
> Side inputs are not sup
Steve Niemitz created BEAM-7684:
---
Summary: WindmillStateCache grossly misunderestimates object size
in its weighting function
Key: BEAM-7684
URL: https://issues.apache.org/jira/browse/BEAM-7684
Project:
[
https://issues.apache.org/jira/browse/BEAM-7716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16882640#comment-16882640
]
Steve Niemitz commented on BEAM-7716:
-
I did a little debugging tonight and tracked th
[
https://issues.apache.org/jira/browse/BEAM-7716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16882640#comment-16882640
]
Steve Niemitz edited comment on BEAM-7716 at 7/11/19 4:14 AM:
--
[
https://issues.apache.org/jira/browse/BEAM-7716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16882993#comment-16882993
]
Steve Niemitz commented on BEAM-7716:
-
Hacking up PubsubMessagePayloadOnlyCoder to alw
[
https://issues.apache.org/jira/browse/BEAM-7717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16882998#comment-16882998
]
Steve Niemitz commented on BEAM-7717:
-
[https://github.com/apache/beam/blob/5b68aae06c
[
https://issues.apache.org/jira/browse/BEAM-7718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883006#comment-16883006
]
Steve Niemitz commented on BEAM-7718:
-
One thing I did notice using the gRPC client is
[
https://issues.apache.org/jira/browse/BEAM-7718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883084#comment-16883084
]
Steve Niemitz commented on BEAM-7718:
-
Additionally, the gRPC implementation seems eff
[
https://issues.apache.org/jira/browse/BEAM-7718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883837#comment-16883837
]
Steve Niemitz commented on BEAM-7718:
-
Looks like there was a change very recently
([
[
https://issues.apache.org/jira/browse/BEAM-7718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steve Niemitz closed BEAM-7718.
---
Resolution: Done
Fix Version/s: 2.14.0
> PubsubIO to use gRPC API instead of JSON REST API
> --
Steve Niemitz created BEAM-7745:
---
Summary: StreamingSideInputDoFnRunner/StreamingSideInputFetcher
have suboptimal state access pattern during normal operation
Key: BEAM-7745
URL: https://issues.apache.org/jira/brows
[
https://issues.apache.org/jira/browse/BEAM-2680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16899655#comment-16899655
]
Steve Niemitz commented on BEAM-2680:
-
I ran into this today. We have a long-running
[
https://issues.apache.org/jira/browse/BEAM-2680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16900133#comment-16900133
]
Steve Niemitz commented on BEAM-2680:
-
Sharding would delay the inevitable more, but t
Steve Niemitz created BEAM-9795:
---
Summary: Support custom avro DatumWriters when writing to BigQuery
Key: BEAM-9795
URL: https://issues.apache.org/jira/browse/BEAM-9795
Project: Beam
Issue Type
[
https://issues.apache.org/jira/browse/BEAM-9795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on BEAM-9795 started by Steve Niemitz.
---
> Support custom avro DatumWriters when writing to BigQuery
> -
[
https://issues.apache.org/jira/browse/BEAM-9795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steve Niemitz updated BEAM-9795:
Status: Open (was: Triage Needed)
> Support custom avro DatumWriters when writing to BigQuery
> ---
[
https://issues.apache.org/jira/browse/BEAM-9795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steve Niemitz resolved BEAM-9795.
-
Fix Version/s: 2.22.0
Resolution: Fixed
> Support custom avro DatumWriters when writing to
Steve Niemitz created BEAM-9931:
---
Summary: Support custom avro DatumReaders in AvroIO
Key: BEAM-9931
URL: https://issues.apache.org/jira/browse/BEAM-9931
Project: Beam
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/BEAM-1589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014335#comment-17014335
]
Steve Niemitz commented on BEAM-1589:
-
this is really cool! Both of these features ar
[
https://issues.apache.org/jira/browse/BEAM-9557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17065090#comment-17065090
]
Steve Niemitz commented on BEAM-9557:
-
imo this should be a blocker for 2.20. It brea
[
https://issues.apache.org/jira/browse/BEAM-9557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17065220#comment-17065220
]
Steve Niemitz commented on BEAM-9557:
-
I had actually tried that (for other reasons) i
[
https://issues.apache.org/jira/browse/BEAM-9557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17066280#comment-17066280
]
Steve Niemitz commented on BEAM-9557:
-
The default case will work as you mentioned, bu
1 - 100 of 136 matches
Mail list logo
