[jira] [Updated] (BEAM-3787) Migrate Fn API to be bidirectional instruction/request stream

[ https://issues.apache.org/jira/browse/BEAM-3787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-3787: -- Labels: portability triaged (was: portability) > Migrate Fn API to be bidirectional

[jira] [Updated] (BEAM-3367) The Java SDK Harness should not expect WindowedValueCoders in FnApiDoFnRunner

[ https://issues.apache.org/jira/browse/BEAM-3367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-3367: -- Labels: portability triaged (was: portability) > The Java SDK Harness should not expect

[jira] [Updated] (BEAM-3367) The Java SDK Harness should not expect WindowedValueCoders in FnApiDoFnRunner

[ https://issues.apache.org/jira/browse/BEAM-3367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-3367: -- Priority: Critical (was: Major) > The Java SDK Harness should not expect WindowedValueCoders

[jira] [Updated] (BEAM-3367) The Java SDK Harness should not expect WindowedValueCoders in FnApiDoFnRunner

[ https://issues.apache.org/jira/browse/BEAM-3367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-3367: -- Labels: portability (was: portability triaged) > The Java SDK Harness should not expect

[jira] [Updated] (BEAM-4513) Slack self-service join link is outdated on "Contact us" page

[ https://issues.apache.org/jira/browse/BEAM-4513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-4513: -- Labels: newbie starter triaged usability (was: newbie usability) > Slack self-service join

[jira] [Updated] (BEAM-3203) Spec out what mutations are allowed to a constructed model pipeline, particularly coders

[ https://issues.apache.org/jira/browse/BEAM-3203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-3203: -- Labels: portability triaged (was: portability) > Spec out what mutations are allowed to a

[jira] [Updated] (BEAM-5075) Please add OWASP Dependency Check to the build

[ https://issues.apache.org/jira/browse/BEAM-5075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-5075: -- Labels: build easy-fix security triaged (was: build easy-fix security) > Please add OWASP

[jira] [Commented] (BEAM-3367) The Java SDK Harness should not expect WindowedValueCoders in FnApiDoFnRunner

[ https://issues.apache.org/jira/browse/BEAM-3367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16786756#comment-16786756 ] Kenneth Knowles commented on BEAM-3367: --- I expect this is obsolete, but leaving it open because I

[jira] [Updated] (BEAM-6773) Add ValueProvider to enable parametrization at runtime

[ https://issues.apache.org/jira/browse/BEAM-6773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-6773: -- Labels: features triaged (was: features) > Add ValueProvider to enable parametrization at

[jira] [Updated] (BEAM-6773) Add ValueProvider to enable parametrization at runtime

[ https://issues.apache.org/jira/browse/BEAM-6773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-6773: -- Affects Version/s: (was: 2.12.0) > Add ValueProvider to enable parametrization at runtime >

[jira] [Updated] (BEAM-2878) Release process for container images

[ https://issues.apache.org/jira/browse/BEAM-2878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-2878: -- Labels: portability triaged (was: portability) > Release process for container images >

[jira] [Updated] (BEAM-4660) Add well known timer coder for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-4660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-4660: -- Labels: portability triaged (was: portability) > Add well known timer coder for Python SDK >

[jira] [Updated] (BEAM-5150) MqttIOTest.testRead is flaky

[ https://issues.apache.org/jira/browse/BEAM-5150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-5150: -- Labels: flake sickbay triaged (was: flake sickbay) > MqttIOTest.testRead is flaky >

[jira] [Commented] (BEAM-6506) Dataflow runner harness should always use proper coder URNs

[ https://issues.apache.org/jira/browse/BEAM-6506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16788064#comment-16788064 ] Kenneth Knowles commented on BEAM-6506: --- There's not a component for the pieces of the Python

[jira] [Updated] (BEAM-6492) BoundedReadFromUnboundedSourceTest#testTimeBound hangs since at least 2.8.0

[ https://issues.apache.org/jira/browse/BEAM-6492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-6492: -- Labels: sickbay triaged (was: sickbay) > BoundedReadFromUnboundedSourceTest#testTimeBound

[jira] [Updated] (BEAM-6492) BoundedReadFromUnboundedSourceTest#testTimeBound hangs since at least 2.8.0

[ https://issues.apache.org/jira/browse/BEAM-6492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-6492: -- Affects Version/s: 2.10.0 2.11.0 >

[jira] [Updated] (BEAM-6506) Dataflow runner harness should always use proper coder URNs

[ https://issues.apache.org/jira/browse/BEAM-6506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-6506: -- Component/s: (was: runner-core) sdk-py-core > Dataflow runner harness

[jira] [Updated] (BEAM-6506) Dataflow runner harness should always use proper coder URNs

[ https://issues.apache.org/jira/browse/BEAM-6506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-6506: -- Labels: portability triaged (was: portability) > Dataflow runner harness should always use

[jira] [Updated] (BEAM-3545) Fn API metrics in Go SDK harness

[ https://issues.apache.org/jira/browse/BEAM-3545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-3545: -- Labels: portability triaged (was: portability) > Fn API metrics in Go SDK harness >

[jira] [Updated] (BEAM-3367) The Java SDK Harness should not expect WindowedValueCoders in FnApiDoFnRunner

[ https://issues.apache.org/jira/browse/BEAM-3367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-3367: -- Labels: portability triaged (was: portability) > The Java SDK Harness should not expect

[jira] [Updated] (BEAM-4296) Defer window assignment in portable Flink runner to SDK

[ https://issues.apache.org/jira/browse/BEAM-4296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-4296: -- Labels: portability triaged (was: portability) > Defer window assignment in portable Flink

[jira] [Updated] (BEAM-5440) Add option to mount a directory inside SDK harness containers

[ https://issues.apache.org/jira/browse/BEAM-5440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-5440: -- Labels: portability portability-flink (was: portability portability-flink triaged) > Add

[jira] [Updated] (BEAM-4819) Make portable Flink runner JobBundleFactory configurable

[ https://issues.apache.org/jira/browse/BEAM-4819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-4819: -- Labels: portability portability-flink triaged (was: portability portability-flink) > Make

[jira] [Updated] (BEAM-2891) Spark runs portable pipelines

[ https://issues.apache.org/jira/browse/BEAM-2891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-2891: -- Labels: portability triaged (was: portability) > Spark runs portable pipelines >

[jira] [Updated] (BEAM-2358) "/test-your-pipeline" example code results in an exception

[ https://issues.apache.org/jira/browse/BEAM-2358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-2358: -- Labels: documentation easyfix starter triaged (was: documentation easyfix triaged) >

[jira] [Updated] (BEAM-2611) Better document and validate arguments of WindowInto

[ https://issues.apache.org/jira/browse/BEAM-2611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-2611: -- Labels: documentation newbie starter triaged (was: documentation newbie starter) > Better

[jira] [Updated] (BEAM-4012) Suppress tracebacks on failure-catching tests

[ https://issues.apache.org/jira/browse/BEAM-4012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-4012: -- Labels: beginner starter triaged (was: beginner) > Suppress tracebacks on failure-catching

[jira] [Updated] (BEAM-2887) Python SDK support for portable pipelines

[ https://issues.apache.org/jira/browse/BEAM-2887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-2887: -- Labels: portability triaged (was: portability) > Python SDK support for portable pipelines >

[jira] [Updated] (BEAM-4296) Defer window assignment in portable Flink runner to SDK

[ https://issues.apache.org/jira/browse/BEAM-4296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-4296: -- Component/s: triaged > Defer window assignment in portable Flink runner to SDK >

[jira] [Updated] (BEAM-4296) Defer window assignment in portable Flink runner to SDK

[ https://issues.apache.org/jira/browse/BEAM-4296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-4296: -- Component/s: (was: triaged) > Defer window assignment in portable Flink runner to SDK >

[jira] [Updated] (BEAM-4439) Do not convert a join that we cannot support

[ https://issues.apache.org/jira/browse/BEAM-4439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-4439: -- Labels: starter triaged (was: starter) > Do not convert a join that we cannot support >

[jira] [Updated] (BEAM-3514) Use portable WindowIntoPayload in DataflowRunner

[ https://issues.apache.org/jira/browse/BEAM-3514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-3514: -- Priority: Minor (was: Major) > Use portable WindowIntoPayload in DataflowRunner >

[jira] [Updated] (BEAM-6118) Maven dependency conflicts between google-cloud-pubsub and Apache Beam packages

[ https://issues.apache.org/jira/browse/BEAM-6118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-6118: -- Component/s: (was: dependencies) io-java-gcp > Maven dependency conflicts

[jira] [Updated] (BEAM-5440) Add option to mount a directory inside SDK harness containers

[ https://issues.apache.org/jira/browse/BEAM-5440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-5440: -- Labels: portability portability-flink triaged (was: portability portability-flink) > Add

[jira] [Resolved] (BEAM-2885) Local Dataflow proxy for portable job submission

[ https://issues.apache.org/jira/browse/BEAM-2885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles resolved BEAM-2885. --- Resolution: Done Fix Version/s: Not applicable Not sure this one is still relevant. We

[jira] [Updated] (BEAM-3221) Model pipeline representation improvements

[ https://issues.apache.org/jira/browse/BEAM-3221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-3221: -- Labels: portability triaged (was: portability) > Model pipeline representation improvements >

[jira] [Updated] (BEAM-5859) Improve Traceability of Pipeline translation

[ https://issues.apache.org/jira/browse/BEAM-5859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-5859: -- Labels: portability portability-flink triaged (was: portability portability-flink) > Improve

[jira] [Commented] (BEAM-3221) Model pipeline representation improvements

[ https://issues.apache.org/jira/browse/BEAM-3221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16788190#comment-16788190 ] Kenneth Knowles commented on BEAM-3221: --- [~lostluck] I feel like we discussed this over lunch one

[jira] [Updated] (BEAM-6118) Maven dependency conflicts between google-cloud-pubsub and Apache Beam packages

[ https://issues.apache.org/jira/browse/BEAM-6118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-6118: -- Labels: maven triaged (was: maven) > Maven dependency conflicts between google-cloud-pubsub

[jira] [Commented] (BEAM-5440) Add option to mount a directory inside SDK harness containers

[ https://issues.apache.org/jira/browse/BEAM-5440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16788188#comment-16788188 ] Kenneth Knowles commented on BEAM-5440: --- The component here doesn't seem right - isn't

[jira] [Commented] (BEAM-6118) Maven dependency conflicts between google-cloud-pubsub and Apache Beam packages

[ https://issues.apache.org/jira/browse/BEAM-6118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16788186#comment-16788186 ] Kenneth Knowles commented on BEAM-6118: --- [~chamikara] is there a known range of good versions, or

[jira] [Commented] (BEAM-6257) Can we deprecate the side input paths through PAssert?

[ https://issues.apache.org/jira/browse/BEAM-6257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16786367#comment-16786367 ] Kenneth Knowles commented on BEAM-6257: --- OK now I'm watching this issue :-) Generally, each PAssert

[jira] [Updated] (BEAM-1448) Coder encode/decode context documentation is lacking

[ https://issues.apache.org/jira/browse/BEAM-1448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1448: -- Labels: documentation triaged (was: documentation) > Coder encode/decode context documentation

[jira] [Commented] (BEAM-1324) Able to define the thread count via PipelineOptions

[ https://issues.apache.org/jira/browse/BEAM-1324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16795605#comment-16795605 ] Kenneth Knowles commented on BEAM-1324: --- [~zborisha] yes I think that is already the implementation.

[jira] [Updated] (BEAM-296) Retry failures in the DirectRunner

[ https://issues.apache.org/jira/browse/BEAM-296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-296: - Labels: newbie starter triaged (was: newbie starter) > Retry failures in the DirectRunner >

[jira] [Closed] (BEAM-2891) Spark runs portable pipelines

[ https://issues.apache.org/jira/browse/BEAM-2891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles closed BEAM-2891. - Resolution: Later Fix Version/s: Not applicable > Spark runs portable pipelines >

[jira] [Closed] (BEAM-2895) JStorm runs portable pipelines

[ https://issues.apache.org/jira/browse/BEAM-2895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles closed BEAM-2895. - Resolution: Later Fix Version/s: Not applicable > JStorm runs portable pipelines >

[jira] [Resolved] (BEAM-2887) Python SDK support for portable pipelines

[ https://issues.apache.org/jira/browse/BEAM-2887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles resolved BEAM-2887. --- Resolution: Implemented Fix Version/s: Not applicable > Python SDK support for

[jira] [Closed] (BEAM-2896) Portability milestone: wordcount runs everywhere

[ https://issues.apache.org/jira/browse/BEAM-2896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles closed BEAM-2896. - Resolution: Later Fix Version/s: Not applicable > Portability milestone: wordcount runs

[jira] [Updated] (BEAM-5864) Host Grafana UI on GrafanaCloud

[ https://issues.apache.org/jira/browse/BEAM-5864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-5864: -- Labels: community-metrics triaged (was: community-metrics) > Host Grafana UI on GrafanaCloud >

[jira] [Updated] (BEAM-5863) Automate Community Metrics infrastructure deployment

[ https://issues.apache.org/jira/browse/BEAM-5863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-5863: -- Labels: community-metrics triaged (was: community-metrics) > Automate Community Metrics

[jira] [Commented] (BEAM-2907) Flink supports portable progress reporting

[ https://issues.apache.org/jira/browse/BEAM-2907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16795682#comment-16795682 ] Kenneth Knowles commented on BEAM-2907: --- [~thw] [~angoenka] still open? > Flink supports portable

[jira] [Updated] (BEAM-3072) Improve error handling at staging time time for DataflowRunner

[ https://issues.apache.org/jira/browse/BEAM-3072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-3072: -- Labels: starter triaged (was: starter) > Improve error handling at staging time time for

[jira] [Updated] (BEAM-332) Matcher(s) for TableRow

[ https://issues.apache.org/jira/browse/BEAM-332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-332: - Labels: starter triaged (was: starter) > Matcher(s) for TableRow > --- > >

[jira] [Updated] (BEAM-3128) Add debug option to dump the submitted pipeline proto

[ https://issues.apache.org/jira/browse/BEAM-3128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-3128: -- Labels: portability starter triaged (was: portability) > Add debug option to dump the

[jira] [Commented] (BEAM-2306) @Deprecated without @deprecated javadoc explanation should cause build failure

[ https://issues.apache.org/jira/browse/BEAM-2306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16795603#comment-16795603 ] Kenneth Knowles commented on BEAM-2306: --- I'm pretty sure this does cause failure. > @Deprecated

[jira] [Resolved] (BEAM-2306) @Deprecated without @deprecated javadoc explanation should cause build failure

[ https://issues.apache.org/jira/browse/BEAM-2306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles resolved BEAM-2306. --- Resolution: Fixed Fix Version/s: Not applicable > @Deprecated without @deprecated

[jira] [Updated] (BEAM-2306) @Deprecated without @deprecated javadoc explanation should cause build failure

[ https://issues.apache.org/jira/browse/BEAM-2306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-2306: -- Labels: starter triaged (was: starter) > @Deprecated without @deprecated javadoc explanation

[jira] [Updated] (BEAM-2525) WindowFnTestUtils#runWindowFn should be removed

[ https://issues.apache.org/jira/browse/BEAM-2525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-2525: -- Labels: easyfix newbie starter triaged (was: easyfix newbie starter) >

[jira] [Updated] (BEAM-6846) Beam Performance Degradation on Dataflow Runner

[ https://issues.apache.org/jira/browse/BEAM-6846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-6846: -- Labels: patch (was: patch triaged) > Beam Performance Degradation on Dataflow Runner >

[jira] [Closed] (BEAM-2893) Tez runs portable pipelines

[ https://issues.apache.org/jira/browse/BEAM-2893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles closed BEAM-2893. - Resolution: Later Fix Version/s: Not applicable > Tez runs portable pipelines >

[jira] [Closed] (BEAM-2592) Python shim for submitting to ApexRunner

[ https://issues.apache.org/jira/browse/BEAM-2592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles closed BEAM-2592. - Resolution: Won't Do Fix Version/s: Not applicable > Python shim for submitting to

[jira] [Commented] (BEAM-2593) Python shim for submitting to SparkRunner

[ https://issues.apache.org/jira/browse/BEAM-2593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16795625#comment-16795625 ] Kenneth Knowles commented on BEAM-2593: --- [~angoenka] I think we are not doing these shims, right?

[jira] [Updated] (BEAM-2593) Python shim for submitting to SparkRunner

[ https://issues.apache.org/jira/browse/BEAM-2593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-2593: -- Labels: portability (was: portability triaged) > Python shim for submitting to SparkRunner >

[jira] [Closed] (BEAM-2894) MapReduce runs portable pipelines

[ https://issues.apache.org/jira/browse/BEAM-2894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles closed BEAM-2894. - Resolution: Later Fix Version/s: Not applicable > MapReduce runs portable pipelines >

[jira] [Updated] (BEAM-3320) DataflowRunner for python streaming uses portable containers

[ https://issues.apache.org/jira/browse/BEAM-3320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-3320: -- Labels: portability (was: portability triaged) > DataflowRunner for python streaming uses

[jira] [Commented] (BEAM-5649) Remove deprecated primitive CREATE_VIEW transform from Runner API

[ https://issues.apache.org/jira/browse/BEAM-5649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16795634#comment-16795634 ] Kenneth Knowles commented on BEAM-5649: --- [~lcwik] [~mxm] can this be removed now? It is definitely

[jira] [Updated] (BEAM-1081) annotations should support custom messages and classes

[ https://issues.apache.org/jira/browse/BEAM-1081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1081: -- Labels: newbie starter triaged (was: newbie starter) > annotations should support custom

[jira] [Commented] (BEAM-3320) DataflowRunner for python streaming uses portable containers

[ https://issues.apache.org/jira/browse/BEAM-3320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16795627#comment-16795627 ] Kenneth Knowles commented on BEAM-3320: --- This is done, right? > DataflowRunner for python streaming

[jira] [Commented] (BEAM-6845) [beam_PostCommit_Py_ValCont] [test_metrics_fnapi_it] Missing dependency causing failures

[ https://issues.apache.org/jira/browse/BEAM-6845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16795591#comment-16795591 ] Kenneth Knowles commented on BEAM-6845: --- Is this still currently failing? If it is blocking

[jira] [Commented] (BEAM-6846) Beam Performance Degradation on Dataflow Runner

[ https://issues.apache.org/jira/browse/BEAM-6846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16795589#comment-16795589 ] Kenneth Knowles commented on BEAM-6846: --- Hi [~KishanK]. Can you give some steps to reproduce? Do you

[jira] [Updated] (BEAM-6846) Beam Performance Degradation on Dataflow Runner

[ https://issues.apache.org/jira/browse/BEAM-6846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-6846: -- Labels: patch triaged (was: patch) > Beam Performance Degradation on Dataflow Runner >

[jira] [Commented] (BEAM-3300) Portable flattens in Go SDK Harness

[ https://issues.apache.org/jira/browse/BEAM-3300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16795599#comment-16795599 ] Kenneth Knowles commented on BEAM-3300: --- [~lostluck] just going through things lacking "triage"

[jira] [Commented] (BEAM-3377) assert_that not working for streaming

[ https://issues.apache.org/jira/browse/BEAM-3377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16795598#comment-16795598 ] Kenneth Knowles commented on BEAM-3377: --- [~mariagh] is this now done? > assert_that not working for

[jira] [Updated] (BEAM-3300) Portable flattens in Go SDK Harness

[ https://issues.apache.org/jira/browse/BEAM-3300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-3300: -- Labels: portability triaged (was: portability) > Portable flattens in Go SDK Harness >

[jira] [Updated] (BEAM-3658) Port SpannerIOReadTest off DoFnTester

[ https://issues.apache.org/jira/browse/BEAM-3658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-3658: -- Labels: beginner newbie starter triaged (was: beginner newbie starter) > Port

[jira] [Closed] (BEAM-39) Audit trigger implementations to ensure they prefetch appropriately

[ https://issues.apache.org/jira/browse/BEAM-39?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles closed BEAM-39. --- Resolution: Won't Do Fix Version/s: Not applicable > Audit trigger implementations to ensure

[jira] [Updated] (BEAM-39) Audit trigger implementations to ensure they prefetch appropriately

[ https://issues.apache.org/jira/browse/BEAM-39?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-39: Labels: Triggers triaged (was: Triggers) > Audit trigger implementations to ensure they prefetch

[jira] [Closed] (BEAM-2940) Portability milestone: mobile gaming runs everywhere

[ https://issues.apache.org/jira/browse/BEAM-2940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles closed BEAM-2940. - Resolution: Later Fix Version/s: Not applicable > Portability milestone: mobile gaming

[jira] [Closed] (BEAM-2941) Portability milestone: windowed wordcount runs everywhere

[ https://issues.apache.org/jira/browse/BEAM-2941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles closed BEAM-2941. - Resolution: Later Fix Version/s: Not applicable > Portability milestone: windowed

[jira] [Updated] (BEAM-2386) Change regex used for splitting words

[ https://issues.apache.org/jira/browse/BEAM-2386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-2386: -- Labels: newbie starter triaged (was: newbie starter) > Change regex used for splitting words >

[jira] [Commented] (BEAM-308) PipelineOptions throws when using package-private PipelineOptions interfaces from multiple packages

[ https://issues.apache.org/jira/browse/BEAM-308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16795637#comment-16795637 ] Kenneth Knowles commented on BEAM-308: -- I actually think that since the state is global it is a spec

[jira] [Updated] (BEAM-6832) Populate labels and custom metadata on VMs that serves Dataflow

[ https://issues.apache.org/jira/browse/BEAM-6832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-6832: -- Labels: google-dataflow triaged (was: google-dataflow) > Populate labels and custom metadata

[jira] [Updated] (BEAM-6831) python sdk WriteToBigQuery excessive usage of metered API

[ https://issues.apache.org/jira/browse/BEAM-6831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-6831: -- Labels: bigquery dataflow gcp python triaged (was: bigquery dataflow gcp python) > python sdk

[jira] [Updated] (BEAM-6811) [JobName] [TestName] Failure summaryBuild broken: repo.spring.io is down

[ https://issues.apache.org/jira/browse/BEAM-6811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-6811: -- Labels: currently-failing triaged (was: currently-failing) > [JobName] [TestName] Failure

[jira] [Updated] (BEAM-2715) Expose PubsubSource to create UnboundedSource and utilize withMaxNumRecords from BoundedReadFromUnboundedSource

[ https://issues.apache.org/jira/browse/BEAM-2715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-2715: -- Labels: pubsub triaged (was: pubsub) > Expose PubsubSource to create UnboundedSource and

[jira] [Updated] (BEAM-2715) Expose PubsubSource to create UnboundedSource and utilize withMaxNumRecords from BoundedReadFromUnboundedSource

[ https://issues.apache.org/jira/browse/BEAM-2715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-2715: -- Component/s: (was: runner-direct) io-java-gcp > Expose PubsubSource to

[jira] [Updated] (BEAM-4682) Integrate support for timers using the portability APIs into Dataflow

[ https://issues.apache.org/jira/browse/BEAM-4682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-4682: -- Labels: portability triaged (was: portability) > Integrate support for timers using the

[jira] [Commented] (BEAM-2715) Expose PubsubSource to create UnboundedSource and utilize withMaxNumRecords from BoundedReadFromUnboundedSource

[ https://issues.apache.org/jira/browse/BEAM-2715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16795596#comment-16795596 ] Kenneth Knowles commented on BEAM-2715: --- [~alevy] is this still an outstanding request? It is quite

[jira] [Commented] (BEAM-28) Support side inputs for Sessions

[ https://issues.apache.org/jira/browse/BEAM-28?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16795622#comment-16795622 ] Kenneth Knowles commented on BEAM-28: - [~lcwik] [~CraigChambersG] another issue for the portable model

[jira] [Updated] (BEAM-1308) Consider removing TimeDomain from user APIs

[ https://issues.apache.org/jira/browse/BEAM-1308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1308: -- Labels: backward-incompatible triaged (was: backward-incompatible) > Consider removing

[jira] [Updated] (BEAM-2593) Python shim for submitting to SparkRunner

[ https://issues.apache.org/jira/browse/BEAM-2593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-2593: -- Labels: portability triaged (was: portability) > Python shim for submitting to SparkRunner >

[jira] [Updated] (BEAM-2069) Remove ResourceId.getCurrentDirectory()?

[ https://issues.apache.org/jira/browse/BEAM-2069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-2069: -- Labels: backward-incompatible triaged (was: backward-incompatible) > Remove

[jira] [Updated] (BEAM-2902) Add user state support for ParDo.Multi for the Dataflow runner

[ https://issues.apache.org/jira/browse/BEAM-2902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-2902: -- Labels: portability sickbay triaged (was: portability sickbay) > Add user state support for

[jira] [Updated] (BEAM-2207) BeamSqlInputRefExpression in BeamSQLFnExecutor.buildExpression error

[ https://issues.apache.org/jira/browse/BEAM-2207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-2207: -- Labels: easyfix triaged (was: easyfix) > BeamSqlInputRefExpression in

[jira] [Commented] (BEAM-6846) Beam Performance Degradation on Dataflow Runner

[ https://issues.apache.org/jira/browse/BEAM-6846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16795656#comment-16795656 ] Kenneth Knowles commented on BEAM-6846: --- TableRow is a pretty heavyweight object. I would definitely

[jira] [Updated] (BEAM-6845) [beam_PostCommit_Py_ValCont] [test_metrics_fnapi_it] Missing dependency causing failures

[ https://issues.apache.org/jira/browse/BEAM-6845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-6845: -- Priority: Blocker (was: Major) > [beam_PostCommit_Py_ValCont] [test_metrics_fnapi_it] Missing

[jira] [Closed] (BEAM-2589) ApexRunner shim for Job API

[ https://issues.apache.org/jira/browse/BEAM-2589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles closed BEAM-2589. - Resolution: Won't Do Fix Version/s: Not applicable [~thw] I figure there's no point

[jira] [Updated] (BEAM-2819) Key only reads from Google Datastore

[ https://issues.apache.org/jira/browse/BEAM-2819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-2819: -- Labels: datastore triaged (was: datastore) > Key only reads from Google Datastore >

[jira] [Resolved] (BEAM-2335) Document various maven commands for running tests

[ https://issues.apache.org/jira/browse/BEAM-2335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles resolved BEAM-2335. --- Resolution: Won't Do Fix Version/s: Not applicable No more maven - no more

<    3   4   5   6   7   8   9   10   11   12   >