I believe you owe me an apology I dont want your thanks. Where is Jeff's advice. LIAR
I only see him giving you config properties based on your cock and bull theories. There're 2 properties you can set to control the port range: zeppelin.server.rpc.portRange zeppelin.interpreter.rpc.portRange On Mon, 4 May 2020, 04:05 Ravi Pullareddy, <ravi.pullare...@minlog.com.au> wrote: > Guys > > > > Thanks for your unsolicited advice. > > > > Bye > > > > *From:* Som Lima <somplastic...@gmail.com> > *Sent:* Monday, 4 May 2020 12:46 PM > *To:* users@zeppelin.apache.org > *Subject:* Re: Job manager URI rpc address:port > > > > Jeff did not know which flavour of linux I was using when he gave the > installation instructions. > > > > That in itself should tell you your OS theory was silly. > > > > On Mon, 4 May 2020, 02:04 Ravi Pullareddy, <ravi.pullare...@minlog.com.au> > wrote: > > Hi Som > > > > Looks like you are getting confused with this issue. It is very different > to what Jeff has explained there. Setting 0.0.0.0 is not the solution for > everything. There was no issue with accessing Zeppelin from Windows as WSL > is linux kernel running within Windows system. However, the issue arose > when the interpreter server started. The interpreter creates a run time > server when a job is submitted. The run time server gets the IpAddress of > the host server by using Java.net.IpAddress and thereby was getting wrong > IpAddress because of two network addresses on the machine. > > > > Let us say if a machine has multiple network cards and you want Zeppelin > to be bound to a specific IpAddress then 0.0.0.0 is not the solution. One > has to get a clear understanding of what we are trying to achieve. In any > case from Jeff explanation, I got to understand that Zeppelin spins up > runtime interpreter server that may not line up with Zeppelin server and > that is the issue. Although in my instance changing it to 0.0.0.0 fixed the > issue in other instances it might not be of help. > > > > Thanks > > Ravi Pullareddy > > > > *From:* Som Lima <somplastic...@gmail.com> > *Sent:* Monday, 4 May 2020 10:48 AM > *To:* users@zeppelin.apache.org > *Subject:* Re: Job manager URI rpc address:port > > > > Here are the instructions . Go to getting started link. > > > > It took me hours first time and I had many errors because I had spark > installed earlier on same machine. > > > > Then when I switched flink remote from client to server and server to > client > > it only took me five minutes because this time it was clean install. > > On Sun, 19 Apr 2020, 14:58 Jeff Zhang, <zjf...@gmail.com> wrote: > > Hi Som, > > > > You can take a look at flink on zeppelin, in zeppelin you can connect to a > remote flink cluster via a few configuration, and you don't need to worry > about the jars. Flink interpreter will ship necessary jars for you. Here's > a list of tutorials. > > > > 1) Get started https://link.medium.com/oppqD6dIg5 > <https://t.co/PTouUYYTrv?amp=1> 2) Batch > https://link.medium.com/3qumbwRIg5 <https://t.co/Yo9QAY0Joj?amp=1> 3) > Streaming https://link.medium.com/RBHa2lTIg5 > <https://t.co/sUapN40tvI?amp=1> 4) Advanced usage > https://link.medium.com/CAekyoXIg5 <https://t.co/MXolULmafZ?amp=1> > > > > > > Zahid Rahman <zahidr1...@gmail.com> 于2020年4月19日周日 下午7:27写道： > > Hi Tison, > > > > I think I may have found what I want in example 22. > > > https://www.programcreek.com/java-api-examples/?api=org.apache.flink.configuration.Configuration > > > > I need to create Configuration object first as shown . > > > > Also I think flink-conf.yaml file may contain configuration for client > rather than server. So before starting is irrelevant. > > I am going to play around and see but if the Configuration class allows me > to set configuration programmatically and overrides the yaml file then that > would be great. > > > > > > > > On Sun, 19 Apr 2020, 11:35 Som Lima, <somplastic...@gmail.com> wrote: > > Thanks. > > flink-conf.yaml does allow me to do what I need to do without making any > changes to client source code. > > > > But > > RemoteStreamEnvironment constructor expects a jar file as the third > parameter also. > > > > *RemoteStreamEnvironment > <https://ci.apache.org/projects/flink/flink-docs-release-1.7/api/java/org/apache/flink/streaming/api/environment/RemoteStreamEnvironment.html#RemoteStreamEnvironment-java.lang.String-int-java.lang.String...->* > (*String* > <http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true> > host, > int port, *String* > <http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true> > ... jarFiles) > > Creates a new RemoteStreamEnvironment that points to the master > (JobManager) described by the given host name and port. > > > > On Sun, 19 Apr 2020, 11:02 tison, <wander4...@gmail.com> wrote: > > You can change flink-conf.yaml "jobmanager.address" or "jobmanager.port" > options before run the program or take a look at RemoteStreamEnvironment > which enables configuring host and port. > > > > Best, > > tison. > > > > > > Som Lima <somplastic...@gmail.com> 于2020年4月19日周日 下午5:58写道： > > Hi, > > > > After running > > $ ./bin/start-cluster.sh > > The following line of code defaults jobmanager to localhost:6123 > > > > final ExecutionEnvironment env = Environment.getExecutionEnvironment(); > > > > which is same on spark. > > > > val spark = > SparkSession.builder.master(local[*]).appname("anapp").getOrCreate > > > > However if I wish to run the servers on a different physical computer. > > Then in Spark I can do it this way using the spark URI in my IDE. > > > > Conf = > SparkConf().setMaster("spark://<hostip>:<port>").setAppName("anapp") > > > > Can you please tell me the equivalent change to make so I can run my > servers and my IDE from different physical computers. > > > > > > > > > > > > > > > > > > > > > > > > > > > > > -- > > Best Regards > > Jeff Zhang > >
