Re: Job Stealing node not stealing jobs

2019-09-10 Thread Pascoe Scholle
sizes. > > Regards, > Stephen > > On 10 Sep 2019, at 10:19, Pascoe Scholle > wrote: > > Hello, > > is there any update on this? > > We have not been able to resolve this issue > > Kind regards > > > On Wed, 04 Sep 2019 at 07:44, Pascoe Scholle >

Re: Job Stealing node not stealing jobs

2019-09-10 Thread Pascoe Scholle
Hello, is there any update on this? We have not been able to resolve this issue Kind regards On Wed, 04 Sep 2019 at 07:44, Pascoe Scholle wrote: > Hi, > > attached a small scala project. Just set the build path to src after > building and compiling with sbt. > > We want to

Re: Job Stealing node not stealing jobs

2019-09-03 Thread Pascoe Scholle
began executions of some tasks in > public pool but just do it longer then faster one. > > Could you please share your full reproducer for investigation? > > BR, > Andrei > > 9/3/2019 1:43 PM, Pascoe Scholle пишет: > > HI there, > > > > I have asked this qu

Job Stealing node not stealing jobs

2019-09-03 Thread Pascoe Scholle
HI there, I have asked this question, however I asked it under a different and resolved topic, so I posted the quest under a more suitable title. I hope thats ok We have tried to configure two compute server nodes one of which is running on a weaker machine. The node running on the more powerful

Re: Load balancing and executing python processes

2019-08-30 Thread Pascoe Scholle
Just some more info. I use a ContinousMapper within a task that sends off these jobs. Can this maybe be the reason? On Fri, 30 Aug 2019 at 21:49, Pascoe Scholle wrote: > Hi Illya, > > So I have exciting news. Like you say we have to configure some of the > nodes manually and I ha

Re: Load balancing and executing python processes

2019-08-30 Thread Pascoe Scholle
heMode.PARTITIONED); cfg.setCacheConfiguration(cacheConfig); cfg.setPeerClassLoadingEnabled(true); cfg.setFailoverSpi(failoverSpi); cfg.setCollisionSpi(jobStealer); cfg.setUserAttributes(Map("compute.node" -> true)); """""""""&quo

Load balancing and executing python processes

2019-08-29 Thread Pascoe Scholle
Hi, I have a question regarding the workings of the load balancer and running prcesses which are outside the jvm. We have a python commandline tool which is used for processing big data. The tool is highly optimized and is able to instantly load data into ram. Some data can be as large as 20 Gb.

Re: Question on submitted post

2019-08-26 Thread Pascoe Scholle
ll reproducer on github would be ideal. > > Stan > > On Mon, Aug 26, 2019 at 4:09 PM Pascoe Scholle > wrote: > >> Hi Stan, >> >> Thanks for your response. I have tried this, but it has not fixed the >> issue. >> The grpc server class was moved into the

Re: Question on submitted post

2019-08-26 Thread Pascoe Scholle
pass gRPC to the service instance > - add an init() method implementation to your service > - in your init() start your gRPC server > > Stan > > On Thu, Aug 22, 2019 at 10:52 AM Pascoe Scholle > wrote: > >> Hi there, >> >> How long does it usually take, for

Question on submitted post

2019-08-22 Thread Pascoe Scholle
Hi there, How long does it usually take, for a post to be seen on the forum? Maybe I made a mistake so I will provide my question here. Excuse me if I am being impatient: = Good afternoon everyone, I have recently run into an issue and I think the problem

Re: Task flow implementation question

2019-05-30 Thread Pascoe Scholle
work in your case. > > > Thanks, > Pavel > > чт, 30 мая 2019 г. в 08:34, Pascoe Scholle : > >> Hello everyone, >> >> So I am trying to put together a task flow chain. A task can have any >> number of inputs and outputs, what I would call ports and each

Task flow implementation question

2019-05-29 Thread Pascoe Scholle
Hello everyone, So I am trying to put together a task flow chain. A task can have any number of inputs and outputs, what I would call ports and each port has a value stored in the cache. A task can have numerous predecessors. For example say I have two nodes which can be executed in parallel: on