[jira] [Commented] (FLINK-7668) Add AccessExecutionGraph refresh interval to ExecutionGraphHolder

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

[GitHub] flink pull request #4728: [FLINK-7668] Add ExecutionGraphCache for Execution...

2017-09-27 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4728#discussion_r141319310 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/RestfulGateway.java --- @@ -38,5 +44,36 @@ * @param timeout for

[GitHub] flink pull request #4728: [FLINK-7668] Add ExecutionGraphCache for Execution...

2017-09-27 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4728#discussion_r141319696 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/WebRuntimeMonitor.java --- @@ -193,11 +198,23 @@ public

[jira] [Commented] (FLINK-7668) Add AccessExecutionGraph refresh interval to ExecutionGraphHolder

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

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

2017-09-27 Thread Gabor Gevay (JIRA)
Gabor Gevay created FLINK-7702: -- Summary: Javadocs link broken Key: FLINK-7702 URL: https://issues.apache.org/jira/browse/FLINK-7702 Project: Flink Issue Type: Bug Components:

[GitHub] flink pull request #4733: [FLINK-7701][network] really fix watermark configu...

2017-09-27 Thread NicoK
GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/4733 [FLINK-7701][network] really fix watermark configuration order this time ## What is the purpose of the change Netty (in the version we use) only allows setting high and low watermarks after

[jira] [Commented] (FLINK-7701) IllegalArgumentException in Netty bootstrap with small memory state segment size

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182438#comment-16182438 ] ASF GitHub Bot commented on FLINK-7701: --- GitHub user NicoK opened a pull request:

[jira] [Commented] (FLINK-7668) Add AccessExecutionGraph refresh interval to ExecutionGraphHolder

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

[GitHub] flink pull request #4728: [FLINK-7668] Add ExecutionGraphCache for Execution...

2017-09-27 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4728#discussion_r141320964 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/ExecutionGraphCache.java --- @@ -0,0 +1,182 @@ +/* + *

[GitHub] flink pull request #4728: [FLINK-7668] Add ExecutionGraphCache for Execution...

2017-09-27 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4728#discussion_r141320991 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/ExecutionGraphCache.java --- @@ -0,0 +1,182 @@ +/* + *

[GitHub] flink pull request #4728: [FLINK-7668] Add ExecutionGraphCache for Execution...

2017-09-27 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4728#discussion_r141321081 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/ExecutionGraphCache.java --- @@ -0,0 +1,182 @@ +/* + *

[jira] [Commented] (FLINK-7668) Add AccessExecutionGraph refresh interval to ExecutionGraphHolder

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

[GitHub] flink pull request #4728: [FLINK-7668] Add ExecutionGraphCache for Execution...

2017-09-27 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4728#discussion_r141321257 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/ExecutionGraphCacheTest.java --- @@ -0,0 +1,357 @@ +/* + *

[jira] [Commented] (FLINK-7668) Add AccessExecutionGraph refresh interval to ExecutionGraphHolder

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

[jira] [Commented] (FLINK-7668) Add AccessExecutionGraph refresh interval to ExecutionGraphHolder

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

[GitHub] flink pull request #4728: [FLINK-7668] Add ExecutionGraphCache for Execution...

2017-09-27 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4728#discussion_r141321341 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/ExecutionGraphCacheTest.java --- @@ -0,0 +1,357 @@ +/* + *

[jira] [Commented] (FLINK-7668) Add AccessExecutionGraph refresh interval to ExecutionGraphHolder

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

[GitHub] flink pull request #4734: [FLINK-7652] [flip6] Port CurrentJobIdsHandler to ...

2017-09-27 Thread tzulitai
GitHub user tzulitai opened a pull request: https://github.com/apache/flink/pull/4734 [FLINK-7652] [flip6] Port CurrentJobIdsHandler to new REST endpoint ## What is the purpose of the change This PR ports the existing `CurrentJobIdsHandler` to the new REST endpoint. The

[jira] [Commented] (FLINK-7652) Port CurrentJobIdsHandler to new REST endpoint

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182466#comment-16182466 ] ASF GitHub Bot commented on FLINK-7652: --- GitHub user tzulitai opened a pull request:

[GitHub] flink issue #4728: [FLINK-7668] Add ExecutionGraphCache for ExecutionGraph b...

2017-09-27 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4728 Thanks for the review @zentol. I've addressed your comments. Since the `WebRuntimeMonitor` requests the actual `ExecutionGraph` from the `JobManagerGateway` instead of the

[jira] [Commented] (FLINK-7668) Add AccessExecutionGraph refresh interval to ExecutionGraphHolder

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

[GitHub] flink issue #4722: [FLINK-7683] Iterate over keys in KeyedStateBackend

2017-09-27 Thread pnowojski
Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/4722 We have got carried away with those concurrent modifications and snapshots. To rewrite keyed state variable from an old to a new one, old is used as a read only. Thus `getKeys` for the the old one

[jira] [Commented] (FLINK-7683) Add method to iterate over all of the existing keys in a statebackend

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182475#comment-16182475 ] ASF GitHub Bot commented on FLINK-7683: --- Github user pnowojski commented on the issue:

[GitHub] flink pull request #4728: [FLINK-7668] Add ExecutionGraphCache for Execution...

2017-09-27 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4728#discussion_r141334334 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/WebRuntimeMonitor.java --- @@ -193,11 +198,23 @@ public WebRuntimeMonitor(

[jira] [Commented] (FLINK-7668) Add AccessExecutionGraph refresh interval to ExecutionGraphHolder

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

[GitHub] flink issue #4728: [FLINK-7668] Add ExecutionGraphCache for ExecutionGraph b...

2017-09-27 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4728 But that's not the case for the flip-6 code, is it? There the JobMaster creates a separate ArchivedExecutionGraph that is not automatically updated. ---

[jira] [Commented] (FLINK-7668) Add AccessExecutionGraph refresh interval to ExecutionGraphHolder

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

[GitHub] flink pull request #4660: [FLINK-7050][table] Add support of RFC compliant C...

2017-09-27 Thread uybhatti
Github user uybhatti commented on a diff in the pull request: https://github.com/apache/flink/pull/4660#discussion_r141336157 --- Diff: flink-libraries/flink-table/pom.xml --- @@ -114,6 +114,12 @@ under the License. joda-time

[jira] [Commented] (FLINK-7050) RFC Compliant CSV Parser for Table Source

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

[jira] [Commented] (FLINK-7050) RFC Compliant CSV Parser for Table Source

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182526#comment-16182526 ] ASF GitHub Bot commented on FLINK-7050: --- Github user uybhatti commented on the issue:

[GitHub] flink issue #4660: [FLINK-7050][table] Add support of RFC compliant CSV pars...

2017-09-27 Thread uybhatti
Github user uybhatti commented on the issue: https://github.com/apache/flink/pull/4660 Hi @fhueske , thanks for your feedback. I have addressed your feedback. Please take a look on changes. Thanks, Usman ---

[GitHub] flink pull request #4697: [FLINK-7650] [flip6] Port JobCancellationHandler t...

2017-09-27 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4697#discussion_r141336714 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobCancellationHeaders.java --- @@ -0,0 +1,68 @@ +/* + * Licensed to

[jira] [Assigned] (FLINK-7698) Join with null literals leads to NPE

2017-09-27 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui reassigned FLINK-7698: -- Assignee: Xingcan Cui > Join with null literals leads to NPE >

[jira] [Commented] (FLINK-7650) Port JobCancellationHandler to new REST endpoint

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

[GitHub] flink issue #4699: [FLINK-7663] [flip6] Return BAD_REQUEST if HandlerRequest...

2017-09-27 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4699 +1. ---

[jira] [Commented] (FLINK-7663) Allow AbstractRestHandler to handle bad requests

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

[GitHub] flink issue #4727: [FLINK-7667] [flip6] Use ArchivedExecutionGraph as serial...

2017-09-27 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4727 +1. ---

[jira] [Commented] (FLINK-7667) Add serializable AccessExecutionGraph implementation

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

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

2017-09-27 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-7702: --- Assignee: Timo Walther > Javadocs link broken > > >

[GitHub] flink issue #4447: [FLINK-7312][checkstyle] activate checkstyle for flink/co...

2017-09-27 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/4447 Just curious whether we can merge this now - it has been laying around for too long. ---

[jira] [Commented] (FLINK-7312) activate checkstyle for flink/core/memory/*

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182538#comment-16182538 ] ASF GitHub Bot commented on FLINK-7312: --- Github user NicoK commented on the issue:

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

2017-09-27 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182541#comment-16182541 ] Timo Walther commented on FLINK-7702: - Thanks for reporting this. I thought actually that an Jira

[GitHub] flink issue #4506: [FLINK-7400][cluster] fix off-heap limits set to conserva...

2017-09-27 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/4506 @tillrohrmann can you have a look at this? ---

[jira] [Commented] (FLINK-7400) off-heap limits set to conservatively in cluster environments

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182543#comment-16182543 ] ASF GitHub Bot commented on FLINK-7400: --- Github user NicoK commented on the issue:

[GitHub] flink pull request #4731: [FLINK-7700] Fix RocksDB state merging

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

[jira] [Commented] (FLINK-7700) State merging in RocksDB backend leaves old state

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

[GitHub] flink pull request #4517: [FLINK-7411][network] minor performance improvemen...

2017-09-27 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4517#discussion_r141341300 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java --- @@ -130,34 +128,31 @@ protected void

[GitHub] flink issue #4696: [FLINK-7632] [document] Overhaul on Cassandra connector d...

2017-09-27 Thread mcfongtw
Github user mcfongtw commented on the issue: https://github.com/apache/flink/pull/4696 @zentol, Could you take another look? Thank you. ---

[jira] [Commented] (FLINK-7411) minor performance improvements in NettyMessage

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

[jira] [Commented] (FLINK-7632) Better documentation and examples on C* sink usage for Pojo and Tuples data types

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

[GitHub] flink issue #4697: [FLINK-7650] [flip6] Port JobCancellationHandler to new R...

2017-09-27 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4697 I see a few problems with separating running jobs. * The monitoring pattern for a job becomes quite weird. While a job is running you ask "/jobs/running/:jobid", until you get a 404 and then

[jira] [Commented] (FLINK-7650) Port JobCancellationHandler to new REST endpoint

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

[GitHub] flink issue #4700: [FLINK-7649] [flip6] Extend JobTerminationHandler to supp...

2017-09-27 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4700 +1, feel free to merge once we concluded our discussions in #4697 :) ---

[jira] [Commented] (FLINK-7649) Port JobStoppingHandler to new REST endpoint

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

[jira] [Commented] (FLINK-6949) Add ability to ship custom resource files to YARN cluster

2017-09-27 Thread Mikhail Pryakhin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182562#comment-16182562 ] Mikhail Pryakhin commented on FLINK-6949: - Unfortunately, the workaround you suggested doesn't

[GitHub] flink pull request #4517: [FLINK-7411][network] minor performance improvemen...

2017-09-27 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4517#discussion_r141345178 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java --- @@ -242,21 +239,22 @@ ByteBuf write(ByteBufAllocator

[jira] [Assigned] (FLINK-7697) Add metrics for Elasticsearch Sink

2017-09-27 Thread Hai Zhou UTC+8 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou UTC+8 reassigned FLINK-7697: - Assignee: Hai Zhou UTC+8 > Add metrics for Elasticsearch Sink >

[jira] [Commented] (FLINK-7411) minor performance improvements in NettyMessage

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

[GitHub] flink issue #4605: [FLINK-4500] [C* Connector] CassandraSinkBase implements ...

2017-09-27 Thread mcfongtw
Github user mcfongtw commented on the issue: https://github.com/apache/flink/pull/4605 @zentol, could you also take another look if the revision has addressed the concerns? Thank you. ---

[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

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

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

2017-09-27 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141352765 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java --- @@ -0,0 +1,133 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

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

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

2017-09-27 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay updated FLINK-7702: --- Fix Version/s: 1.4.0 > Javadocs link broken > > > Key:

[GitHub] flink pull request #4624: [FLINK-7410] [table] Use toString method to displa...

2017-09-27 Thread hequn8128
Github user hequn8128 commented on a diff in the pull request: https://github.com/apache/flink/pull/4624#discussion_r141354970 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/UserDefinedFunction.scala --- @@ -41,7 +41,7 @@ abstract class

[jira] [Commented] (FLINK-7410) Use toString method to display operator names for UserDefinedFunction

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

[GitHub] flink issue #4624: [FLINK-7410] [table] Use toString method to display opera...

2017-09-27 Thread hequn8128
Github user hequn8128 commented on the issue: https://github.com/apache/flink/pull/4624 @wuchong Thanks for your review, I have updated the PR according to your comments. ---

[jira] [Commented] (FLINK-7410) Use toString method to display operator names for UserDefinedFunction

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182632#comment-16182632 ] ASF GitHub Bot commented on FLINK-7410: --- Github user hequn8128 commented on the issue:

[jira] [Commented] (FLINK-2170) Add OrcTableSource

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

[GitHub] flink pull request #4670: [FLINK-2170] [connectors] Add ORC connector for Ta...

2017-09-27 Thread uybhatti
Github user uybhatti commented on a diff in the pull request: https://github.com/apache/flink/pull/4670#discussion_r141356723 --- Diff: flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcUtils.java --- @@ -0,0 +1,2229 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-7668) Add AccessExecutionGraph refresh interval to ExecutionGraphHolder

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

[jira] [Commented] (FLINK-7668) Add AccessExecutionGraph refresh interval to ExecutionGraphHolder

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

[jira] [Commented] (FLINK-7668) Add AccessExecutionGraph refresh interval to ExecutionGraphHolder

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

[GitHub] flink pull request #4728: [FLINK-7668] Add ExecutionGraphCache for Execution...

2017-09-27 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4728#discussion_r141348426 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/JobConfigHandler.java --- @@ -42,7 +42,7 @@ private

[GitHub] flink pull request #4728: [FLINK-7668] Add ExecutionGraphCache for Execution...

2017-09-27 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4728#discussion_r141351624 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/ExecutionGraphCacheTest.java --- @@ -0,0 +1,357 @@ +/* + *

[GitHub] flink pull request #4728: [FLINK-7668] Add ExecutionGraphCache for Execution...

2017-09-27 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4728#discussion_r141337553 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/ExecutionGraphCache.java --- @@ -0,0 +1,182 @@ +/* + * Licensed

[jira] [Commented] (FLINK-7668) Add AccessExecutionGraph refresh interval to ExecutionGraphHolder

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

[jira] [Commented] (FLINK-7668) Add AccessExecutionGraph refresh interval to ExecutionGraphHolder

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

[jira] [Commented] (FLINK-7668) Add AccessExecutionGraph refresh interval to ExecutionGraphHolder

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

[GitHub] flink pull request #4728: [FLINK-7668] Add ExecutionGraphCache for Execution...

2017-09-27 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4728#discussion_r141357865 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/ExecutionGraphCacheTest.java --- @@ -0,0 +1,357 @@ +/* + *

[GitHub] flink pull request #4728: [FLINK-7668] Add ExecutionGraphCache for Execution...

2017-09-27 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4728#discussion_r141359484 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/ExecutionGraphCacheTest.java --- @@ -0,0 +1,357 @@ +/* + *

[GitHub] flink pull request #4728: [FLINK-7668] Add ExecutionGraphCache for Execution...

2017-09-27 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4728#discussion_r141341929 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/ExecutionGraphCache.java --- @@ -0,0 +1,180 @@ +/* + * Licensed

[jira] [Commented] (FLINK-7668) Add AccessExecutionGraph refresh interval to ExecutionGraphHolder

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

[GitHub] flink pull request #4728: [FLINK-7668] Add ExecutionGraphCache for Execution...

2017-09-27 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4728#discussion_r141360498 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/ExecutionGraphCacheTest.java --- @@ -0,0 +1,357 @@ +/* + *

[jira] [Commented] (FLINK-7698) Join with null literals leads to NPE

2017-09-27 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182660#comment-16182660 ] Xingcan Cui commented on FLINK-7698: Hi [~twalthr], thanks for this ticket. It seems that the null

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

2017-09-27 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-7703: -- Summary: Port JobExceptionsHandler to new REST endpoint Key: FLINK-7703 URL: https://issues.apache.org/jira/browse/FLINK-7703 Project: Flink

[GitHub] flink pull request #4735: [FLINK-7699][core] Define the BufferListener inter...

2017-09-27 Thread zhijiangW
GitHub user zhijiangW opened a pull request: https://github.com/apache/flink/pull/4735 [FLINK-7699][core] Define the BufferListener interface to replace EventlListener in BufferProvider ## What is the purpose of the change *Currently the EventListener is used in

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

2017-09-27 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-7703: --- Fix Version/s: 1.4.0 > Port JobExceptionsHandler to new REST endpoint >

[jira] [Commented] (FLINK-7699) Define the BufferListener interface to replace EventlListener in BufferProvider

2017-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182673#comment-16182673 ] ASF GitHub Bot commented on FLINK-7699: --- GitHub user zhijiangW opened a pull request:

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

2017-09-27 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-7703: --- Description: Port existing {{JobExceptionsHandler}} to new REST endpoint. > Port

[jira] [Created] (FLINK-7704) Port JobPlanHandler to new REST endpoint

2017-09-27 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-7704: -- Summary: Port JobPlanHandler to new REST endpoint Key: FLINK-7704 URL: https://issues.apache.org/jira/browse/FLINK-7704 Project: Flink Issue

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

2017-09-27 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-7703: --- Labels: flip-6 (was: ) > Port JobExceptionsHandler to new REST endpoint >

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

2017-09-27 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-7705: -- Summary: Port JobDetailsHandler to new REST endpoint Key: FLINK-7705 URL: https://issues.apache.org/jira/browse/FLINK-7705 Project: Flink Issue

[jira] [Created] (FLINK-7706) Port JobAccumulatorsHandler to new REST endpoint

2017-09-27 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-7706: -- Summary: Port JobAccumulatorsHandler to new REST endpoint Key: FLINK-7706 URL: https://issues.apache.org/jira/browse/FLINK-7706 Project: Flink

[jira] [Created] (FLINK-7707) Port CheckpointStatsDetailsSubtasksHandler to new REST endpoint

2017-09-27 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-7707: -- Summary: Port CheckpointStatsDetailsSubtasksHandler to new REST endpoint Key: FLINK-7707 URL: https://issues.apache.org/jira/browse/FLINK-7707 Project:

[jira] [Created] (FLINK-7708) Port CheckpointConfigHandler to new REST endpoint

2017-09-27 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-7708: -- Summary: Port CheckpointConfigHandler to new REST endpoint Key: FLINK-7708 URL: https://issues.apache.org/jira/browse/FLINK-7708 Project: Flink

[jira] [Created] (FLINK-7709) Port CheckpointStatsDetailsHandler to new REST endpoint

2017-09-27 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-7709: -- Summary: Port CheckpointStatsDetailsHandler to new REST endpoint Key: FLINK-7709 URL: https://issues.apache.org/jira/browse/FLINK-7709 Project: Flink

[jira] [Created] (FLINK-7710) Port CheckpointStatsHandler to new REST endpoint

2017-09-27 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-7710: -- Summary: Port CheckpointStatsHandler to new REST endpoint Key: FLINK-7710 URL: https://issues.apache.org/jira/browse/FLINK-7710 Project: Flink

[GitHub] flink pull request #4697: [FLINK-7650] [flip6] Port JobCancellationHandler t...

2017-09-27 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4697#discussion_r141370485 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobCancellationHeaders.java --- @@ -0,0 +1,68 @@ +/* + * Licensed

[jira] [Commented] (FLINK-7650) Port JobCancellationHandler to new REST endpoint

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

[GitHub] flink issue #4517: [FLINK-7411][network] minor performance improvements in N...

2017-09-27 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/4517 how about now? ---

<    1   2   3   4   5   >