[jira] [Created] (FLINK-8077) Can't distinguish overloaded user-defined functions that have Double and BigDecimal arguments

2017-11-15 Thread yuqi (JIRA)
yuqi created FLINK-8077: --- Summary: Can't distinguish overloaded user-defined functions that have Double and BigDecimal arguments Key: FLINK-8077 URL: https://issues.apache.org/jira/browse/FLINK-8077 Project: Fl

[jira] [Closed] (FLINK-8077) Can't distinguish overloaded user-defined functions that have Double and BigDecimal arguments

2017-11-15 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuqi closed FLINK-8077. --- Resolution: Not A Problem > Can't distinguish overloaded user-defined functions that have Double and > BigDecimal arg

[jira] [Commented] (FLINK-7942) NPE when apply FilterJoinRule

2017-11-15 Thread lincoln.lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253111#comment-16253111 ] lincoln.lee commented on FLINK-7942: [~twalthr] It's great if you have time to fix thi

[jira] [Closed] (FLINK-8075) Lack of synchronization calling clone() in Configuration ctor

2017-11-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8075. --- Resolution: Not A Problem This code is copied straight from hadoop for shading reasons. Any is

[jira] [Created] (FLINK-8078) Decouple Execution from actual slot implementation

2017-11-15 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-8078: Summary: Decouple Execution from actual slot implementation Key: FLINK-8078 URL: https://issues.apache.org/jira/browse/FLINK-8078 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-7490) UDF Agg throws Exception when flink-table is loaded with AppClassLoader

2017-11-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-7490: Assignee: Fabian Hueske > UDF Agg throws Exception when flink-table is loaded with AppClass

[jira] [Updated] (FLINK-7490) UDF Agg throws Exception when flink-table is loaded with AppClassLoader

2017-11-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7490: - Priority: Blocker (was: Major) > UDF Agg throws Exception when flink-table is loaded with AppClas

[jira] [Commented] (FLINK-7490) UDF Agg throws Exception when flink-table is loaded with AppClassLoader

2017-11-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253152#comment-16253152 ] Fabian Hueske commented on FLINK-7490: -- I had a look at it and it seems that the wron

[jira] [Updated] (FLINK-8047) Create HTTP Sink

2017-11-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8047: Fix Version/s: (was: 1.4.0) 1.5.0 > Create HTTP Sink > --

[jira] [Updated] (FLINK-7991) Cleanup kafka example jar filters

2017-11-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7991: Fix Version/s: (was: 1.4.0) > Cleanup kafka example jar filters > --

[GitHub] flink issue #5013: [FLINK-7973] disable JNI bridge for relocated hadoop clas...

2017-11-15 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5013 Unfortunately, I don't think we can test this now. I have in mind to add more end-to-end tests or "system tests" that run nightly on AWS or some proper Hadoop and they should catch it. What

[jira] [Commented] (FLINK-7973) Fix service shading relocation for S3 file systems

2017-11-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253174#comment-16253174 ] ASF GitHub Bot commented on FLINK-7973: --- Github user aljoscha commented on the issue

[GitHub] flink issue #5013: [FLINK-7973] disable JNI bridge for relocated hadoop clas...

2017-11-15 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5013 I expected that we can't test automatically this for now. From my side, +1 to merge. We definitely need more tests that actually run against flink-dist though. ---

[jira] [Commented] (FLINK-7973) Fix service shading relocation for S3 file systems

2017-11-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253183#comment-16253183 ] ASF GitHub Bot commented on FLINK-7973: --- Github user zentol commented on the issue:

[GitHub] flink issue #5013: [FLINK-7973] disable JNI bridge for relocated hadoop clas...

2017-11-15 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5013 Jip, the end-to-end tests are a first step but we need more. 👌 ---

[jira] [Commented] (FLINK-7973) Fix service shading relocation for S3 file systems

2017-11-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253184#comment-16253184 ] ASF GitHub Bot commented on FLINK-7973: --- Github user aljoscha commented on the issue

[jira] [Closed] (FLINK-8072) Travis job marked as failed for no apparent reason

2017-11-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8072. --- Resolution: Not A Problem My bad, one of the E2E tests did fail. Would be neat if we could mak

[jira] [Created] (FLINK-8079) Skip remaining E2E tests if one failed

2017-11-15 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8079: --- Summary: Skip remaining E2E tests if one failed Key: FLINK-8079 URL: https://issues.apache.org/jira/browse/FLINK-8079 Project: Flink Issue Type: Improv

[jira] [Closed] (FLINK-7973) Fix service shading relocation for S3 file systems

2017-11-15 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7973. --- Resolution: Fixed Fixed on release-1.4 in d6d35fa145c122f469d72bf73433afde5d778aac Fixed on m

[jira] [Updated] (FLINK-7468) Implement sender backlog logic for credit-based

2017-11-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7468: Fix Version/s: (was: 1.4.0) 1.5.0 > Implement sender backlog logic fo

[jira] [Updated] (FLINK-7456) Implement Netty sender incoming pipeline for credit-based

2017-11-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7456: Fix Version/s: (was: 1.4.0) 1.5.0 > Implement Netty sender incoming p

[jira] [Updated] (FLINK-7416) Implement Netty receiver outgoing pipeline for credit-based

2017-11-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7416: Fix Version/s: (was: 1.4.0) 1.5.0 > Implement Netty receiver outgoing

[jira] [Updated] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based

2017-11-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7406: Fix Version/s: (was: 1.4.0) 1.5.0 > Implement Netty receiver incoming

[GitHub] flink pull request #5018: [FLINK-7490] [table] Use correct classloader to co...

2017-11-15 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/5018 [FLINK-7490] [table] Use correct classloader to compile generated cod… … *Thank you very much for contributing to Apache Flink - we are happy that you want to help us improve Flink

[jira] [Commented] (FLINK-7490) UDF Agg throws Exception when flink-table is loaded with AppClassLoader

2017-11-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253215#comment-16253215 ] ASF GitHub Bot commented on FLINK-7490: --- GitHub user fhueske opened a pull request:

[GitHub] flink issue #4921: [FLINK-7943] Make ParameterTool thread safe

2017-11-15 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4921 +1 ---

[jira] [Commented] (FLINK-7943) OptionalDataException when launching Flink jobs concurrently

2017-11-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253226#comment-16253226 ] ASF GitHub Bot commented on FLINK-7943: --- Github user zentol commented on the issue:

[GitHub] flink issue #5013: [FLINK-7973] disable JNI bridge for relocated hadoop clas...

2017-11-15 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5013 @NicoK could you please close this PR? And thanks for the work! 👍 ---

[jira] [Commented] (FLINK-7973) Fix service shading relocation for S3 file systems

2017-11-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253232#comment-16253232 ] ASF GitHub Bot commented on FLINK-7973: --- Github user aljoscha commented on the issue

[jira] [Assigned] (FLINK-7942) NPE when apply FilterJoinRule

2017-11-15 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-7942: --- Assignee: Timo Walther (was: lincoln.lee) > NPE when apply FilterJoinRule >

[GitHub] flink issue #4936: [FLINK-7962] Add built-in support for min/max aggregation...

2017-11-15 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/4936 LGTM as well. +1 to merge ---

[jira] [Commented] (FLINK-7962) Add built-in support for min/max aggregation for Timestamp

2017-11-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253247#comment-16253247 ] ASF GitHub Bot commented on FLINK-7962: --- Github user fhueske commented on the issue:

[jira] [Commented] (FLINK-7923) SQL parser exception when accessing subfields of a Composite element in an Object Array type column

2017-11-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253258#comment-16253258 ] Fabian Hueske commented on FLINK-7923: -- Great, thanks! > SQL parser exception when a

[jira] [Updated] (FLINK-6369) Better support for overlay networks

2017-11-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6369: Fix Version/s: (was: 1.4.0) 1.5.0 > Better support for overlay networ

[jira] [Updated] (FLINK-7962) Add built-in support for min/max aggregation for Timestamp

2017-11-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7962: - Component/s: Table API & SQL > Add built-in support for min/max aggregation for Timestamp > --

[jira] [Updated] (FLINK-7962) Add built-in support for min/max aggregation for Timestamp

2017-11-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7962: - Issue Type: Sub-task (was: Task) Parent: FLINK-4600 > Add built-in support for min/max ag

[jira] [Updated] (FLINK-7962) Add built-in support for min/max aggregation for Timestamp

2017-11-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7962: - Fix Version/s: 1.5.0 > Add built-in support for min/max aggregation for Timestamp > --

[jira] [Closed] (FLINK-7848) Allow time attributes for atomic types

2017-11-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-7848. Resolution: Fixed Fix Version/s: 1.4.0 Fixed for 1.4.0 with 9a2ba6e058e907aef65e0af8731ca5ec8

[GitHub] flink pull request #5019: [FLINK-7942] [table] Reduce aliasing in RexNodes

2017-11-15 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/5019 [FLINK-7942] [table] Reduce aliasing in RexNodes ## What is the purpose of the change This PR reduces the number of `AS` expressions in projects. This fixes the bug mentioned in FLINK-7942

[jira] [Commented] (FLINK-7942) NPE when apply FilterJoinRule

2017-11-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253293#comment-16253293 ] ASF GitHub Bot commented on FLINK-7942: --- GitHub user twalthr opened a pull request:

[GitHub] flink issue #4544: [FLINK-7451] [table] Support non-ascii character literals...

2017-11-15 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/4544 I will finalize this PR and merge it. ---

[jira] [Commented] (FLINK-7451) Query fails when non-ascii characters are used in string literals

2017-11-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253305#comment-16253305 ] ASF GitHub Bot commented on FLINK-7451: --- Github user twalthr commented on the issue:

[GitHub] flink pull request #5016: [FLINK-8069] [table] Support empty watermark strat...

2017-11-15 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/5016#discussion_r151099552 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/table/TableSourceITCase.scala --- @@ -154,6 +154,40 @@ class Tabl

[GitHub] flink pull request #5016: [FLINK-8069] [table] Support empty watermark strat...

2017-11-15 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/5016#discussion_r151096958 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/definedTimeAttributes.scala --- @@ -62,12 +62,13 @@ trait DefinedRowtime

[GitHub] flink pull request #5016: [FLINK-8069] [table] Support empty watermark strat...

2017-11-15 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/5016#discussion_r151096563 --- Diff: docs/dev/table/sourceSinks.md --- @@ -316,7 +316,7 @@ A table schema field of type `SQL_TIMESTAMP` can be declared as rowtime attribut *

[GitHub] flink pull request #5016: [FLINK-8069] [table] Support empty watermark strat...

2017-11-15 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/5016#discussion_r151095005 --- Diff: docs/dev/table/sourceSinks.md --- @@ -316,7 +316,7 @@ A table schema field of type `SQL_TIMESTAMP` can be declared as rowtime attribut *

[GitHub] flink pull request #5016: [FLINK-8069] [table] Support empty watermark strat...

2017-11-15 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/5016#discussion_r151100405 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/table/TableSourceITCase.scala --- @@ -154,6 +154,40 @@ class Tabl

[jira] [Commented] (FLINK-8069) Support empty watermark strategy for TableSources

2017-11-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253314#comment-16253314 ] ASF GitHub Bot commented on FLINK-8069: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-8069) Support empty watermark strategy for TableSources

2017-11-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253315#comment-16253315 ] ASF GitHub Bot commented on FLINK-8069: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-8069) Support empty watermark strategy for TableSources

2017-11-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253316#comment-16253316 ] ASF GitHub Bot commented on FLINK-8069: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-8069) Support empty watermark strategy for TableSources

2017-11-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253317#comment-16253317 ] ASF GitHub Bot commented on FLINK-8069: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-8069) Support empty watermark strategy for TableSources

2017-11-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253318#comment-16253318 ] ASF GitHub Bot commented on FLINK-8069: --- Github user fhueske commented on a diff in

[GitHub] flink pull request #5011: [FLINK-8013] [table] Support aggregate functions w...

2017-11-15 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/5011#discussion_r151102649 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/utils/UserDefinedAggFunctions.scala --- @@ -0,0 +1,107 @@ +package org.apach

[GitHub] flink pull request #5011: [FLINK-8013] [table] Support aggregate functions w...

2017-11-15 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/5011#discussion_r151102741 --- Diff: flink-tests/src/test/scala/org/apache/flink/api/scala/util/CollectionDataSets.scala --- @@ -55,7 +55,6 @@ object CollectionDataSets { dat

[jira] [Commented] (FLINK-8013) Check of AggregateFunction merge function signature is too strict.

2017-11-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253328#comment-16253328 ] ASF GitHub Bot commented on FLINK-8013: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-8013) Check of AggregateFunction merge function signature is too strict.

2017-11-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253329#comment-16253329 ] ASF GitHub Bot commented on FLINK-8013: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-7962) Add built-in support for min/max aggregation for Timestamp

2017-11-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253331#comment-16253331 ] ASF GitHub Bot commented on FLINK-7962: --- Github user wuchong commented on the issue:

[GitHub] flink issue #4936: [FLINK-7962] Add built-in support for min/max aggregation...

2017-11-15 Thread wuchong
Github user wuchong commented on the issue: https://github.com/apache/flink/pull/4936 I will help and merge this . ---

[jira] [Created] (FLINK-8080) Remove need for "metrics.reporters"

2017-11-15 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8080: --- Summary: Remove need for "metrics.reporters" Key: FLINK-8080 URL: https://issues.apache.org/jira/browse/FLINK-8080 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-8081) Annotate MetricRegistry#getReporters() with @VisibleForTesting

2017-11-15 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8081: --- Summary: Annotate MetricRegistry#getReporters() with @VisibleForTesting Key: FLINK-8081 URL: https://issues.apache.org/jira/browse/FLINK-8081 Project: Flink

[jira] [Updated] (FLINK-7880) flink-queryable-state-java fails with core-dump

2017-11-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7880: Priority: Critical (was: Blocker) > flink-queryable-state-java fails with core-dump > -

[GitHub] flink pull request #5011: [FLINK-8013] [table] Support aggregate functions w...

2017-11-15 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/5011#discussion_r151108713 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/utils/UserDefinedAggFunctions.scala --- @@ -0,0 +1,107 @@ +package org.apach

[jira] [Commented] (FLINK-8013) Check of AggregateFunction merge function signature is too strict.

2017-11-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253345#comment-16253345 ] ASF GitHub Bot commented on FLINK-8013: --- Github user fhueske commented on a diff in

[GitHub] flink pull request #4939: [FLINK-4228][yarn/s3a] fix yarn resource upload s3...

2017-11-15 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4939#discussion_r151110083 --- Diff: flink-yarn/pom.xml --- @@ -153,6 +159,63 @@ under the License. + +

[jira] [Commented] (FLINK-4228) YARN artifact upload does not work with S3AFileSystem

2017-11-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253353#comment-16253353 ] ASF GitHub Bot commented on FLINK-4228: --- Github user zentol commented on a diff in t

[jira] [Updated] (FLINK-5505) Harmonize ZooKeeper configuration parameters

2017-11-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5505: Fix Version/s: (was: 1.4.0) 1.5.0 > Harmonize ZooKeeper configuration

[GitHub] flink issue #4945: [FLINK-7977][build] bump version of compatibility check f...

2017-11-15 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4945 Will set the version to compare against to 1.3.2 and merge it. ---

[jira] [Commented] (FLINK-7977) bump version of compatibility check for Flink 1.4

2017-11-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253363#comment-16253363 ] ASF GitHub Bot commented on FLINK-7977: --- Github user zentol commented on the issue:

[GitHub] flink issue #5016: [FLINK-8069] [table] Support empty watermark strategy for...

2017-11-15 Thread xccui
Github user xccui commented on the issue: https://github.com/apache/flink/pull/5016 Thanks for the review @fhueske. I think you are right. A dedicated `WatermarkStrategy` with watermark-preserve semantics should be better. I'll update the PR according to your comments. Thanks. ---

[jira] [Commented] (FLINK-8069) Support empty watermark strategy for TableSources

2017-11-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253370#comment-16253370 ] ASF GitHub Bot commented on FLINK-8069: --- Github user xccui commented on the issue:

[jira] [Created] (FLINK-8082) Bump version compatibility check to 1.4

2017-11-15 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8082: --- Summary: Bump version compatibility check to 1.4 Key: FLINK-8082 URL: https://issues.apache.org/jira/browse/FLINK-8082 Project: Flink Issue Type: Impro

[GitHub] flink pull request #5019: [FLINK-7942] [table] Reduce aliasing in RexNodes

2017-11-15 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/5019#discussion_r151110174 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/stream/table/OverWindowTest.scala --- @@ -203,19 +203,17 @@ class OverWindow

[jira] [Commented] (FLINK-7942) NPE when apply FilterJoinRule

2017-11-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253379#comment-16253379 ] ASF GitHub Bot commented on FLINK-7942: --- Github user fhueske commented on a diff in

[jira] [Updated] (FLINK-8083) FileSystem class not binary compatible with 1.3

2017-11-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8083: Priority: Blocker (was: Major) > FileSystem class not binary compatible with 1.3 >

[jira] [Created] (FLINK-8083) FileSystem class not binary compatible with 1.3

2017-11-15 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8083: --- Summary: FileSystem class not binary compatible with 1.3 Key: FLINK-8083 URL: https://issues.apache.org/jira/browse/FLINK-8083 Project: Flink Issue Typ

[jira] [Created] (FLINK-8084) Remove japicmp deactivations in several modules

2017-11-15 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8084: --- Summary: Remove japicmp deactivations in several modules Key: FLINK-8084 URL: https://issues.apache.org/jira/browse/FLINK-8084 Project: Flink Issue Typ

[jira] [Commented] (FLINK-8084) Remove japicmp deactivations in several modules

2017-11-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253403#comment-16253403 ] ASF GitHub Bot commented on FLINK-8084: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #5020: [FLINK-8084][build] Remove unnecessary japicmp pom...

2017-11-15 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/5020 [FLINK-8084][build] Remove unnecessary japicmp pom entries ## What is the purpose of the change This PR removes unnecessary japicmp module entries from the java8, yarn-tests and quickstart p

[jira] [Updated] (FLINK-8082) Bump version compatibility check to 1.4

2017-11-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8082: Description: Similar to FLINK-7977, we must bump the version of the compatibility check to c

[jira] [Updated] (FLINK-8083) FileSystem class not binary compatible with 1.3

2017-11-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8083: Issue Type: Bug (was: Improvement) > FileSystem class not binary compatible with 1.3 >

[jira] [Updated] (FLINK-8084) Remove japicmp deactivations in several modules

2017-11-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8084: Fix Version/s: 1.5.0 > Remove japicmp deactivations in several modules > ---

[jira] [Commented] (FLINK-8083) FileSystem class not binary compatible with 1.3

2017-11-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253412#comment-16253412 ] Chesnay Schepler commented on FLINK-8083: - Technically the method was never remove

[jira] [Updated] (FLINK-8064) Extend dependency section to list flink-core

2017-11-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8064: Summary: Extend dependency section to list flink-core (was: Extend dependecy section to lis

[GitHub] flink issue #4945: [FLINK-7977][build] bump version of compatibility check f...

2017-11-15 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4945 Merging on hold until FLINK-8083 is resolved. ---

[jira] [Commented] (FLINK-7977) bump version of compatibility check for Flink 1.4

2017-11-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253421#comment-16253421 ] ASF GitHub Bot commented on FLINK-7977: --- Github user zentol commented on the issue:

[GitHub] flink issue #4921: [FLINK-7943] Make ParameterTool thread safe

2017-11-15 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4921 merging. ---

[jira] [Commented] (FLINK-7943) OptionalDataException when launching Flink jobs concurrently

2017-11-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253424#comment-16253424 ] ASF GitHub Bot commented on FLINK-7943: --- Github user zentol commented on the issue:

[GitHub] flink issue #5001: [FLINK-7679][build][java9] Upgrade maven enforcer plugin ...

2017-11-15 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5001 merging. ---

[jira] [Commented] (FLINK-7679) Upgrade maven enforcer plugin to 3.0.0-M1

2017-11-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253425#comment-16253425 ] ASF GitHub Bot commented on FLINK-7679: --- Github user zentol commented on the issue:

[GitHub] flink issue #5001: [FLINK-7679][build][java9] Upgrade maven enforcer plugin ...

2017-11-15 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5001 The PR was messed up during a merge; the enforcer plugin is no correctly properly incremented in the root pom, but only in force-shading. ---

[GitHub] flink issue #4794: [build][minor] Add missing licenses

2017-11-15 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4794 merging. ---

[jira] [Updated] (FLINK-8031) Provide configuration to enable/disable ability to cancel jobs in Web Frontend

2017-11-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8031: Fix Version/s: 1.5.0 > Provide configuration to enable/disable ability to cancel jobs in Web

[jira] [Commented] (FLINK-8048) RAT check complaint

2017-11-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253435#comment-16253435 ] Chesnay Schepler commented on FLINK-8048: - On which version does this occur, and w

[jira] [Comment Edited] (FLINK-8048) RAT check complaint

2017-11-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253435#comment-16253435 ] Chesnay Schepler edited comment on FLINK-8048 at 11/15/17 1:35 PM: -

[jira] [Comment Edited] (FLINK-8048) RAT check complaint

2017-11-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253435#comment-16253435 ] Chesnay Schepler edited comment on FLINK-8048 at 11/15/17 1:35 PM: -

[jira] [Comment Edited] (FLINK-8048) RAT check complaint

2017-11-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253435#comment-16253435 ] Chesnay Schepler edited comment on FLINK-8048 at 11/15/17 1:36 PM: -

[GitHub] flink pull request #4544: [FLINK-7451] [table] Support non-ascii character l...

2017-11-15 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4544#discussion_r151128673 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/calcite/FlinkTypeFactory.scala --- @@ -269,6 +272,10 @@ class FlinkTypeFactory(t

[jira] [Commented] (FLINK-7451) Query fails when non-ascii characters are used in string literals

2017-11-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253456#comment-16253456 ] ASF GitHub Bot commented on FLINK-7451: --- Github user twalthr commented on a diff in

[GitHub] flink pull request #5021: [FLINK-8063][QS] QS client does not retry when an ...

2017-11-15 Thread kl0u
GitHub user kl0u opened a pull request: https://github.com/apache/flink/pull/5021 [FLINK-8063][QS] QS client does not retry when an UnknownKvStateLocation. ## What is the purpose of the change Fix bug in QS client. Before if the client submitted a query with invalid queryab

[jira] [Commented] (FLINK-8063) Client blocks indefinitely when querying a non-existing state

2017-11-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253459#comment-16253459 ] ASF GitHub Bot commented on FLINK-8063: --- GitHub user kl0u opened a pull request:

  1   2   3   >