[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=16253959#comment-16253959 ] ASF GitHub Bot commented on FLINK-7977: --- Github user bowenli86 commented on the issue:

[GitHub] flink issue #5017: [FLINK-8076] Upgrade KinesisProducer to 0.10.6 to set pro...

2017-11-15 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/5017 cc @tzulitai ---

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

2017-11-15 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4945 Sounds good. Thanks @zentol ! 👍 ---

[jira] [Assigned] (FLINK-8090) Improve error message when registering different states under the same name.

2017-11-15 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-8090: - Assignee: Kostas Kloudas > Improve error message when registering different states under

[jira] [Assigned] (FLINK-8090) Improve error message when registering different states under the same name.

2017-11-15 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-8090: - Assignee: (was: Kostas Kloudas) > Improve error message when registering different

[jira] [Commented] (FLINK-8076) Upgrade KinesisProducer to 0.10.6 to set properties approperiately

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

[jira] [Created] (FLINK-8091) Support running historyserver in foreground

2017-11-15 Thread Joshua Griffith (JIRA)
Joshua Griffith created FLINK-8091: -- Summary: Support running historyserver in foreground Key: FLINK-8091 URL: https://issues.apache.org/jira/browse/FLINK-8091 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-8060) Operator can make states queryable under the same name

2017-11-15 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-8060: - Assignee: Kostas Kloudas > Operator can make states queryable under the same name >

[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

[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=16253111#comment-16253111 ] lincoln.lee commented on FLINK-7942: [~twalthr] It's great if you have time to fix this, I'm on

[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.

[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=16253174#comment-16253174 ] ASF GitHub Bot commented on FLINK-7973: --- Github user aljoscha commented on the issue:

[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=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

[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] [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:

[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

[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

[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=16253152#comment-16253152 ] Fabian Hueske commented on FLINK-7490: -- I had a look at it and it seems that the wrong classloader is

[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 >

[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=16253183#comment-16253183 ] ASF GitHub Bot commented on FLINK-7973: --- Github user zentol commented on the issue:

[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

[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:

[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] [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:

[jira] [Updated] (FLINK-7954) sideoutput in async function

2017-11-15 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-7954: Priority: Major (was: Minor) > sideoutput in async function > > >

[jira] [Updated] (FLINK-6105) Properly handle InterruptedException in HadoopInputFormatBase

2017-11-15 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-6105: -- Description: When catching InterruptedException, we should throw InterruptedIOException instead of

[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=16254675#comment-16254675 ] ASF GitHub Bot commented on FLINK-7962: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #4936: [FLINK-7962] Add built-in support for min/max aggr...

2017-11-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4936 ---

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

2017-11-15 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu resolved FLINK-7962. Resolution: Fixed > Add built-in support for min/max aggregation for Timestamp >

[jira] [Updated] (FLINK-7897) Consider using nio.Files for file deletion in TransientBlobCleanupTask

2017-11-15 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-7897: -- Description: nio.Files#delete() provides better clue as to why the deletion may fail:

[jira] [Commented] (FLINK-7954) sideoutput in async function

2017-11-15 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16254591#comment-16254591 ] Bowen Li commented on FLINK-7954: - [~foxss] [~aljoscha] Hi guys, I think this feature is really useful and

[jira] [Comment Edited] (FLINK-5486) Lack of synchronization in BucketingSink#handleRestoredBucketState()

2017-11-15 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16211139#comment-16211139 ] Ted Yu edited comment on FLINK-5486 at 11/16/17 3:49 AM: - The reason for

[jira] [Commented] (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:comment-tabpanel=16254863#comment-16254863 ] Fabian Hueske commented on FLINK-7962: -- Implemented for 1.5.0 with

[jira] [Updated] (FLINK-7642) Upgrade maven surefire plugin to 2.19.1

2017-11-15 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-7642: -- Description: Surefire 2.19 release introduced more useful test filters which would let us run a subset of the

[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

[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

[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-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=16253314#comment-16253314 ] ASF GitHub Bot commented on FLINK-8069: --- Github user fhueske commented on a diff in the pull

[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=16253315#comment-16253315 ] ASF GitHub Bot commented on FLINK-8069: --- Github user fhueske commented on a diff in the pull

[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=16253316#comment-16253316 ] ASF GitHub Bot commented on FLINK-8069: --- Github user fhueske commented on a diff in the pull

[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=16253317#comment-16253317 ] ASF GitHub Bot commented on FLINK-8069: --- Github user fhueske commented on a diff in the pull

[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=16253318#comment-16253318 ] ASF GitHub Bot commented on FLINK-8069: --- Github user fhueske commented on a diff in the pull

[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

[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

[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

[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-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

[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

[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=16253226#comment-16253226 ] ASF GitHub Bot commented on FLINK-7943: --- Github user zentol commented on the issue:

[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] [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

[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] [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=16253215#comment-16253215 ] ASF GitHub Bot commented on FLINK-7490: --- GitHub user fhueske opened a pull request:

[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

[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=16253232#comment-16253232 ] ASF GitHub Bot commented on FLINK-7973: --- Github user aljoscha 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=16253258#comment-16253258 ] Fabian Hueske commented on FLINK-7923: -- Great, thanks! > SQL parser exception when accessing

[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

[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=16253329#comment-16253329 ] ASF GitHub Bot commented on FLINK-8013: --- Github user fhueske commented on a diff in the pull

[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:

[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

[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] [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 >

[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=16253247#comment-16253247 ] ASF GitHub Bot commented on FLINK-7962: --- Github user fhueske commented on the issue:

[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

[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=16253293#comment-16253293 ] ASF GitHub Bot commented on FLINK-7942: --- GitHub user twalthr opened a pull request:

[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-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=16253305#comment-16253305 ] ASF GitHub Bot commented on FLINK-7451: --- Github user twalthr commented on the issue:

[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. ---

[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

[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 {

[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=16253328#comment-16253328 ] ASF GitHub Bot commented on FLINK-8013: --- Github user fhueske commented on a diff in the pull

[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=16253331#comment-16253331 ] ASF GitHub Bot commented on FLINK-7962: --- Github user wuchong commented on the issue:

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

2017-11-15 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253683#comment-16253683 ] Greg Hogan commented on FLINK-8048: --- [~tedyu] {{mvn rat:check}} is from a different plugin and {{mvn

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

2017-11-15 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-7451. - Resolution: Fixed Fix Version/s: 1.5.0 1.4.0 Fixed in 1.5:

[jira] [Created] (FLINK-8085) Thin out the LogicalSlot interface

2017-11-15 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-8085: Summary: Thin out the LogicalSlot interface Key: FLINK-8085 URL: https://issues.apache.org/jira/browse/FLINK-8085 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-8014) Add Kafka010JsonTableSink

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

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

2017-11-15 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16253559#comment-16253559 ] Ted Yu commented on FLINK-8048: --- Linux 3.10.0-327.28.3.el7.x86_64 #1 SMP Thu Aug 18 19:05:49 UTC 2016 x86_64

[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=16253488#comment-16253488 ] ASF GitHub Bot commented on FLINK-8013: --- Github user twalthr commented on a diff in the pull

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

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

[GitHub] flink issue #5011: [FLINK-8013] [table] Support aggregate functions with gen...

2017-11-15 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/5011 Merging this... ---

[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=16253490#comment-16253490 ] ASF GitHub Bot commented on FLINK-8013: --- Github user twalthr commented on the issue:

[GitHub] flink pull request #4990: [FLINK-8014] [FLINK-8016] Add Kafka010JsonTableSin...

2017-11-15 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4990#discussion_r151140372 --- Diff: flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/Kafka010JsonTableSink.java --- @@ -0,0

[jira] [Created] (FLINK-8086) FlinkKafkaProducer011 can permanently fail in recovery

2017-11-15 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-8086: - Summary: FlinkKafkaProducer011 can permanently fail in recovery Key: FLINK-8086 URL: https://issues.apache.org/jira/browse/FLINK-8086 Project: Flink Issue

[jira] [Updated] (FLINK-8086) FlinkKafkaProducer011 can permanently fail in recovery through ProducerFencedException

2017-11-15 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-8086: -- Summary: FlinkKafkaProducer011 can permanently fail in recovery through ProducerFencedException

[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

[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

[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-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=16253370#comment-16253370 ] ASF GitHub Bot commented on FLINK-8069: --- Github user xccui 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] [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

[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

[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

[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 >

  1   2   3   >