unsubscribe

2020-09-22 Thread arvindsheri...@northwesternmutual.com




This e-mail and any attachments may contain confidential information of 
Northwestern Mutual. If you are not the intended recipient of this message, be 
aware that any disclosure, copying, distribution or use of this e-mail and any 
attachments is prohibited. If you have received this e-mail in error, please 
notify Northwestern Mutual immediately by returning it to the sender and delete 
all copies from your system. Please be advised that communications with {SECURE 
MESSAGE} in the subject line have been sent using a secure messaging system. 
Communications that do not have this tag may not be secure and could be 
observed by a third party. Our commitment to privacy: At Northwestern Mutual, 
your privacy is important to us. For more information about our privacy 
practices, please review our privacy notices. 




Re: [EXTERNAL] Re: git commit user is always zeppelin

2022-01-21 Thread arvindsheri...@northwesternmutual.com
Unsubscribe

Arvind Sherigar

 

On 1/21/22, 12:06 PM, "Jim Lola"  wrote:

Unsubscribe

On Fri, Jan 21, 2022 at 9:44 AM Jason-Morries Adam
 wrote:
>
> Hi,
>
> ticket created here: 
https://urldefense.com/v3/__https://issues.apache.org/jira/browse/ZEPPELIN-5640__;!!IqRYp603ny2KL2MbNA!jUl3aTPNOWwyFFyuAt4U8vOPd3cP7PejIV9LFkjJ1N7KRd9J1FokoYuw0geFuRTs3Jk5RmPVytoQ$
 
>
> Jeff Zhang  schrieb am Fr., 21. Jan. 2022, 12:51:
>>
>> I don't think it is supported now, please file a ticket for this feature.
>>
>> On Fri, Jan 21, 2022 at 6:17 PM André Weidemann  
wrote:
>>>
>>> Hi,
>>>
>>> we have set up Zeppelin Notebook storage with Git integration. It works
>>> fine so far.
>>> The only thing that is sub-optimal, is the fact, that every commit is
>>> done as user zeppelin. The commit log then looks like this:
>>>
>>>  > commit d80ab9a7e998f3847a47dd4b052a03a3bb12f014 (HEAD -> master)
>>>  > Author: zeppelin 
>>>  > Date:   Thu Jan 20 16:01:25 2022 +0100
>>>  >
>>>  > 1st test commit
>>>
>>> So when multiple users are working with Zeppelin it is difficult to see
>>> who committed a change.
>>> Is there perhaps a way to make Zeppelin commit as the current user?
>>>
>>> Thanks
>>>   André
>>
>>
>>
>> --
>> Best Regards
>>
>> Jeff Zhang




This e-mail and any attachments may contain confidential information of 
Northwestern Mutual. If you are not the intended recipient of this message, be 
aware that any disclosure, copying, distribution or use of this e-mail and any 
attachments is prohibited. If you have received this e-mail in error, please 
notify Northwestern Mutual immediately by returning it to the sender and delete 
all copies from your system. Please be advised that communications with {SECURE 
MESSAGE} in the subject line have been sent using a secure messaging system. 
Communications that do not have this tag may not be secure and could be 
observed by a third party. Our commitment to privacy: At Northwestern Mutual, 
your privacy is important to us. For more information about our privacy 
practices, please review our privacy notices. 




Issue working with R/SparkR

2019-04-28 Thread arvindsheri...@northwesternmutual.com
https://zeppelin.apache.org/docs/0.8.1/interpreter/r.html

I am trying out a basic command as shown in the link above and I get the 
following error. Any help will be appreciated.

%spark.r
2+2

java.lang.ClassCastException: scala.Tuple2 cannot be cast to java.lang.Integer 
at scala.runtime.BoxesRunTime.unboxToInt(BoxesRunTime.java:101) at 
org.apache.spark.SparkRBackend$.init(SparkRBackend.scala:42) at 
org.apache.spark.SparkRBackend.init(SparkRBackend.scala) at 
org.apache.zeppelin.spark.SparkRInterpreter.open(SparkRInterpreter.java:88) at 
org.apache.zeppelin.interpreter.LazyOpenInterpreter.open(LazyOpenInterpreter.java:69)
 at 
org.apache.zeppelin.interpreter.remote.RemoteInterpreterServer$InterpretJob.jobRun(RemoteInterpreterServer.java:616)
 at org.apache.zeppelin.scheduler.Job.run(Job.java:188) at 
org.apache.zeppelin.scheduler.FIFOScheduler$1.run(FIFOScheduler.java:140) at 
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at 
java.util.concurrent.FutureTask.run(FutureTask.java:266) at 
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
 at 
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
 at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) 
at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) 
at java.lang.Thread.run(Thread.java:748)

Thanks
Arvind



This e-mail and any attachments may contain confidential information of 
Northwestern Mutual. If you are not the intended recipient of this message, be 
aware that any disclosure, copying, distribution or use of this e-mail and any 
attachments is prohibited. If you have received this e-mail in error, please 
notify Northwestern Mutual immediately by returning it to the sender and delete 
all copies from your system. Please be advised that communications with {SECURE 
MESSAGE} in the subject line have been sent using a secure messaging system. 
Communications that do not have this tag may not be secure and could be 
observed by a third party. Thank you for your cooperation. 




Re: [EXTERNAL] Re: Issue working with R/SparkR

2019-04-29 Thread arvindsheri...@northwesternmutual.com
DataStax distribution version 6.7

From: Jeff Zhang 
Reply-To: "users@zeppelin.apache.org" 
Date: Sunday, April 28, 2019 at 11:01 PM
To: users 
Subject: [EXTERNAL] Re: Issue working with R/SparkR

Which spark version do you use ?

arvindsheri...@northwesternmutual.com<mailto:arvindsheri...@northwesternmutual.com>
 
mailto:arvindsheri...@northwesternmutual.com>>
 于2019年4月29日周一 上午10:23写道:
https://zeppelin.apache.org/docs/0.8.1/interpreter/r.html<https://urldefense.proofpoint.com/v2/url?u=https-3A__zeppelin.apache.org_docs_0.8.1_interpreter_r.html&d=DwMFaQ&c=oBIBfyrVf5fVcKOfTTdY_d7WoqYVCfQW6jezwvkj5jg&r=2ozYxxrO5uy6i7CP-nMc0wdBTNfkSGa4age9CqpA0b3LBZZ_7ZITfmsqWijkzea1&m=R9XdjivdKYjYFmH_RUlm1VSWtiBcfNWHMgP6hbxtMJI&s=-p1MV9gJn5XAIepg-nkje92IM9e_kPaXsv8m7AYXSnA&e=>

I am trying out a basic command as shown in the link above and I get the 
following error. Any help will be appreciated.

%spark.r
2+2

java.lang.ClassCastException: scala.Tuple2 cannot be cast to java.lang.Integer 
at scala.runtime.BoxesRunTime.unboxToInt(BoxesRunTime.java:101) at 
org.apache.spark.SparkRBackend$.init(SparkRBackend.scala:42) at 
org.apache.spark.SparkRBackend.init(SparkRBackend.scala) at 
org.apache.zeppelin.spark.SparkRInterpreter.open(SparkRInterpreter.java:88) at 
org.apache.zeppelin.interpreter.LazyOpenInterpreter.open(LazyOpenInterpreter.java:69)
 at 
org.apache.zeppelin.interpreter.remote.RemoteInterpreterServer$InterpretJob.jobRun(RemoteInterpreterServer.java:616)
 at org.apache.zeppelin.scheduler.Job.run(Job.java:188) at 
org.apache.zeppelin.scheduler.FIFOScheduler$1.run(FIFOScheduler.java:140) at 
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at 
java.util.concurrent.FutureTask.run(FutureTask.java:266) at 
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
 at 
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
 at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) 
at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) 
at java.lang.Thread.run(Thread.java:748)

Thanks
Arvind


This e-mail and any attachments may contain confidential information of 
Northwestern Mutual. If you are not the intended recipient of this message, be 
aware that any disclosure, copying, distribution or use of this e-mail and any 
attachments is prohibited. If you have received this e-mail in error, please 
notify Northwestern Mutual immediately by returning it to the sender and delete 
all copies from your system. Please be advised that communications with {SECURE 
MESSAGE} in the subject line have been sent using a secure messaging system. 
Communications that do not have this tag may not be secure and could be 
observed by a third party. Thank you for your cooperation.



--
Best Regards

Jeff Zhang



This e-mail and any attachments may contain confidential information of 
Northwestern Mutual. If you are not the intended recipient of this message, be 
aware that any disclosure, copying, distribution or use of this e-mail and any 
attachments is prohibited. If you have received this e-mail in error, please 
notify Northwestern Mutual immediately by returning it to the sender and delete 
all copies from your system. Please be advised that communications with {SECURE 
MESSAGE} in the subject line have been sent using a secure messaging system. 
Communications that do not have this tag may not be secure and could be 
observed by a third party. Thank you for your cooperation. 




Re: [EXTERNAL] Re: Issue working with R/SparkR

2019-04-29 Thread arvindsheri...@northwesternmutual.com
Ok, I talked to the DSE architect and he told me that they had to do a security 
patch (spark version example -> 2.2.2.5),  which broke this piece of zeppelin 
code - bolded.
https://github.com/apache/zeppelin/blob/735064fdc57ae958fabae85b399bb5af3cb79144/spark/interpreter/src/main/scala/org/apache/spark/SparkRBackend.scala#L34-L44

def init(version: SparkVersion) : Unit = {


val rBackendClass = classOf[RBackend]


if (version.isSecretSocketSupported) {


  val result = 
rBackendClass.getMethod("init").invoke(backend).asInstanceOf[Tuple2[Int, 
Object]]


  portNumber = result._1


  val rAuthHelper = result._2


  secret = 
rAuthHelper.getClass.getMethod("secret").invoke(rAuthHelper).asInstanceOf[String]


} else {


  portNumber = 
rBackendClass.getMethod("init").invoke(backend).asInstanceOf[Int]


}


  }



From: "arvindsheri...@northwesternmutual.com" 

Reply-To: "users@zeppelin.apache.org" 
Date: Monday, April 29, 2019 at 9:01 AM
To: "users@zeppelin.apache.org" 
Subject: Re: [EXTERNAL] Re: Issue working with R/SparkR

DataStax distribution version 6.7

From: Jeff Zhang 
Reply-To: "users@zeppelin.apache.org" 
Date: Sunday, April 28, 2019 at 11:01 PM
To: users 
Subject: [EXTERNAL] Re: Issue working with R/SparkR

Which spark version do you use ?

arvindsheri...@northwesternmutual.com<mailto:arvindsheri...@northwesternmutual.com>
 
mailto:arvindsheri...@northwesternmutual.com>>
 于2019年4月29日周一 上午10:23写道:
https://zeppelin.apache.org/docs/0.8.1/interpreter/r.html<https://urldefense.proofpoint.com/v2/url?u=https-3A__zeppelin.apache.org_docs_0.8.1_interpreter_r.html&d=DwMFaQ&c=oBIBfyrVf5fVcKOfTTdY_d7WoqYVCfQW6jezwvkj5jg&r=2ozYxxrO5uy6i7CP-nMc0wdBTNfkSGa4age9CqpA0b3LBZZ_7ZITfmsqWijkzea1&m=R9XdjivdKYjYFmH_RUlm1VSWtiBcfNWHMgP6hbxtMJI&s=-p1MV9gJn5XAIepg-nkje92IM9e_kPaXsv8m7AYXSnA&e=>

I am trying out a basic command as shown in the link above and I get the 
following error. Any help will be appreciated.

%spark.r
2+2

java.lang.ClassCastException: scala.Tuple2 cannot be cast to java.lang.Integer 
at scala.runtime.BoxesRunTime.unboxToInt(BoxesRunTime.java:101) at 
org.apache.spark.SparkRBackend$.init(SparkRBackend.scala:42) at 
org.apache.spark.SparkRBackend.init(SparkRBackend.scala) at 
org.apache.zeppelin.spark.SparkRInterpreter.open(SparkRInterpreter.java:88) at 
org.apache.zeppelin.interpreter.LazyOpenInterpreter.open(LazyOpenInterpreter.java:69)
 at 
org.apache.zeppelin.interpreter.remote.RemoteInterpreterServer$InterpretJob.jobRun(RemoteInterpreterServer.java:616)
 at org.apache.zeppelin.scheduler.Job.run(Job.java:188) at 
org.apache.zeppelin.scheduler.FIFOScheduler$1.run(FIFOScheduler.java:140) at 
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at 
java.util.concurrent.FutureTask.run(FutureTask.java:266) at 
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
 at 
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
 at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) 
at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) 
at java.lang.Thread.run(Thread.java:748)

Thanks
Arvind


This e-mail and any attachments may contain confidential information of 
Northwestern Mutual. If you are not the intended recipient of this message, be 
aware that any disclosure, copying, distribution or use of this e-mail and any 
attachments is prohibited. If you have received this e-mail in error, please 
notify Northwestern Mutual immediately by returning it to the sender and delete 
all copies from your system. Please be advised that communications with {SECURE 
MESSAGE} in the subject line have been sent using a secure messaging system. 
Communications that do not have this tag may not be secure and could be 
observed by a third party. Thank you for your cooperation.




--
Best Regards

Jeff Zhang


This e-mail and any attachments may contain confidential information of 
Northwestern Mutual. If you are not the intended recipient of this message, be 
aware that any disclosure, copying, distribution or use of this e-mail and any 
attachments is prohibited. If you have received this e-mail in error, please 
notify Northwestern Mutual immediately by returning it to the sender and delete 
all copies from your system. Please be advised that communications with {SECURE 
MESSAGE} in the subject line have been sent using a secure messaging system. 
Communications that do not have this tag may not be secure and could be 
observed by a third party. Thank you for your cooperation.




This e-mail and any attachments may contain confidential information of 
Northwestern Mutual. If you are not the intended recipient of this message, be 
aware that any disclosure, copying, distr

Re: [EXTERNAL] Re: Issue working with R/SparkR

2019-04-29 Thread arvindsheri...@northwesternmutual.com
I am doing a local fix for this problem, but I am unable to compile the code. I 
checked maven central and this jar does not exist. Am I missing something here? 
I could change the pom in the project, but wanted to make sure I don’t break 
something else.

[ERROR] Failed to execute goal on project zeppelin-beam: Could not resolve 
dependencies for project org.apache.zeppelin:zeppelin-beam:jar:0.9.0-SNAPSHOT: 
Failure to find org.apache.beam:beam-runners-flink_2.11:jar:2.0.0 in 
https://repo.maven.apache.org/maven2 was cached in the local repository, 
resolution will not be reattempted until the update interval of central has 
elapsed or updates are forced

https://mvnrepository.com/artifact/org.apache.beam/beam-runners-flink

Thanks
Arvind


From: Jeff Zhang 
Reply-To: "users@zeppelin.apache.org" 
Date: Monday, April 29, 2019 at 9:54 AM
To: users 
Subject: Re: [EXTERNAL] Re: Issue working with R/SparkR


That's right

arvindsheri...@northwesternmutual.com<mailto:arvindsheri...@northwesternmutual.com>
 
mailto:arvindsheri...@northwesternmutual.com>>
 于2019年4月29日周一 下午10:33写道:
Ok, I talked to the DSE architect and he told me that they had to do a security 
patch (spark version example -> 2.2.2.5),  which broke this piece of zeppelin 
code - bolded.
https://github.com/apache/zeppelin/blob/735064fdc57ae958fabae85b399bb5af3cb79144/spark/interpreter/src/main/scala/org/apache/spark/SparkRBackend.scala#L34-L44<https://urldefense.proofpoint.com/v2/url?u=https-3A__github.com_apache_zeppelin_blob_735064fdc57ae958fabae85b399bb5af3cb79144_spark_interpreter_src_main_scala_org_apache_spark_SparkRBackend.scala-23L34-2DL44&d=DwMFaQ&c=oBIBfyrVf5fVcKOfTTdY_d7WoqYVCfQW6jezwvkj5jg&r=2ozYxxrO5uy6i7CP-nMc0wdBTNfkSGa4age9CqpA0b3LBZZ_7ZITfmsqWijkzea1&m=p8jIjG5K5TauQWxRvMhReOCieAiUTuZCr22KAO-YRW0&s=B1shgXQUvveI8LYid8Sji-gKZDnypoDJ_AM9B-L7pow&e=>

def init(version: SparkVersion) : Unit = {


val rBackendClass = classOf[RBackend]


if (version.isSecretSocketSupported) {


  val result = 
rBackendClass.getMethod("init").invoke(backend).asInstanceOf[Tuple2[Int, 
Object]]


  portNumber = result._1


  val rAuthHelper = result._2


  secret = 
rAuthHelper.getClass.getMethod("secret").invoke(rAuthHelper).asInstanceOf[String]


} else {


  portNumber = 
rBackendClass.getMethod("init").invoke(backend).asInstanceOf[Int]


}


  }



From: 
"arvindsheri...@northwesternmutual.com<mailto:arvindsheri...@northwesternmutual.com>"
 
mailto:arvindsheri...@northwesternmutual.com>>
Reply-To: "users@zeppelin.apache.org<mailto:users@zeppelin.apache.org>" 
mailto:users@zeppelin.apache.org>>
Date: Monday, April 29, 2019 at 9:01 AM
To: "users@zeppelin.apache.org<mailto:users@zeppelin.apache.org>" 
mailto:users@zeppelin.apache.org>>
Subject: Re: [EXTERNAL] Re: Issue working with R/SparkR

DataStax distribution version 6.7

From: Jeff Zhang mailto:zjf...@gmail.com>>
Reply-To: "users@zeppelin.apache.org<mailto:users@zeppelin.apache.org>" 
mailto:users@zeppelin.apache.org>>
Date: Sunday, April 28, 2019 at 11:01 PM
To: users mailto:users@zeppelin.apache.org>>
Subject: [EXTERNAL] Re: Issue working with R/SparkR

Which spark version do you use ?

arvindsheri...@northwesternmutual.com<mailto:arvindsheri...@northwesternmutual.com>
 
mailto:arvindsheri...@northwesternmutual.com>>
 于2019年4月29日周一 上午10:23写道:
https://zeppelin.apache.org/docs/0.8.1/interpreter/r.html<https://urldefense.proofpoint.com/v2/url?u=https-3A__zeppelin.apache.org_docs_0.8.1_interpreter_r.html&d=DwMFaQ&c=oBIBfyrVf5fVcKOfTTdY_d7WoqYVCfQW6jezwvkj5jg&r=2ozYxxrO5uy6i7CP-nMc0wdBTNfkSGa4age9CqpA0b3LBZZ_7ZITfmsqWijkzea1&m=R9XdjivdKYjYFmH_RUlm1VSWtiBcfNWHMgP6hbxtMJI&s=-p1MV9gJn5XAIepg-nkje92IM9e_kPaXsv8m7AYXSnA&e=>

I am trying out a basic command as shown in the link above and I get the 
following error. Any help will be appreciated.

%spark.r
2+2

java.lang.ClassCastException: scala.Tuple2 cannot be cast to java.lang.Integer 
at scala.runtime.BoxesRunTime.unboxToInt(BoxesRunTime.java:101) at 
org.apache.spark.SparkRBackend$.init(SparkRBackend.scala:42) at 
org.apache.spark.SparkRBackend.init(SparkRBackend.scala) at 
org.apache.zeppelin.spark.SparkRInterpreter.open(SparkRInterpreter.java:88) at 
org.apache.zeppelin.interpreter.LazyOpenInterpreter.open(LazyOpenInterpreter.java:69)
 at 
org.apache.zeppelin.interpreter.remote.RemoteInterpreterServer$InterpretJob.jobRun(RemoteInterpreterServer.java:616)
 at org.apache.zeppelin.scheduler.Job.run(Job.java:188) at 
org.apache.zeppelin.scheduler.FIFOScheduler$1.run(FIFOScheduler.java:140) at 
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at 
java.util.concurrent.FutureTask.run(FutureTask.java:266) at 
java.util.concurrent.ScheduledThreadPoolExecutor$Schedul

Binary distribution of Zeppelin - Master branch

2019-05-01 Thread arvindsheri...@northwesternmutual.com
How to get a binary distribution of the master version of Zeppelin? A bug is 
fixed with this PR that I want to get. Not able to build locally on my machine, 
running into number of problems. Any help appreciated.

https://github.com/apache/zeppelin/commit/938ed0c36f03a77b9cb271c428032ef821241c00

Thanks
Arvind



This e-mail and any attachments may contain confidential information of 
Northwestern Mutual. If you are not the intended recipient of this message, be 
aware that any disclosure, copying, distribution or use of this e-mail and any 
attachments is prohibited. If you have received this e-mail in error, please 
notify Northwestern Mutual immediately by returning it to the sender and delete 
all copies from your system. Please be advised that communications with {SECURE 
MESSAGE} in the subject line have been sent using a secure messaging system. 
Communications that do not have this tag may not be secure and could be 
observed by a third party. Thank you for your cooperation.