[
https://issues.apache.org/jira/browse/BEAM-3371?focusedWorklogId=145811&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-145811
]
ASF GitHub Bot logged work on BEAM-3371:
----------------------------------------
Author: ASF GitHub Bot
Created on: 19/Sep/18 21:09
Start Date: 19/Sep/18 21:09
Worklog Time Spent: 10m
Work Description: lgajowy commented on issue #6244: [BEAM-3371] Enable
running integration tests on Spark
URL: https://github.com/apache/beam/pull/6244#issuecomment-422959486
@mxm @aromanenko-dev thanks!
I added tests for Flink. Due to the fact that Spark runner invokes the code
in run() method and creates SparkContext there, I had some trouble with
creating similar tests for Spark too so i didn't submit them in this PR. Maybe
we can do this later. I got the following error when I run similar tests:
> Cannot reuse spark context with different spark master URL. Existing:
local[1], requested: spark://localhost:7077.
I tried to reuse the context (with `ReuseContextRule.java` class). I also
tried to stop the context somehow but all this lead me nowhere. The code I used
is here:
https://github.com/apache/beam/compare/master...lgajowy:spark-integration-tests-2?expand=1#diff-9336eb87a4aea9ba0f254a1318f1fc90
@mxm @aromanenko-dev could you take a look again?
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
Issue Time Tracking
-------------------
Worklog Id: (was: 145811)
Time Spent: 3.5h (was: 3h 20m)
> Add ability to stage directories with compiled classes to Spark
> ---------------------------------------------------------------
>
> Key: BEAM-3371
> URL: https://issues.apache.org/jira/browse/BEAM-3371
> Project: Beam
> Issue Type: Sub-task
> Components: runner-spark
> Reporter: Lukasz Gajowy
> Assignee: Jean-Baptiste Onofré
> Priority: Minor
> Time Spent: 3.5h
> Remaining Estimate: 0h
>
> This one is basically the same issue as
> [this Flink's one|https://issues.apache.org/jira/browse/BEAM-3370], except
> of two things:
> - a detection of files to stage has to be provided in Spark, which is already
> being developed [here|https://issues.apache.org/jira/browse/BEAM-981]
> - the test execution is not interrupted by FileNotFoundException but by *the
> effect* of the directory not being staged (absence of test classes on the
> Spark's classpath, hence ClassNotFoundException).
> Again, this probably could be resolved analogously as in flink, while
> BEAM-981 issue is resolved.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
