Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

Appearance settings
Discussion options

Description:

After starting the Celeborn Worker, the following issues occur:

  1. Worker not getting resources (Slots)
    The logs show:

    maxSlots: 0
    activeSlots: 0
    

    This indicates that the Worker is not being allocated any resources, preventing it from executing any tasks.

  2. Incorrect disk space information
    In the heartbeat message sent from the Worker to the Master, the disk space shows:

    usableSpace: 8.0 EiB
    totalSpace: 0.0 B
    

    This suggests that the Worker is not correctly detecting the disk space, which may indicate a problem with the storage path or mount.

  3. No running Shuffle tasks
    The logs show:

    committed shuffles: 0
    running applications: 0
    

    This indicates that no tasks are being submitted to the Worker, likely due to insufficient resources or failed shuffle allocation.

  4. Memory management is normal, but no Shuffle operations are taking place
    Even though memory usage is normal:

    Direct memory usage: 4.0 MiB/1024.0 MiB
    

    No shuffle operations are occurring due to the lack of available resources.

Steps to Reproduce:

  1. Start the Celeborn Worker.
  2. Start a Spark job that performs a shuffle operation.
  3. Check the logs of the Celeborn Worker, paying attention to the maxSlots, activeSlots, usableSpace, totalSpace, and committed shuffles fields.

Log Summary:

Here are the relevant log entries:

25/01/21 16:57:32,635 DEBUG [worker-disk-checker] LocalDeviceMonitor: Device check start
25/01/21 16:57:34,108 INFO [worker-memory-manager-reporter] MemoryManager: Direct memory usage: 4.0 MiB/1024.0 MiB, disk buffer size: 0.0 B, sort memory size: 0.0 B, read buffer size: 0.0 B, memory file storage size: 0.0 B
25/01/21 16:57:37,897 INFO [worker-forward-message-scheduler] StorageManager: Updated diskInfos:
25/01/21 16:57:37,898 DEBUG [worker-forward-message-scheduler] MasterClient: Send rpc message HeartbeatFromWorker(21.102.91.135,38565,35711,40333,42329, Stream(DiskInfo(maxSlots: 0, committed shuffles 0, running applications 0, shuffleAllocations: Map(), mountPoint: HDFS, usableSpace: 8.0 EiB, totalSpace: 0.0 B , avgFlushTime: 999999 ns, avgFetchTime: 999999 ns, activeSlots: 0, storageType: HDFS) status: HEALTHY dirs , ?),{},[],{}, false,WorkerStatus{state= Normal, stateStartTime=1737448232150},688489b2-4a4b-4840-bb9f-78bfd46031b8#54)

Expected Result:

We expect the Celeborn Worker to correctly allocate resources, detect disk space, and handle shuffle tasks.

Actual Result:

The Worker is not getting any resources, the disk space is incorrectly detected, and no shuffle tasks are being processed.

You must be logged in to vote

Replies: 0 comments

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
1 participant
Morty Proxy This is a proxified and sanitized view of the page, visit original site.