[
https://issues.apache.org/jira/browse/BEAM-13624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde reassigned BEAM-13624:
Assignee: Sam Rohde
> pipeline_fragment incorrectly prunes producer transform
> --
[
https://issues.apache.org/jira/browse/BEAM-12984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde updated BEAM-12984:
-
Resolution: Fixed
Status: Resolved (was: Open)
> InteractiveRunner cannot collect PCollections f
Sam Rohde created BEAM-12984:
Summary: InteractiveRunner cannot collect PCollections from
composites
Key: BEAM-12984
URL: https://issues.apache.org/jira/browse/BEAM-12984
Project: Beam
Issue Ty
[
https://issues.apache.org/jira/browse/BEAM-12843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17419460#comment-17419460
]
Sam Rohde commented on BEAM-12843:
--
Nothing concrete. It could be that GCS updated their
[
https://issues.apache.org/jira/browse/BEAM-12843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17419433#comment-17419433
]
Sam Rohde commented on BEAM-12843:
--
Looking at this a little bit more, the IO uses a [GC
[
https://issues.apache.org/jira/browse/BEAM-12842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17413267#comment-17413267
]
Sam Rohde commented on BEAM-12842:
--
Made https://github.com/apache/beam/pull/15492
> St
[
https://issues.apache.org/jira/browse/BEAM-12842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17413246#comment-17413246
]
Sam Rohde commented on BEAM-12842:
--
Looking at the code, the test puts a 0 as the timest
[
https://issues.apache.org/jira/browse/BEAM-12842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde updated BEAM-12842:
-
Summary: StreamingDataflowWorkerTest.testHotKeyLogging test flake (was:
StreamingDataflowWorkerTest.test
[
https://issues.apache.org/jira/browse/BEAM-12842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17411379#comment-17411379
]
Sam Rohde commented on BEAM-12842:
--
The test is essentially a copy of testBasic except w
[
https://issues.apache.org/jira/browse/BEAM-12764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17404084#comment-17404084
]
Sam Rohde commented on BEAM-12764:
--
Yes, that's fine to go ahead and rollback.
> Can't
[
https://issues.apache.org/jira/browse/BEAM-12764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17403397#comment-17403397
]
Sam Rohde commented on BEAM-12764:
--
Yeah, that's my guess too. I'll take a look today
>
[
https://issues.apache.org/jira/browse/BEAM-12698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401845#comment-17401845
]
Sam Rohde commented on BEAM-12698:
--
I am unable to reproduce on either 2.31.0 or 2.32.0.
[
https://issues.apache.org/jira/browse/BEAM-12531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde updated BEAM-12531:
-
Resolution: Fixed
Status: Resolved (was: Open)
> ib.show does not handle deferred dataframe inst
[
https://issues.apache.org/jira/browse/BEAM-12388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde reassigned BEAM-12388:
Assignee: Sam Rohde
> Improve caching experience on InteractiveRunner with dataframes
> --
Sam Rohde created BEAM-12388:
Summary: Improve caching experience on InteractiveRunner with
dataframes
Key: BEAM-12388
URL: https://issues.apache.org/jira/browse/BEAM-12388
Project: Beam
Issue T
[
https://issues.apache.org/jira/browse/BEAM-12246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on BEAM-12246 started by Sam Rohde.
> ib.collect doesn't preserve the index from DeferredDataFrame instances
> -
[
https://issues.apache.org/jira/browse/BEAM-10994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde updated BEAM-10994:
-
Status: Resolved (was: Resolved)
> Add Hot Key Logging in Dataflow Runner
>
[
https://issues.apache.org/jira/browse/BEAM-10970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde updated BEAM-10970:
-
Resolution: Fixed
Status: Resolved (was: Resolved)
> apache_beam.runners.interactive.recording_m
[
https://issues.apache.org/jira/browse/BEAM-10921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde updated BEAM-10921:
-
Resolution: Fixed
Status: Resolved (was: Resolved)
> Interactive Runner Python unit tests are fl
[
https://issues.apache.org/jira/browse/BEAM-9687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde updated BEAM-9687:
Resolution: Fixed
Status: Resolved (was: Resolved)
> Names of temporary files created by interactiv
[
https://issues.apache.org/jira/browse/BEAM-10994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde updated BEAM-10994:
-
Fix Version/s: 2.29.0
Resolution: Fixed
Status: Resolved (was: Open)
> Add Hot Key Log
[
https://issues.apache.org/jira/browse/BEAM-10956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde updated BEAM-10956:
-
Resolution: Fixed
Status: Resolved (was: Resolved)
> PipelineInstrumentTest is flaky
> -
[
https://issues.apache.org/jira/browse/BEAM-10954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde updated BEAM-10954:
-
Resolution: Fixed
Status: Resolved (was: Resolved)
> PipelineInstrumentTest.test_not_has_unbound
[
https://issues.apache.org/jira/browse/BEAM-11151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde updated BEAM-11151:
-
Resolution: Fixed
Status: Resolved (was: Open)
> Add ToString support
>
>
>
[
https://issues.apache.org/jira/browse/BEAM-11151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17313996#comment-17313996
]
Sam Rohde commented on BEAM-11151:
--
Still requires Go support
> Add ToString support
>
[
https://issues.apache.org/jira/browse/BEAM-11855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde reassigned BEAM-11855:
Assignee: Sam Rohde
> ib.collect should accept DeferredDataFrame instances
> -
[
https://issues.apache.org/jira/browse/BEAM-10603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde updated BEAM-10603:
-
Resolution: Fixed
Status: Resolved (was: Open)
> Large Source Recording for Interarctive Runner
[
https://issues.apache.org/jira/browse/BEAM-10603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306589#comment-17306589
]
Sam Rohde commented on BEAM-10603:
--
Yep, thanks for the ping
> Large Source Recording f
[
https://issues.apache.org/jira/browse/BEAM-11151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde reassigned BEAM-11151:
Assignee: Sam Rohde
> Add ToString support
>
>
> Key: BEAM-11
[
https://issues.apache.org/jira/browse/BEAM-11666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde reassigned BEAM-11666:
Assignee: Sam Rohde
> apache_beam.runners.interactive.recording_manager_test.RecordingManagerTest.
[
https://issues.apache.org/jira/browse/BEAM-10994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde reassigned BEAM-10994:
Assignee: Sam Rohde
> Add Hot Key Logging in Dataflow Runner
> ---
[
https://issues.apache.org/jira/browse/BEAM-10994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde updated BEAM-10994:
-
Labels: (was: stale-P2)
> Add Hot Key Logging in Dataflow Runner
>
[
https://issues.apache.org/jira/browse/BEAM-10921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde reassigned BEAM-10921:
Assignee: Ning Kang (was: Sam Rohde)
> Python unit tests on windows flaky
> -
Sam Rohde created BEAM-11151:
Summary: Add ToString support
Key: BEAM-11151
URL: https://issues.apache.org/jira/browse/BEAM-11151
Project: Beam
Issue Type: New Feature
Components: beam-
[
https://issues.apache.org/jira/browse/BEAM-10970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17219235#comment-17219235
]
Sam Rohde commented on BEAM-10970:
--
This is a dupe of https://issues.apache.org/jira/bro
[
https://issues.apache.org/jira/browse/BEAM-10970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde updated BEAM-10970:
-
Status: Resolved (was: Resolved)
> apache_beam.runners.interactive.recording_manager_test.ElementStreamT
[
https://issues.apache.org/jira/browse/BEAM-10970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde updated BEAM-10970:
-
Status: Resolved (was: Triage Needed)
> apache_beam.runners.interactive.recording_manager_test.ElementSt
[
https://issues.apache.org/jira/browse/BEAM-10921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217151#comment-17217151
]
Sam Rohde commented on BEAM-10921:
--
Ack, taking a look
> Python unit tests on windows f
Sam Rohde created BEAM-10994:
Summary: Add Hot Key Logging in Dataflow Runner
Key: BEAM-10994
URL: https://issues.apache.org/jira/browse/BEAM-10994
Project: Beam
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/BEAM-10956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde updated BEAM-10956:
-
Status: Resolved (was: Open)
> PipelineInstrumentTest is flaky
> ---
>
>
[
https://issues.apache.org/jira/browse/BEAM-10956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde updated BEAM-10956:
-
Status: Resolved (was: Resolved)
> PipelineInstrumentTest is flaky
> ---
>
>
[
https://issues.apache.org/jira/browse/BEAM-10954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17201170#comment-17201170
]
Sam Rohde commented on BEAM-10954:
--
Dupe of https://issues.apache.org/jira/browse/BEAM-1
[
https://issues.apache.org/jira/browse/BEAM-10954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde updated BEAM-10954:
-
Status: Resolved (was: Resolved)
> PipelineInstrumentTest.test_not_has_unbounded_source flaky on ubuntu
[
https://issues.apache.org/jira/browse/BEAM-10954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde updated BEAM-10954:
-
Status: Resolved (was: Open)
> PipelineInstrumentTest.test_not_has_unbounded_source flaky on ubuntu
> --
[
https://issues.apache.org/jira/browse/BEAM-10956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17201048#comment-17201048
]
Sam Rohde commented on BEAM-10956:
--
Able to repro with `for i in \{1..100}; do python pi
Sam Rohde created BEAM-10956:
Summary: PipelineInstrumentTest is flaky
Key: BEAM-10956
URL: https://issues.apache.org/jira/browse/BEAM-10956
Project: Beam
Issue Type: Improvement
Compon
[
https://issues.apache.org/jira/browse/BEAM-10921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde updated BEAM-10921:
-
Status: Resolved (was: Resolved)
> Python unit tests on windows flaky
>
[
https://issues.apache.org/jira/browse/BEAM-10695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde updated BEAM-10695:
-
Status: Resolved (was: Resolved)
> Cannot evict PCollections from InteractiveEnvironment
> -
[
https://issues.apache.org/jira/browse/BEAM-10695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde updated BEAM-10695:
-
Status: Resolved (was: Open)
> Cannot evict PCollections from InteractiveEnvironment
> -
[
https://issues.apache.org/jira/browse/BEAM-10921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17197874#comment-17197874
]
Sam Rohde commented on BEAM-10921:
--
Made [https://github.com/apache/beam/pull/12866] for
[
https://issues.apache.org/jira/browse/BEAM-10921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17197861#comment-17197861
]
Sam Rohde commented on BEAM-10921:
--
I noticed the flakiness yesterday and integrated a f
Sam Rohde created BEAM-10695:
Summary: Cannot evict PCollections from InteractiveEnvironment
Key: BEAM-10695
URL: https://issues.apache.org/jira/browse/BEAM-10695
Project: Beam
Issue Type: Improv
[
https://issues.apache.org/jira/browse/BEAM-10635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171039#comment-17171039
]
Sam Rohde commented on BEAM-10635:
--
Bumped to a P0 because it breaks the build.
> Incom
[
https://issues.apache.org/jira/browse/BEAM-10635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde updated BEAM-10635:
-
Priority: P0 (was: P1)
> Incompatible google-api-core and google-cloud-bigquery
> --
[
https://issues.apache.org/jira/browse/BEAM-10635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde updated BEAM-10635:
-
Priority: P1 (was: P2)
> Incompatible google-api-core and google-cloud-bigquery
> --
Sam Rohde created BEAM-10603:
Summary: Large Source Recording for Interarctive Runner
Key: BEAM-10603
URL: https://issues.apache.org/jira/browse/BEAM-10603
Project: Beam
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/BEAM-9692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde resolved BEAM-9692.
-
Fix Version/s: 2.23.0
Resolution: Fixed
> Clean Python DataflowRunner to use portable pipelines
> -
[
https://issues.apache.org/jira/browse/BEAM-9767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17106529#comment-17106529
]
Sam Rohde commented on BEAM-9767:
-
Yep, it should be the fix.
> test_streaming_wordcount
[
https://issues.apache.org/jira/browse/BEAM-9767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde closed BEAM-9767.
---
> test_streaming_wordcount flaky timeouts
> ---
>
> Key: BEAM-
[
https://issues.apache.org/jira/browse/BEAM-9767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde resolved BEAM-9767.
-
Fix Version/s: 2.22.0
Resolution: Fixed
> test_streaming_wordcount flaky timeouts
> ---
[
https://issues.apache.org/jira/browse/BEAM-9767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104733#comment-17104733
]
Sam Rohde edited comment on BEAM-9767 at 5/11/20, 6:19 PM:
---
Than
[
https://issues.apache.org/jira/browse/BEAM-9767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104733#comment-17104733
]
Sam Rohde commented on BEAM-9767:
-
Thanks for the update Brian, I have root caused it and
[
https://issues.apache.org/jira/browse/BEAM-9767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17089912#comment-17089912
]
Sam Rohde commented on BEAM-9767:
-
Copying comment from Ning in duped JIRA:
> We'll prob
[
https://issues.apache.org/jira/browse/BEAM-9767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17089908#comment-17089908
]
Sam Rohde commented on BEAM-9767:
-
PR 11440 didn't fix the flakiness, it only added a GRP
[
https://issues.apache.org/jira/browse/BEAM-9803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde closed BEAM-9803.
---
Fix Version/s: Not applicable
Resolution: Duplicate
> test_streaming_wordcount flaky
>
[
https://issues.apache.org/jira/browse/BEAM-9322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17078662#comment-17078662
]
Sam Rohde commented on BEAM-9322:
-
We can consider the issue resolved, but let's keep the
Sam Rohde created BEAM-9692:
---
Summary: Clean Python DataflowRunner to use portable pipelines
Key: BEAM-9692
URL: https://issues.apache.org/jira/browse/BEAM-9692
Project: Beam
Issue Type: Improvemen
[
https://issues.apache.org/jira/browse/BEAM-9601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde resolved BEAM-9601.
-
Fix Version/s: 2.20.0
Resolution: Fixed
> Interactive test_streaming_wordcount failing
> --
[
https://issues.apache.org/jira/browse/BEAM-9548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde resolved BEAM-9548.
-
Fix Version/s: 2.20.0
Resolution: Fixed
> Bad error handling with errors from TestStreamService whe
[
https://issues.apache.org/jira/browse/BEAM-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde resolved BEAM-8335.
-
Fix Version/s: 2.20.0
Resolution: Fixed
> Add streaming support to Interactive Beam
> -
[
https://issues.apache.org/jira/browse/BEAM-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde resolved BEAM-9013.
-
Fix Version/s: 2.18.0
Resolution: Fixed
> Multi-output TestStream breaks the DataflowRunner
> -
[
https://issues.apache.org/jira/browse/BEAM-9524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde closed BEAM-9524.
---
Fix Version/s: 2.21.0
Resolution: Fixed
> ib.show() spins forever when cells are re-executed
>
Sam Rohde created BEAM-9548:
---
Summary: Bad error handling with errors from TestStreamService
when using Interactive Beam
Key: BEAM-9548
URL: https://issues.apache.org/jira/browse/BEAM-9548
Project: Beam
Sam Rohde created BEAM-9524:
---
Summary: ib.show() spins forever when cells are re-executed
Key: BEAM-9524
URL: https://issues.apache.org/jira/browse/BEAM-9524
Project: Beam
Issue Type: Bug
[
https://issues.apache.org/jira/browse/BEAM-9447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde reassigned BEAM-9447:
---
Assignee: Sam Rohde
> Generalize the InteractiveRunner StreamingCache
> -
Sam Rohde created BEAM-9447:
---
Summary: Generalize the InteractiveRunner StreamingCache
Key: BEAM-9447
URL: https://issues.apache.org/jira/browse/BEAM-9447
Project: Beam
Issue Type: Bug
Co
[
https://issues.apache.org/jira/browse/BEAM-9322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17043991#comment-17043991
]
Sam Rohde commented on BEAM-9322:
-
No this Jira won't be able to be solved by by the 2.20.
Sam Rohde created BEAM-9322:
---
Summary: Python SDK ignores manually set PCollection tags
Key: BEAM-9322
URL: https://issues.apache.org/jira/browse/BEAM-9322
Project: Beam
Issue Type: Bug
C
[
https://issues.apache.org/jira/browse/BEAM-1833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde reassigned BEAM-1833:
---
Assignee: Sam Rohde
> Restructure Python pipeline construction to better follow the Runner API
>
Sam Rohde created BEAM-9073:
---
Summary: PipelineVisitor is topologically-order dependent
Key: BEAM-9073
URL: https://issues.apache.org/jira/browse/BEAM-9073
Project: Beam
Issue Type: Bug
C
Sam Rohde created BEAM-9013:
---
Summary: Multi-output TestStream breaks the DataflowRunner
Key: BEAM-9013
URL: https://issues.apache.org/jira/browse/BEAM-9013
Project: Beam
Issue Type: Bug
[
https://issues.apache.org/jira/browse/BEAM-8582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde closed BEAM-8582.
---
> Python SDK emits duplicate records for Default and AfterWatermark triggers
> ---
[
https://issues.apache.org/jira/browse/BEAM-8581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde resolved BEAM-8581.
-
Fix Version/s: 2.19.0
Resolution: Fixed
> Python SDK labels ontime empty panes as late
> --
[
https://issues.apache.org/jira/browse/BEAM-8582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde resolved BEAM-8582.
-
Fix Version/s: 2.19.0
Resolution: Fixed
> Python SDK emits duplicate records for Default and AfterW
[
https://issues.apache.org/jira/browse/BEAM-8581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde closed BEAM-8581.
---
> Python SDK labels ontime empty panes as late
>
>
>
[
https://issues.apache.org/jira/browse/BEAM-8738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde updated BEAM-8738:
Description:
The current proto representation of timesetamp and durations in Beam is either
raw int64s or t
[
https://issues.apache.org/jira/browse/BEAM-8738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde updated BEAM-8738:
Description:
The current proto representation of timesetamp and durations in Beam is either
raw int64s or t
Sam Rohde created BEAM-8738:
---
Summary: Revisit timestamp and duration representation
Key: BEAM-8738
URL: https://issues.apache.org/jira/browse/BEAM-8738
Project: Beam
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/BEAM-6274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde closed BEAM-6274.
---
Fix Version/s: Not applicable
Resolution: Won't Fix
> Timer Backlog Bug
> -
>
>
[
https://issues.apache.org/jira/browse/BEAM-6453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde reassigned BEAM-6453:
---
Assignee: (was: Sam Rohde)
> Create a single Jenkins job or Gradle task to serve for release test
[
https://issues.apache.org/jira/browse/BEAM-6672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde reassigned BEAM-6672:
---
Assignee: (was: Sam Rohde)
> Make bundle execution with ExecutableStage support user states
> ---
[
https://issues.apache.org/jira/browse/BEAM-8491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde resolved BEAM-8491.
-
Fix Version/s: 2.16.0
Resolution: Fixed
> Add ability for multiple output PCollections from composi
Sam Rohde created BEAM-8582:
---
Summary: Python SDK emits duplicate records for Default and
AfterWatermark triggers
Key: BEAM-8582
URL: https://issues.apache.org/jira/browse/BEAM-8582
Project: Beam
Sam Rohde created BEAM-8581:
---
Summary: Python SDK labels ontime empty panes as late
Key: BEAM-8581
URL: https://issues.apache.org/jira/browse/BEAM-8581
Project: Beam
Issue Type: Bug
Compo
Sam Rohde created BEAM-8491:
---
Summary: Add ability for multiple output PCollections from
composites
Key: BEAM-8491
URL: https://issues.apache.org/jira/browse/BEAM-8491
Project: Beam
Issue Type: Im
Sam Rohde created BEAM-8335:
---
Summary: Add streaming support to Interactive Beam
Key: BEAM-8335
URL: https://issues.apache.org/jira/browse/BEAM-8335
Project: Beam
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/BEAM-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde reassigned BEAM-6442:
---
Assignee: (was: Sam Rohde)
> Incomplete JobService API Semantics
> --
[
https://issues.apache.org/jira/browse/BEAM-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16908507#comment-16908507
]
Sam Rohde commented on BEAM-6442:
-
I unfortunately don't have time to work on this.
> Inc
[
https://issues.apache.org/jira/browse/BEAM-7820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Rohde resolved BEAM-7820.
-
Resolution: Fixed
Fix Version/s: 2.16.0
2.15.0
> Add hot key detection to Datafl
Sam Rohde created BEAM-7820:
---
Summary: Add hot key detection to Dataflow Runner
Key: BEAM-7820
URL: https://issues.apache.org/jira/browse/BEAM-7820
Project: Beam
Issue Type: New Feature
C
1 - 100 of 202 matches
Mail list logo
