apache / seatunnel

SeaTunnel is a next-generation super high-performance, distributed, massive data integration tool.
https://seatunnel.apache.org/
Apache License 2.0
7.79k stars 1.74k forks source link

The result was achieved, but the printed result was not successfully written #7240

Closed wxp2023 closed 1 week ago

wxp2023 commented 1 month ago

Search before asking

What happened

I am creating a new sink for the redission, and I saw that the key for the redission was successfully written, but the printed result was not successfully written;


Start Time : 2024-07-22 01:15:08 End Time : 2024-07-22 01:15:10 Total Time(s) : 1 Total Read Count : 2 Total Write Count : 0 Total Failed Count : 2


SeaTunnel Version

2.3.4

SeaTunnel Config

env {
    parallelism = 1
    job.mode = "BATCH"
}
source {
    Kafka {
      schema = {
          fields {
              measuredt = "string"
              parmvalue = "double"
              mpointId = "string"
              unitId = "string"
              id = "string"
          }
      }
      bootstrap.servers = "132.120.132.56:9092"
      topic = "seatunnel-kafka-in"
      consumer.group = "seatunnel-test"
      result_table_name="mpoint_kafka_stream"
      kafka.config = {
        client.id = client_sea
        max.poll.records = 500
        auto.offset.reset = "earliest"
        enable.auto.commit = "false"
      }
  }
}

transform {
   Sql {
    source_table_name = ["mpoint_kafka_stream"]
    result_table_name = "mpoint_kafka_stream_filter"
    query = "select measuredt as time ,parmvalue as mpointValue,mpointId,id from mpoint_kafka_stream;"
  }
}

sink {

  Redission {
    source_table_name = ["mpoint_kafka_stream_filter"]
    host = 132.120.132.71
    port = 6379
    auth = "ZAQwsx@2008"
  }

}

Running Command

./bin/seatunnel.sh --config ./config/kafkatosqlserverAredission.conf

Error Exception

no errors

Zeta or Flink or Spark Version

No response

Java or Scala Version

java1.8

Screenshots

![Uploading 1721626277243.jpg…]()

Are you willing to submit PR?

Code of Conduct

github-actions[bot] commented 2 weeks ago

This issue has been automatically marked as stale because it has not had recent activity for 30 days. It will be closed in next 7 days if no further activity occurs.

github-actions[bot] commented 1 week ago

This issue has been closed because it has not received response for too long time. You could reopen it if you encountered similar problems in the future.