[
https://issues.apache.org/jira/browse/BEAM-2175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur resolved BEAM-2175.
-
Resolution: Implemented
> Support state API in Spark batch mode.
> --
[
https://issues.apache.org/jira/browse/BEAM-2175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16234069#comment-16234069
]
Aviem Zur commented on BEAM-2175:
-
Marked as Resolved
> Support state API in Spark batch mode.
>
[
https://issues.apache.org/jira/browse/BEAM-2175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur updated BEAM-2175:
Fix Version/s: 2.1.0
> Support state API in Spark batch mode.
> --
>
>
Aviem Zur created BEAM-2968:
---
Summary: Master build broken due to error when running
autocomplete_test.py
Key: BEAM-2968
URL: https://issues.apache.org/jira/browse/BEAM-2968
Project: Beam
Issue
[
https://issues.apache.org/jira/browse/BEAM-2954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16165183#comment-16165183
]
Aviem Zur edited comment on BEAM-2954 at 9/13/17 8:25 PM:
--
We cannot opt-out of
[
https://issues.apache.org/jira/browse/BEAM-2954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur updated BEAM-2954:
Description:
{{guava}} is shaded by default in beam modules, while {{calcite}}(a dependency
of SQL)
[
https://issues.apache.org/jira/browse/BEAM-2954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16165183#comment-16165183
]
Aviem Zur edited comment on BEAM-2954 at 9/13/17 7:48 PM:
--
We cannot opt-out of
[
https://issues.apache.org/jira/browse/BEAM-2954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16165183#comment-16165183
]
Aviem Zur commented on BEAM-2954:
-
We cannot opt-out of the shading rules in the SQL module as we cannot
Aviem Zur created BEAM-2847:
---
Summary: Stop streaming pipeline when global watermark reaches
+INF
Key: BEAM-2847
URL: https://issues.apache.org/jira/browse/BEAM-2847
Project: Beam
Issue Type:
[
https://issues.apache.org/jira/browse/BEAM-2719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur closed BEAM-2719.
---
Resolution: Not A Problem
Fix Version/s: Not applicable
> Beam job hangs at Evaluating ParMultiDo when
[
https://issues.apache.org/jira/browse/BEAM-2719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur reassigned BEAM-2719:
---
Assignee: Aviem Zur (was: Jean-Baptiste Onofré)
> Beam job hangs at Evaluating ParMultiDo when
[
https://issues.apache.org/jira/browse/BEAM-2719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16155300#comment-16155300
]
Aviem Zur commented on BEAM-2719:
-
Problem was identified, the job here was being run on a Spark 2.1.1
[
https://issues.apache.org/jira/browse/BEAM-2278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur reassigned BEAM-2278:
---
Assignee: (was: Aviem Zur)
> ServiceResourceTransformer missing from Spark runner documentation
[
https://issues.apache.org/jira/browse/BEAM-1763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16146568#comment-16146568
]
Aviem Zur commented on BEAM-1763:
-
Currently, {{TestPipeline}} does the validation using the success
[
https://issues.apache.org/jira/browse/BEAM-2669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur updated BEAM-2669:
Fix Version/s: 2.2.0
> Kryo serialization exception when DStreams containing non-Kryo-serializable
> data
[
https://issues.apache.org/jira/browse/BEAM-2669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur updated BEAM-2669:
Description:
Today, when we detect re-use of a dataset in a pipeline in Spark runner we
eagerly cache it to
[
https://issues.apache.org/jira/browse/BEAM-2812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur updated BEAM-2812:
Description:
In https://github.com/apache/beam/pull/2838 aggregators were removed from Spark
runner, this
Aviem Zur created BEAM-2812:
---
Summary: Dropped windows counters / log prints no longer working
Key: BEAM-2812
URL: https://issues.apache.org/jira/browse/BEAM-2812
Project: Beam
Issue Type: Bug
Aviem Zur created BEAM-2811:
---
Summary: Complete the removal of aggregators from Spark runner.
Key: BEAM-2811
URL: https://issues.apache.org/jira/browse/BEAM-2811
Project: Beam
Issue Type: Task
[
https://issues.apache.org/jira/browse/BEAM-2789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur updated BEAM-2789:
Affects Version/s: (was: 2.0.0)
> Watermark can become unavailable for executors while it's updated with
[
https://issues.apache.org/jira/browse/BEAM-2789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16139764#comment-16139764
]
Aviem Zur commented on BEAM-2789:
-
While this affects the tests greatly since these are in a single JVM, I
[
https://issues.apache.org/jira/browse/BEAM-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16118451#comment-16118451
]
Aviem Zur commented on BEAM-2671:
-
[~jkff] we've been running Spark runner in streaming mode using 2.0.0
[
https://issues.apache.org/jira/browse/BEAM-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16115336#comment-16115336
]
Aviem Zur edited comment on BEAM-2671 at 8/5/17 8:54 AM:
-
[~jkff] Please see the
[
https://issues.apache.org/jira/browse/BEAM-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16115339#comment-16115339
]
Aviem Zur edited comment on BEAM-2671 at 8/5/17 8:54 AM:
-
If we want streaming to
[
https://issues.apache.org/jira/browse/BEAM-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16115339#comment-16115339
]
Aviem Zur commented on BEAM-2671:
-
If we want streaming to be working in Spark runner in 2.1.0 we should
[
https://issues.apache.org/jira/browse/BEAM-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16115336#comment-16115336
]
Aviem Zur commented on BEAM-2671:
-
[~jkff] Please see the comments made by JB and myself which help
[
https://issues.apache.org/jira/browse/BEAM-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur updated BEAM-2671:
Fix Version/s: (was: 2.2.0)
2.1.0
> CreateStreamTest.testFirstElementLate
[
https://issues.apache.org/jira/browse/BEAM-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16106440#comment-16106440
]
Aviem Zur edited comment on BEAM-2671 at 8/2/17 6:44 AM:
-
CreateStreamTest has
[
https://issues.apache.org/jira/browse/BEAM-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16106440#comment-16106440
]
Aviem Zur edited comment on BEAM-2671 at 7/30/17 11:41 AM:
---
CreateStreamTest has
[
https://issues.apache.org/jira/browse/BEAM-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16106440#comment-16106440
]
Aviem Zur edited comment on BEAM-2671 at 7/30/17 11:13 AM:
---
CreateStreamTest has
[
https://issues.apache.org/jira/browse/BEAM-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16106440#comment-16106440
]
Aviem Zur commented on BEAM-2671:
-
20820fa5477ffcdd4a9ef2e9340353ed3c5691a9
added an element of flakiness
[
https://issues.apache.org/jira/browse/BEAM-2669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur updated BEAM-2669:
Description:
Today, when we detect re-use of a dataset in a pipeline in Spark runner we
eagerly cache it to
Aviem Zur created BEAM-2669:
---
Summary: Kryo serialization exception when DStreams containing
non-Kryo-serializable data are cached
Key: BEAM-2669
URL: https://issues.apache.org/jira/browse/BEAM-2669
[
https://issues.apache.org/jira/browse/BEAM-2176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur reassigned BEAM-2176:
---
Assignee: (was: Aviem Zur)
> Support state API in Spark streaming mode.
>
[
https://issues.apache.org/jira/browse/BEAM-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16073258#comment-16073258
]
Aviem Zur commented on BEAM-2359:
-
Yeah, the PR was merged, marking as resolved.
> SparkTimerInternals
[
https://issues.apache.org/jira/browse/BEAM-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur resolved BEAM-2359.
-
Resolution: Fixed
> SparkTimerInternals inputWatermarkTime does not get updated in cluster mode
>
[
https://issues.apache.org/jira/browse/BEAM-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur reassigned BEAM-2359:
---
Assignee: Aviem Zur (was: Amit Sela)
> SparkTimerInternals inputWatermarkTime does not get updated
[
https://issues.apache.org/jira/browse/BEAM-2409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur reassigned BEAM-2409:
---
Assignee: Amit Sela (was: Aviem Zur)
> Spark runner produces exactly twice the number of results in
[
https://issues.apache.org/jira/browse/BEAM-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur updated BEAM-2359:
Description:
{{SparkTimerInternals#inputWatermarkTime}} does not get updated in cluster mode.
This causes
[
https://issues.apache.org/jira/browse/BEAM-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur updated BEAM-2359:
Description:
{{SparkTimerInternals#inputWatermarkTime}} does not get updated in cluster mode.
This causes
Aviem Zur created BEAM-2359:
---
Summary: SparkTimerInternals inputWatermarkTime does not get
updated in cluster mode
Key: BEAM-2359
URL: https://issues.apache.org/jira/browse/BEAM-2359
Project: Beam
[
https://issues.apache.org/jira/browse/BEAM-2277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur updated BEAM-2277:
Description:
IllegalArgumentException when using Hadoop file system for WordCount example.
Occurred when
[
https://issues.apache.org/jira/browse/BEAM-2277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur reassigned BEAM-2277:
---
Assignee: Aviem Zur (was: Davor Bonaci)
> IllegalArgumentException when using Hadoop file system for
[
https://issues.apache.org/jira/browse/BEAM-2279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur updated BEAM-2279:
Description: Hadoop file system support (dependency on
{{beam-sdks-java-io-hadoop-file-system}}) should be
[
https://issues.apache.org/jira/browse/BEAM-2279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur updated BEAM-2279:
Summary: Hadoop file system support should be included in
examples/archetype profiles of Spark runner.
[
https://issues.apache.org/jira/browse/BEAM-2277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur updated BEAM-2277:
Description:
IllegalArgumentException when using Hadoop file system for WordCount example.
Occurred when
[
https://issues.apache.org/jira/browse/BEAM-2277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur updated BEAM-2277:
Description:
IllegalArgumentException when using Hadoop file system for WordCount example.
Occurred when
Aviem Zur created BEAM-2278:
---
Summary: ServiceResourceTransformer missing from Spark runner
documentation on shading
Key: BEAM-2278
URL: https://issues.apache.org/jira/browse/BEAM-2278
Project: Beam
Aviem Zur created BEAM-2277:
---
Summary: IllegalArgumentException when using Hadoop file system
for WordCount example.
Key: BEAM-2277
URL: https://issues.apache.org/jira/browse/BEAM-2277
Project: Beam
[
https://issues.apache.org/jira/browse/BEAM-1482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur reassigned BEAM-1482:
---
Assignee: (was: Aviem Zur)
> Support SetState in Spark runner
>
[
https://issues.apache.org/jira/browse/BEAM-1482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur resolved BEAM-1482.
-
Resolution: Duplicate
Fix Version/s: Not applicable
> Support SetState in Spark runner
>
[
https://issues.apache.org/jira/browse/BEAM-1477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur reassigned BEAM-1477:
---
Assignee: (was: Aviem Zur)
> Support MapState in Spark runner
>
[
https://issues.apache.org/jira/browse/BEAM-1477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur resolved BEAM-1477.
-
Resolution: Duplicate
Fix Version/s: Not applicable
> Support MapState in Spark runner
>
[
https://issues.apache.org/jira/browse/BEAM-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur reassigned BEAM-2111:
---
Assignee: (was: Aviem Zur)
> ClassCastException in streaming Spark pipeline.
>
[
https://issues.apache.org/jira/browse/BEAM-981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16004990#comment-16004990
]
Aviem Zur commented on BEAM-981:
Moving this to version 2.1.0 as it is not a blocker for 2.0.0 and can be
[
https://issues.apache.org/jira/browse/BEAM-981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur updated BEAM-981:
---
Fix Version/s: (was: 2.0.0)
2.1.0
> Not possible to directly submit a pipeline on spark
[
https://issues.apache.org/jira/browse/BEAM-1672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16001125#comment-16001125
]
Aviem Zur edited comment on BEAM-1672 at 5/8/17 5:16 PM:
-
Has not been
[
https://issues.apache.org/jira/browse/BEAM-1672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16001125#comment-16001125
]
Aviem Zur commented on BEAM-1672:
-
Has not been cherry-picked to the release branch yet, so not marked as
[
https://issues.apache.org/jira/browse/BEAM-1672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur updated BEAM-1672:
Fix Version/s: 2.0.0
> Accumulable MetricsContainers.
> --
>
>
[
https://issues.apache.org/jira/browse/BEAM-1035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur reassigned BEAM-1035:
---
Assignee: (was: Aviem Zur)
> Support for new State API in SparkRunner
>
Aviem Zur created BEAM-2175:
---
Summary: Support state API in Spark batch mode.
Key: BEAM-2175
URL: https://issues.apache.org/jira/browse/BEAM-2175
Project: Beam
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/BEAM-2176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur reassigned BEAM-2176:
---
Assignee: Aviem Zur (was: Amit Sela)
> Support state API in Spark streaming mode.
>
[
https://issues.apache.org/jira/browse/BEAM-2175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur reassigned BEAM-2175:
---
Assignee: Jingsong Lee (was: Amit Sela)
> Support state API in Spark batch mode.
>
Aviem Zur created BEAM-2176:
---
Summary: Support state API in Spark streaming mode.
Key: BEAM-2176
URL: https://issues.apache.org/jira/browse/BEAM-2176
Project: Beam
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/BEAM-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15997742#comment-15997742
]
Aviem Zur edited comment on BEAM-1582 at 5/5/17 3:03 AM:
-
I don't think we should
[
https://issues.apache.org/jira/browse/BEAM-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur reassigned BEAM-1582:
---
Assignee: (was: Amit Sela)
> ResumeFromCheckpointStreamingTest flakes with what appears as a
[
https://issues.apache.org/jira/browse/BEAM-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur updated BEAM-1582:
Fix Version/s: (was: First stable release)
> ResumeFromCheckpointStreamingTest flakes with what appears
[
https://issues.apache.org/jira/browse/BEAM-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15997742#comment-15997742
]
Aviem Zur edited comment on BEAM-1582 at 5/5/17 3:02 AM:
-
I don't think we should
[
https://issues.apache.org/jira/browse/BEAM-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur updated BEAM-1582:
Priority: Minor (was: Major)
> ResumeFromCheckpointStreamingTest flakes with what appears as a second
[
https://issues.apache.org/jira/browse/BEAM-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15997742#comment-15997742
]
Aviem Zur edited comment on BEAM-1582 at 5/5/17 3:01 AM:
-
I don't think we should
[
https://issues.apache.org/jira/browse/BEAM-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15997742#comment-15997742
]
Aviem Zur edited comment on BEAM-1582 at 5/5/17 3:02 AM:
-
I don't think we should
[
https://issues.apache.org/jira/browse/BEAM-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15997742#comment-15997742
]
Aviem Zur commented on BEAM-1582:
-
I don't think we should disable this test as it is a very important one.
[
https://issues.apache.org/jira/browse/BEAM-2002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur resolved BEAM-2002.
-
Resolution: Done
> Verify PAssert execution in TestSparkRunner
>
[
https://issues.apache.org/jira/browse/BEAM-1726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur resolved BEAM-1726.
-
Resolution: Done
> Verify PAssert execution in TestFlinkRunner
>
[
https://issues.apache.org/jira/browse/BEAM-1763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur resolved BEAM-1763.
-
Resolution: Implemented
> TestPipeline should ensure that all assertions succeeded
>
[
https://issues.apache.org/jira/browse/BEAM-1763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur updated BEAM-1763:
Fix Version/s: First stable release
> TestPipeline should ensure that all assertions succeeded
>
[
https://issues.apache.org/jira/browse/BEAM-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur updated BEAM-2111:
Summary: ClassCastException in streaming Spark pipeline. (was:
java.lang.ClassCastException in spark in
[
https://issues.apache.org/jira/browse/BEAM-2139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur updated BEAM-2139:
Issue Type: Task (was: Bug)
> Disable SplittableDoFn ValidatesRunner tests for Streaming Flink Runner
>
[
https://issues.apache.org/jira/browse/BEAM-2139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur updated BEAM-2139:
Summary: Disable SplittableDoFn ValidatesRunner tests for Streaming Flink
Runner (was: Disable
[
https://issues.apache.org/jira/browse/BEAM-2139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur reassigned BEAM-2139:
---
Assignee: Aviem Zur (was: Aljoscha Krettek)
> Disable SplittableDoFn ValidatesRunner tests for Flink
[
https://issues.apache.org/jira/browse/BEAM-2129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur resolved BEAM-2129.
-
Resolution: Fixed
Fix Version/s: Not applicable
> KafkaIOTest.testUnboundedSourceMetrics is flaky
>
[
https://issues.apache.org/jira/browse/BEAM-2127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur reassigned BEAM-2127:
---
Assignee: (was: Amit Sela)
> Test Spark streaming pipelines with maxRecordsPerBatch
>
[
https://issues.apache.org/jira/browse/BEAM-2127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur updated BEAM-2127:
Priority: Minor (was: Major)
> Test Spark streaming pipelines with maxRecordsPerBatch
>
Aviem Zur created BEAM-2127:
---
Summary: Test Spark streaming pipelines with maxRecordsPerBatch
Key: BEAM-2127
URL: https://issues.apache.org/jira/browse/BEAM-2127
Project: Beam
Issue Type: Test
[
https://issues.apache.org/jira/browse/BEAM-2057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur resolved BEAM-2057.
-
Resolution: Done
> Test metrics are reported to Spark Metrics sink.
>
[
https://issues.apache.org/jira/browse/BEAM-1398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur resolved BEAM-1398.
-
Resolution: Implemented
> KafkaIO metrics
> ---
>
> Key: BEAM-1398
>
[
https://issues.apache.org/jira/browse/BEAM-1398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur updated BEAM-1398:
Fix Version/s: First stable release
> KafkaIO metrics
> ---
>
> Key: BEAM-1398
>
[
https://issues.apache.org/jira/browse/BEAM-2057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur updated BEAM-2057:
Fix Version/s: First stable release
> Test metrics are reported to Spark Metrics sink.
>
[
https://issues.apache.org/jira/browse/BEAM-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur reassigned BEAM-2111:
---
Assignee: Aviem Zur (was: Amit Sela)
> java.lang.ClassCastException in spark in streaming mode
>
[
https://issues.apache.org/jira/browse/BEAM-1814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur resolved BEAM-1814.
-
Resolution: Duplicate
Fix Version/s: Not applicable
> Support for new State API in Spark runner
>
[
https://issues.apache.org/jira/browse/BEAM-1148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur updated BEAM-1148:
Issue Type: Improvement (was: New Feature)
> Port PAssert away from Aggregators
>
[
https://issues.apache.org/jira/browse/BEAM-1148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur resolved BEAM-1148.
-
Resolution: Done
> Port PAssert away from Aggregators
> --
>
>
[
https://issues.apache.org/jira/browse/BEAM-1148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur reassigned BEAM-1148:
---
Assignee: Pablo Estrada
> Port PAssert away from Aggregators
> --
>
>
[
https://issues.apache.org/jira/browse/BEAM-1148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur updated BEAM-1148:
Fix Version/s: First stable release
> Port PAssert away from Aggregators
>
[
https://issues.apache.org/jira/browse/BEAM-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur resolved BEAM-2106.
-
Resolution: Fixed
> NotSerializableException thrown when serializing EvaluationContext
>
[
https://issues.apache.org/jira/browse/BEAM-2029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur updated BEAM-2029:
Fix Version/s: First stable release
> NullPointerException when using multi output ParDo in Spark runner in
[
https://issues.apache.org/jira/browse/BEAM-2029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur updated BEAM-2029:
Summary: NullPointerException when using multi output ParDo in Spark runner
in streaming mode. (was:
[
https://issues.apache.org/jira/browse/BEAM-2001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur updated BEAM-2001:
Fix Version/s: (was: First stable release)
> Verify PAssert execution in all runners
>
[
https://issues.apache.org/jira/browse/BEAM-2004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15985987#comment-15985987
]
Aviem Zur commented on BEAM-2004:
-
Adding this back to First stable release.
[~thw] is there anything we
[
https://issues.apache.org/jira/browse/BEAM-2004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur updated BEAM-2004:
Fix Version/s: First stable release
> Verify PAssert execution in TestApexRunner
>
1 - 100 of 393 matches
Mail list logo
