SparkJobServerClient
SparkJobServerClient copied to clipboard
Java Client of the Spark Job Server implementing the arranged Rest APIs
Bumps httpclient from 4.5 to 4.5.13. [](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores) Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a...
Bumps commons-io from 2.5 to 2.7. [](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores) Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a...
Bumps [junit](https://github.com/junit-team/junit4) from 4.12 to 4.13.1. Release notes Sourced from junit's releases. JUnit 4.13.1 Please refer to the release notes for details. JUnit 4.13 Please refer to the release notes...
Bumps commons-beanutils from 1.8.0 to 1.9.2. [](https://help.github.com/articles/configuring-automated-security-fixes) Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a...
hello, I see the code you have added user name and account login, when release version using user name and password,as below: private String getBasicAuthHeader(){ if (isNotEmpty(this.jobServerUsername) && this.jobServerPassword !=...
There is sometimes an error while getting job status : 2018-05-18 08:29:46,557 [pool-5-thread-1] ERROR [com.bluebreezecf.tools.sparkjobserver.api.SparkJobServerClientImpl] - Error occurs when trying to get information of the target job: java.lang.NullPointerException at com.bluebreezecf.tools.sparkjobserver.api.SparkJobServerClientImpl.parseResult(SparkJobServerClientImpl.java:577)...
When I use this method. my params is 'xxx.jar and appName',but no pass One of these two conditions should be met, not both,right?
I am new to this, How can run this the example code given, What are the softwares needed like tomcat, to execute that example. I have spark running in a...
I used the following method to submit tasks:public SparkJobResult startJob(String data, Map params) throws SparkJobServerClientException.I set the parameter data, like this:input.string=20171202142711145423 20171202142722193966 hdfs://ip:9090/user/ethinkops/ p1512120681406_Auto_2 /home/ethinkops/.But I got the following error:...
When I run the method client.getJobResult(jobId), the response is `{ "duration": "22.278 secs", "classPath": "events_introduction", "startTime": "2017-11-05T21:56:03.104+08:00", "context": "43ec02b5-events_introduction", "status": "FINISHED", "jobId": "6372e979-3a4c-4b4b-b155-8815dcc3310f" }` however, the 'result' field is missing....