Re: New licensing for Akka

That is great to hear. I have updated the blog post accordingly. On 09/09/2022 19:29, Matthias Pohl wrote: Looks like there will be a bit of a grace period till Sep 2023 for vulnerability fixes in akka 2.6.x [1] [1] https://discuss.lightbend.com/t/2-6-x-maintenance-proposal/9949 On Wed, Sep 7

Re: Fail to build Flink 1.15.1

hmm...we've only seen that error in older Flink version: https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/flinkdev/ide_setup/#compilation-fails-with-cannot-find-symbol-symbol-method-defineclass-location-class-sunmiscunsafe Please double-check whether you actually checked out 1.15.

Fail to build Flink 1.15.1

I have an issue when build a clean Flink 1.15.1 on MacOS with: mvn clean install -DskipTests -Dfast % echo $JAVA_HOME /usr/local/Cellar/ope

Re: Understanding webhook checks in flink operator

Hi Prakhar, the webhook is an optional component in the Flink Operator. It's responsible mainly for validation through: https://github.com/apache/flink-kubernetes-operator/blob/main/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/validation/DefaultValidator.java This

Understanding webhook checks in flink operator

Hi, We are trying to install Flink Kubernetes operator v1.1.0. Few questions regarding the webhooks: - Is it necessary to install webhooks? If not, what can be the implications? - What type of validations and mutations does it support? Thanks Prakhar Mathur

Re: New licensing for Akka

Looks like there will be a bit of a grace period till Sep 2023 for vulnerability fixes in akka 2.6.x [1] [1] https://discuss.lightbend.com/t/2-6-x-maintenance-proposal/9949 On Wed, Sep 7, 2022 at 4:30 PM Robin Cassan via user wrote: > Thanks a lot for your answers, this is reassuring! > > Cheer

Access to Table environent properties/Job arguents from DynamicTableFactory

Hi, is there a way to access a Table Environment configuration or Job arguments from DynamicTableFactory (Sink/Source)? I'm guessing no but I just want to double check that I'm not missing anything here. For my understanding we have access only to Table definition. Thanks, Krzysztof Chmielewski

Insert into JDBC table

Why this INSERT does not insert row in table (jdbc connection works, I can create 'Customers' table from MySQL table)?   tEnv.executeSql("CREATE TABLE Customers (" + " customer_number INT, " + " pid_no INT, " + " na

Re: Slow Tests in Flink 1.15

Oh my. Thank you so much, Maciek! I added the proposed snippet from the page you linked[0] to all pipeline tests and they are all performing as before. Perfect. Interestingly enough, I read about it in the changelog, but seem to have ignored it. Notably though, I would expect the following to m

Re: Slow Tests in Flink 1.15

Hi, we also had similar problems in Nussknacker recently (tests on fake sources), my colleague found out it's due to ENABLE_CHECKPOINTS_AFTER_FINISH flag (https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/fault-tolerance/checkpointing/#waiting-for-the-final-checkpoint-be

Re: Slow Tests in Flink 1.15

Hey, sorry for not coming back to this earlier, but I was hoping to better isolate the problem for analysis. Maybe for comparison to Alexey's case: We have four different pipelines at ours, which are all built similarly. Though we use Kafka in the actual jobs, the tests are using fake sources a