-
Notifications
You must be signed in to change notification settings - Fork 119
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
Fix maven assembly plugin configuration #535
Fix maven assembly plugin configuration #535
Conversation
@@ -57,6 +57,7 @@ | |||
<plugin> | |||
<artifactId>maven-assembly-plugin</artifactId> | |||
<configuration> | |||
<tarLongFileMode>posix</tarLongFileMode> |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Здесь это не нужно
@@ -44,6 +44,7 @@ | |||
<plugin> | |||
<artifactId>maven-assembly-plugin</artifactId> | |||
<configuration> | |||
<tarLongFileMode>posix</tarLongFileMode> |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Здесь это не нужно
@@ -14,14 +14,15 @@ private[spark] class YTsaurusClusterApplication extends SparkApplication with Lo | |||
|
|||
override def start(args: Array[String], conf: SparkConf): Unit = { | |||
val masterURL = conf.get("spark.master") | |||
val ytProxy = YTsaurusUtils.parseMasterUrl(masterURL) | |||
val ytProxy = conf.get("spark.hadoop.yt.clientProxy", YTsaurusUtils.parseMasterUrl(masterURL)) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Протекло из другого ПР
@@ -202,6 +202,9 @@ | |||
<groupId>org.apache.maven.plugins</groupId> | |||
<artifactId>maven-assembly-plugin</artifactId> | |||
<version>3.1.0</version> | |||
<configuration> |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
В yt/spark/spark/* мы не принимаем доработки, т.к. скоро это будет удалено
@@ -96,7 +96,7 @@ object PythonRunner { | |||
try { | |||
val process = builder.start() | |||
|
|||
new RedirectThread(process.getInputStream, System.out, "redirect output").start() | |||
new RedirectThread(process.getInputStream, System.err, "redirect output").start() |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Я это сделаю в ближайшее время немного другим способом, войдёт в ближайший релиз.
848bf12
to
3ae5956
Compare
Partly implemented in another commits, partly declined because of removal of Spark fork |
No description provided.