[jira] [Commented] (FLINK-4923) Expose input/output buffers and bufferPool usage as a metric for a Task

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

[jira] [Created] (FLINK-4939) GenericWriteAheadSink: Decouple the subtask that created a pending checkpoint from the one that commits it.

2016-10-27 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-4939: - Summary: GenericWriteAheadSink: Decouple the subtask that created a pending checkpoint from the one that commits it. Key: FLINK-4939 URL:

[jira] [Updated] (FLINK-4911) Non-disruptive JobManager Failures via Reconciliation

2016-10-27 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang updated FLINK-4911: - Component/s: TaskManager > Non-disruptive JobManager Failures via Reconciliation >

[jira] [Commented] (FLINK-4562) table examples make an divided module in flink-examples

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611141#comment-15611141 ] ASF GitHub Bot commented on FLINK-4562: --- Github user shijinkui commented on the issue:

[GitHub] flink issue #2460: [FLINK-4562] table examples make an divided module in fli...

2016-10-27 Thread shijinkui
Github user shijinkui commented on the issue: https://github.com/apache/flink/pull/2460 fixed it. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if

[jira] [Commented] (FLINK-4579) Add StateBackendFactory for RocksDB Backend

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

[GitHub] flink pull request #2693: [FLINK-4923] [Metrics] Expose input/output buffers...

2016-10-27 Thread zhuhaifengleon
Github user zhuhaifengleon commented on a diff in the pull request: https://github.com/apache/flink/pull/2693#discussion_r85282572 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java --- @@ -1264,4 +1271,76 @@ public void run() {

[GitHub] flink pull request #2482: [FLINK-4579] [StateBackend] Add StateBackendFactor...

2016-10-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2482 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Updated] (FLINK-4923) Expose input/output buffers and bufferPool usage as a metric for a Task

2016-10-27 Thread zhuhaifeng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhuhaifeng updated FLINK-4923: -- Description: We should expose the following Metrics on the TaskIOMetricGroup: 1.

[GitHub] flink issue #2652: [FLINK-4715] Fail TaskManager with fatal error if task ca...

2016-10-27 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/2652 OK thanks. I addressed one last issue with shutting down the watch dog thread (it was lingering around sleeping and only noticed that the task has terminated after that sleep... now the task canceler

[jira] [Closed] (FLINK-4579) Add StateBackendFactory for RocksDB Backend

2016-10-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4579. --- > Add StateBackendFactory for RocksDB Backend > --- > >

[jira] [Resolved] (FLINK-4579) Add StateBackendFactory for RocksDB Backend

2016-10-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4579. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in fc730bb079fe43b550954a91d981b9996c2be4c1

[GitHub] flink pull request #2693: [FLINK-4923] [Metrics] Expose input/output buffers...

2016-10-27 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2693#discussion_r85304524 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java --- @@ -347,6 +348,12 @@ public Task( // finally,

[jira] [Commented] (FLINK-4800) Introduce the TimestampedFileInputSplit for Continuous File Processing

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611422#comment-15611422 ] ASF GitHub Bot commented on FLINK-4800: --- Github user kl0u commented on the issue:

[jira] [Commented] (FLINK-4938) Unnecessary update() call for Views to be removed in ViewUpdater#run()

2016-10-27 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611424#comment-15611424 ] Chesnay Schepler commented on FLINK-4938: - This is intended, to make sure that update is called at

[GitHub] flink issue #2618: [FLINK-4800] Refactor the ContinuousFileMonitoringFunctio...

2016-10-27 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/2618 @mxm I just did. Let's wait for travis again. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature

[GitHub] flink issue #2702: Improved heaptimerservice

2016-10-27 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/2702 R @aljoscha --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so,

[jira] [Commented] (FLINK-3347) TaskManager (or its ActorSystem) need to restart in case they notice quarantine

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611647#comment-15611647 ] ASF GitHub Bot commented on FLINK-3347: --- Github user StephanEwen commented on the issue:

[jira] [Commented] (FLINK-4923) Expose input/output buffers and bufferPool usage as a metric for a Task

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

[GitHub] flink pull request #2693: [FLINK-4923] [Metrics] Expose input/output buffers...

2016-10-27 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2693#discussion_r85322207 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java --- @@ -347,6 +348,12 @@ public Task( //

[GitHub] flink issue #2664: [FLINK-4861] [build] Package optional project artifacts

2016-10-27 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2664 Subdirectories of `lib` are currently not considered. That would require a bunch of changes, in the shell scripts and in the Yarn/Mesos setup code. Do you think that is important? If we

[jira] [Created] (FLINK-4941) Show ship strategy in web interface

2016-10-27 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-4941: - Summary: Show ship strategy in web interface Key: FLINK-4941 URL: https://issues.apache.org/jira/browse/FLINK-4941 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-4800) Introduce the TimestampedFileInputSplit for Continuous File Processing

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611742#comment-15611742 ] ASF GitHub Bot commented on FLINK-4800: --- Github user mxm commented on the issue:

[jira] [Created] (FLINK-4942) Improve processing performance of HeapInternalTimerService with key groups

2016-10-27 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-4942: - Summary: Improve processing performance of HeapInternalTimerService with key groups Key: FLINK-4942 URL: https://issues.apache.org/jira/browse/FLINK-4942 Project:

[jira] [Commented] (FLINK-4715) TaskManager should commit suicide after cancellation failure

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611336#comment-15611336 ] ASF GitHub Bot commented on FLINK-4715: --- Github user uce commented on the issue:

[GitHub] flink pull request #2690: [FLINK-4894] [network] Don't request buffer after ...

2016-10-27 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/2690#discussion_r85299971 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/RecordWriter.java --- @@ -108,15 +108,25 @@ private void sendToTarget(T

[jira] [Commented] (FLINK-4894) Don't block on buffer request after broadcastEvent

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

[jira] [Commented] (FLINK-3930) Implement Service-Level Authorization

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611368#comment-15611368 ] ASF GitHub Bot commented on FLINK-3930: --- Github user mxm commented on the issue:

[jira] [Commented] (FLINK-3347) TaskManager (or its ActorSystem) need to restart in case they notice quarantine

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611669#comment-15611669 ] ASF GitHub Bot commented on FLINK-3347: --- Github user StephanEwen commented on the issue:

[jira] [Commented] (FLINK-3347) TaskManager (or its ActorSystem) need to restart in case they notice quarantine

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611673#comment-15611673 ] ASF GitHub Bot commented on FLINK-3347: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #2696: [FLINK-3347] [akka] Add QuarantineMonitor which shuts a q...

2016-10-27 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2696 This means we should do a separate pull request which changes the TaskManager side of the failure detection from Akka watch to the TaskManager heartbeats. After that is in, we merge

[jira] [Commented] (FLINK-4861) Package optional project artifacts

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611696#comment-15611696 ] ASF GitHub Bot commented on FLINK-4861: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #2690: [FLINK-4894] [network] Don't request buffer after writing...

2016-10-27 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/2690 That is tested in the record serializer tests and now also in the added writer test. In general, the record writer and serializer are very tightly coupled and confusing at times. I think it

[GitHub] flink issue #2626: [FLINK-4787] [runtime-web] Expose cancel-with-savepoint v...

2016-10-27 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/2626 Updated the commits. The build error was caused by a failure during rebase. Should be fixed now. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

[jira] [Commented] (FLINK-4787) Add REST API call for cancel-with-savepoints

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611383#comment-15611383 ] ASF GitHub Bot commented on FLINK-4787: --- Github user uce commented on the issue:

[jira] [Created] (FLINK-4940) Add Support for Broadcast/Global State

2016-10-27 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4940: --- Summary: Add Support for Broadcast/Global State Key: FLINK-4940 URL: https://issues.apache.org/jira/browse/FLINK-4940 Project: Flink Issue Type:

[jira] [Commented] (FLINK-4378) Enable RollingSink to custom HDFS client configuration

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611525#comment-15611525 ] ASF GitHub Bot commented on FLINK-4378: --- Github user wenlong88 commented on the issue:

[GitHub] flink pull request #2702: Improved heaptimerservice

2016-10-27 Thread StefanRRichter
GitHub user StefanRRichter opened a pull request: https://github.com/apache/flink/pull/2702 Improved heaptimerservice This PR improves the performance of `HeapInternalTimerService`by pushing all key-group related overhead into the snapshot part. This is done by performing

[jira] [Commented] (FLINK-4923) Expose input/output buffers and bufferPool usage as a metric for a Task

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611358#comment-15611358 ] ASF GitHub Bot commented on FLINK-4923: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #2693: [FLINK-4923] [Metrics] Expose input/output buffers and bu...

2016-10-27 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2693 This looks good, thanks! Merging this... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this

[GitHub] flink issue #2692: [FLINK-4913][yarn] include user jar in system class loade...

2016-10-27 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2692 Pushed a minor change to check which jars are required in case the cluster is used to execute multiple jobs with different dependencies. Merigng after a local Travis run. --- If your project is set up

[jira] [Commented] (FLINK-4913) Per-job Yarn clusters: include user jar in system class loader

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611437#comment-15611437 ] ASF GitHub Bot commented on FLINK-4913: --- Github user mxm commented on the issue:

[GitHub] flink issue #2696: [FLINK-3347] [akka] Add QuarantineMonitor which shuts a q...

2016-10-27 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2696 That's a very good addition, we need something like that. After an offline discussion with @tillrohrmann we came to the following conclusion: There is a tricky problem with that

[jira] [Updated] (FLINK-4941) Show ship strategy in web interface

2016-10-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4941: -- Attachment: ship_strategy_bad.png ship_strategy_good.png I attached two

[jira] [Commented] (FLINK-4894) Don't block on buffer request after broadcastEvent

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611349#comment-15611349 ] ASF GitHub Bot commented on FLINK-4894: --- Github user uce commented on the issue:

[jira] [Commented] (FLINK-4923) Expose input/output buffers and bufferPool usage as a metric for a Task

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

[jira] [Commented] (FLINK-4378) Enable RollingSink to custom HDFS client configuration

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611579#comment-15611579 ] ASF GitHub Bot commented on FLINK-4378: --- Github user aljoscha commented on the issue:

[GitHub] flink issue #2356: [FLINK-4378]Enable RollingSink to custom HDFS client conf...

2016-10-27 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2356 Ah I see. I didn't see that before, sorry. I'll merge this once it passes on Travis. Thanks for your work! 😃 --- If your project is set up for it, you can reply to this email and have

[jira] [Commented] (FLINK-4913) Per-job Yarn clusters: include user jar in system class loader

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

[GitHub] flink pull request #2692: [FLINK-4913][yarn] include user jar in system clas...

2016-10-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2692 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-4800) Introduce the TimestampedFileInputSplit for Continuous File Processing

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

[jira] [Commented] (FLINK-4933) ExecutionGraph.scheduleOrUpdateConsumers can fail the ExecutionGraph

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611364#comment-15611364 ] ASF GitHub Bot commented on FLINK-4933: --- GitHub user tillrohrmann opened a pull request:

[GitHub] flink issue #2425: FLINK-3930 Added shared secret based authorization for Fl...

2016-10-27 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2425 CC @uce to check out the network layer changes. This is a very sensitive and performance critical part of Flink. We should be very sure nothing breaks it with the changes. @vijikarthi Please

[jira] [Commented] (FLINK-4913) Per-job Yarn clusters: include user jar in system class loader

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611367#comment-15611367 ] ASF GitHub Bot commented on FLINK-4913: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #2692: [FLINK-4913][yarn] include user jar in system class loade...

2016-10-27 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2692 Okay, nice. Please merge then! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature

[jira] [Commented] (FLINK-4378) Enable RollingSink to custom HDFS client configuration

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611442#comment-15611442 ] ASF GitHub Bot commented on FLINK-4378: --- Github user aljoscha commented on the issue:

[GitHub] flink issue #2356: [FLINK-4378]Enable RollingSink to custom HDFS client conf...

2016-10-27 Thread wenlong88
Github user wenlong88 commented on the issue: https://github.com/apache/flink/pull/2356 I have commented above, it is to make sure that the customized configuration work --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[GitHub] flink issue #2684: Add EvaluateDataSet Operation for LabeledVector - This cl...

2016-10-27 Thread tfournier314
Github user tfournier314 commented on the issue: https://github.com/apache/flink/pull/2684 Ok thanks ! We don't need to care about Jenkins/Travis fails, do we ? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[GitHub] flink issue #2697: [backport] [FLINK-3347] [akka] Add QuarantineMonitor whic...

2016-10-27 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2697 Looks good to me. I would suggest to rename `taskmanager.quarantine-monitor.enable` to make it more accessible to users (few will understand what quarantine means). We could call it

[jira] [Closed] (FLINK-4913) Per-job Yarn clusters: include user jar in system class loader

2016-10-27 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4913. - Resolution: Fixed master: 2b600d355f5df9364c634282469acd608d7a2104 release-1.1:

[GitHub] flink pull request #2700: [FLINK-4933] [exec graph] Don't let the EG fail in...

2016-10-27 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/2700 [FLINK-4933] [exec graph] Don't let the EG fail in case of a failing scheduleOrUpdateConsumers call Instead of failing the complete ExecutionGraph, a failing scheduleOrUpdateConsumers call

[jira] [Commented] (FLINK-4933) ExecutionGraph.scheduleOrUpdateConsumers can fail the ExecutionGraph

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611564#comment-15611564 ] ASF GitHub Bot commented on FLINK-4933: --- GitHub user tillrohrmann opened a pull request:

[GitHub] flink issue #2702: Improved heaptimerservice

2016-10-27 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2702 Does a JIRA exist for this issue? Would be great to format the description accordingly. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

[GitHub] flink pull request #2618: [FLINK-4800] Refactor the ContinuousFileMonitoring...

2016-10-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2618 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink issue #2618: [FLINK-4800] Refactor the ContinuousFileMonitoringFunctio...

2016-10-27 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2618 Merged. Thank you! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if

[jira] [Deleted] (FLINK-4931) Implement FLIP-6 YARN client

2016-10-27 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels deleted FLINK-4931: -- > Implement FLIP-6 YARN client > > > Key:

[jira] [Commented] (FLINK-4883) Prevent UDFs implementations through Scala singleton objects

2016-10-27 Thread Renkai Ge (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611756#comment-15611756 ] Renkai Ge commented on FLINK-4883: -- How about to extend the method

[jira] [Assigned] (FLINK-4942) Improve processing performance of HeapInternalTimerService with key groups

2016-10-27 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-4942: - Assignee: Stefan Richter > Improve processing performance of HeapInternalTimerService

[jira] [Commented] (FLINK-4800) Introduce the TimestampedFileInputSplit for Continuous File Processing

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15611380#comment-15611380 ] ASF GitHub Bot commented on FLINK-4800: --- Github user mxm commented on the issue:

[GitHub] flink issue #2618: [FLINK-4800] Refactor the ContinuousFileMonitoringFunctio...

2016-10-27 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2618 Looks good @kl0u. Could you push the rebased version? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this

[jira] [Updated] (FLINK-3659) Allow One Input of ConnectedStream to be Broadcast

2016-10-27 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3659: Summary: Allow One Input of ConnectedStream to be Broadcast (was: Allow ConnectedStreams

[GitHub] flink issue #2356: [FLINK-4378]Enable RollingSink to custom HDFS client conf...

2016-10-27 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2356 @wenlong88 thanks for the update! What's the reason for setting the `fs.%s.impl.disable.cache` parameter explicitly? --- If your project is set up for it, you can reply to this email and have your

[GitHub] flink pull request #2701: [backport] [FLINK-4933] [exec graph] Don't let the...

2016-10-27 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/2701 [backport] [FLINK-4933] [exec graph] Don't let the EG fail in case of a failing scheduleOrUpdateConsumers call This is a backport for the release-1.1 branch. The only thing adapted is the

[jira] [Commented] (FLINK-4552) Refactor WindowOperator/Trigger Tests

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

[jira] [Commented] (FLINK-4552) Refactor WindowOperator/Trigger Tests

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

[jira] [Closed] (FLINK-4894) Don't block on buffer request after broadcastEvent

2016-10-27 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-4894. -- Resolution: Fixed Fix Version/s: 1.1.4 1.2.0 Fixed in 529534f (release-1.1),

[jira] [Commented] (FLINK-2608) Arrays.asList(..) does not work with CollectionInputFormat

2016-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612306#comment-15612306 ] ASF GitHub Bot commented on FLINK-2608: --- Github user StephanEwen commented on the issue:

[GitHub] flink pull request #2572: [FLINK-4552] Refactor WindowOperator/Trigger Tests

2016-10-27 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/2572#discussion_r85360968 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/PurgingTriggerTest.java --- @@ -0,0 +1,149 @@

[GitHub] flink pull request #2572: [FLINK-4552] Refactor WindowOperator/Trigger Tests

2016-10-27 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/2572#discussion_r85359406 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/CountTriggerTest.java --- @@ -0,0 +1,123 @@

[GitHub] flink pull request #2572: [FLINK-4552] Refactor WindowOperator/Trigger Tests

2016-10-27 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/2572#discussion_r85361208 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/TriggerTestHarness.java --- @@ -0,0 +1,369 @@

[GitHub] flink pull request #2572: [FLINK-4552] Refactor WindowOperator/Trigger Tests

2016-10-27 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/2572#discussion_r85360454 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/EventTimeTriggerTest.java --- @@ -0,0 +1,153 @@

[jira] [Commented] (FLINK-4552) Refactor WindowOperator/Trigger Tests

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

[GitHub] flink pull request #2572: [FLINK-4552] Refactor WindowOperator/Trigger Tests

2016-10-27 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/2572#discussion_r85359630 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/CountTriggerTest.java --- @@ -0,0 +1,123 @@

[GitHub] flink pull request #2572: [FLINK-4552] Refactor WindowOperator/Trigger Tests

2016-10-27 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/2572#discussion_r85361303 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/TriggerTestHarness.java --- @@ -0,0 +1,369 @@

[jira] [Commented] (FLINK-4552) Refactor WindowOperator/Trigger Tests

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

[jira] [Reopened] (FLINK-4510) Always create CheckpointCoordinator

2016-10-27 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reopened FLINK-4510: > Always create CheckpointCoordinator > --- > > Key:

[jira] [Closed] (FLINK-4715) TaskManager should commit suicide after cancellation failure

2016-10-27 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-4715. -- Resolution: Fixed Fix Version/s: 1.1.4 Fixed in cc6655b (release-1.1), 27fd249 (master). >

[GitHub] flink pull request #2652: [FLINK-4715] Fail TaskManager with fatal error if ...

2016-10-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2652 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-4715) TaskManager should commit suicide after cancellation failure

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

[GitHub] flink issue #2623: [FLINK-2608] Updated Twitter Chill version.

2016-10-27 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2623 I like this approach. One minor question, otherwise +1 to go here --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project

[jira] [Commented] (FLINK-4510) Always create CheckpointCoordinator

2016-10-27 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15612226#comment-15612226 ] Ufuk Celebi commented on FLINK-4510: Fixed in {{b420750}} (release-1.1). > Always create

[jira] [Closed] (FLINK-4510) Always create CheckpointCoordinator

2016-10-27 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-4510. -- Resolution: Fixed Fix Version/s: 1.1.4 > Always create CheckpointCoordinator >

[jira] [Commented] (FLINK-4894) Don't block on buffer request after broadcastEvent

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

[jira] [Commented] (FLINK-4552) Refactor WindowOperator/Trigger Tests

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

[GitHub] flink pull request #2623: [FLINK-2608] Updated Twitter Chill version.

2016-10-27 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2623#discussion_r85368023 --- Diff: flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/util/CollectionDataSets.java --- @@ -710,7 +712,103 @@ public String

[GitHub] flink pull request #2623: [FLINK-2608] Updated Twitter Chill version.

2016-10-27 Thread chermenin
Github user chermenin commented on a diff in the pull request: https://github.com/apache/flink/pull/2623#discussion_r85369265 --- Diff: flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/util/CollectionDataSets.java --- @@ -710,7 +712,103 @@ public String toString()

[jira] [Commented] (FLINK-2608) Arrays.asList(..) does not work with CollectionInputFormat

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

[GitHub] flink pull request #2572: [FLINK-4552] Refactor WindowOperator/Trigger Tests

2016-10-27 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/2572#discussion_r85360067 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/EventTimeSessionWindowsWindowsTest.java --- @@

[jira] [Commented] (FLINK-4552) Refactor WindowOperator/Trigger Tests

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

[GitHub] flink pull request #2690: [FLINK-4894] [network] Don't request buffer after ...

2016-10-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2690 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

  1   2   3   >