[jira] [Created] (FLINK-7358) Add implicitly converts support for User-defined function

sunjincheng created FLINK-7358: -- Summary: Add implicitly converts support for User-defined function Key: FLINK-7358 URL: https://issues.apache.org/jira/browse/FLINK-7358 Project: Flink Issue

[jira] [Created] (FLINK-7357) HOP_START() HOP_END() does not work when using HAVING clause with GROUP BY HOP window

Rong Rong created FLINK-7357: Summary: HOP_START() HOP_END() does not work when using HAVING clause with GROUP BY HOP window Key: FLINK-7357 URL: https://issues.apache.org/jira/browse/FLINK-7357 Project:

Re: [VOTE] Release 1.3.2, release candidate #2

-1 The Gelly examples jar is not included in the Scala 2.11 convenience binaries since change-scala-version.sh is not switching the hard-coded Scala version from 2.10 to 2.11 in ./flink-dist/src/main/assemblies/bin.xml. The simplest fix may be to revert FLINK-7211 and simply exclude the

[jira] [Created] (FLINK-7356) misleading s3 file uri in configuration file

Bowen Li created FLINK-7356: --- Summary: misleading s3 file uri in configuration file Key: FLINK-7356 URL: https://issues.apache.org/jira/browse/FLINK-7356 Project: Flink Issue Type: Bug

Re: [DISCUSS] Service Authorization (redux)

Thanks Till and Aljoscha for the feedback. Seems there are two ways to proceed here, if we accept mutual SSL as the basis. a) Backport mutual-auth support from Akka 2.4 to Flakka. b) Drop support for Scala 2.10 (FLINK-?), move to Akka 2.4 (FLINK-3662). Let's assume (a) for now. On Tue, Aug

Re: [VOTE] Release 1.3.2, release candidate #2

+-1 (non-binding) L.1 Check if checksums and GPG files match the corresponding release files - found an issue with a malformed flink-1.3.2-src.tgz.md5 that gnu coreutils 8.27 was not accepting - already fixed by now L.3 Check if the source release is building properly (mvn clean verify) - found

[jira] [Created] (FLINK-7355) YARNSessionFIFOITCase#testfullAlloc does not run anymore

Nico Kruber created FLINK-7355: -- Summary: YARNSessionFIFOITCase#testfullAlloc does not run anymore Key: FLINK-7355 URL: https://issues.apache.org/jira/browse/FLINK-7355 Project: Flink Issue

Re: [VOTE] Release 1.3.2, release candidate #2

+1 1. Cluster tests Tested with the stateful state machine job, using the following settings and variations: - Cloud env: GCE - Distributions: CDH 5.9.0 - Flink deployment method: YARN per-job (Hadoop 2.6.0) - HA: both enabled & disabled - Kerberos: enabled, keytab mode - Kafka version: 0.9.0.1

[jira] [Created] (FLINK-7354) test instability in LocalFlinkMiniClusterITCase#testLocalFlinkMiniClusterWithMultipleTaskManagers

Nico Kruber created FLINK-7354: -- Summary: test instability in LocalFlinkMiniClusterITCase#testLocalFlinkMiniClusterWithMultipleTaskManagers Key: FLINK-7354 URL: https://issues.apache.org/jira/browse/FLINK-7354

[jira] [Created] (FLINK-7353) Bring project README.md up to date

Tzu-Li (Gordon) Tai created FLINK-7353: -- Summary: Bring project README.md up to date Key: FLINK-7353 URL: https://issues.apache.org/jira/browse/FLINK-7353 Project: Flink Issue Type:

Re: [POLL] Dropping savepoint format compatibility for 1.1.x in the Flink 1.4.0 release

+1 > On Aug 2, 2017, at 3:16 PM, Till Rohrmann wrote: > > +1 > > On Wed, Aug 2, 2017 at 9:12 AM, Stefan Richter > wrote: > >> +1 >> >> Am 28.07.2017 um 16:03 schrieb Stephan Ewen : >> >> Seems like no one raised a concern

Re: [POLL] Dropping savepoint format compatibility for 1.1.x in the Flink 1.4.0 release

+1 On Wed, Aug 2, 2017 at 9:12 AM, Stefan Richter wrote: > +1 > > Am 28.07.2017 um 16:03 schrieb Stephan Ewen : > > Seems like no one raised a concern so far about dropping the savepoint > format compatibility for 1.1 in 1.4. > > Leaving this

[jira] [Created] (FLINK-7352) ExecutionGraphRestartTest timeouts

Nico Kruber created FLINK-7352: -- Summary: ExecutionGraphRestartTest timeouts Key: FLINK-7352 URL: https://issues.apache.org/jira/browse/FLINK-7352 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-7351) test instability in JobClientActorRecoveryITCase#testJobClientRecovery

Nico Kruber created FLINK-7351: -- Summary: test instability in JobClientActorRecoveryITCase#testJobClientRecovery Key: FLINK-7351 URL: https://issues.apache.org/jira/browse/FLINK-7351 Project: Flink

[jira] [Created] (FLINK-7350) only execute japicmp in one build profile

Chesnay Schepler created FLINK-7350: --- Summary: only execute japicmp in one build profile Key: FLINK-7350 URL: https://issues.apache.org/jira/browse/FLINK-7350 Project: Flink Issue Type:

[jira] [Created] (FLINK-7349) Only execute checkstyle in one build profile

Chesnay Schepler created FLINK-7349: --- Summary: Only execute checkstyle in one build profile Key: FLINK-7349 URL: https://issues.apache.org/jira/browse/FLINK-7349 Project: Flink Issue Type:

[jira] [Created] (FLINK-7348) Allow redundant modifiers on methods

Chesnay Schepler created FLINK-7348: --- Summary: Allow redundant modifiers on methods Key: FLINK-7348 URL: https://issues.apache.org/jira/browse/FLINK-7348 Project: Flink Issue Type:

[jira] [Created] (FLINK-7347) "removeAll" is extremely inefficient in MessageAcknowledgingSourceBase.notifyCheckpointComplete

Yonatan Most created FLINK-7347: --- Summary: "removeAll" is extremely inefficient in MessageAcknowledgingSourceBase.notifyCheckpointComplete Key: FLINK-7347 URL: https://issues.apache.org/jira/browse/FLINK-7347

[jira] [Created] (FLINK-7346) EventTimeWindowCheckpointingITCase.testPreAggregatedSlidingTimeWindow killed by maven watchdog on Travis

Nico Kruber created FLINK-7346: -- Summary: EventTimeWindowCheckpointingITCase.testPreAggregatedSlidingTimeWindow killed by maven watchdog on Travis Key: FLINK-7346 URL:

[jira] [Created] (FLINK-7345) Add BRANCH PATTERN.

zhangxiaoyu created FLINK-7345: -- Summary: Add BRANCH PATTERN. Key: FLINK-7345 URL: https://issues.apache.org/jira/browse/FLINK-7345 Project: Flink Issue Type: Bug Reporter:

Re: [POLL] Dropping savepoint format compatibility for 1.1.x in the Flink 1.4.0 release

+1 > Am 28.07.2017 um 16:03 schrieb Stephan Ewen : > > Seems like no one raised a concern so far about dropping the savepoint format > compatibility for 1.1 in 1.4. > > Leaving this thread open for some more days, but from the sentiment, it seems > like we should go ahead? >

[jira] [Created] (FLINK-7343) Kafka010ProducerITCase instability

Piotr Nowojski created FLINK-7343: - Summary: Kafka010ProducerITCase instability Key: FLINK-7343 URL: https://issues.apache.org/jira/browse/FLINK-7343 Project: Flink Issue Type: Bug

Re: Towards a spec for robust streaming SQL, Part 2

Thank you all for the comments/input, I appreciate the time you've put into this. I've responded to a handful of the major ones. There are some more I'd like to respond to, but I'm out of time for tonight, so more tomorrow. -Tyler On Tue, Aug 1, 2017 at 12:24 PM Julian Hyde