Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

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

Open
2 of 3 tasks
wxp2023 opened this issue Jul 22, 2024 · 1 comment
Open
2 of 3 tasks

Comments

@wxp2023
Copy link

wxp2023 commented Jul 22, 2024

Search before asking

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

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?

  • Yes I am willing to submit a PR!

Code of Conduct

@wxp2023 wxp2023 added the bug label Jul 22, 2024
Copy link

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 github-actions bot added the stale label Aug 22, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

No branches or pull requests

1 participant