Comments (4)
Hi Yitong,
Thanks for your interest in the project! I have unfortunately not tried this with YARN, and I personally have never used YARN before. I do think it would be very interesting to get it to work with YARN, so I'll read up on it and see what needs to be done to make it work. However, given the complexity of something like YARN, and my total lack of experience with it, I can't give an accurate time estimate on when this will be completed.
If you find the time yourself to make it work with YARN, I'd be more than happy to look at pull requests as well.
from glint.
HI @rjagerman
Not sure you noticed me before, and I have used glint as main parameter server tech solution for a while, and it works well.
And later I will put out some modifies on glint, including the yarn patch which will ensure the glint could be run on yarn like a yarn application.
And I have a failover problem. When I push a lot of data at the same time (10billion vector), the pull or push will timeout and the paritialServer will cashed silence. I am working on adding an failover method for partialServers and have you any idea about failover?
These days very busy because I am working on an Internet Corp, when I get rest, I will fork glint codes and add my patch carefully, could you please review it? Thanks.
from glint.
Hi,
And later I will put out some modifies on glint, including the yarn patch which will ensure the glint could be run on yarn like a yarn application.
Thanks, that sounds great, I look forward to it! Just submit the pull request when you are ready and I'll review it.
And I have a failover problem. When I push a lot of data at the same time (10billion vector), the pull or push will timeout and the paritialServer will cashed silence. I am working on adding an failover method for partialServers and have you any idea about failover?
Failover is something I'm very interested in, but the underlying problem of the crashes is much deeper. Since we use Akka's message-based communication there is no real back pressure and it's very easy to keep sending messages causing the parameter servers to eventually fail. To solve this problem, we need to somehow limit the communication which requires some form of synchronous blocking to stop the client from sending too much stuff.
I previously used some very crude heuristics which limits the number of open pull/push requests to a fixed amount via a semaphore (like in GlintLDA). This does stabilize and prevents crashes but also reduces our CPU utilization because we are blocking/waiting at times. Tuning the optimal number of open requests remains very problem-specific and hardware-specific and is a nightmare.
I'm currently looking into the new version of Akka remoting (codename Artery). The performance gains should be quite substantial. In particular this is interesting for the use-case of back-pressure:
Isolation of internal control messages from user messages improving stability and reducing false failure detection in case of heavy traffic by using a dedicated subchannel.
Upgrading Akka to this new remoting does require some fixes to protocol compatibility and serialization that I will have to look into.
from glint.
Hi @rjagerman, I just have finish a very simple yarn application which could running glint on it, and Later, I could share some performance data about glint on huge vector, because we already have used it as main parameter server solution. And it works well.
Thanks
from glint.
Related Issues (20)
- Actor Not Found
- Can glint support SSP mode HOT 3
- PullFailedException in large dataset HOT 8
- Implementation bug in ColumnIterator? HOT 15
- A question about glint HOT 4
- Rework of Glint internals HOT 7
- Struggling with data transfer / actor disassociated HOT 5
- Not able to pull matrix slice with rows != cols HOT 5
- Look into Akka Artery
- Random init HOT 1
- why make "push" as an “accumulator” rather than “replacer”? HOT 6
- BigMatrix should support push(rows)
- Can glint support BigInt type? HOT 1
- Does glint support (key, value) store ? HOT 1
- BigMatrix push and pull is high network consumption HOT 1
- Can not create Glint Client in Apache Spark HOT 4
- Akka Actor Error when initializing Glint Client HOT 2
- cluster conf example
- Got runtime issues when using spark-shell HOT 2
- Need Save Operation to store the big vector/matrix into HDFS HOT 1
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from glint.