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

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

[GitHub] flink issue #4909: [FLINK-7880][QS] Fix QS test instabilities.

2017-10-26 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/4909 It should call `dispose()`, you are correct. This was a mistake due to sloppy "manual rebasing". ---

[jira] [Commented] (FLINK-7548) Support watermark generation for TableSource

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

[jira] [Commented] (FLINK-7548) Support watermark generation for TableSource

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

[jira] [Commented] (FLINK-7548) Support watermark generation for TableSource

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

[jira] [Commented] (FLINK-7548) Support watermark generation for TableSource

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

[jira] [Commented] (FLINK-7548) Support watermark generation for TableSource

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

[jira] [Commented] (FLINK-7548) Support watermark generation for TableSource

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

[jira] [Commented] (FLINK-7548) Support watermark generation for TableSource

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

[jira] [Commented] (FLINK-7548) Support watermark generation for TableSource

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

[jira] [Commented] (FLINK-7548) Support watermark generation for TableSource

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

[GitHub] flink pull request #4894: [FLINK-7548] [table] Improve rowtime support of Ta...

2017-10-26 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4894#discussion_r146574319 --- Diff: flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java --- @@ -84,6 +86,13 @@

[GitHub] flink pull request #4894: [FLINK-7548] [table] Improve rowtime support of Ta...

2017-10-26 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4894#discussion_r146582532 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/ExternalTableSourceUtil.scala --- @@ -124,9 +124,15 @@ object ExternalTa

[GitHub] flink pull request #4894: [FLINK-7548] [table] Improve rowtime support of Ta...

2017-10-26 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4894#discussion_r146576347 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableSchema.scala --- @@ -50,6 +50,11 @@ class TableSchema( val

[GitHub] flink pull request #4894: [FLINK-7548] [table] Improve rowtime support of Ta...

2017-10-26 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4894#discussion_r146586028 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/CommonScan.scala --- @@ -18,55 +18,7 @@ package org.apache

[GitHub] flink pull request #4894: [FLINK-7548] [table] Improve rowtime support of Ta...

2017-10-26 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4894#discussion_r146584051 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala --- @@ -246,40 +245,31 @@ abstract class CodeGenerat

[GitHub] flink pull request #4894: [FLINK-7548] [table] Improve rowtime support of Ta...

2017-10-26 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4894#discussion_r146585641 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala --- @@ -1332,6 +1322,11 @@ abstract class CodeGenera

[GitHub] flink pull request #4894: [FLINK-7548] [table] Improve rowtime support of Ta...

2017-10-26 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4894#discussion_r146587166 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/PhysicalTableSourceScan.scala --- @@ -22,24 +22,30 @@ import org.apac

[GitHub] flink pull request #4894: [FLINK-7548] [table] Improve rowtime support of Ta...

2017-10-26 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4894#discussion_r146575110 --- Diff: flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBaseTableSource.java --- @@ -89,34 +98,50 @@ public void addColumn(Strin

[GitHub] flink pull request #4894: [FLINK-7548] [table] Improve rowtime support of Ta...

2017-10-26 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4894#discussion_r146583860 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala --- @@ -246,40 +245,31 @@ abstract class CodeGenerat

[jira] [Created] (FLINK-7936) Lack of synchronization w.r.t. taskManagers in MetricStore#add()

2017-10-26 Thread Ted Yu (JIRA)
Ted Yu created FLINK-7936: - Summary: Lack of synchronization w.r.t. taskManagers in MetricStore#add() Key: FLINK-7936 URL: https://issues.apache.org/jira/browse/FLINK-7936 Project: Flink Issue Type:

[jira] [Commented] (FLINK-7574) flink-clients

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

[GitHub] flink issue #4712: [FLINK-7574][build] POM Cleanup flink-clients

2017-10-26 Thread yew1eb
Github user yew1eb commented on the issue: https://github.com/apache/flink/pull/4712 thx @zentol, I will add the `maven-dependency-plugin` to flink-parent pom.xml file. ``` org.apache.maven.plugins maven-dependency-plugin 3.0.2

[jira] [Commented] (FLINK-6875) Remote DataSet API job submission timing out

2017-10-26 Thread hetang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16221634#comment-16221634 ] hetang commented on FLINK-6875: --- 十月 26, 2017 7:51:15 δΈ‹εˆ org.apache.flink.runtime.blob.BlobCl

[jira] [Commented] (FLINK-7705) Port JobDetailsHandler to new REST endpoint

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

[GitHub] flink issue #4884: [FLINK-7705] Add JobDetailsHandler

2017-10-26 Thread zjureel
Github user zjureel commented on the issue: https://github.com/apache/flink/pull/4884 Hi @tillrohrmann , could you merge this PR when you're free? Some issues depend on `MetricFetcher` and I found it would be added to `DispatcherRestEndpoint` in this PR. THX ---

[jira] [Commented] (FLINK-7100) TaskManager metrics are registered twice

2017-10-26 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16221567#comment-16221567 ] Fang Yong commented on FLINK-7100: -- [~Zentol] [~till.rohrmann], thank you for your sugges

[jira] [Commented] (FLINK-7935) Metrics with user supplied scope variables

2017-10-26 Thread Wei-Che Wei (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16221566#comment-16221566 ] Wei-Che Wei commented on FLINK-7935: Hi [~elevy] Is this issue same as FLINK-7692 > M

[jira] [Created] (FLINK-7935) Metrics with user supplied scope variables

2017-10-26 Thread Elias Levy (JIRA)
Elias Levy created FLINK-7935: - Summary: Metrics with user supplied scope variables Key: FLINK-7935 URL: https://issues.apache.org/jira/browse/FLINK-7935 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-7051) Bump up Calcite version to 1.14

2017-10-26 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16221305#comment-16221305 ] Fabian Hueske commented on FLINK-7051: -- Calcite dependency has been upgraded to 1.14

[jira] [Commented] (FLINK-6173) flink-table not pack-in com.fasterxml.jackson.* in after #FLINK-5414

2017-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16221301#comment-16221301 ] ASF GitHub Bot commented on FLINK-6173: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-7051) Bump up Calcite version to 1.14

2017-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16221300#comment-16221300 ] ASF GitHub Bot commented on FLINK-7051: --- Github user asfgit closed the pull request

[GitHub] flink pull request #4837: [FLINK-6173] [table] Clean-up flink-table jar and ...

2017-10-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4837 ---

[GitHub] flink pull request #4873: [FLINK-7051] [table] Bump Calcite version to 1.14.

2017-10-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4873 ---

[jira] [Commented] (FLINK-6225) Support Row Stream for CassandraSink

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

[GitHub] flink issue #3748: [FLINK-6225] [Cassandra Connector] add CassandraTableSink

2017-10-26 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3748 Thanks for the update and reminder @PangZhi. I'll have a look tomorrow. Maybe we can include this in the upcoming 1.4.0 release. Thanks, Fabian ---

[jira] [Commented] (FLINK-6173) flink-table not pack-in com.fasterxml.jackson.* in after #FLINK-5414

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

[GitHub] flink issue #4837: [FLINK-6173] [table] Clean-up flink-table jar and depende...

2017-10-26 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/4837 I'll fix the broken build and will merge this PR. ---

[jira] [Commented] (FLINK-7784) Don't fail TwoPhaseCommitSinkFunction when failing to commit

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

[jira] [Commented] (FLINK-7784) Don't fail TwoPhaseCommitSinkFunction when failing to commit

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

[GitHub] flink issue #4910: [FLINK-7784] [kafka-producer] Don't fail TwoPhaseCommitSi...

2017-10-26 Thread GJL
Github user GJL commented on the issue: https://github.com/apache/flink/pull/4910 @aljoscha ---

[GitHub] flink pull request #4910: [FLINK-7784] [kafka-producer] Don't fail TwoPhaseC...

2017-10-26 Thread GJL
GitHub user GJL opened a pull request: https://github.com/apache/flink/pull/4910 [FLINK-7784] [kafka-producer] Don't fail TwoPhaseCommitSinkFunction when failing to commit during job recovery ## What is the purpose of the change This makes it possible to configure the TwoPhaseCo

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

2017-10-26 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16220895#comment-16220895 ] Rong Rong commented on FLINK-7923: -- Done, created umbrella task for Calcite 1.15 release.

[jira] [Created] (FLINK-7934) Upgrade Calcite dependency to 1.15

2017-10-26 Thread Rong Rong (JIRA)
Rong Rong created FLINK-7934: Summary: Upgrade Calcite dependency to 1.15 Key: FLINK-7934 URL: https://issues.apache.org/jira/browse/FLINK-7934 Project: Flink Issue Type: Bug Reporter

[jira] [Commented] (FLINK-6225) Support Row Stream for CassandraSink

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

[GitHub] flink issue #3748: [FLINK-6225] [Cassandra Connector] add CassandraTableSink

2017-10-26 Thread PangZhi
Github user PangZhi commented on the issue: https://github.com/apache/flink/pull/3748 @zentol Hey zentol, when do you think we will be able to merge in. ---

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

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

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

2017-10-26 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16220825#comment-16220825 ] Kostas Kloudas commented on FLINK-7880: --- I think this PR fixes it. > flink-queryabl

[GitHub] flink pull request #4909: [FLINK-7880][QS] Fix QS test instabilities.

2017-10-26 Thread kl0u
GitHub user kl0u opened a pull request: https://github.com/apache/flink/pull/4909 [FLINK-7880][QS] Fix QS test instabilities. You can merge this pull request into a Git repository by running: $ git pull https://github.com/kl0u/flink qs-test-instability Alternatively you can r

[GitHub] flink pull request #4908: [FLINK-7933][metrics] Improve PrometheusReporter t...

2017-10-26 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/4908 [FLINK-7933][metrics] Improve PrometheusReporter tests ## What is the purpose of the change This PR resolves the test instabilities of the prometheus reporter. ## Brief change log

[jira] [Commented] (FLINK-7933) Test instability PrometheusReporterTest

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

[jira] [Closed] (FLINK-7908) Restructure the QS module to reduce client deps.

2017-10-26 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-7908. - Resolution: Fixed Merged at 0c771505b84cdacf7a359c3be0efe38a30f9e660 > Restructure the QS module

[jira] [Closed] (FLINK-7824) Put the queryable state jars in the opt folder.

2017-10-26 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-7824. - Resolution: Fixed > Put the queryable state jars in the opt folder. >

[jira] [Assigned] (FLINK-7933) Test instability PrometheusReporterTest

2017-10-26 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-7933: --- Assignee: Chesnay Schepler > Test instability PrometheusReporterTest > --

[jira] [Commented] (FLINK-7824) Put the queryable state jars in the opt folder.

2017-10-26 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16220791#comment-16220791 ] Kostas Kloudas commented on FLINK-7824: --- Merged at 2fd8721d0375bfa60a190bb206a65287c

[jira] [Commented] (FLINK-7908) Restructure the QS module to reduce client deps.

2017-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16220789#comment-16220789 ] ASF GitHub Bot commented on FLINK-7908: --- Github user asfgit closed the pull request

[GitHub] flink pull request #4906: [FLINK-7908][FLINK-7824][QS] Restructure QS packag...

2017-10-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4906 ---

[jira] [Commented] (FLINK-7840) Shade Akka's Netty Dependency

2017-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16220771#comment-16220771 ] ASF GitHub Bot commented on FLINK-7840: --- Github user StephanEwen commented on the is

[jira] [Commented] (FLINK-7840) Shade Akka's Netty Dependency

2017-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16220772#comment-16220772 ] ASF GitHub Bot commented on FLINK-7840: --- Github user StephanEwen closed the pull req

[GitHub] flink issue #4827: [FLINK-7840] [build] Shade netty in akka

2017-10-26 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4827 Merged in 8595dadb89a1276c6c7d0ed2e2fae396a5c1d222 ---

[jira] [Closed] (FLINK-7840) Shade Akka's Netty Dependency

2017-10-26 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-7840. --- > Shade Akka's Netty Dependency > - > > Key: FLINK-7840 >

[GitHub] flink pull request #4827: [FLINK-7840] [build] Shade netty in akka

2017-10-26 Thread StephanEwen
Github user StephanEwen closed the pull request at: https://github.com/apache/flink/pull/4827 ---

[jira] [Resolved] (FLINK-7840) Shade Akka's Netty Dependency

2017-10-26 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-7840. - Resolution: Fixed Fixed via 8595dadb89a1276c6c7d0ed2e2fae396a5c1d222 > Shade Akka's Netty Depende

[jira] [Commented] (FLINK-7100) TaskManager metrics are registered twice

2017-10-26 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16220765#comment-16220765 ] Till Rohrmann commented on FLINK-7100: -- True, the PR does not address a single proble

[jira] [Commented] (FLINK-7914) Expose Akka gated interval as user option

2017-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16220763#comment-16220763 ] ASF GitHub Bot commented on FLINK-7914: --- Github user StephanEwen commented on the is

[GitHub] flink issue #4903: [FLINK-7914] Introduce AkkaOptions.RETRY_GATE_CLOSED_FOR

2017-10-26 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4903 Sounds fair, +1 ---

[jira] [Commented] (FLINK-7844) Fine Grained Recovery triggers checkpoint timeout failure

2017-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16220750#comment-16220750 ] ASF GitHub Bot commented on FLINK-7844: --- Github user StephanEwen commented on the is

[GitHub] flink issue #4844: [FLINK-7844] [ckPt] Fail unacknowledged pending checkpoin...

2017-10-26 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4844 Had an offline discussion with @tillrohrmann - rewriting this without Mockito results in a similar amount of code with similar maintenance effort, so seems to be okay in this case. +1 to

[jira] [Updated] (FLINK-7933) Test instability PrometheusReporterTest

2017-10-26 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-7933: -- Component/s: Tests > Test instability PrometheusReporterTest > -

[jira] [Updated] (FLINK-7933) Test instability PrometheusReporterTest

2017-10-26 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-7933: -- Labels: test-stability (was: ) > Test instability PrometheusReporterTest >

[jira] [Updated] (FLINK-7933) Test instability PrometheusReporterTest

2017-10-26 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-7933: -- Priority: Critical (was: Major) > Test instability PrometheusReporterTest > ---

[jira] [Created] (FLINK-7933) Test instability PrometheusReporterTest

2017-10-26 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-7933: - Summary: Test instability PrometheusReporterTest Key: FLINK-7933 URL: https://issues.apache.org/jira/browse/FLINK-7933 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-7800) Enable window joins without equi-join predicates

2017-10-26 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16220670#comment-16220670 ] Fabian Hueske commented on FLINK-7800: -- That's a good point. I think we can remove th

[jira] [Commented] (FLINK-7932) Best Practices docs recommend passing parameters through open(Configuration c)

2017-10-26 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16220666#comment-16220666 ] Fabian Hueske commented on FLINK-7932: -- I see, thanks for the info. Might make sense

[jira] [Commented] (FLINK-7932) Best Practices docs recommend passing parameters through open(Configuration c)

2017-10-26 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16220662#comment-16220662 ] Chesnay Schepler commented on FLINK-7932: - This section was removed recently for 1

[jira] [Created] (FLINK-7932) Best Practices docs recommend passing parameters through open(Configuration c)

2017-10-26 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-7932: Summary: Best Practices docs recommend passing parameters through open(Configuration c) Key: FLINK-7932 URL: https://issues.apache.org/jira/browse/FLINK-7932 Project:

[jira] [Commented] (FLINK-7840) Shade Akka's Netty Dependency

2017-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16220639#comment-16220639 ] ASF GitHub Bot commented on FLINK-7840: --- Github user StephanEwen commented on the is

[GitHub] flink issue #4827: [FLINK-7840] [build] Shade netty in akka

2017-10-26 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4827 Merging as soon as Travis gives a green light on the rebased branch... ---

[jira] [Commented] (FLINK-7840) Shade Akka's Netty Dependency

2017-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16220633#comment-16220633 ] ASF GitHub Bot commented on FLINK-7840: --- Github user StephanEwen commented on the is

[GitHub] flink issue #4827: [FLINK-7840] [build] Shade netty in akka

2017-10-26 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4827 Thanks for the review, merging... ---

[jira] [Commented] (FLINK-7737) On HCFS systems, FSDataOutputStream does not issue hsync only hflush which leads to data loss

2017-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16220629#comment-16220629 ] ASF GitHub Bot commented on FLINK-7737: --- Github user StephanEwen commented on the is

[GitHub] flink issue #4876: [FLINK-7737][filesystem] Add syncOnFlush flag to StreamWr...

2017-10-26 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4876 A quick post-mortem comment here: This adds a lot of `equals()` and `hashCode()` on classes where these are ill-defined. For example: `StreamWriterBase` defines `equals()` and `h

[jira] [Assigned] (FLINK-7153) Eager Scheduling can't allocate source for ExecutionGraph correctly

2017-10-26 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-7153: Assignee: Till Rohrmann > Eager Scheduling can't allocate source for ExecutionGraph correct

[jira] [Commented] (FLINK-7840) Shade Akka's Netty Dependency

2017-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16220560#comment-16220560 ] ASF GitHub Bot commented on FLINK-7840: --- Github user StephanEwen commented on a diff

[GitHub] flink pull request #4827: [FLINK-7840] [build] Shade netty in akka

2017-10-26 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/4827#discussion_r147165565 --- Diff: flink-test-utils-parent/flink-test-utils/pom.xml --- @@ -117,6 +124,41 @@ under the License. true

[jira] [Commented] (FLINK-7846) Remove guava shading from ES2 connector

2017-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16220556#comment-16220556 ] ASF GitHub Bot commented on FLINK-7846: --- Github user asfgit closed the pull request

[GitHub] flink pull request #4902: [FLINK-7846] [elasticsearch] Remove unnecessary gu...

2017-10-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4902 ---

[jira] [Closed] (FLINK-7846) Remove guava shading from ES2 connector

2017-10-26 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7846. --- Resolution: Fixed 1.4: dc1a0dce060c7a4af9fec3a5d3d0ccf564e08060 > Remove guava shading from E

[jira] [Commented] (FLINK-7368) MetricStore makes cpu spin at 100%

2017-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16220553#comment-16220553 ] ASF GitHub Bot commented on FLINK-7368: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-7368) MetricStore makes cpu spin at 100%

2017-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16220554#comment-16220554 ] ASF GitHub Bot commented on FLINK-7368: --- Github user asfgit closed the pull request

[GitHub] flink pull request #4840: [FLINK-7368][metrics] Make MetricStore ThreadSafe ...

2017-10-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4840 ---

[GitHub] flink pull request #4472: FLINK-7368: MetricStore makes cpu spin at 100%

2017-10-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4472 ---

[jira] [Closed] (FLINK-7368) MetricStore makes cpu spin at 100%

2017-10-26 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7368. --- Resolution: Fixed 1.4: f622de3ecbc2ae17f2d15fe46828c48747c2b6ae > MetricStore makes cpu spin

[jira] [Commented] (FLINK-7844) Fine Grained Recovery triggers checkpoint timeout failure

2017-10-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16220545#comment-16220545 ] ASF GitHub Bot commented on FLINK-7844: --- Github user StephanEwen commented on a diff

[GitHub] flink pull request #4844: [FLINK-7844] [ckPt] Fail unacknowledged pending ch...

2017-10-26 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/4844#discussion_r147162652 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java --- @@ -1270,6 +1272,42 @@ public void run() {

[jira] [Commented] (FLINK-7051) Bump up Calcite version to 1.14

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

[jira] [Commented] (FLINK-7051) Bump up Calcite version to 1.14

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

[jira] [Commented] (FLINK-7051) Bump up Calcite version to 1.14

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

[jira] [Commented] (FLINK-7051) Bump up Calcite version to 1.14

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

[GitHub] flink pull request #4873: [FLINK-7051] [table] Bump Calcite version to 1.14.

2017-10-26 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4873#discussion_r147154899 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/batch/sql/AggregateTest.scala --- @@ -208,29 +208,29 @@ class AggregateTest

  1   2   3   >