Unable to restore from checkpoint (Flink 1.13.2 and 1.13.0): serial version has changed in InflightDataRescalingDescriptor

2021-12-14 Thread Adam Roberts
Hi everyone, I'm aware of the compatibility matrix for Flink which is available here https://nightlies.apache.org/flink/flink-docs-master/docs/ops/upgrading/ - which suggests 1.13.x and 1.13.x should work just fine. However, if we try to restore a 1.13.0 checkpoint with 1.13.2, we'll get a proble

[jira] [Created] (FLINK-25211) Elasticsearch connector version compatibility

2021-12-07 Thread Adam Roberts (Jira)
Adam Roberts created FLINK-25211: Summary: Elasticsearch connector version compatibility Key: FLINK-25211 URL: https://issues.apache.org/jira/browse/FLINK-25211 Project: Flink Issue Type

Re: Dev process: testing one suite only (and are our docs suggesting Java 8 accurate?)

2021-04-09 Thread Adam Roberts
27; -DfailIfNoTests=false -am > > I will add it to the wiki. > > Concerning FLINK-21672, I think it would be really great to not use vendor > specific classes if possible. If you find a solution for it, then let's > apply it. > > Cheers, > Till > > > > On T

Dev process: testing one suite only (and are our docs suggesting Java 8 accurate?)

2021-04-08 Thread Adam Roberts
Hey everyone, I'm looking to get the full set of unit tests working using AdoptOpenJDK 11 with the OpenJ9 VM and I'm basically seeing problems with the runtime tests (always going OoM creating new threads) and I'd also like to have a go at https://issues.apache.org/jira/browse/FLINK-21672. That be

[jira] [Created] (FLINK-21672) End to end tests (streaming) aren't Java vendor neutral (sun.management bean used)

2021-03-08 Thread Adam Roberts (Jira)
Adam Roberts created FLINK-21672: Summary: End to end tests (streaming) aren't Java vendor neutral (sun.management bean used) Key: FLINK-21672 URL: https://issues.apache.org/jira/browse/FLINK-

[jira] [Created] (FLINK-21670) Bump log4j version to 2.8.2

2021-03-08 Thread Adam Roberts (Jira)
Adam Roberts created FLINK-21670: Summary: Bump log4j version to 2.8.2 Key: FLINK-21670 URL: https://issues.apache.org/jira/browse/FLINK-21670 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-21546) Upgrade io.netty netty-codec in Flink (four findings)

2021-03-01 Thread Adam Roberts (Jira)
Adam Roberts created FLINK-21546: Summary: Upgrade io.netty netty-codec in Flink (four findings) Key: FLINK-21546 URL: https://issues.apache.org/jira/browse/FLINK-21546 Project: Flink Issue

[jira] [Created] (FLINK-21544) Upgrade Jackson databind version from 2.10.1 used in, at least, Flink Python jar

2021-03-01 Thread Adam Roberts (Jira)
Adam Roberts created FLINK-21544: Summary: Upgrade Jackson databind version from 2.10.1 used in, at least, Flink Python jar Key: FLINK-21544 URL: https://issues.apache.org/jira/browse/FLINK-21544

Re: Source of Cloudera 3 Hadoop Flink shaded uber jars?

2021-02-10 Thread Adam Roberts
2021 at 7:27 PM Chesnay Schepler > wrote: > >> I can't tell you where it comes from, just that the Flink project had >> nothing to do with it. >> >> FYI; Hadoop 3 has been supported by Flink since 1.11 . We do no longer >> publish shaded-hadoop jars thou

Source of Cloudera 3 Hadoop Flink shaded uber jars?

2021-02-10 Thread Adam Roberts
Hey everyone, I realise this could be a long shot (but perhaps not given the list of committers and perhaps some are from Cloudera!) - I'm wondering if anyone knows the source location and build instructions for the jars at https://repository.cloudera.com/artifactory/libs-release-local/org/apache/f

Re: Flink 1.11.4 release? And usual plan for maintenance etc

2021-02-08 Thread Adam Roberts
ce Flink 1.13 is released, Flink 1.11.x won't be maintained anymore by > the community. This means that problems won't be fixed in the 1.11.x > release branch. > > [1] https://flink.apache.org/downloads.html#update-policy-for-old-releases > > Cheers, > Till > > On F

Flink 1.11.4 release? And usual plan for maintenance etc

2021-02-05 Thread Adam Roberts
Hey everyone, a few short questions please - is there an expected release date/target for 1.11.4 please? I ask as I've noticed a couple of dependency upgrades that I'd really like to pick up if possible, instead of moving to Flink 1.12 or 1.13 due to the existing Flink jobs we have. My second qu