Skip to content

Conversation

@arnaud-daroussin
Copy link
Contributor

Hi @novakov-alexey,

Here is the PR discussed in issue #187.

About your questions in the issue:

  1. Yes, there is no difference between Scala versions, it's just a matter of Flink configuration.
  2. As you can see in the PR, pipeline.serialization-config property do nothing before Flink 1.19, so there is no need to drop support. When 1.18 support will be dropped, we'll be able to use PipelineOptions.SERIALIZATION_CONFIG constant and simplify the test.

Is the modification in the readme and explanations given by the exception clear enough to you?

Thanks

Copy link
Collaborator

@novakov-alexey novakov-alexey left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Thanks, looks good. Few minor things only.

* Pass a custom configuration into the cluster.
*/
def getExecutionEnvironment(configuration: Configuration): StreamExecutionEnvironment = {
configureFailFastOnScalaTypeResolutionWithClass(configuration)
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Let's keep user's configuration: Configuration argument unchanged. There are no much benefits for user to know that we injected additional properties into the Configuration for that FailFastFactory.

@arnaud-daroussin
Copy link
Contributor Author

Hi @novakov-alexey,
I did requested changes, is it better now?
I also did a UT to test feature flag, but I didn't committed it because it was very cumbersome due to the difficulty to mock env var. Do you want it or is it fine like is?

@novakov-alexey novakov-alexey merged commit df845a0 into flink-extended:master Jan 30, 2025
5 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants