Skip to content

[Bug] [seatunnel-engine] close pending status job failed #8564

@Xuzhengz

Description

@Xuzhengz

Search before asking

  • I had searched in the issues and found no similar issues.

What happened

close pending status job failed

SeaTunnel Version

2.3.9 and dev

SeaTunnel Config

{
    "env": {
        "job.mode": "batch"
        "parallelism" : 50   // 大于slot数量

    },
    "source": [
        {
            "plugin_name": "FakeSource",
            "plugin_output": "fake",
            "row.num": 100,
            "schema": {
                "fields": {
                    "name": "string",
                    "age": "int",
                    "card": "int"
                }
            }
        }
    ],
    "transform": [
    ],
    "sink": [
        {
            "plugin_name": "Console",
            "plugin_input": ["fake"]
        }
    ]
}

Running Command

bin/seatunnel.sh -c demo.json

Error Exception

pending,but close job failed

Zeta or Flink or Spark Version

2.3.9 and dev

Java or Scala Version

1.8

Screenshots

Image

![Image](https://github.com/user-attachments/assets/a0f76830-4a59-4809-ab

Image

69-de57f8d738c1)

Are you willing to submit PR?

  • Yes I am willing to submit a PR!

Code of Conduct

Metadata

Metadata

Assignees

No one assigned

    Labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions