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

Cannot write data to a specific partition #547

Closed
zzgzy opened this issue Oct 21, 2020 · 1 comment
Closed

Cannot write data to a specific partition #547

zzgzy opened this issue Oct 21, 2020 · 1 comment
Assignees
Labels
known issue This is a verified bug in the codebase.

Comments

@zzgzy
Copy link

zzgzy commented Oct 21, 2020

Feature Requests:

  • What issue are you trying to solve?
    cannot write data to a specific partition
  • How do you want to solve it?
    want to understand if it's a bug or the I use it in a wrong way
  • What is your use case for this feature?
    want to send some signal data to event hub and have to send to every partition.

Bug Report:

  • Actual behavior
    I specified the "partitionId" column (with “body”) in the data query and send the data to 3 different partitions. When processing the data from a c# app, I noticed that the signal messages are not present in every partitions.
    messages
      .select("partitionId", "body")
      .write
      .format("eventhubs")
      .option("checkpointLocation", XXX)
      .options(ehConf.toMap).save()   // messages: Dataset[(String, String)]
  • Expected behavior
    The messages should be sent to every single partitions defined by the partitionId column.
  • Spark version
    2.4 on HDInsight
  • spark-eventhubs artifactId and version
    azure-eventhubs-spark_2.11:2.3.15
@nyaghma nyaghma self-assigned this Oct 26, 2020
@nyaghma nyaghma added the possible issue This is a user-reported bug that has yet to be confirmed. label Oct 26, 2020
@nyaghma nyaghma added known issue This is a verified bug in the codebase. and removed possible issue This is a user-reported bug that has yet to be confirmed. labels Nov 2, 2020
@nyaghma
Copy link
Contributor

nyaghma commented Nov 16, 2020

The change is included in version 2.3.18.

@nyaghma nyaghma closed this as completed Nov 16, 2020
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
known issue This is a verified bug in the codebase.
Projects
None yet
Development

No branches or pull requests

2 participants