[
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 validatesRun
[
https://issues.apache.org/jira/browse/BEAM-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16115336#comment-16115336
]
Aviem Zur commented on BEAM-2671:
-
[~jkff] Please see the comments made by JB and myself wh
[
https://issues.apache.org/jira/browse/BEAM-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16115339#comment-16115339
]
Aviem Zur commented on BEAM-2671:
-
If we want streaming to be working in Spark runner in 2.
[
https://issues.apache.org/jira/browse/BEAM-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16115339#comment-16115339
]
Aviem Zur edited comment on BEAM-2671 at 8/5/17 8:54 AM:
-
If we wan
[
https://issues.apache.org/jira/browse/BEAM-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16115336#comment-16115336
]
Aviem Zur edited comment on BEAM-2671 at 8/5/17 8:54 AM:
-
[~jkff] P
[
https://issues.apache.org/jira/browse/BEAM-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16118451#comment-16118451
]
Aviem Zur commented on BEAM-2671:
-
[~jkff] we've been running Spark runner in streaming mod
[
https://issues.apache.org/jira/browse/BEAM-2789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16139764#comment-16139764
]
Aviem Zur commented on BEAM-2789:
-
While this affects the tests greatly since these are in
[
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-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985205#comment-15985205
]
Aviem Zur commented on BEAM-1582:
-
AFAIK there is no current solution for this in sight for
[
https://issues.apache.org/jira/browse/BEAM-2057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur reassigned BEAM-2057:
---
Assignee: Holden Karau
> Test metrics are reported to Spark Metrics sink.
> --
[
https://issues.apache.org/jira/browse/BEAM-1958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur updated BEAM-1958:
Fix Version/s: First stable release
> Standard IO Metrics in Java SDK
> ---
>
>
[
https://issues.apache.org/jira/browse/BEAM-1958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur resolved BEAM-1958.
-
Resolution: Implemented
> Standard IO Metrics in Java SDK
> ---
>
>
[
https://issues.apache.org/jira/browse/BEAM-2057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur updated BEAM-2057:
Description:
Test that metrics are reported to Spark's metric sink.
Use {{InMemoryMetrics}} and {{InMemoryMe
[
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
> --
[
https://issues.apache.org/jira/browse/BEAM-2004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985987#comment-15985987
]
Aviem Zur commented on BEAM-2004:
-
Adding this back to First stable release.
[~thw] is the
[
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-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: NullPoi
[
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
Aviem Zur created BEAM-2106:
---
Summary: NotSerializableException thrown when serializing
EvaluationContext
Key: BEAM-2106
URL: https://issues.apache.org/jira/browse/BEAM-2106
Project: Beam
Issue Ty
[
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-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-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 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 updated BEAM-1148:
Issue Type: Improvement (was: New Feature)
> Port PAssert away from Aggregators
> --
[
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-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-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 resolved BEAM-2057.
-
Resolution: Done
> Test metrics are reported to Spark Metrics sink.
> -
[
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-1398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur resolved BEAM-1398.
-
Resolution: Implemented
> KafkaIO metrics
> ---
>
> Key: BEAM-1398
>
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-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
>
[
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-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-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991017#comment-15991017
]
Aviem Zur commented on BEAM-2111:
-
I was able to create a test to reproduce it, however it
[
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-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 SplittableDoF
[
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-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 stre
[
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-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-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-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-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15997742#comment-15997742
]
Aviem Zur commented on BEAM-1582:
-
I don't think we should disable this test as it is a ver
[
https://issues.apache.org/jira/browse/BEAM-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15997742#comment-15997742
]
Aviem Zur edited comment on BEAM-1582 at 5/5/17 3:02 AM:
-
I don't t
[
https://issues.apache.org/jira/browse/BEAM-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15997742#comment-15997742
]
Aviem Zur edited comment on BEAM-1582 at 5/5/17 3:01 AM:
-
I don't t
[
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 firing
[
https://issues.apache.org/jira/browse/BEAM-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15997742#comment-15997742
]
Aviem Zur edited comment on BEAM-1582 at 5/5/17 3:02 AM:
-
I don't t
[
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 a
[
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 secon
[
https://issues.apache.org/jira/browse/BEAM-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15997742#comment-15997742
]
Aviem Zur edited comment on BEAM-1582 at 5/5/17 3:03 AM:
-
I don't t
[
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
Co
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
Compon
[
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-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
> --
[
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:comment-tabpanel&focusedCommentId=16073258#comment-16073258
]
Aviem Zur commented on BEAM-2359:
-
Yeah, the PR was merged, marking as resolved.
> SparkTi
[
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.
>
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
Project
[
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-1672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur updated BEAM-1672:
Fix Version/s: 2.0.0
> Accumulable MetricsContainers.
> --
>
> Ke
[
https://issues.apache.org/jira/browse/BEAM-1672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16001125#comment-16001125
]
Aviem Zur commented on BEAM-1672:
-
Has not been cherry-picked to the release branch yet, so
[
https://issues.apache.org/jira/browse/BEAM-1672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16001125#comment-16001125
]
Aviem Zur edited comment on BEAM-1672 at 5/8/17 5:16 PM:
-
Has not b
[
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 c
[
https://issues.apache.org/jira/browse/BEAM-981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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
[
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-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-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-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-1482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aviem Zur reassigned BEAM-1482:
---
Assignee: (was: Aviem Zur)
> Support SetState in Spark runner
>
>
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
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-2279:
---
Summary: Hadoop file system support should be included in
archetype profiles of Spark runner.
Key: BEAM-2279
URL: https://issues.apache.org/jira/browse/BEAM-2279
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 run
[
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 run
[
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 run
[
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. (was:
[
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 in
[
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-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 run
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
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
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
[
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 ca
[
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-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 ar
[
https://issues.apache.org/jira/browse/BEAM-1763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16146568#comment-16146568
]
Aviem Zur commented on BEAM-1763:
-
Currently, {{TestPipeline}} does the validation using th
[
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 on
[
https://issues.apache.org/jira/browse/BEAM-2719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16155300#comment-16155300
]
Aviem Zur commented on BEAM-2719:
-
Problem was identified, the job here was being run on a
[
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 submit
[
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 s
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: Imp
[
https://issues.apache.org/jira/browse/BEAM-2954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16165183#comment-16165183
]
Aviem Zur commented on BEAM-2954:
-
We cannot opt-out of the shading rules in the SQL module
[
https://issues.apache.org/jira/browse/BEAM-2954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16165183#comment-16165183
]
Aviem Zur edited comment on BEAM-2954 at 9/13/17 7:48 PM:
--
We cann
[
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) includes
[
https://issues.apache.org/jira/browse/BEAM-2954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16165183#comment-16165183
]
Aviem Zur edited comment on BEAM-2954 at 9/13/17 8:25 PM:
--
We cann
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 Ty
[
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.
> --
>
>
[
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.
> --
>
101 - 200 of 456 matches
Mail list logo