[GitHub] flink issue #4848: [FLINK-7839] [doc] Add a note on possible maven failure f...

2017-10-18 Thread mcfongtw
Github user mcfongtw commented on the issue: https://github.com/apache/flink/pull/4848 @aljoscha, do you think adding these note would suffice? ---

[jira] [Commented] (FLINK-7839) Creating Quickstart project for SNAPSHOT version fails

2017-10-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16208896#comment-16208896 ] ASF GitHub Bot commented on FLINK-7839: --- Github user mcfongtw commented on the issue:

[GitHub] flink pull request #4764: [FLINK-7757] [checkpointing] Introduce resource gu...

2017-10-18 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/4764#discussion_r145341988 --- Diff: flink-core/src/test/java/org/apache/flink/util/ResourceGuardTest.java --- @@ -0,0 +1,135 @@ +/* + * Licensed to the Apache Software

[jira] [Commented] (FLINK-7420) Move all Avro code to flink-avro

2017-10-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16209006#comment-16209006 ] Till Rohrmann commented on FLINK-7420: -- What's the state of the issue [~twalthr]? > Move all Avro

[jira] [Commented] (FLINK-7021) Flink Task Manager hangs on startup if one Zookeeper node is unresolvable

2017-10-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16209039#comment-16209039 ] ASF GitHub Bot commented on FLINK-7021: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #4214: [FLINK-7021] Flink Task Manager hangs on startup if one Z...

2017-10-18 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4214 I'll address my comment myself and then merge the PR. Thanks a lot for your contribution @skidder. ---

[jira] [Commented] (FLINK-5789) Make Bucketing Sink independent of Hadoop's FileSystem

2017-10-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16209064#comment-16209064 ] Till Rohrmann commented on FLINK-5789: -- Is this a strict blocker for 1.4? > Make Bucketing Sink

[jira] [Updated] (FLINK-4811) Checkpoint Overview should list failed checkpoints

2017-10-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4811: - Priority: Major (was: Blocker) > Checkpoint Overview should list failed checkpoints >

[jira] [Closed] (FLINK-7819) Check object to clean is closure

2017-10-18 Thread Hai Zhou UTC+8 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou UTC+8 closed FLINK-7819. - Resolution: Won't Fix > Check object to clean is closure > > >

[jira] [Updated] (FLINK-7819) Check object to clean is closure

2017-10-18 Thread Hai Zhou UTC+8 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou UTC+8 updated FLINK-7819: -- Description: in *ClosureCleaner.clean(func) * method, we expect the *func* is closure. (was:

[jira] [Updated] (FLINK-4810) Checkpoint Coordinator should fail ExecutionGraph after "n" unsuccessful checkpoints

2017-10-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4810: - Priority: Major (was: Blocker) > Checkpoint Coordinator should fail ExecutionGraph after "n"

[jira] [Updated] (FLINK-4809) Operators should tolerate checkpoint failures

2017-10-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4809: - Priority: Major (was: Blocker) > Operators should tolerate checkpoint failures >

[GitHub] flink pull request #4849: [FLINK-6861][metrics] Use OperatorID in metric sys...

2017-10-18 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/4849 [FLINK-6861][metrics] Use OperatorID in metric system ## What is the purpose of the change This PR introduces Operator IDs to the metric system. ## Brief change log * store

[jira] [Closed] (FLINK-7757) RocksDB lock is too strict and can block snapshots in synchronous phase

2017-10-18 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-7757. - Resolution: Fixed Fixed in 7d026aa728. > RocksDB lock is too strict and can block snapshots in

[jira] [Commented] (FLINK-7757) RocksDB lock is too strict and can block snapshots in synchronous phase

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

[jira] [Commented] (FLINK-7826) Add support for all types of state to the QueryableStateClient.

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

[jira] [Closed] (FLINK-7826) Add support for all types of state to the QueryableStateClient.

2017-10-18 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-7826. - Resolution: Fixed Merged with abc3e1c888ceee941d557381a8cb8a7df8af2058 > Add support for all

[GitHub] flink pull request #4842: [FLINK-7853] [table] Reject table function outer j...

2017-10-18 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4842#discussion_r145345140 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/table/CorrelateITCase.scala --- @@ -82,6 +82,45 @@ class

[jira] [Commented] (FLINK-7703) Port JobExceptionsHandler to new REST endpoint

2017-10-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16208970#comment-16208970 ] ASF GitHub Bot commented on FLINK-7703: --- Github user zentol commented on the issue:

[GitHub] flink pull request #4803: [FLINK-7813] [metrics] Replace MetricRegistryThrea...

2017-10-18 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4803#discussion_r145347968 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricRegistry.java --- @@ -402,25 +401,4 @@ public void run() {

[jira] [Commented] (FLINK-6314) Allow setting CassandraSink mapper options

2017-10-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16208969#comment-16208969 ] ASF GitHub Bot commented on FLINK-6314: --- Github user zentol commented on the issue:

[GitHub] flink issue #4803: [FLINK-7813] [metrics] Replace MetricRegistryThreadFactor...

2017-10-18 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4803 merging. ---

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

2017-10-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16208971#comment-16208971 ] Till Rohrmann commented on FLINK-7824: -- Not a release blocker. > Put the queryable state jars in the

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

2017-10-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7824: - Priority: Major (was: Blocker) > Put the queryable state jars in the opt folder. >

[jira] [Updated] (FLINK-7610) xerces lib conflict

2017-10-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7610: - Priority: Critical (was: Blocker) > xerces lib conflict > --- > >

[jira] [Updated] (FLINK-7866) Weigh list of preferred locations for scheduling

2017-10-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7866: - Description: [~sihuazhou] proposed to not only use the list of preferred locations to decide

[jira] [Created] (FLINK-7866) Weigh list of preferred locations for scheduling

2017-10-18 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7866: Summary: Weigh list of preferred locations for scheduling Key: FLINK-7866 URL: https://issues.apache.org/jira/browse/FLINK-7866 Project: Flink Issue Type:

[jira] [Commented] (FLINK-6584) Support multiple consecutive windows in SQL

2017-10-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16209052#comment-16209052 ] Till Rohrmann commented on FLINK-6584: -- Is this truly a blocker for 1.4 [~fhueske]? It says that it

[jira] [Updated] (FLINK-5372) Fix RocksDBAsyncSnapshotTest.testCancelFullyAsyncCheckpoints()

2017-10-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-5372: - Labels: test-stability (was: ) > Fix RocksDBAsyncSnapshotTest.testCancelFullyAsyncCheckpoints()

[jira] [Commented] (FLINK-6861) Use OperatorID in metric system

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

[jira] [Commented] (FLINK-7608) LatencyGauge change to histogram metric

2017-10-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16209103#comment-16209103 ] ASF GitHub Bot commented on FLINK-7608: --- Github user yew1eb commented on a diff in the pull request:

[jira] [Commented] (FLINK-7757) RocksDB lock is too strict and can block snapshots in synchronous phase

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

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

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

[jira] [Commented] (FLINK-7853) Reject table function outer joins with predicates in Table API

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

[jira] [Updated] (FLINK-7837) AggregatingFunction does not work with immutable types

2017-10-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7837: - Priority: Major (was: Blocker) > AggregatingFunction does not work with immutable types >

[GitHub] flink issue #4843: [FLINK-7703] Port JobExceptionsHandler to new REST endpoi...

2017-10-18 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4843 merging. ---

[jira] [Commented] (FLINK-7837) AggregatingFunction does not work with immutable types

2017-10-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16208967#comment-16208967 ] Till Rohrmann commented on FLINK-7837: -- Not strictly a release blocker I would say, because it has

[GitHub] flink issue #4831: [FLINK-6314] [cassandra] Support user-defined Mapper opti...

2017-10-18 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4831 merging. ---

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

2017-10-18 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16209055#comment-16209055 ] Chesnay Schepler commented on FLINK-7100: - Note that there is also a second occurrence of this

[jira] [Commented] (FLINK-7608) LatencyGauge change to histogram metric

2017-10-18 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16209085#comment-16209085 ] Robert Metzger commented on FLINK-7608: --- +1 I agree > LatencyGauge change to histogram metric >

[jira] [Comment Edited] (FLINK-4808) Allow skipping failed checkpoints

2017-10-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16209082#comment-16209082 ] Till Rohrmann edited comment on FLINK-4808 at 10/18/17 9:42 AM: Is this

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

2017-10-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16209096#comment-16209096 ] Till Rohrmann edited comment on FLINK-7368 at 10/18/17 10:01 AM: - Piotr

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

2017-10-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16209096#comment-16209096 ] Till Rohrmann commented on FLINK-7368: -- Piotr correctly pointed out to me that copying a {{HashMap}}

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

2017-10-18 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16209106#comment-16209106 ] Piotr Nowojski commented on FLINK-7368: --- Ops my bad. I assumed that copying should be fast (one

[GitHub] flink issue #4842: [FLINK-7853] [table] Reject table function outer joins wi...

2017-10-18 Thread xccui
Github user xccui commented on the issue: https://github.com/apache/flink/pull/4842 Thanks for the review, @fhueske. I've updated the code and create a JIRA FLINK-7865 to track the resolving process of CALCITE-2004. ---

[jira] [Commented] (FLINK-7853) Reject table function outer joins with predicates in Table API

2017-10-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16209156#comment-16209156 ] ASF GitHub Bot commented on FLINK-7853: --- Github user xccui commented on the issue:

[jira] [Commented] (FLINK-5920) Make port (range) of queryable state server configurable

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

[GitHub] flink pull request #4814: [FLINK-5920][FLINK-7788][QS] Allow to specify a ra...

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

[jira] [Closed] (FLINK-5920) Make port (range) of queryable state server configurable

2017-10-18 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-5920. - Resolution: Fixed > Make port (range) of queryable state server configurable >

[jira] [Commented] (FLINK-7702) Javadocs link broken

2017-10-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16208985#comment-16208985 ] Till Rohrmann commented on FLINK-7702: -- Since it only affects the master, it should not be a blocker

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

2017-10-18 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7548: - Issue Type: Improvement (was: Bug) > Support watermark generation for TableSource >

[jira] [Updated] (FLINK-7702) Javadocs link broken

2017-10-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7702: - Priority: Critical (was: Blocker) > Javadocs link broken > > >

[jira] [Assigned] (FLINK-7864) Support side-outputs in CoProcessFunction

2017-10-18 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-7864: --- Assignee: Bowen Li > Support side-outputs in CoProcessFunction >

[jira] [Updated] (FLINK-7608) LatencyGauge change to histogram metric

2017-10-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7608: - Priority: Major (was: Blocker) > LatencyGauge change to histogram metric >

[jira] [Commented] (FLINK-7608) LatencyGauge change to histogram metric

2017-10-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16208999#comment-16208999 ] Till Rohrmann commented on FLINK-7608: -- I think this issue should not block the 1.4 release.

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

2017-10-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16209002#comment-16209002 ] Till Rohrmann commented on FLINK-7548: -- Is this strictly a blocker for 1.4? > Support watermark

[jira] [Commented] (FLINK-6944) Introduce DefaultTypeSerializerConfigSnapshot as a base implementation for serializer compatibility checks

2017-10-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16209049#comment-16209049 ] Till Rohrmann commented on FLINK-6944: -- I think this is not a blocker for 1.4. > Introduce

[jira] [Commented] (FLINK-6697) Add batch multi-window support

2017-10-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16209050#comment-16209050 ] Till Rohrmann commented on FLINK-6697: -- Is this truly a blocker for 1.4 [~fhueske]? > Add batch

[jira] [Updated] (FLINK-6944) Introduce DefaultTypeSerializerConfigSnapshot as a base implementation for serializer compatibility checks

2017-10-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-6944: - Priority: Major (was: Blocker) > Introduce DefaultTypeSerializerConfigSnapshot as a base

[jira] [Commented] (FLINK-5704) Deprecate FlinkKafkaConsumer constructors in favor of improvements to decoupling from Kafka offset committing

2017-10-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16209065#comment-16209065 ] Till Rohrmann commented on FLINK-5704: -- Are we gonna have this improvement in 1.4? > Deprecate

[jira] [Commented] (FLINK-4808) Allow skipping failed checkpoints

2017-10-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16209082#comment-16209082 ] Till Rohrmann commented on FLINK-4808: -- Is this truly a blocker for 1.4? I would actually downgrade

[GitHub] flink pull request #4826: [FLINK-7608][metric] Refactoring latency statistic...

2017-10-18 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4826#discussion_r145366433 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/util/latency/LatencyHistogram.java --- @@ -0,0 +1,51 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-7608) LatencyGauge change to histogram metric

2017-10-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16209090#comment-16209090 ] ASF GitHub Bot commented on FLINK-7608: --- Github user zentol commented on a diff in the pull request:

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

2017-10-18 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16209106#comment-16209106 ] Piotr Nowojski edited comment on FLINK-7368 at 10/18/17 10:15 AM: -- Ops my

[jira] [Commented] (FLINK-7420) Move all Avro code to flink-avro

2017-10-18 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16209108#comment-16209108 ] Timo Walther commented on FLINK-7420: - In theory, I have this ready in branch. I can open a PR for it.

[jira] [Assigned] (FLINK-5372) Fix RocksDBAsyncSnapshotTest.testCancelFullyAsyncCheckpoints()

2017-10-18 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-5372: - Assignee: Stefan Richter > Fix

[jira] [Closed] (FLINK-7813) Replace MetricRegistryThreadFactory

2017-10-18 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7813. --- Resolution: Fixed 1.4: e14f2dbddbf1b4c4dc29cf20e47b6b04c5876109 > Replace

[jira] [Closed] (FLINK-7703) Port JobExceptionsHandler to new REST endpoint

2017-10-18 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7703. --- Resolution: Fixed Fix Version/s: (was: 1.5.0) 1.4.0 1.4:

[GitHub] flink pull request #4831: [FLINK-6314] [cassandra] Support user-defined Mapp...

2017-10-18 Thread zentol
Github user zentol closed the pull request at: https://github.com/apache/flink/pull/4831 ---

[jira] [Commented] (FLINK-7757) RocksDB lock is too strict and can block snapshots in synchronous phase

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

[jira] [Commented] (FLINK-7757) RocksDB lock is too strict and can block snapshots in synchronous phase

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

[GitHub] flink pull request #4764: [FLINK-7757] [checkpointing] Introduce resource gu...

2017-10-18 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/4764#discussion_r145341268 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java --- @@

[GitHub] flink pull request #4764: [FLINK-7757] [checkpointing] Introduce resource gu...

2017-10-18 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/4764#discussion_r145341403 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java --- @@ -66,14 +66,13 @@ import

[GitHub] flink pull request #4838: [FLINK-7826][QS] Add support for all types of stat...

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

[GitHub] flink pull request #4764: [FLINK-7757] [checkpointing] Introduce resource gu...

2017-10-18 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/4764#discussion_r145341323 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackendTest.java --- @@

[jira] [Closed] (FLINK-7796) RocksDBKeyedStateBackend#RocksDBFullSnapshotOperation should close snapshotCloseableRegistry

2017-10-18 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-7796. - Resolution: Invalid > RocksDBKeyedStateBackend#RocksDBFullSnapshotOperation should close >

[jira] [Commented] (FLINK-7796) RocksDBKeyedStateBackend#RocksDBFullSnapshotOperation should close snapshotCloseableRegistry

2017-10-18 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16208979#comment-16208979 ] Stefan Richter commented on FLINK-7796: --- It is closed by the creator/owner in

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

2017-10-18 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: (was: Stephan Ewen) > Eager Scheduling can't allocate source for

[jira] [Commented] (FLINK-6951) Incompatible versions of httpcomponents jars for Flink kinesis connector

2017-10-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16209048#comment-16209048 ] Till Rohrmann commented on FLINK-6951: -- Not sure whether we have this much time if this is a true 1.4

[jira] [Commented] (FLINK-7777) Bump japicmp to 0.10.0

2017-10-18 Thread Hai Zhou UTC+8 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16209045#comment-16209045 ] Hai Zhou UTC+8 commented on FLINK-: --- True, I found more incompatible when switching to version

[jira] [Commented] (FLINK-5015) Add Tests/ITCase for Kafka Per-Partition Watermarks

2017-10-18 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16209119#comment-16209119 ] Tzu-Li (Gordon) Tai commented on FLINK-5015: Yes, have a branch almost ready for this. > Add

[jira] [Commented] (FLINK-7788) Allow port range for queryable state client proxy.

2017-10-18 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16208891#comment-16208891 ] Kostas Kloudas commented on FLINK-7788: --- Merged at 5338f856b42422189246130cc245754162fa9913 > Allow

[jira] [Closed] (FLINK-7788) Allow port range for queryable state client proxy.

2017-10-18 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-7788. - Resolution: Fixed > Allow port range for queryable state client proxy. >

[jira] [Commented] (FLINK-5920) Make port (range) of queryable state server configurable

2017-10-18 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16208890#comment-16208890 ] Kostas Kloudas commented on FLINK-5920: --- Merged at 717a7dc81d066dc7d6e1a17099c0f5e1bc96b5d1 > Make

[jira] [Commented] (FLINK-7813) Replace MetricRegistryThreadFactory

2017-10-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16208974#comment-16208974 ] ASF GitHub Bot commented on FLINK-7813: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-7418) Replace all uses of jackson with flink-shaded-jackson

2017-10-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16208977#comment-16208977 ] Till Rohrmann commented on FLINK-7418: -- What's the state of this issue [~Zentol]? > Replace all uses

[jira] [Commented] (FLINK-7853) Reject table function outer joins with predicates in Table API

2017-10-18 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16208976#comment-16208976 ] Fabian Hueske commented on FLINK-7853: -- And the answer is also the same as for FLINK-7854. > Reject

[jira] [Commented] (FLINK-7854) Reject lateral table outer joins with predicates in SQL

2017-10-18 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16208973#comment-16208973 ] Fabian Hueske commented on FLINK-7854: -- IMO, this is a blocker. We are silently computing wrong

[jira] [Updated] (FLINK-7781) Support simple on-demand metrics aggregation

2017-10-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7781: - Priority: Major (was: Blocker) > Support simple on-demand metrics aggregation >

[jira] [Updated] (FLINK-7778) Relocate ZooKeeper

2017-10-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7778: - Priority: Critical (was: Blocker) > Relocate ZooKeeper > -- > >

[jira] [Updated] (FLINK-7779) Relocate Curator

2017-10-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7779: - Priority: Critical (was: Blocker) > Relocate Curator > > > Key:

[jira] [Commented] (FLINK-7781) Support simple on-demand metrics aggregation

2017-10-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16208975#comment-16208975 ] Till Rohrmann commented on FLINK-7781: -- Not a blocker I would say. > Support simple on-demand

[jira] [Commented] (FLINK-7813) Replace MetricRegistryThreadFactory

2017-10-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16208972#comment-16208972 ] ASF GitHub Bot commented on FLINK-7813: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-7637) FlinkKinesisProducer violates at-least-once guarantees

2017-10-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16208990#comment-16208990 ] Till Rohrmann commented on FLINK-7637: -- Is this issue in progress? > FlinkKinesisProducer violates

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

2017-10-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16209021#comment-16209021 ] Till Rohrmann commented on FLINK-7153: -- These are good ideas [~sihuazhou]. I like counting which

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

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

[jira] [Updated] (FLINK-7777) Bump japicmp to 0.10.0

2017-10-18 Thread Hai Zhou UTC+8 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou UTC+8 updated FLINK-: -- Summary: Bump japicmp to 0.10.0 (was: Upgrade maven plugin japicmp version to 0.10.0) > Bump

[jira] [Commented] (FLINK-7067) Cancel with savepoint does not restart checkpoint scheduler on failure

2017-10-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16209038#comment-16209038 ] Till Rohrmann commented on FLINK-7067: -- [~uce] are you still working on this issue so that it makes

[jira] [Updated] (FLINK-7777) Upgrade maven plugin japicmp version to 0.10.0

2017-10-18 Thread Hai Zhou UTC+8 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou UTC+8 updated FLINK-: -- Fix Version/s: (was: 1.4.0) 1.5.0 > Upgrade maven plugin japicmp version

[jira] [Commented] (FLINK-5823) Store Checkpoint Root Metadata in StateBackend (not in HA custom store)

2017-10-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16209061#comment-16209061 ] Till Rohrmann commented on FLINK-5823: -- Is it still realistic that this will make it into the 1.4

  1   2   3   >