[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

2016-10-17 Thread Anton Mushin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15581442#comment-15581442 ] Anton Mushin commented on FLINK-4604: - Do you talking about new issue for support

[jira] [Commented] (FLINK-4840) Introduce an OperatorSystemMetricGroup

2016-10-17 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15581661#comment-15581661 ] Chesnay Schepler commented on FLINK-4840: - How does this differ from FLINK-4773? > Introduce an

[jira] [Commented] (FLINK-2752) Documentation is not easily differentiable from the Flink homepage

2016-10-17 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15581658#comment-15581658 ] Aljoscha Krettek commented on FLINK-2752: - I think the consensus was that this is not really

[GitHub] flink issue #2518: [FLINK-3931] Implement Transport Encryption (SSL/TLS)

2016-10-17 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2518 Thanks for the update @skrishnappa. The test changes look good. Merging the PR to master. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[jira] [Commented] (FLINK-3931) Implement Transport Encryption (SSL/TLS)

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

[GitHub] flink pull request #2645: [FLINK-4838] remove STREAM keyword in StreamSQLExa...

2016-10-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2645#discussion_r83611534 --- Diff: docs/dev/table_api.md --- @@ -1180,7 +1180,7 @@ Although not every SQL feature is implemented yet, some string combinations are {%

[jira] [Commented] (FLINK-4838) remove STREAM keyword in StreamSQLExample

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

[jira] [Created] (FLINK-4843) Introduce Test for FsCheckpointStateOutputStream::getPos

2016-10-17 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-4843: - Summary: Introduce Test for FsCheckpointStateOutputStream::getPos Key: FLINK-4843 URL: https://issues.apache.org/jira/browse/FLINK-4843 Project: Flink

[GitHub] flink issue #2629: [FLINK-4391] Provide support for asynchronous operations ...

2016-10-17 Thread bjlovegithub
Github user bjlovegithub commented on the issue: https://github.com/apache/flink/pull/2629 Update the PR based on the latest review. --- 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] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

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

[jira] [Resolved] (FLINK-4405) Implement Blob Server SSL

2016-10-17 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-4405. --- Resolution: Fixed Fix Version/s: 1.2.0 Implemented with

[jira] [Commented] (FLINK-3931) Implement Transport Encryption (SSL/TLS)

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

[GitHub] flink issue #2518: [FLINK-3931] Implement Transport Encryption (SSL/TLS)

2016-10-17 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2518 Thanks for your contribution @skrishnappa! --- 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-4842) Introduce test to enforce order of operator / udf lifecycles

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

[GitHub] flink pull request #2646: [FLINK-4842] Test for FsCheckpointStateOutputStrea...

2016-10-17 Thread StefanRRichter
GitHub user StefanRRichter opened a pull request: https://github.com/apache/flink/pull/2646 [FLINK-4842] Test for FsCheckpointStateOutputStream::getPos() This PR Introduces a test to check FsCheckpointStateOutputStream::getPos(). You can merge this pull request into a Git

[jira] [Commented] (FLINK-3674) Add an interface for Time aware User Functions

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

[GitHub] flink issue #2570: [FLINK-3674] Add an interface for Time aware User Functio...

2016-10-17 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2570 R: @StefanRRichter @kl0u could you please review again, I pushed some changes and rebased on top of master. Each commit can stand on its own and the purpose of each commit is documented in

[jira] [Commented] (FLINK-4283) ExecutionGraphRestartTest fails

2016-10-17 Thread Alexander Shoshin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15581727#comment-15581727 ] Alexander Shoshin commented on FLINK-4283: -- I found out that these tests will fail if you run

[jira] [Resolved] (FLINK-3931) Implement Transport Encryption (SSL/TLS)

2016-10-17 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-3931. --- Resolution: Fixed Fix Version/s: 1.2.0 Implemented with

[GitHub] flink pull request #2518: [FLINK-3931] Implement Transport Encryption (SSL/T...

2016-10-17 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2518 --- 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-3931) Implement Transport Encryption (SSL/TLS)

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

[jira] [Created] (FLINK-4840) Introduce an OperatorSystemMetricGroup

2016-10-17 Thread zhuhaifeng (JIRA)
zhuhaifeng created FLINK-4840: - Summary: Introduce an OperatorSystemMetricGroup Key: FLINK-4840 URL: https://issues.apache.org/jira/browse/FLINK-4840 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-4840) Introduce an OperatorSystemMetricGroup

2016-10-17 Thread zhuhaifeng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhuhaifeng updated FLINK-4840: -- Description: There will introduces the OperatorSystemMetricGroup, which encapsulates the insantiation

[jira] [Created] (FLINK-4842) Introduce test to enforce order of operator / udf lifecycles

2016-10-17 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-4842: - Summary: Introduce test to enforce order of operator / udf lifecycles Key: FLINK-4842 URL: https://issues.apache.org/jira/browse/FLINK-4842 Project: Flink

[jira] [Assigned] (FLINK-4840) Introduce an OperatorSystemMetricGroup

2016-10-17 Thread zhuhaifeng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhuhaifeng reassigned FLINK-4840: - Assignee: zhuhaifeng > Introduce an OperatorSystemMetricGroup >

[jira] [Created] (FLINK-4841) Suicide TaskManager if Task doesn't react to cancel signal

2016-10-17 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-4841: -- Summary: Suicide TaskManager if Task doesn't react to cancel signal Key: FLINK-4841 URL: https://issues.apache.org/jira/browse/FLINK-4841 Project: Flink Issue

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

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

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

2016-10-17 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2572 R: @StefanRRichter @kl0u , this sits on top of #2570 so you can review that one first and then this one additional commit here. --- If your project is set up for it, you can reply to this email

[jira] [Resolved] (FLINK-4404) Implement Data Transfer SSL

2016-10-17 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-4404. --- Resolution: Fixed Fix Version/s: 1.2.0 Implemented with

[jira] [Resolved] (FLINK-4325) Implement Web UI HTTPS

2016-10-17 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-4325. --- Resolution: Fixed Fix Version/s: 1.2.0 Implemented with

[jira] [Resolved] (FLINK-4324) Enable Akka SSL

2016-10-17 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-4324. --- Resolution: Fixed Fix Version/s: 1.2.0 Implemented with

[jira] [Commented] (FLINK-4283) ExecutionGraphRestartTest fails

2016-10-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15581770#comment-15581770 ] Till Rohrmann commented on FLINK-4283: -- Maybe we could also replace the {{ExecutionContext.global}}

[jira] [Commented] (FLINK-4835) Implement standalone High Availability Services

2016-10-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15581790#comment-15581790 ] Till Rohrmann commented on FLINK-4835: -- Don't we need

[jira] [Commented] (FLINK-4315) Deprecate Hadoop dependent methods in flink-java

2016-10-17 Thread Evgeny Kincharov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15584198#comment-15584198 ] Evgeny Kincharov commented on FLINK-4315: - I have pushed new version of PR. Could you look it? BR,

[jira] [Commented] (FLINK-4469) Add support for user defined table function in Table API & SQL

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

[GitHub] flink issue #2653: [FLINK-4469] [table] Add support for user defined table f...

2016-10-17 Thread wuchong
Github user wuchong commented on the issue: https://github.com/apache/flink/pull/2653 Hi @twalthr @fhueske , it will be great if you can review 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

[jira] [Commented] (FLINK-4723) Unify behaviour of committed offsets to Kafka / ZK for Kafka 0.8 and 0.9 consumer

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

[GitHub] flink issue #2580: [FLINK-4723] [kafka-connector] Unify committed offsets to...

2016-10-17 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2580 Merging this to master now ... --- 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

[jira] [Commented] (FLINK-3931) Implement Transport Encryption (SSL/TLS)

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

[jira] [Commented] (FLINK-4727) Kafka 0.9 Consumer should also checkpoint auto retrieved offsets even when no data is read

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

[GitHub] flink issue #2585: [FLINK-4727] [kafka-connector] Set missing initial offset...

2016-10-17 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2585 Rebasing to include f46ca39 with the IT tests de-commented. Will merge when Travis turns green. --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Resolved] (FLINK-4723) Unify behaviour of committed offsets to Kafka / ZK for Kafka 0.8 and 0.9 consumer

2016-10-17 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-4723. Resolution: Fixed > Unify behaviour of committed offsets to Kafka / ZK for Kafka

[jira] [Commented] (FLINK-4723) Unify behaviour of committed offsets to Kafka / ZK for Kafka 0.8 and 0.9 consumer

2016-10-17 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15584364#comment-15584364 ] Tzu-Li (Gordon) Tai commented on FLINK-4723: [~rmetzger] Should this fix go into release-1.1

[jira] [Commented] (FLINK-4723) Unify behaviour of committed offsets to Kafka / ZK for Kafka 0.8 and 0.9 consumer

2016-10-17 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15584361#comment-15584361 ] Tzu-Li (Gordon) Tai commented on FLINK-4723: Resolved for master via

[GitHub] flink pull request #2653: [FLINK-4469] [table] Add support for user defined ...

2016-10-17 Thread wuchong
GitHub user wuchong opened a pull request: https://github.com/apache/flink/pull/2653 [FLINK-4469] [table] Add support for user defined table function in Table API & SQL Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list

[jira] [Commented] (FLINK-4469) Add support for user defined table function in Table API & SQL

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

[GitHub] flink issue #2518: [FLINK-3931] Implement Transport Encryption (SSL/TLS)

2016-10-17 Thread skrishnappa
Github user skrishnappa commented on the issue: https://github.com/apache/flink/pull/2518 Thanks @mxm for following this up. Cheers --- 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] [Commented] (FLINK-4723) Unify behaviour of committed offsets to Kafka / ZK for Kafka 0.8 and 0.9 consumer

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

[GitHub] flink pull request #2580: [FLINK-4723] [kafka-connector] Unify committed off...

2016-10-17 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2580 --- 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] [Comment Edited] (FLINK-4723) Unify behaviour of committed offsets to Kafka / ZK for Kafka 0.8 and 0.9 consumer

2016-10-17 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15584364#comment-15584364 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4723 at 10/18/16 3:58 AM: --

[jira] [Commented] (FLINK-4848) keystoreFilePath should be checked against null in SSLUtils#createSSLServerContext

2016-10-17 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15582930#comment-15582930 ] Ted Yu commented on FLINK-4848: --- There is similar issue with trustStoreFilePath > keystoreFilePath should

[jira] [Resolved] (FLINK-4849) keystoreFilePath should be checked against null in SSLUtils#createSSLServerContext

2016-10-17 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved FLINK-4849. --- Resolution: Duplicate Dup of FLINK-4848 > keystoreFilePath should be checked against null in >

[jira] [Created] (FLINK-4848) keystoreFilePath should be checked against null in SSLUtils#createSSLServerContext

2016-10-17 Thread Ted Yu (JIRA)
Ted Yu created FLINK-4848: - Summary: keystoreFilePath should be checked against null in SSLUtils#createSSLServerContext Key: FLINK-4848 URL: https://issues.apache.org/jira/browse/FLINK-4848 Project: Flink

[jira] [Created] (FLINK-4849) keystoreFilePath should be checked against null in SSLUtils#createSSLServerContext

2016-10-17 Thread Ted Yu (JIRA)
Ted Yu created FLINK-4849: - Summary: keystoreFilePath should be checked against null in SSLUtils#createSSLServerContext Key: FLINK-4849 URL: https://issues.apache.org/jira/browse/FLINK-4849 Project: Flink

[GitHub] flink issue #2453: [FLINK-4510] [checkpoint] Always create CheckpointCoordin...

2016-10-17 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/2453 Thanks for the contribution. I'm going to merge this with slight modifications. We don't need the introduced checks with the current master as there is a check whether periodic checkpoints are

[jira] [Commented] (FLINK-4619) JobManager does not answer to client when restore from savepoint fails

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

[GitHub] flink issue #2498: [FLINK-4619] - JobManager does not answer to client when ...

2016-10-17 Thread mproch
Github user mproch commented on the issue: https://github.com/apache/flink/pull/2498 @StephanEwen can I retrigger this or whatever? --- 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-4829) Accumulators are not thread safe

2016-10-17 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4829: -- Fix Version/s: 1.1.4 > Accumulators are not thread safe >

[jira] [Updated] (FLINK-4829) Accumulators are not thread safe

2016-10-17 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4829: -- Affects Version/s: 1.1.3 > Accumulators are not thread safe >

[jira] [Commented] (FLINK-4619) JobManager does not answer to client when restore from savepoint fails

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

[GitHub] flink issue #2498: [FLINK-4619] - JobManager does not answer to client when ...

2016-10-17 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2498 No need to re-trigger this. Travis green light is good. @uce - Do you think this works well with your latest changes? --- If your project is set up for it, you can reply to this email

[jira] [Closed] (FLINK-4841) Suicide TaskManager if Task doesn't react to cancel signal

2016-10-17 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4841. --- > Suicide TaskManager if Task doesn't react to cancel signal >

[jira] [Created] (FLINK-4844) Partitionable Raw Keyed/Operator State

2016-10-17 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-4844: - Summary: Partitionable Raw Keyed/Operator State Key: FLINK-4844 URL: https://issues.apache.org/jira/browse/FLINK-4844 Project: Flink Issue Type: New

[GitHub] flink pull request #2648: [FLINK-4844] Partitionable Raw Keyed/Operator Stat...

2016-10-17 Thread StefanRRichter
GitHub user StefanRRichter opened a pull request: https://github.com/apache/flink/pull/2648 [FLINK-4844] Partitionable Raw Keyed/Operator State Partitionable operator and keyed state are currently only available by using backends. However, the serialization code for many operators

[jira] [Commented] (FLINK-2428) Clean up unused properties in StreamConfig

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

[GitHub] flink issue #1554: [FLINK-2428] Clean up unused properties in StreamConfig

2016-10-17 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/1554 Hi @hczerpak do you plan to update this PR? Otherwise, I'd like to close it. Thanks --- 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 pull request #2606: [FLINK-3888] Allow custom convergence criterion in...

2016-10-17 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/2606#discussion_r83632808 --- Diff: flink-optimizer/src/main/java/org/apache/flink/optimizer/plantranslate/JobGraphGenerator.java --- @@ -1513,14 +1513,21 @@ private void

[jira] [Commented] (FLINK-3888) Custom Aggregator with Convergence can't be registered directly with DeltaIteration

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

[jira] [Commented] (FLINK-4283) ExecutionGraphRestartTest fails

2016-10-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15582116#comment-15582116 ] Till Rohrmann commented on FLINK-4283: -- I think we can do this by not using the

[GitHub] flink issue #2645: [FLINK-4838] remove STREAM keyword in StreamSQLExample

2016-10-17 Thread manuzhang
Github user manuzhang commented on the issue: https://github.com/apache/flink/pull/2645 @fhueske updated. --- 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-4838) remove STREAM keyword in StreamSQLExample

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

[GitHub] flink issue #2645: [FLINK-4838] remove STREAM keyword in StreamSQLExample

2016-10-17 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2645 Thanks for the update @manuzhang! +1 to merge --- 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 #2648: [FLINK-4844] Partitionable Raw Keyed/Operator State

2016-10-17 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/2648 Please review @aljoscha and whoever else wants to take a look. --- 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-4844) Partitionable Raw Keyed/Operator State

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

[jira] [Commented] (FLINK-4844) Partitionable Raw Keyed/Operator State

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

[jira] [Commented] (FLINK-2125) String delimiter for SocketTextStream

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

[jira] [Commented] (FLINK-4283) ExecutionGraphRestartTest fails

2016-10-17 Thread Alexander Shoshin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15582125#comment-15582125 ] Alexander Shoshin commented on FLINK-4283: -- I agree that these tests shouldn't depends on

[GitHub] flink pull request #2649: [FLINK-4829] snapshot accumulators on a best-effor...

2016-10-17 Thread mxm
GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/2649 [FLINK-4829] snapshot accumulators on a best-effort basis Heartbeats should not fail when accumulators could not be snapshotted. Instead, we should simply skip the reporting of the failed accumulator.

[jira] [Commented] (FLINK-4835) Implement standalone High Availability Services

2016-10-17 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15582152#comment-15582152 ] Stephan Ewen commented on FLINK-4835: - You are right, that is probably an artifact right now. I was

[jira] [Commented] (FLINK-4840) Introduce an OperatorSystemMetricGroup

2016-10-17 Thread zhuhaifeng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15582211#comment-15582211 ] zhuhaifeng commented on FLINK-4840: --- I would like to add TPS / lantency metrics. The

[jira] [Commented] (FLINK-4839) JobManager handle TaskManager's slot offering

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

[jira] [Commented] (FLINK-4833) Unstable test OperatorStatsAccumulatorTest.testAccumulatorHeavyHitterCountMinSketch

2016-10-17 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15581816#comment-15581816 ] Maximilian Michels commented on FLINK-4833: --- This can also be tracked down to FLINK-4829. >

[jira] [Commented] (FLINK-4833) Unstable test OperatorStatsAccumulatorTest.testAccumulatorHeavyHitterCountMinSketch

2016-10-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15581841#comment-15581841 ] Robert Metzger commented on FLINK-4833: --- More of this:

[jira] [Commented] (FLINK-4833) Unstable test OperatorStatsAccumulatorTest.testAccumulatorHeavyHitterCountMinSketch

2016-10-17 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15581973#comment-15581973 ] Maximilian Michels commented on FLINK-4833: --- I think this occurs when the TaskManager snapshots

[jira] [Commented] (FLINK-4841) Suicide TaskManager if Task doesn't react to cancel signal

2016-10-17 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15581990#comment-15581990 ] Aljoscha Krettek commented on FLINK-4841: - [~uce] This is a duplicate of FLINK-4715. > Suicide

[jira] [Resolved] (FLINK-4841) Suicide TaskManager if Task doesn't react to cancel signal

2016-10-17 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4841. - Resolution: Duplicate Duplicate of FLINK-4715 > Suicide TaskManager if Task doesn't react to

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

2016-10-17 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-4715: Assignee: Ufuk Celebi > TaskManager should commit suicide after cancellation failure >

[jira] [Commented] (FLINK-3599) GSoC: Code Generation in Serializers

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

[jira] [Comment Edited] (FLINK-4283) ExecutionGraphRestartTest fails

2016-10-17 Thread Alexander Shoshin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15582125#comment-15582125 ] Alexander Shoshin edited comment on FLINK-4283 at 10/17/16 12:37 PM: -

[jira] [Commented] (FLINK-4829) Accumulators are not thread safe

2016-10-17 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15581850#comment-15581850 ] Maximilian Michels commented on FLINK-4829: --- Locking on a per-element basis in the Accumulator

[jira] [Commented] (FLINK-4283) ExecutionGraphRestartTest fails

2016-10-17 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15582023#comment-15582023 ] Stephan Ewen commented on FLINK-4283: - There seems to be something wrong if this blocks threads such

[jira] [Created] (FLINK-4845) Fix Job Exceptions page

2016-10-17 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-4845: --- Summary: Fix Job Exceptions page Key: FLINK-4845 URL: https://issues.apache.org/jira/browse/FLINK-4845 Project: Flink Issue Type: Bug

[GitHub] flink issue #1491: [FLINK-2125][streaming] Delimiter change from char to str...

2016-10-17 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/1491 Hi @ajaybhat, do you plan to update this PR? Otherwise, I'd like to close 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

[GitHub] flink pull request #2647: [FLINK-4839] [cluster management] JobManager handl...

2016-10-17 Thread KurtYoung
GitHub user KurtYoung opened a pull request: https://github.com/apache/flink/pull/2647 [FLINK-4839] [cluster management] JobManager handle TaskManager's slot offering This PR is based on #2643 , only the last commit is related. You can merge this pull request into a Git repository

[jira] [Commented] (FLINK-4492) Cleanup files from canceled snapshots

2016-10-17 Thread Nikolay Vasilishin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15581831#comment-15581831 ] Nikolay Vasilishin commented on FLINK-4492: --- [~srichter] Does this issue still persist? I've

[jira] [Commented] (FLINK-4835) Implement standalone High Availability Services

2016-10-17 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15582027#comment-15582027 ] Stephan Ewen commented on FLINK-4835: - Yes, there are right now multiple variants: -

[jira] [Commented] (FLINK-4835) Implement standalone High Availability Services

2016-10-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15582109#comment-15582109 ] Till Rohrmann commented on FLINK-4835: -- Why does the NonHAServices inherit from

[GitHub] flink issue #2211: [WIP][FLINK-3599] Code generation for PojoSerializer and ...

2016-10-17 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2211 Hi @Xazax-hun, is the PR still WIP? Can you remove the [WIP] tag from the title if it is good to review? Thanks, Fabian --- If your project is set up for it, you can reply to this

[jira] [Commented] (FLINK-4829) Accumulators are not thread safe

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

[GitHub] flink pull request #2651: [FLINK-4847] Let RpcEndpoint.start/shutDown throw ...

2016-10-17 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/2651 [FLINK-4847] Let RpcEndpoint.start/shutDown throw exceptions Allowing the RpcEndpoint.start/shutDown to throw exceptions will help to let rpc endpoints to quickly fail without having to

  1   2   3   >