Comments (7)
irvinlim
commented on July 2, 2024
I added some logging in process.py after line 300:
while True:
logger.info('process=%s,conn=%s,master=%s', self, conn, self._master)
if not conn and self._master:
conn = Connection(self._master, self)
logger.info('process=%s, conn=%s', self, conn)Notice how the self._master variable is always None for MesosOperatorMasterDriver:
framework_1 | 2018-07-27 18:04:40.172|INFO|process=<pymesos.scheduler.MesosSchedulerDriver object at 0x7fbf17bea450>,conn=None,master=None
framework_1 | 2018-07-27 18:04:40.177|INFO|process=<pymesos.operator_v1.MesosOperatorMasterDriver object at 0x7fbf17bea650>,conn=None,master=None
framework_1 | 2018-07-27 18:04:40.183|INFO|process=<pymesos.scheduler.MesosSchedulerDriver object at 0x7fbf17bea450>,conn=None,master=mesos-master:5050
framework_1 | 2018-07-27 18:04:40.187|INFO|process=<pymesos.scheduler.MesosSchedulerDriver object at 0x7fbf17bea450>, conn=<pymesos.process.Connection object at 0x7fbf17beaf10>
mesos-master_1 | I0727 10:04:40.189290 15 http.cpp:1185] HTTP POST for /master/api/v1/scheduler from 172.26.0.5:49914
mesos-master_1 | I0727 10:04:40.189538 15 master.cpp:2610] Received subscription request for HTTP framework 'scheduler'
mesos-master_1 | I0727 10:04:40.189677 15 master.cpp:2745] Subscribing framework 'scheduler' with checkpointing disabled and capabilities [ TASK_KILLING_STATE, GPU_RESOURCES ]
mesos-master_1 | I0727 10:04:40.189718 15 master.cpp:7195] Updating framework 0bc93f09-207f-4528-9b20-d2f0527286c7-0000 (scheduler) with roles { } suppressed
framework_1 | 2018-07-27 18:04:40.188|INFO|process=<pymesos.scheduler.MesosSchedulerDriver object at 0x7fbf17bea450>,conn=<pymesos.process.Connection object at 0x7fbf17beaf10>,master=mesos-master:5050
framework_1 | 2018-07-27 18:04:40.190|INFO|process=<pymesos.scheduler.MesosSchedulerDriver object at 0x7fbf17bea450>,conn=<pymesos.process.Connection object at 0x7fbf17beaf10>,master=mesos-master:5050
framework_1 | 2018-07-27 18:04:40.195|INFO|scheduler_re_registered|master={'hostname': 'mesos-master', 'port': 5050, 'version': u'1.5.0'}
framework_1 | 2018-07-27 18:04:40.195|INFO|process=<pymesos.scheduler.MesosSchedulerDriver object at 0x7fbf17bea450>,conn=<pymesos.process.Connection object at 0x7fbf17beaf10>,master=mesos-master:5050
from pymesos.
ariesdevil
commented on July 2, 2024
I reproduce this problem with operator_v1.py in examples. I notice that _send is failed only if try to connect mesos slave directly. This's what you mean?
from pymesos.
irvinlim
commented on July 2, 2024
See https://github.com/irvinlim/pymesos-0.3.4-bugrepro for what I mean. The operator is not able to subscribe to any events when using version 0.3.4.
Using the example code, I connected to the master directly with python operator_v1.py mesos-master:5050.
from pymesos.
ariesdevil
commented on July 2, 2024
Thanks very for your bug report repo.
from pymesos.
irvinlim
commented on July 2, 2024
Thank you for the fix! π
Can I get you to publish a new version of the package when you can? Thank you!
from pymesos.
ariesdevil
commented on July 2, 2024
Done (https://github.com/douban/pymesos/releases/tag/0.3.5)
from pymesos.
irvinlim
commented on July 2, 2024
@ariesdevil ε€θ°’δΊπ
from pymesos.
Related Issues (20)
- Using 'offer_id' instead of 'inverse_offer_id' in RescindInverseOffer
- Process.start() method does not call Process._notify() HOT 7
- Missing comma in list.
- missing kazoo dependency HOT 5
- Exponential backoff for executors incompatible with default & max executor_reregistration_timeout HOT 1
- Add support for HTTPS HOT 2
- Add support for executor authentication HOT 1
- Add specific timeout for http requests HOT 3
- pymesos doesn't install on python 3.7 HOT 5
- Ability to run 10,000 tasks HOT 1
- Pymesos doesn't install properly on python3.11 due to http_parser
- python version, is python2 and python3 compatible? HOT 2
- Scheduler failover flag is unsettable HOT 13
- Socket errors are not handled properly which is resulting in unexpected behavior HOT 2
- how do i get status of a task from scheduler? HOT 3
- Custom field on update dictionary not working HOT 2
- Error parsing `mins` and `ns` time units since items()
- Framework does not get HeartBeats HOT 1
- Timeout for connection refused errors?
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 pymesos.