Re: [DISCUSS] Dropping Scala 2.10

+1 for dropping support for Scala 2.10 On Tue, Sep 19, 2017 at 3:29 AM, Sean Owen wrote: > For the curious, here's the overall task in Spark: > > https://issues.apache.org/jira/browse/SPARK-14220 > > and most of the code-related changes: > > https://github.com/apache/spark/pull/18645 > > and wh

[jira] [Created] (FLINK-7646) Restart failed jobs with configurable parallelism range

Elias Levy created FLINK-7646: - Summary: Restart failed jobs with configurable parallelism range Key: FLINK-7646 URL: https://issues.apache.org/jira/browse/FLINK-7646 Project: Flink Issue Type: I

Re: got Warn message - "the expected leader session ID did not equal the received leader session ID " when using LocalFlinkMiniCluster to interpret scala code

Hi Till, Thanks for your answer,it worked when i use StandaloneMiniCluster,but another problem is that i can’t find a way to cancel a running Flink job without shutting down the cluster,for LocalFlinkMiniCluster i can do it with below code : for (job <- cluster.getCurrentlyRunningJo

[jira] [Created] (FLINK-7645) Modify system-metrics part show in the document

Hai Zhou_UTC+8 created FLINK-7645: - Summary: Modify system-metrics part show in the document Key: FLINK-7645 URL: https://issues.apache.org/jira/browse/FLINK-7645 Project: Flink Issue Type: I

[jira] [Created] (FLINK-7644) Line the extra semicolon in the source code

Hai Zhou_UTC+8 created FLINK-7644: - Summary: Line the extra semicolon in the source code Key: FLINK-7644 URL: https://issues.apache.org/jira/browse/FLINK-7644 Project: Flink Issue Type: Impro

[jira] [Created] (FLINK-7643) HadoopFileSystem always reloads GlobalConfiguration

Ufuk Celebi created FLINK-7643: -- Summary: HadoopFileSystem always reloads GlobalConfiguration Key: FLINK-7643 URL: https://issues.apache.org/jira/browse/FLINK-7643 Project: Flink Issue Type: Bug

Re: [DISCUSS] Dropping Scala 2.10

For the curious, here's the overall task in Spark: https://issues.apache.org/jira/browse/SPARK-14220 and most of the code-related changes: https://github.com/apache/spark/pull/18645 and where it's stuck at the moment: https://mail-archives.apache.org/mod_mbox/spark-dev/201709.mbox/%3CCAMAsSdK

Re: [DISCUSS] Dropping Scala 2.10

Hi Aljoscha, I am in favor of the change. No concerns on my side, just one remark that I have talked to Sean last week (ccd) and he mentioned that he has faced some technical issues while driving the transition from 2.10 to 2.12 for Spark. It had to do with changes in the scope of implicits. You m

Re: [DISCUSS] Dropping Scala 2.10

Given that the last maintenance release Scala 2.10.6 is from about 2 years ago, I would also be in favour of dropping Scala 2.10 support from Flink. This will make maintenance easier for us and allow us to drop artifacts like Flakka. Cheers, Till On Tue, Sep 19, 2017 at 11:56 AM, Aljoscha Krettek

[DISCUSS] Dropping Scala 2.10

Hi, Talking to some people I get the impression that Scala 2.10 is quite outdated by now. I would like to drop support for Scala 2.10 and my main motivation is that this would allow us to drop our custom Flakka build of Akka that we use because newer Akka versions only support Scala 2.11/2.12 a

Re: Elasticsearch connector

Hi, that's correct. Elasticsearch changed its API from 5.1 to 5.2. There is a JIRA issue for the problem [1] and a pull request [2]. It would be great if you could help to resolve the problem by verifying the PR. Thanks, Fabian [1] https://issues.apache.org/jira/browse/FLINK-7386 [2] https://gi