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

[SUPPORT] HoodieFlinkWriteClient.getOrCreateWriteHandle throws an exception NoSuchElementException. More details are required #5782

Closed
LinMingQiang opened this issue Jun 7, 2022 · 7 comments
Assignees
Labels
flink Issues related to flink priority:major degraded perf; unable to move forward; potential bugs

Comments

@LinMingQiang
Copy link
Contributor

Tips before filing an issue

  • Have you gone through our FAQs?

  • Join the mailing list to engage in conversations and get faster support at dev-subscribe@hudi.apache.org.

  • If you have triaged this as a bug, then file an issue directly.

Describe the problem you faced
When we instantiate the hoodiemergehandle, sometimes a certain fielID under a partition does not exist,but the 'loc.getinstanttime()' is 'U' causes an exception NoSuchElementException to be thrown,but the exception information does not tell which fileID file does not exist, which makes it difficult to locate.

A clear and concise description of the problem.

To Reproduce

Steps to reproduce the behavior:

Expected behavior

A clear and concise description of what you expected to happen.

Environment Description

  • Hudi version :

  • Spark version :

  • Hive version :

  • Hadoop version :

  • Storage (HDFS/S3/GCS..) :

  • Running on Docker? (yes/no) :

Additional context

Add any other context about the problem here.

Stacktrace

Add the stacktrace of the error.

@nsivabalan nsivabalan added flink Issues related to flink priority:major degraded perf; unable to move forward; potential bugs labels Jun 7, 2022
@nsivabalan
Copy link
Contributor

@wangxianghu @danny0405 @leesf : can you loop in someone to assist here.

@danny0405
Copy link
Contributor

Did you use the bucket index instead ? There are some fixes for it:

#5590
#5763

@LinMingQiang
Copy link
Contributor Author

Yes, but someone encountered an nosuchelementexception: no value present in option error again, so I hope to bring more detailed information when reporting this exception, such as the fileID under which partition.Facilitate troubleshooting; There's only one small change here,You can check my PR : #5788

@danny0405
Copy link
Contributor

The error throws because an INSERT records was recognized as an UPDATE and appended to a UPDATE bucket, we may need to figure out why an INSERT has been seen as an UPDATE yet.

@LinMingQiang
Copy link
Contributor Author

When enable write.insert.cluster, an error NoSuchElementexception: no value present in option will be reported after the data is written for a period of time。This problem is not easy to locate because of the lack of information, and this problem will not occur during local debugging

@hbgstc123
Copy link
Contributor

@danny0405 @LinMingQiang
do you know the cause of this problem or have fixes now? We meet this problem too today. Use hudi 0.12.1 version

@LinMingQiang
Copy link
Contributor Author

@danny0405 @LinMingQiang do you know the cause of this problem or have fixes now? We meet this problem too today. Use hudi 0.12.1 version

This problem has been solved in 0.12.1. You can open a new issue.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
flink Issues related to flink priority:major degraded perf; unable to move forward; potential bugs
Projects
None yet
Development

No branches or pull requests

4 participants