Skip to content

Flink SQL validations using env #7722

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.

Sign up for GitHub

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

Jump to bottom
Draft
wants to merge 10 commits into
base: staging
Choose a base branch
from
Draft

Flink SQL validations using env #7722

wants to merge 10 commits into from

Conversation

mslabek
Copy link
Member

@mslabek mslabek commented Mar 21, 2025

Describe your changes

Checklist before merge

  • Related issue ID is placed at the beginning of PR title in [brackets] (can be GH issue or Nu Jira issue)
  • Code is cleaned from temporary changes and commented out lines
  • Parts of the code that are not easy to understand are documented in the code
  • Changes are covered by automated tests
  • Showcase in dev-application.conf added to demonstrate the feature
  • Documentation added or updated
  • Added entry in Changelog.md describing the change from the perspective of a public distribution user
  • Added MigrationGuide.md entry in the appropriate subcategory if introducing a breaking change
  • Verify that PR will be squashed during merge

arkadius added 3 commits March 10, 2025 17:42
@arkadius
Flink MiniCluster: IO.pure instead of IO.delay + attached StreamExecu…
1732ed1 
…tionEnvironment
@arkadius
SyncIO
18d7c88
@arkadius
[NU-2045] FlinkMiniClusterWithServices: attached variants of methods …
960ff62 
…creating StreamExecutionEnvironment + SyncIO to fix problem with ThreadLocal + clean up
Base automatically changed from update-table-components to staging March 21, 2025 15:41
mslabek added 3 commits March 21, 2025 16:50
@mslabek
remove flink classloader wrapper
9b1dbd1
@mslabek
Merge remote-tracking branch 'origin/minicluster-SyncIO-attached' int…
2338323 
…o flink-sql-validations-using-env

# Conflicts:
#	engine/flink/minicluster/src/main/scala/pl/touk/nussknacker/engine/flink/minicluster/FlinkMiniClusterFactory.scala
@mslabek
add flink sql validations using env
786cdda
@mslabek mslabek force-pushed the flink-sql-validations-using-env branch from b04dbc4 to 786cdda Compare March 21, 2025 15:54
@mslabek mslabek marked this pull request as ready for review March 21, 2025 15:55
@mslabek mslabek marked this pull request as draft March 21, 2025 15:55
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.
2 participants
@mslabek @arkadius