Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

Sign up
Appearance settings

Hudi sink for Python #141

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

Open
GaganBrahmi wants to merge 1 commit into aws-samples:main
base: main
Choose a base branch
Loading
from GaganBrahmi:hudi-sink-python

Conversation

Copy link
Contributor

@GaganBrahmi GaganBrahmi commented Sep 29, 2025

Purpose of the change

Sample application to write to Apache Hudi table format using Python/PyFlink

Verifying this change

Please test your changes both running locally, in the IDE, and in Managed Service for Apache Flink. All examples must run
in both environment without code changes.

Describe how you tested your application, show the output of the running application with screenshots.

[INFO] 
[INFO] --- assembly:3.3.0:single (make-assembly) @ managed-flink-pyfink-hudi-sink-example ---
[INFO] Reading assembly descriptor: assembly/assembly.xml
[INFO] Building zip: /Users/brahmi/git-repos/amazon-managed-service-for-apache-flink-examples/python/HudiSink/target/managed-flink-pyfink-hudi-sink-example-1.0.0.zip
[INFO] ------------------------------------------------------------------------
[INFO] BUILD SUCCESS
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 19.858 s
[INFO] Finished at: 2025年09月29日T07:33:52-07:00
[INFO] ------------------------------------------------------------------------

Significant changes

(Please check any boxes [x] if the answer is "yes". You can first publish the PR and check them afterward, for convenience.)

  • Completely new example
  • Updated an existing example to newer Flink version or dependencies versions
  • Improved an existing example
  • Modified the runtime configuration of an existing example (i.e. added/removed/modified any runtime properties)
  • Modified the expected input or output of an existing example (e.g. modified the source or sink, modified the record schema)

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Reviewers
No reviews
Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
No milestone
Development

Successfully merging this pull request may close these issues.

AltStyle によって変換されたページ (->オリジナル) /