[
https://issues.apache.org/jira/browse/BEAM-12942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17544772#comment-17544772
]
Sam Whittle commented on BEAM-12942:
Java sdk was fixed with 2.34, reopening to add s
[
https://issues.apache.org/jira/browse/BEAM-12942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle reopened BEAM-12942:
> Dataflow runner specialization of PubsubIO should validate messages
> ---
[
https://issues.apache.org/jira/browse/BEAM-14167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle reassigned BEAM-14167:
--
Assignee: Kiley Sok (was: Luke Cwik)
Feel free to mark as duplicate or blocker of BEAM-13695
[
https://issues.apache.org/jira/browse/BEAM-14167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle updated BEAM-14167:
---
Labels: Java11 (was: )
> Jamm exceptions "JVM prevents jamm from accessing subgraph - cache sizes ma
[
https://issues.apache.org/jira/browse/BEAM-14167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17511869#comment-17511869
]
Sam Whittle edited comment on BEAM-14167 at 3/24/22, 1:59 PM:
-
[
https://issues.apache.org/jira/browse/BEAM-14167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17511869#comment-17511869
]
Sam Whittle commented on BEAM-14167:
>From
>https://stackoverflow.com/questions/4126
Sam Whittle created BEAM-14167:
--
Summary: Jamm exceptions "JVM prevents jamm from accessing
subgraph - cache sizes may be underestimated"
Key: BEAM-14167
URL: https://issues.apache.org/jira/browse/BEAM-14167
Sam Whittle created BEAM-13826:
--
Summary: Reduce number of Gax related threads, likely by providing
common executor to GAX clients
Key: BEAM-13826
URL: https://issues.apache.org/jira/browse/BEAM-13826
Pr
Sam Whittle created BEAM-13684:
--
Summary: Consider adding information to ProcessBundleRequest
indicating there is no existing state
Key: BEAM-13684
URL: https://issues.apache.org/jira/browse/BEAM-13684
P
[
https://issues.apache.org/jira/browse/BEAM-12857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477130#comment-17477130
]
Sam Whittle edited comment on BEAM-12857 at 1/17/22, 11:18 AM:
[
https://issues.apache.org/jira/browse/BEAM-12857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477130#comment-17477130
]
Sam Whittle commented on BEAM-12857:
>From looking at code it does seem that that suc
[
https://issues.apache.org/jira/browse/BEAM-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle reopened BEAM-12776:
There is a large buffer by default for GCS writes and closing all windows in
parallel can increase mem
[
https://issues.apache.org/jira/browse/BEAM-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle updated BEAM-12776:
---
Status: Open (was: Triage Needed)
> Improve parallelism of closing files in FileIO
> ---
[
https://issues.apache.org/jira/browse/BEAM-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on BEAM-12776 started by Sam Whittle.
--
> Improve parallelism of closing files in FileIO
> -
[
https://issues.apache.org/jira/browse/BEAM-12144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle updated BEAM-12144:
---
Fix Version/s: 2.32.0
(was: 2.31.0)
> Dataflow streaming worker stuck and unab
[
https://issues.apache.org/jira/browse/BEAM-13268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle updated BEAM-13268:
---
Fix Version/s: 2.35.0
Resolution: Fixed
Status: Resolved (was: Triage Needed)
> Re
[
https://issues.apache.org/jira/browse/BEAM-12818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle updated BEAM-12818:
---
Resolution: Fixed
Status: Resolved (was: Open)
> When writing to GCS, spread prefix of tempo
[
https://issues.apache.org/jira/browse/BEAM-13268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17445154#comment-17445154
]
Sam Whittle commented on BEAM-13268:
Actually it looks like Pablo improved the BQ ser
[
https://issues.apache.org/jira/browse/BEAM-12472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle updated BEAM-12472:
---
Fix Version/s: 2.35.0
(was: 2.34.0)
> BigQuery streaming writes can be batched
[
https://issues.apache.org/jira/browse/BEAM-12472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle updated BEAM-12472:
---
Fix Version/s: 2.34.0
Resolution: Fixed
Status: Resolved (was: Open)
> BigQuery st
[
https://issues.apache.org/jira/browse/BEAM-12472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle reassigned BEAM-12472:
--
Assignee: Pablo Estrada
> BigQuery streaming writes can be batched beyond request limit with
[
https://issues.apache.org/jira/browse/BEAM-12472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17445136#comment-17445136
]
Sam Whittle commented on BEAM-12472:
I believe this would be fixed by Pablo's PR as i
[
https://issues.apache.org/jira/browse/BEAM-13268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle reassigned BEAM-13268:
--
Assignee: Sam Whittle
> Reduce latency by parallelizing BQ inserts when flushing due to row li
Sam Whittle created BEAM-13268:
--
Summary: Reduce latency by parallelizing BQ inserts when flushing
due to row limit
Key: BEAM-13268
URL: https://issues.apache.org/jira/browse/BEAM-13268
Project: Beam
[
https://issues.apache.org/jira/browse/BEAM-13042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle updated BEAM-13042:
---
Fix Version/s: 2.35.0
Resolution: Fixed
Status: Resolved (was: Open)
> Prevent une
[
https://issues.apache.org/jira/browse/BEAM-12856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle updated BEAM-12856:
---
Fix Version/s: 2.34.0
Resolution: Fixed
Status: Resolved (was: Open)
> Allow for c
[
https://issues.apache.org/jira/browse/BEAM-12291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17428227#comment-17428227
]
Sam Whittle commented on BEAM-12291:
Sorry I didn't see this was assigned to me earli
[
https://issues.apache.org/jira/browse/BEAM-12291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle reassigned BEAM-12291:
--
Assignee: (was: Sam Whittle)
> org.apache.beam.runners.flink.ReadSourcePortableTest.testEx
Sam Whittle created BEAM-13042:
--
Summary: Prevent unexpected blocking in
RegisterAndProcessBundleOperation hasFailed
Key: BEAM-13042
URL: https://issues.apache.org/jira/browse/BEAM-13042
Project: Beam
[
https://issues.apache.org/jira/browse/BEAM-12942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle updated BEAM-12942:
---
Fix Version/s: (was: 2.33.0)
2.34.0
> Dataflow runner specialization of Pubsub
[
https://issues.apache.org/jira/browse/BEAM-12942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle updated BEAM-12942:
---
Fix Version/s: 2.33.0
Resolution: Fixed
Status: Resolved (was: Open)
> Dataflow ru
[
https://issues.apache.org/jira/browse/BEAM-12942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17419231#comment-17419231
]
Sam Whittle commented on BEAM-12942:
The validation seems like it could be helpful fo
Sam Whittle created BEAM-12942:
--
Summary: Dataflow runner specialization of PubsubIO should
validate messages
Key: BEAM-12942
URL: https://issues.apache.org/jira/browse/BEAM-12942
Project: Beam
[
https://issues.apache.org/jira/browse/BEAM-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on BEAM-7913 started by null.
--
> Add drain() to DataflowPipelineJob
> --
>
> Key: BE
[
https://issues.apache.org/jira/browse/BEAM-12740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle updated BEAM-12740:
---
Resolution: Fixed
Status: Resolved (was: Open)
> Reduce and backoff GCS metadata operations
[
https://issues.apache.org/jira/browse/BEAM-12740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle updated BEAM-12740:
---
Fix Version/s: 2.34.0
> Reduce and backoff GCS metadata operations when writing to GCS files
> --
[
https://issues.apache.org/jira/browse/BEAM-12445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17416247#comment-17416247
]
Sam Whittle commented on BEAM-12445:
I believe the timeout needs to be set on the new
[
https://issues.apache.org/jira/browse/BEAM-12776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle updated BEAM-12776:
---
Resolution: Fixed
Status: Resolved (was: Open)
> Improve parallelism of closing files in Fil
[
https://issues.apache.org/jira/browse/BEAM-12856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle updated BEAM-12856:
---
Description:
Currently in WorkerCustomSources.java it is hard-coded to 10 seconds, 10k
elements, wit
Sam Whittle created BEAM-12856:
--
Summary: Allow for configuration of unbounded reader max elements,
read time etc in StreamingDataflowRunner
Key: BEAM-12856
URL: https://issues.apache.org/jira/browse/BEAM-12856
[
https://issues.apache.org/jira/browse/BEAM-11994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17406716#comment-17406716
]
Sam Whittle commented on BEAM-11994:
I observed the following in a test, it seems rel
Sam Whittle created BEAM-12818:
--
Summary: When writing to GCS, spread prefix of temporary files and
reuse autoscaling of the temporary directory
Key: BEAM-12818
URL: https://issues.apache.org/jira/browse/BEAM-12818
[
https://issues.apache.org/jira/browse/BEAM-12780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle updated BEAM-12780:
---
Fix Version/s: 2.32.0
Resolution: Fixed
Status: Resolved (was: In Progress)
> Stre
[
https://issues.apache.org/jira/browse/BEAM-12780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on BEAM-12780 started by Sam Whittle.
--
> StreamingDataflowWorker should limit local retries
> -
[
https://issues.apache.org/jira/browse/BEAM-12780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle updated BEAM-12780:
---
Status: Open (was: Triage Needed)
> StreamingDataflowWorker should limit local retries
> ---
[
https://issues.apache.org/jira/browse/BEAM-12780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle reassigned BEAM-12780:
--
Assignee: Sam Whittle
> StreamingDataflowWorker should limit local retries
> -
Sam Whittle created BEAM-12780:
--
Summary: StreamingDataflowWorker should limit local retries
Key: BEAM-12780
URL: https://issues.apache.org/jira/browse/BEAM-12780
Project: Beam
Issue Type: Bug
Sam Whittle created BEAM-12776:
--
Summary: Improve parallelism of closing files in FileIO
Key: BEAM-12776
URL: https://issues.apache.org/jira/browse/BEAM-12776
Project: Beam
Issue Type: Bug
Sam Whittle created BEAM-12740:
--
Summary: Reduce and backoff GCS metadata operations when writing
to GCS files
Key: BEAM-12740
URL: https://issues.apache.org/jira/browse/BEAM-12740
Project: Beam
[
https://issues.apache.org/jira/browse/BEAM-12144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle updated BEAM-12144:
---
Fix Version/s: 2.31.0
Resolution: Fixed
Status: Resolved (was: Open)
> Dataflow st
Sam Whittle created BEAM-12516:
--
Summary: StreamingDataflowWorker.ShardedKey.toString throws
exception if key is less than 100 bytes
Key: BEAM-12516
URL: https://issues.apache.org/jira/browse/BEAM-12516
[
https://issues.apache.org/jira/browse/BEAM-12472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364810#comment-17364810
]
Sam Whittle commented on BEAM-12472:
I was using withoutInsertIds, which perhaps trig
Sam Whittle created BEAM-12472:
--
Summary: BigQuery streaming writes can be batched beyond request
limit with BatchAndInsertElements
Key: BEAM-12472
URL: https://issues.apache.org/jira/browse/BEAM-12472
P
[
https://issues.apache.org/jira/browse/BEAM-12402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle updated BEAM-12402:
---
Resolution: Fixed
Status: Resolved (was: Open)
> Optimize PCollectionConsumerRegistry$Multip
Sam Whittle created BEAM-12402:
--
Summary: Optimize
PCollectionConsumerRegistry$MultiplexingMetricTrackingFnDataReceiver
Key: BEAM-12402
URL: https://issues.apache.org/jira/browse/BEAM-12402
Project: Beam
[
https://issues.apache.org/jira/browse/BEAM-7717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle updated BEAM-7717:
--
Fix Version/s: 2.31.0
Resolution: Fixed
Status: Resolved (was: Open)
> PubsubIO water
[
https://issues.apache.org/jira/browse/BEAM-7717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle reassigned BEAM-7717:
-
Assignee: Sam Whittle
> PubsubIO watermark tracking hovers near start of epoch
>
[
https://issues.apache.org/jira/browse/BEAM-12144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17342140#comment-17342140
]
Sam Whittle commented on BEAM-12144:
PR is being reviewed https://github.com/apache/b
[
https://issues.apache.org/jira/browse/BEAM-12144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle updated BEAM-12144:
---
Labels: (was: stale-assigned)
> Dataflow streaming worker stuck and unable to get work from Streami
[
https://issues.apache.org/jira/browse/BEAM-12254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle updated BEAM-12254:
---
Resolution: Fixed
Status: Resolved (was: Open)
> Nexmark UnboundedReader does not report bac
[
https://issues.apache.org/jira/browse/BEAM-12118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle updated BEAM-12118:
---
Resolution: Fixed
Status: Resolved (was: Triage Needed)
> QueuingBeamFnDataClient adds polli
[
https://issues.apache.org/jira/browse/BEAM-12209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle updated BEAM-12209:
---
Resolution: Fixed
Status: Resolved (was: Open)
> DirectStreamObserver is not thread-safe as
[
https://issues.apache.org/jira/browse/BEAM-12203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle updated BEAM-12203:
---
Resolution: Fixed
Status: Resolved (was: Open)
> Reduce thread context switches in BeamFnCon
[
https://issues.apache.org/jira/browse/BEAM-12253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on BEAM-12253 started by Sam Whittle.
--
> Read.UnboundedSourceAsSDFRestrictionTracker doesn't use cache for readers in
> ge
Sam Whittle created BEAM-12254:
--
Summary: Nexmark UnboundedReader does not report backlog correctly
Key: BEAM-12254
URL: https://issues.apache.org/jira/browse/BEAM-12254
Project: Beam
Issue Type
Sam Whittle created BEAM-12253:
--
Summary: Read.UnboundedSourceAsSDFRestrictionTracker doesn't use
cache for readers in getProgress
Key: BEAM-12253
URL: https://issues.apache.org/jira/browse/BEAM-12253
Pr
[
https://issues.apache.org/jira/browse/BEAM-12118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle reopened BEAM-12118:
Reopening to track fixing race triggering precondition
> QueuingBeamFnDataClient adds polling latency
[
https://issues.apache.org/jira/browse/BEAM-12229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle reassigned BEAM-12229:
--
Assignee: Sam Whittle (was: Reuven Lax)
> WindmillStateCache has a 0% hit rate in 2.29
>
[
https://issues.apache.org/jira/browse/BEAM-12229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17333208#comment-17333208
]
Sam Whittle commented on BEAM-12229:
Ugh, I see the issue. I modified how tokens were
Sam Whittle created BEAM-12209:
--
Summary: DirectStreamObserver is not thread-safe as advertised due
to racy integer operations
Key: BEAM-12209
URL: https://issues.apache.org/jira/browse/BEAM-12209
Projec
[
https://issues.apache.org/jira/browse/BEAM-12203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17326662#comment-17326662
]
Sam Whittle edited comment on BEAM-12203 at 4/21/21, 8:15 PM:
-
[
https://issues.apache.org/jira/browse/BEAM-12203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17326662#comment-17326662
]
Sam Whittle commented on BEAM-12203:
Realized that this could further be simplified b
[
https://issues.apache.org/jira/browse/BEAM-12203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle updated BEAM-12203:
---
Summary: Reduce thread context switches in BeamFnControlClient (was:
Remove LinkedBlockingQueue from
[
https://issues.apache.org/jira/browse/BEAM-12203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17326606#comment-17326606
]
Sam Whittle commented on BEAM-12203:
The put/take on this queue appears to be 2% of c
Sam Whittle created BEAM-12203:
--
Summary: Remove LinkedBlockingQueue from BeamFnControlClient
Key: BEAM-12203
URL: https://issues.apache.org/jira/browse/BEAM-12203
Project: Beam
Issue Type: Bug
[
https://issues.apache.org/jira/browse/BEAM-12118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle updated BEAM-12118:
---
Fix Version/s: 2.30.0
Resolution: Fixed
Status: Resolved (was: Open)
> QueuingBeam
[
https://issues.apache.org/jira/browse/BEAM-11910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle updated BEAM-11910:
---
Fix Version/s: 2.29.0
> Increase subsequent page size for bags after the first
>
[
https://issues.apache.org/jira/browse/BEAM-12127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle updated BEAM-12127:
---
Resolution: Fixed
Status: Resolved (was: Open)
> Reduce counter overhead in PCollectionConsu
[
https://issues.apache.org/jira/browse/BEAM-12142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle updated BEAM-12142:
---
Fix Version/s: 2.30.0
Resolution: Fixed
Status: Resolved (was: Open)
> Reduce over
[
https://issues.apache.org/jira/browse/BEAM-12117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle updated BEAM-12117:
---
Resolution: Fixed
Status: Resolved (was: Open)
> QueuingBeamFnDataClient inbound client set
[
https://issues.apache.org/jira/browse/BEAM-11910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle updated BEAM-11910:
---
Resolution: Fixed
Status: Resolved (was: Open)
> Increase subsequent page size for bags afte
Sam Whittle created BEAM-12144:
--
Summary: Dataflow streaming worker stuck and unable to get work
from Streaming Engine
Key: BEAM-12144
URL: https://issues.apache.org/jira/browse/BEAM-12144
Project: Beam
Sam Whittle created BEAM-12142:
--
Summary: Reduce overhead of MetricsEnvironment
Key: BEAM-12142
URL: https://issues.apache.org/jira/browse/BEAM-12142
Project: Beam
Issue Type: Bug
Comp
Sam Whittle created BEAM-12127:
--
Summary: Reduce counter overhead in
PCollectionConsumerRegistry.accept
Key: BEAM-12127
URL: https://issues.apache.org/jira/browse/BEAM-12127
Project: Beam
Issue
Sam Whittle created BEAM-12118:
--
Summary: QueuingBeamFnDataClient adds polling latency to
completing bundle processing
Key: BEAM-12118
URL: https://issues.apache.org/jira/browse/BEAM-12118
Project: Beam
Sam Whittle created BEAM-12117:
--
Summary: QueuingBeamFnDataClient inbound client set grows with
BundleProcessor reuse
Key: BEAM-12117
URL: https://issues.apache.org/jira/browse/BEAM-12117
Project: Beam
[
https://issues.apache.org/jira/browse/BEAM-11727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle updated BEAM-11727:
---
Resolution: Fixed
Status: Resolved (was: Triage Needed)
> Optimize ExecutionStateSampler
> -
[
https://issues.apache.org/jira/browse/BEAM-11730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle updated BEAM-11730:
---
Resolution: Fixed
Status: Resolved (was: Open)
> Reduce context switches for dataflow stream
[
https://issues.apache.org/jira/browse/BEAM-11707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle updated BEAM-11707:
---
Resolution: Fixed
Status: Resolved (was: Open)
> Optimize WindmillStateCache CPU usage
> ---
[
https://issues.apache.org/jira/browse/BEAM-11729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle updated BEAM-11729:
---
Resolution: Fixed
Status: Resolved (was: Open)
> Remove ReduceFnRunner eager class name eval
[
https://issues.apache.org/jira/browse/BEAM-11910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle reassigned BEAM-11910:
--
Assignee: Sam Whittle
> Increase subsequent page size for bags after the first
> -
Sam Whittle created BEAM-11910:
--
Summary: Increase subsequent page size for bags after the first
Key: BEAM-11910
URL: https://issues.apache.org/jira/browse/BEAM-11910
Project: Beam
Issue Type: B
[
https://issues.apache.org/jira/browse/BEAM-11144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17289572#comment-17289572
]
Sam Whittle commented on BEAM-11144:
Yes, thanks!
> TriggerStateMachine.prefetchO
Sam Whittle created BEAM-11730:
--
Summary: Reduce context switches for dataflow streaming appliance
getdata reads
Key: BEAM-11730
URL: https://issues.apache.org/jira/browse/BEAM-11730
Project: Beam
Sam Whittle created BEAM-11729:
--
Summary: Remove ReduceFnRunner eager class name evaluation for
debug logging
Key: BEAM-11729
URL: https://issues.apache.org/jira/browse/BEAM-11729
Project: Beam
[
https://issues.apache.org/jira/browse/BEAM-11706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276313#comment-17276313
]
Sam Whittle commented on BEAM-11706:
I had a typo in the jira issue for the pull requ
[
https://issues.apache.org/jira/browse/BEAM-11727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle updated BEAM-11727:
---
Component/s: (was: runner-dataflow)
runner-core
> Optimize ExecutionStateSampler
[
https://issues.apache.org/jira/browse/BEAM-11727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle updated BEAM-11727:
---
Summary: Optimize ExecutionStateSampler (was: Optimize
ExecutionStateTracker)
> Optimize ExecutionS
[
https://issues.apache.org/jira/browse/BEAM-11727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle reassigned BEAM-11727:
--
Assignee: Sam Whittle
> Optimize ExecutionStateTracker
> --
>
>
Sam Whittle created BEAM-11727:
--
Summary: Optimize ExecutionStateTracker
Key: BEAM-11727
URL: https://issues.apache.org/jira/browse/BEAM-11727
Project: Beam
Issue Type: Bug
Components:
1 - 100 of 171 matches
Mail list logo
