[
https://issues.apache.org/jira/browse/BEAM-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107792#comment-17107792
]
Thomas Weise commented on BEAM-:
Apache Apex itself has moved to attic and there are no users of
[
https://issues.apache.org/jira/browse/BEAM-9811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17092348#comment-17092348
]
Thomas Weise commented on BEAM-9811:
Last build was successful:
[
https://issues.apache.org/jira/browse/BEAM-9811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise resolved BEAM-9811.
Fix Version/s: Not applicable
Resolution: Fixed
> beam_Release_NightlySnapshot failing due
[
https://issues.apache.org/jira/browse/BEAM-9811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise closed BEAM-9811.
--
> beam_Release_NightlySnapshot failing due to "Failed to publish publication
> 'mavenJava'"
>
[
https://issues.apache.org/jira/browse/BEAM-9811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17091792#comment-17091792
]
Thomas Weise commented on BEAM-9811:
Due to the dynamic construction of publish tasks with target
[
https://issues.apache.org/jira/browse/BEAM-9811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17091605#comment-17091605
]
Thomas Weise edited comment on BEAM-9811 at 4/24/20, 2:07 PM:
--
Build still
[
https://issues.apache.org/jira/browse/BEAM-9811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17091605#comment-17091605
]
Thomas Weise commented on BEAM-9811:
Build still fails with this change, I will take another look.
>
[
https://issues.apache.org/jira/browse/BEAM-9811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17090948#comment-17090948
]
Thomas Weise edited comment on BEAM-9811 at 4/23/20, 9:36 PM:
--
./gradlew
[
https://issues.apache.org/jira/browse/BEAM-9811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17090948#comment-17090948
]
Thomas Weise commented on BEAM-9811:
./gradlew
[
https://issues.apache.org/jira/browse/BEAM-9811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17090934#comment-17090934
]
Thomas Weise commented on BEAM-9811:
First failing build:
[
https://issues.apache.org/jira/browse/BEAM-9474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise resolved BEAM-9474.
Fix Version/s: 2.21.0
Resolution: Fixed
> Environment cleanup is not robust enough and may
[
https://issues.apache.org/jira/browse/BEAM-9298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17034809#comment-17034809
]
Thomas Weise commented on BEAM-9298:
[~iemejia] yes, this should be on the mailing list. IMO good to
[
https://issues.apache.org/jira/browse/BEAM-9060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise resolved BEAM-9060.
Fix Version/s: 2.19.0
Resolution: Fixed
> Flink suppresses stdout/stderr during JobGraph
[
https://issues.apache.org/jira/browse/BEAM-8962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise resolved BEAM-8962.
Resolution: Fixed
> FlinkMetricContainer causes churn in the JobManager and lets the web frontend
[
https://issues.apache.org/jira/browse/BEAM-8816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise resolved BEAM-8816.
Fix Version/s: 2.19.0
Resolution: Fixed
> Load balance bundle processing w/ multiple SDK
[
https://issues.apache.org/jira/browse/BEAM-8959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16994909#comment-16994909
]
Thomas Weise commented on BEAM-8959:
[
https://issues.apache.org/jira/browse/BEAM-8815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise resolved BEAM-8815.
Resolution: Fixed
> Portable pipeline execution without artifact staging
>
[
https://issues.apache.org/jira/browse/BEAM-8815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16982811#comment-16982811
]
Thomas Weise commented on BEAM-8815:
[~Ardagan] I'm marking this ticket for 2.17 just so that you see
[
https://issues.apache.org/jira/browse/BEAM-8815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated BEAM-8815:
---
Fix Version/s: 2.17.0
> Portable pipeline execution without artifact staging
>
[
https://issues.apache.org/jira/browse/BEAM-8815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise reassigned BEAM-8815:
--
Assignee: Thomas Weise
> Portable pipeline execution without artifact staging
>
[
https://issues.apache.org/jira/browse/BEAM-8816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated BEAM-8816:
---
Description:
We found skewed utilization of SDK workers causing excessive latency with
Thomas Weise created BEAM-8816:
--
Summary: Load balance bundle processing w/ multiple SDK workers
Key: BEAM-8816
URL: https://issues.apache.org/jira/browse/BEAM-8816
Project: Beam
Issue Type:
Thomas Weise created BEAM-8815:
--
Summary: Portable pipeline execution without artifact staging
Key: BEAM-8815
URL: https://issues.apache.org/jira/browse/BEAM-8815
Project: Beam
Issue Type: Task
[
https://issues.apache.org/jira/browse/BEAM-8471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated BEAM-8471:
---
Fix Version/s: (was: 2.18.0)
2.17.0
> Flink native job submission for portable
[
https://issues.apache.org/jira/browse/BEAM-8670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise closed BEAM-8670.
--
Fix Version/s: 2.18.0
Resolution: Fixed
> Manage environment parallelism in
Thomas Weise created BEAM-8670:
--
Summary: Manage environment parallelism in DefaultJobBundleFactory
Key: BEAM-8670
URL: https://issues.apache.org/jira/browse/BEAM-8670
Project: Beam
Issue Type:
[
https://issues.apache.org/jira/browse/BEAM-8656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated BEAM-8656:
---
Issue Type: Bug (was: Improvement)
> flink_master_url usage in flink_runner.py
>
[
https://issues.apache.org/jira/browse/BEAM-8656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16973934#comment-16973934
]
Thomas Weise commented on BEAM-8656:
+1 for updating the website, there are several more things that
[
https://issues.apache.org/jira/browse/BEAM-8591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16972922#comment-16972922
]
Thomas Weise commented on BEAM-8591:
Please see the following email thread and linked doc for options
[
https://issues.apache.org/jira/browse/BEAM-5187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16972715#comment-16972715
]
Thomas Weise commented on BEAM-5187:
The process environment factory that is part of Beam expects the
[
https://issues.apache.org/jira/browse/BEAM-7870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16966364#comment-16966364
]
Thomas Weise edited comment on BEAM-7870 at 11/4/19 2:25 AM:
-
Thanks for the
[
https://issues.apache.org/jira/browse/BEAM-7870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16966364#comment-16966364
]
Thomas Weise commented on BEAM-7870:
Thanks for the update. I would also prefer the specific record
[
https://issues.apache.org/jira/browse/BEAM-8243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16965163#comment-16965163
]
Thomas Weise commented on BEAM-8243:
I meant older Beam releases, we should probably only advertise
[
https://issues.apache.org/jira/browse/BEAM-8243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16965112#comment-16965112
]
Thomas Weise commented on BEAM-8243:
There are IMO enough other reasons to not keep instructions
[
https://issues.apache.org/jira/browse/BEAM-8243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16964541#comment-16964541
]
Thomas Weise commented on BEAM-8243:
Looking forward to see the gradle commands disappear from
[
https://issues.apache.org/jira/browse/BEAM-8243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16964534#comment-16964534
]
Thomas Weise commented on BEAM-8243:
[~ibzib] [~robertwb] is this going to cover documentation for
[
https://issues.apache.org/jira/browse/BEAM-8372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated BEAM-8372:
---
Fix Version/s: 2.17.0
> Allow submission of Flink UberJar directly to flink cluster.
>
[
https://issues.apache.org/jira/browse/BEAM-8372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated BEAM-8372:
---
Labels: portability portability-flink (was: )
> Allow submission of Flink UberJar directly to flink
Thomas Weise created BEAM-8518:
--
Summary: Pipeline options translation fails silently with
incompatible jackson-core library
Key: BEAM-8518
URL: https://issues.apache.org/jira/browse/BEAM-8518
Project:
[
https://issues.apache.org/jira/browse/BEAM-8471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16961628#comment-16961628
]
Thomas Weise commented on BEAM-8471:
If anyone is interested to try this using curl with a local Flink
[
https://issues.apache.org/jira/browse/BEAM-8471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise closed BEAM-8471.
--
Fix Version/s: 2.18.0
Resolution: Implemented
> Flink native job submission for portable
[
https://issues.apache.org/jira/browse/BEAM-8471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated BEAM-8471:
---
Comment: was deleted
(was: CC: [~robertwb], [~ibzib], [~mxm]
I'm going to upstream this:
[
https://issues.apache.org/jira/browse/BEAM-8471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated BEAM-8471:
---
Description:
There are currently two methods to run a portable pipeline written in a non-JVM
Thomas Weise created BEAM-8471:
--
Summary: Flink native job submission for portable pipelines
Key: BEAM-8471
URL: https://issues.apache.org/jira/browse/BEAM-8471
Project: Beam
Issue Type:
[
https://issues.apache.org/jira/browse/BEAM-8417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise closed BEAM-8417.
--
Fix Version/s: 2.17.0
Resolution: Fixed
> Expose ExternalWorkerHandler hostname
>
[
https://issues.apache.org/jira/browse/BEAM-8387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise resolved BEAM-8387.
Fix Version/s: 2.17.0
Resolution: Fixed
> Remove sdk-worker-parallelism option from
[
https://issues.apache.org/jira/browse/BEAM-8387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated BEAM-8387:
---
Status: Open (was: Triage Needed)
> Remove sdk-worker-parallelism option from JobServerDriver
>
[
https://issues.apache.org/jira/browse/BEAM-8183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise resolved BEAM-8183.
Fix Version/s: 2.17.0
Resolution: Implemented
> Optionally bundle multiple pipelines into a
Thomas Weise created BEAM-8387:
--
Summary: Remove sdk-worker-parallelism option from JobServerDriver
Key: BEAM-8387
URL: https://issues.apache.org/jira/browse/BEAM-8387
Project: Beam
Issue Type:
[
https://issues.apache.org/jira/browse/BEAM-8115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16949726#comment-16949726
]
Thomas Weise commented on BEAM-8115:
The first case will allow to change all runner and SDK worker
[
https://issues.apache.org/jira/browse/BEAM-7980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise closed BEAM-7980.
--
Resolution: Implemented
> External environment with containerized worker pool
>
[
https://issues.apache.org/jira/browse/BEAM-7980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise reopened BEAM-7980:
> External environment with containerized worker pool
>
[
https://issues.apache.org/jira/browse/BEAM-6829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise resolved BEAM-6829.
Fix Version/s: 2.17.0
Resolution: Fixed
> Duplicate metric warnings clutter log
>
[
https://issues.apache.org/jira/browse/BEAM-8351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise reassigned BEAM-8351:
--
Assignee: Wanqi Lyu
> Support passing in arbitrary KV pairs to sdk worker via external
[
https://issues.apache.org/jira/browse/BEAM-8183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16943638#comment-16943638
]
Thomas Weise commented on BEAM-8183:
BEAM-8115 is indeed orthogonal and applicable for the cases where
[
https://issues.apache.org/jira/browse/BEAM-8183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16943170#comment-16943170
]
Thomas Weise commented on BEAM-8183:
{quote}The major issue to me seems to be that we need to execute
[
https://issues.apache.org/jira/browse/BEAM-8183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16943015#comment-16943015
]
Thomas Weise commented on BEAM-8183:
For context:
[
https://issues.apache.org/jira/browse/BEAM-8183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16939795#comment-16939795
]
Thomas Weise commented on BEAM-8183:
Hi Kyle, I have setup my Flink image build to use the jar file
[
https://issues.apache.org/jira/browse/BEAM-6733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16936920#comment-16936920
]
Thomas Weise commented on BEAM-6733:
This has an effect on checkpointing that is probably worth
[
https://issues.apache.org/jira/browse/BEAM-8157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16936835#comment-16936835
]
Thomas Weise commented on BEAM-8157:
I would probably not backport since 2.16 doesn't have this issue
[
https://issues.apache.org/jira/browse/BEAM-7722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise resolved BEAM-7722.
Fix Version/s: 2.16.0
Resolution: Implemented
> Simplify running of Beam Python on Flink
>
[
https://issues.apache.org/jira/browse/BEAM-7962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated BEAM-7962:
---
Issue Type: Task (was: Bug)
> Drop support for Flink 1.5 and 1.6
>
[
https://issues.apache.org/jira/browse/BEAM-7730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16926685#comment-16926685
]
Thomas Weise commented on BEAM-7730:
Removing 2.16 fix version, this is not a release blocker.
>
[
https://issues.apache.org/jira/browse/BEAM-7730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated BEAM-7730:
---
Fix Version/s: (was: 2.16.0)
> Add Flink 1.9 build target and Make FlinkRunner compatible with
[
https://issues.apache.org/jira/browse/BEAM-7962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16926684#comment-16926684
]
Thomas Weise commented on BEAM-7962:
[~markflyhigh] this issue does not block the 2.16 release. I
[
https://issues.apache.org/jira/browse/BEAM-7962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated BEAM-7962:
---
Fix Version/s: (was: 2.16.0)
> Drop support for Flink 1.5 and 1.6
>
[
https://issues.apache.org/jira/browse/BEAM-7980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise resolved BEAM-7980.
Fix Version/s: 2.16.0
Resolution: Incomplete
> External environment with containerized
Thomas Weise created BEAM-8137:
--
Summary: Worker pool option for Java SDK container
Key: BEAM-8137
URL: https://issues.apache.org/jira/browse/BEAM-8137
Project: Beam
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/BEAM-8115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16919657#comment-16919657
]
Thomas Weise commented on BEAM-8115:
I believe this is would have to include support for user pipeline
[
https://issues.apache.org/jira/browse/BEAM-8038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise closed BEAM-8038.
--
Fix Version/s: Not applicable
Resolution: Fixed
> Python Precommit fail:
[
https://issues.apache.org/jira/browse/BEAM-8038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16913571#comment-16913571
]
Thomas Weise commented on BEAM-8038:
Ouch, there is a self. missing. Will send a PR now.
> Python
[
https://issues.apache.org/jira/browse/BEAM-7980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated BEAM-7980:
---
Description:
Augment Beam Python docker image and boot.go so that it can be used to launch
Thomas Weise created BEAM-7980:
--
Summary: External environment with containerized worker pool
Key: BEAM-7980
URL: https://issues.apache.org/jira/browse/BEAM-7980
Project: Beam
Issue Type:
[
https://issues.apache.org/jira/browse/BEAM-7141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise resolved BEAM-7141.
Resolution: Fixed
Fix Version/s: 2.14.0
> Expose kv and window parameters for on_timer
>
[
https://issues.apache.org/jira/browse/BEAM-7868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16897703#comment-16897703
]
Thomas Weise commented on BEAM-7868:
What means "hidden" and what do you expect to happen?
>
[
https://issues.apache.org/jira/browse/BEAM-7597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise closed BEAM-7597.
--
Resolution: Fixed
Fix Version/s: Not applicable
Thanks for the contribution!
> Typo: Correct
[
https://issues.apache.org/jira/browse/BEAM-1318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16865001#comment-16865001
]
Thomas Weise commented on BEAM-1318:
A warning is now logged when options are discarded:
[
https://issues.apache.org/jira/browse/BEAM-1318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise closed BEAM-1318.
--
Resolution: Done
Fix Version/s: 2.11.0
> PipelineOptions should warn if there are unused options
[
https://issues.apache.org/jira/browse/BEAM-7348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise resolved BEAM-7348.
Resolution: Implemented
Fix Version/s: 2.14.0
> Option to expire SDK worker environments
>
[
https://issues.apache.org/jira/browse/BEAM-2591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16846080#comment-16846080
]
Thomas Weise commented on BEAM-2591:
It is possible to spin up a job server and run Flink in embedded
[
https://issues.apache.org/jira/browse/BEAM-2591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise closed BEAM-2591.
--
Resolution: Resolved
Fix Version/s: Not applicable
Runners are implicitly identified through the
[
https://issues.apache.org/jira/browse/BEAM-7348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on BEAM-7348 started by Thomas Weise.
--
> Option to expire SDK worker environments
>
[
https://issues.apache.org/jira/browse/BEAM-7348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated BEAM-7348:
---
Status: Open (was: Triage Needed)
> Option to expire SDK worker environments
>
Thomas Weise created BEAM-7348:
--
Summary: Option to expire SDK worker environments
Key: BEAM-7348
URL: https://issues.apache.org/jira/browse/BEAM-7348
Project: Beam
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/BEAM-7126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16839595#comment-16839595
]
Thomas Weise commented on BEAM-7126:
[~mxm] should the fix version be 2.14 or are you going to add
[
https://issues.apache.org/jira/browse/BEAM-7171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated BEAM-7171:
---
Labels: portability-flink (was: )
> New bundles may start within snapshotState
>
[
https://issues.apache.org/jira/browse/BEAM-7171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829270#comment-16829270
]
Thomas Weise commented on BEAM-7171:
A possible solution is to replace the "finish bundle callback"
Thomas Weise created BEAM-7171:
--
Summary: New bundles may start within snapshotState
Key: BEAM-7171
URL: https://issues.apache.org/jira/browse/BEAM-7171
Project: Beam
Issue Type: Bug
[
https://issues.apache.org/jira/browse/BEAM-7141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16825522#comment-16825522
]
Thomas Weise commented on BEAM-7141:
WindowedValue passed from Flink side:
Thomas Weise created BEAM-7141:
--
Summary: Expose kv and window parameters for on_timer
Key: BEAM-7141
URL: https://issues.apache.org/jira/browse/BEAM-7141
Project: Beam
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/BEAM-7015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise resolved BEAM-7015.
Resolution: Fixed
Fix Version/s: 2.13.0
> Have only a single definition of
[
https://issues.apache.org/jira/browse/BEAM-7058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16825149#comment-16825149
]
Thomas Weise commented on BEAM-7058:
[~ajam...@google.com] any update?
> Python SDK metric
[
https://issues.apache.org/jira/browse/BEAM-7127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16823642#comment-16823642
]
Thomas Weise commented on BEAM-7127:
[~altay] the issue can be reproduced with the Flink runner:
[
https://issues.apache.org/jira/browse/BEAM-7127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16822730#comment-16822730
]
Thomas Weise commented on BEAM-7127:
{code:java}
File
Thomas Weise created BEAM-7127:
--
Summary: Timer parameter not supported in timer callback
Key: BEAM-7127
URL: https://issues.apache.org/jira/browse/BEAM-7127
Project: Beam
Issue Type: Bug
[
https://issues.apache.org/jira/browse/BEAM-6876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16822584#comment-16822584
]
Thomas Weise commented on BEAM-6876:
Bumped the fix version since this is still broken in 2.12
> User
[
https://issues.apache.org/jira/browse/BEAM-6876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated BEAM-6876:
---
Fix Version/s: (was: 2.12.0)
2.13.0
> User state cleanup in portable Flink
Thomas Weise created BEAM-7126:
--
Summary: Double encoding of state keys in portable Flink runner
Key: BEAM-7126
URL: https://issues.apache.org/jira/browse/BEAM-7126
Project: Beam
Issue Type:
Thomas Weise created BEAM-7112:
--
Summary: State cleanup interferes with user timer callback
Key: BEAM-7112
URL: https://issues.apache.org/jira/browse/BEAM-7112
Project: Beam
Issue Type: Bug
[
https://issues.apache.org/jira/browse/BEAM-7035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated BEAM-7035:
---
Component/s: (was: beam-model)
sdk-py-harness
> Clear() method of OutputTimer is
1 - 100 of 208 matches
Mail list logo
