New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

This PR should fix broken integtest #56

Merged
merged 2 commits into from Oct 23, 2017
Jump to file or symbol
Failed to load files and symbols.
+7 −4
Diff settings

Always

Just for now

View
@@ -43,3 +43,4 @@ hs_err_pid*
metastore_db/
tpch
.java-version
View
@@ -3,4 +3,8 @@
BASEDIR=$(dirname "$0")
CLASS="com.pingcap.spark.TestFramework"
java -Dtest.mode=Load -cp ${BASEDIR}/conf:${BASEDIR}/lib/* $CLASS
java -Dtest.mode=Load -cp ${BASEDIR}/conf:${BASEDIR}/lib/* $CLASS
echo "If you have not load tpch data yet, please execute following command"
echo "cd tpch/scripts"
echo "bash genandloadalldata.sh"
@@ -27,14 +27,12 @@ import scala.collection.mutable.ArrayBuffer
class SparkWrapper(prop: Properties) extends LazyLogging {
private val KeyPDAddress = "pd.addrs"
private val spark = SparkSession
.builder()
.appName("TiSpark Integration Test")
.getOrCreate()
val ti = new TiContext(spark, getOrThrow(prop, KeyPDAddress).split(",").toList)
val ti = new TiContext(spark)
def init(databaseName: String): Unit = {
logger.info("Mapping database: " + databaseName)
ProTip! Use n and p to navigate between commits in a pull request.