Skip to content

1641 flink native #7839

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
Closed
wants to merge 4 commits into from
Closed

1641 flink native #7839

wants to merge 4 commits into from
+164 −57

Conversation

apupier
Copy link
Contributor

@apupier apupier commented Oct 15, 2025

No description provided.

@apupier
Auto-generation for promotion to native of Flink component
6bbdb1b 
part of apache#1141

Signed-off-by: Aurélien Pupier <[email protected]>
@apupier
Add native test for Flink in a group
08e5635 
part of apache#1641

Signed-off-by: Aurélien Pupier <[email protected]>
@apupier
attempt to configure native compilation
a40d54e 
the initialize at runtime configured in the code is not working, I do
not understand why; It is working when using the comad-lien parameter
`-Dquarkus.native.additional-build-args="--initialize-at-run-time=org.apache.flink.util.AbstractID,--initialize-at-run-time=com.esotericsoftware.kryo.util.Object"`

the SPI classes are not working. i tried to register by reflection all
specified classes, also to enable ServiceLoader
(`-H:+UseServiceLoaderFeature,-H:+UnlockExperimentalVMOptions` in the
additional native build args) without success as ti is specified
`-H:-UseServiceLoaderFeature` somewhere else and it is this one which is
picked)
@apupier
Documentation regenerated
86068e4 
Signed-off-by: Aurélien Pupier <[email protected]>
@apupier
Copy link
Contributor Author

apupier commented Oct 15, 2025 •
edited
Loading

draft created to better compare what I've done and seeking for help:

the initialize at runtime configured in the code is not working, I do not understand why; It is working when using the comad-lien parameter -Dquarkus.native.additional-build-args="--initialize-at-run-time=org.apache.flink.util.AbstractID,--initialize-at-run-time=com.esotericsoftware.kryo.util.Object".

the SPI classes are not working. i tried to register by reflection all specified classes, also to enable ServiceLoader (-H:+UseServiceLoaderFeature,-H:+UnlockExperimentalVMOptions in the additional native build args) without success as ti is specified -H:-UseServiceLoaderFeature somewhere else and it is this one which is picked)
it is causing this error at runtime:

Caused by: java.lang.IllegalStateException: No ExecutorFactory found to execute the application.
	at org.apache.flink.core.execution.DefaultExecutorServiceLoader.getExecutorFactory(DefaultExecutorServiceLoader.java:88)
	at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.getPipelineExecutor(StreamExecutionEnvironment.java:2995)
	at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:2469)
	at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:2351)
	at org.apache.flink.streaming.api.environment.LocalStreamEnvironment.execute(LocalStreamEnvironment.java:68)
	at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:2325)
	at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:2303)
	at org.apache.camel.quarkus.component.flink.it.FlinkResource$1.doOnDataStream(FlinkResource.java:101)

@apupier apupier closed this Oct 17, 2025
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.

1 participant

@apupier