[jira] [Commented] (FLINK-3848) Add ProjectableTableSource interface and translation rule

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

[GitHub] flink issue #2810: [FLINK-3848] Add ProjectableTableSource interface and tra...

2016-11-25 Thread wuchong
Github user wuchong commented on the issue: https://github.com/apache/flink/pull/2810 Hi @tonycox , the overall change looks good to me. I will do more thorough review in this weekend. --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-5159) Improve perfomance of inner joins with a single row input

2016-11-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15696048#comment-15696048 ] ASF GitHub Bot commented on FLINK-5159: --- Github user AlexanderShoshin commented on a diff in the

[GitHub] flink pull request #2811: [FLINK-5159] Improve perfomance of inner joins wit...

2016-11-25 Thread AlexanderShoshin
Github user AlexanderShoshin commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r89628629 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/RichMapRunner.scala --- @@ -0,0 +1,52 @@ +/* + *

[jira] [Updated] (FLINK-4921) Upgrade to Mesos 1.0.1

2016-11-25 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4921: -- Fix Version/s: 1.2.0 > Upgrade to Mesos 1.0.1 > -- > >

[jira] [Commented] (FLINK-4798) CEPITCase.testSimpleKeyedPatternCEP test failure

2016-11-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15696132#comment-15696132 ] ASF GitHub Bot commented on FLINK-4798: --- Github user zentol commented on the issue:

[jira] [Resolved] (FLINK-4667) Yarn Session CLI not listening on correct ZK namespace when HA is enabled to use ZooKeeper backend

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

[jira] [Commented] (FLINK-5158) Handle ZooKeeperCompletedCheckpointStore exceptions in CheckpointCoordinator

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

[GitHub] flink pull request #2795: Revert "[FLINK-4913][yarn] include user jars in sy...

2016-11-25 Thread uce
Github user uce closed the pull request at: https://github.com/apache/flink/pull/2795 --- 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-4872) Type erasure problem exclusively on cluster execution

2016-11-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15696012#comment-15696012 ] ASF GitHub Bot commented on FLINK-4872: --- Github user twalthr commented on the issue:

[GitHub] flink pull request #2870: [FLINK-4565] Support for SQL IN operator

2016-11-25 Thread NickolayVasilishin
GitHub user NickolayVasilishin opened a pull request: https://github.com/apache/flink/pull/2870 [FLINK-4565] Support for SQL IN operator [FLINK-4565] Support for SQL IN operator This PR is a part of work on SQL IN operator in Table API, which implements IN for

[jira] [Commented] (FLINK-4950) Add support to include multiple Yarn application entries in Yarn properties file

2016-11-25 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15696100#comment-15696100 ] Maximilian Michels commented on FLINK-4950: --- Could you backport your changes part of the pull

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

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

[jira] [Updated] (FLINK-4950) Add support to include multiple Yarn application entries in Yarn properties file

2016-11-25 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4950: -- Fix Version/s: 1.2.0 > Add support to include multiple Yarn application entries in Yarn

[GitHub] flink issue #2827: [FLINK-4921] Upgrade to Mesos 1.0.1

2016-11-25 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2827 Looks good to me. Do we lose backwards-capability for Mesos installations < 1.0? --- 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

[jira] [Updated] (FLINK-4921) Upgrade to Mesos 1.0.1

2016-11-25 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4921: -- Component/s: Mesos > Upgrade to Mesos 1.0.1 > -- > >

[jira] [Updated] (FLINK-5030) Support hostname verification

2016-11-25 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-5030: -- Component/s: Security > Support hostname verification > - >

[jira] [Commented] (FLINK-4921) Upgrade to Mesos 1.0.1

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

[jira] [Commented] (FLINK-3883) Rename flink clients for inclusion on system path

2016-11-25 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15696125#comment-15696125 ] Maximilian Michels commented on FLINK-3883: --- +1 for the proposed renaming. All scripts which

[jira] [Commented] (FLINK-3848) Add ProjectableTableSource interface and translation rule

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

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

2016-11-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-4913. --- Resolution: Fixed I removed fix for version 1.1.4 again. > Per-job Yarn clusters: include

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

2016-11-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4913: -- Fix Version/s: (was: 1.1.4) > Per-job Yarn clusters: include user jar in system class

[jira] [Updated] (FLINK-4667) Yarn Session CLI not listening on correct ZK namespace when HA is enabled to use ZooKeeper backend

2016-11-25 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4667: -- Component/s: Security > Yarn Session CLI not listening on correct ZK namespace when HA

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

2016-11-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reopened FLINK-4913: --- Reverted in 1.1.4: http://git-wip-us.apache.org/repos/asf/flink/commit/3b5d3c6f > Per-job Yarn

[GitHub] flink pull request #2811: [FLINK-5159] Improve perfomance of inner joins wit...

2016-11-25 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2811#discussion_r89635696 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/RichMapRunner.scala --- @@ -0,0 +1,52 @@ +/* + * Licensed to

[jira] [Comment Edited] (FLINK-4565) Support for SQL IN operator

2016-11-25 Thread Nikolay Vasilishin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15696107#comment-15696107 ] Nikolay Vasilishin edited comment on FLINK-4565 at 11/25/16 4:10 PM: -

[jira] [Commented] (FLINK-3551) Sync Scala and Java Streaming Examples

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

[GitHub] flink issue #2823: [FLINK-4872] [types] Type erasure problem exclusively on ...

2016-11-25 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/2823 Thanks for the hint @StephanEwen. I improved the PR. --- 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

[jira] [Updated] (FLINK-4899) Implement DCOS package

2016-11-25 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4899: -- Fix Version/s: 1.2.0 > Implement DCOS package > -- > >

[jira] [Commented] (FLINK-3903) Homebrew Installation

2016-11-25 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15696129#comment-15696129 ] Maximilian Michels commented on FLINK-3903: --- Thanks for the formula! Updating the documentation

[jira] [Updated] (FLINK-3903) Homebrew Installation

2016-11-25 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3903: -- Labels: starter (was: ) > Homebrew Installation > - > >

[GitHub] flink issue #2843: FLINK-4798] CEPITCase.testSimpleKeyedPatternCEP test fail...

2016-11-25 Thread BorisOsipov
Github user BorisOsipov commented on the issue: https://github.com/apache/flink/pull/2843 @zentol this one: https://issues.apache.org/jira/browse/FLINK-2020 --- 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-4975) Add a limit for how much data may be buffered during checkpoint alignment

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

[GitHub] flink pull request #2754: [FLINK-4975] [checkpointing] Add a limit for how m...

2016-11-25 Thread StephanEwen
Github user StephanEwen closed the pull request at: https://github.com/apache/flink/pull/2754 --- 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

[jira] [Commented] (FLINK-5146) Improved resource cleanup in RocksDB keyed state backend

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

[GitHub] flink issue #2810: [FLINK-3848] Add ProjectableTableSource interface and tra...

2016-11-25 Thread tonycox
Github user tonycox commented on the issue: https://github.com/apache/flink/pull/2810 @wuchong could you review my changes? cc @fhueske @StephanEwen --- 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-4565) Support for SQL IN operator

2016-11-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15696057#comment-15696057 ] ASF GitHub Bot commented on FLINK-4565: --- GitHub user NickolayVasilishin opened a pull request:

[jira] [Updated] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

2016-11-25 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3929: -- Component/s: Security > Support for Kerberos Authentication with Keytab Credential >

[jira] [Updated] (FLINK-3932) Implement State Backend Security

2016-11-25 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3932: -- Component/s: Security > Implement State Backend Security >

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

2016-11-25 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3931: -- Component/s: Security > Implement Transport Encryption (SSL/TLS) >

[jira] [Assigned] (FLINK-4680) Add SlidingRow row-windows for streaming tables

2016-11-25 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-4680: -- Assignee: sunjincheng > Add SlidingRow row-windows for streaming tables >

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

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

[GitHub] flink issue #2734: Keytab & TLS support for Flink on Mesos Setup

2016-11-25 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2734 Sorry this is taking so long. You you please rebase to the latest master? @EronWright Could you take a look at the changes? --- If your project is set up for it, you can reply to this email and

[jira] [Updated] (FLINK-4637) Address Yarn proxy incompatibility with Flink Web UI when service level authorization is enabled

2016-11-25 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4637: -- Component/s: Security > Address Yarn proxy incompatibility with Flink Web UI when

[jira] [Updated] (FLINK-4635) Implement Data Transfer Authentication using shared secret configuration

2016-11-25 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4635: -- Component/s: Security > Implement Data Transfer Authentication using shared secret

[GitHub] flink issue #2810: [FLINK-3848] Add ProjectableTableSource interface and tra...

2016-11-25 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2810 Hi @tonycox, I'll have a look over the weekend or early next week as well. Thanks, Fabian --- 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 #2873: [backport] [FLINK-5158] [ckPtCoord] Handle excepti...

2016-11-25 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/2873 [backport] [FLINK-5158] [ckPtCoord] Handle exceptions from CompletedCheckpointStore in CheckpointCoordinator Backport of the #2872 for the release 1.1 branch. Handle exceptions from

[GitHub] flink issue #2857: [FLINK-5146] Improved resource cleanup in RocksDB keyed s...

2016-11-25 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/2857 I introduced the planned change to the test. You could take another look if you want :-) --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Updated] (FLINK-4918) Add SSL support to Mesos artifact server

2016-11-25 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4918: -- Fix Version/s: 1.2.0 > Add SSL support to Mesos artifact server >

[jira] [Updated] (FLINK-4901) Build DCOS Docker image

2016-11-25 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4901: -- Component/s: Mesos > Build DCOS Docker image > --- > >

[jira] [Updated] (FLINK-4899) Implement DCOS package

2016-11-25 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4899: -- Component/s: Mesos > Implement DCOS package > -- > >

[jira] [Updated] (FLINK-4918) Add SSL support to Mesos artifact server

2016-11-25 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4918: -- Component/s: Mesos > Add SSL support to Mesos artifact server >

[jira] [Updated] (FLINK-4919) Add secure cookie support for the cluster deployed in Mesos environment

2016-11-25 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4919: -- Fix Version/s: 1.2.0 > Add secure cookie support for the cluster deployed in Mesos

[jira] [Updated] (FLINK-4919) Add secure cookie support for the cluster deployed in Mesos environment

2016-11-25 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4919: -- Component/s: Mesos > Add secure cookie support for the cluster deployed in Mesos

[jira] [Updated] (FLINK-4901) Build DCOS Docker image

2016-11-25 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4901: -- Fix Version/s: 1.2.0 > Build DCOS Docker image > --- > >

[jira] [Updated] (FLINK-4900) Implement Docker image support

2016-11-25 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4900: -- Component/s: Mesos > Implement Docker image support > -- >

[jira] [Commented] (FLINK-5159) Improve perfomance of inner joins with a single row input

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

[jira] [Commented] (FLINK-4712) Implementing ranking predictions for ALS

2016-11-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15696250#comment-15696250 ] ASF GitHub Bot commented on FLINK-4712: --- Github user thvasilo commented on the issue:

[GitHub] flink issue #2838: [FLINK-4712] [FLINK-4713] [ml] Ranking recommendation & e...

2016-11-25 Thread thvasilo
Github user thvasilo commented on the issue: https://github.com/apache/flink/pull/2838 > The problem is not with the evaluate(test: TestType): DataSet[Double] but rather with evaluate(test: TestType): DataSet[(Prediction,Prediction)]. Completely agree there, I advocated for

[GitHub] flink pull request #2761: [FLINK-3551] [examples] Sync Scala Streaiming Exam...

2016-11-25 Thread ch33hau
Github user ch33hau commented on a diff in the pull request: https://github.com/apache/flink/pull/2761#discussion_r89644293 --- Diff: flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/kafka/ReadFromKafka.scala --- @@ -0,0 +1,72 @@

[jira] [Created] (FLINK-5167) StreamExecutionEnvironment's set function return `this` instead of void

2016-11-25 Thread shijinkui (JIRA)
shijinkui created FLINK-5167: Summary: StreamExecutionEnvironment's set function return `this` instead of void Key: FLINK-5167 URL: https://issues.apache.org/jira/browse/FLINK-5167 Project: Flink

[jira] [Created] (FLINK-5166) TextInputFormatTest.testNestedFileRead

2016-11-25 Thread shijinkui (JIRA)
shijinkui created FLINK-5166: Summary: TextInputFormatTest.testNestedFileRead Key: FLINK-5166 URL: https://issues.apache.org/jira/browse/FLINK-5166 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-5167) StreamExecutionEnvironment's set function return `this` instead of void

2016-11-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15697465#comment-15697465 ] ASF GitHub Bot commented on FLINK-5167: --- GitHub user shijinkui opened a pull request:

[GitHub] flink pull request #2874: [FLINK-5167] StreamExecutionEnvironment set functi...

2016-11-25 Thread shijinkui
GitHub user shijinkui opened a pull request: https://github.com/apache/flink/pull/2874 [FLINK-5167] StreamExecutionEnvironment set function return `this` in… StreamExecutionEnvironment's set function return `this` instead of void for example : public void

[GitHub] flink pull request #2509: [FLINK-4280][kafka-connector] Explicit start posit...

2016-11-25 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/2509#discussion_r89664876 --- Diff: flink-streaming-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka09Fetcher.java ---

[jira] [Commented] (FLINK-3848) Add ProjectableTableSource interface and translation rule

2016-11-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15695980#comment-15695980 ] ASF GitHub Bot commented on FLINK-3848: --- Github user tonycox commented on the issue:

[GitHub] flink issue #2795: Revert "[FLINK-4913][yarn] include user jars in system cl...

2016-11-25 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2795 Merging ... --- 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-4913) Per-job Yarn clusters: include user jar in system class loader

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

[jira] [Updated] (FLINK-4635) Implement Data Transfer Authentication using shared secret configuration

2016-11-25 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4635: -- Fix Version/s: 1.2.0 > Implement Data Transfer Authentication using shared secret

[jira] [Updated] (FLINK-3932) Implement State Backend Security

2016-11-25 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3932: -- Fix Version/s: 1.2.0 > Implement State Backend Security >

[jira] [Updated] (FLINK-4637) Address Yarn proxy incompatibility with Flink Web UI when service level authorization is enabled

2016-11-25 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4637: -- Fix Version/s: 1.2.0 > Address Yarn proxy incompatibility with Flink Web UI when

[jira] [Updated] (FLINK-4826) Add keytab based kerberos support for Mesos environment

2016-11-25 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4826: -- Fix Version/s: 1.2.0 > Add keytab based kerberos support for Mesos environment >

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

2016-11-25 Thread Nikolay Vasilishin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15696107#comment-15696107 ] Nikolay Vasilishin commented on FLINK-4565: --- [~fhueske], I've finally opened the PR,

[jira] [Updated] (FLINK-5091) Formalize the AppMaster environment for docker compability

2016-11-25 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-5091: -- Fix Version/s: 1.2.0 > Formalize the AppMaster environment for docker compability >

[jira] [Updated] (FLINK-4922) Write documentation

2016-11-25 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4922: -- Fix Version/s: 1.2.0 > Write documentation > --- > >

[jira] [Updated] (FLINK-5029) Implement KvState SSL

2016-11-25 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-5029: -- Component/s: Security > Implement KvState SSL > - > >

[jira] [Updated] (FLINK-5091) Formalize the AppMaster environment for docker compability

2016-11-25 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-5091: -- Component/s: Mesos > Formalize the AppMaster environment for docker compability >

[jira] [Updated] (FLINK-4922) Write documentation

2016-11-25 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4922: -- Component/s: Mesos > Write documentation > --- > > Key:

[GitHub] flink issue #2843: FLINK-4798] CEPITCase.testSimpleKeyedPatternCEP test fail...

2016-11-25 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2843 Which "known issue" are you referring to? --- 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-5163) Make the production functions rescalable (apart from the Rolling/Bucketing Sinks)

2016-11-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15696174#comment-15696174 ] ASF GitHub Bot commented on FLINK-5163: --- GitHub user kl0u opened a pull request:

[GitHub] flink pull request #2871: [FLINK-5163] Ports the production functions to the...

2016-11-25 Thread kl0u
GitHub user kl0u opened a pull request: https://github.com/apache/flink/pull/2871 [FLINK-5163] Ports the production functions to the new state abstraction. This includes the following functions: 1) `StatefulSequenceSource` 2) `MessageAcknowledgingSourceBase` 3)

[jira] [Commented] (FLINK-4798) CEPITCase.testSimpleKeyedPatternCEP test failure

2016-11-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15696191#comment-15696191 ] ASF GitHub Bot commented on FLINK-4798: --- Github user BorisOsipov commented on the issue:

[jira] [Comment Edited] (FLINK-4565) Support for SQL IN operator

2016-11-25 Thread Nikolay Vasilishin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15696107#comment-15696107 ] Nikolay Vasilishin edited comment on FLINK-4565 at 11/25/16 4:38 PM: -

[GitHub] flink pull request #2761: [FLINK-3551] [examples] Sync Scala Streaiming Exam...

2016-11-25 Thread thvasilo
Github user thvasilo commented on a diff in the pull request: https://github.com/apache/flink/pull/2761#discussion_r89645498 --- Diff: flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/kafka/ReadFromKafka.scala --- @@ -0,0 +1,72 @@

[jira] [Commented] (FLINK-3551) Sync Scala and Java Streaming Examples

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

[GitHub] flink issue #2510: FLINK-3322 Allow drivers and iterators to reuse the memor...

2016-11-25 Thread ramkrish86
Github user ramkrish86 commented on the issue: https://github.com/apache/flink/pull/2510 @StephanEwen Do you have some time to check 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

[jira] [Commented] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs

2016-11-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15695319#comment-15695319 ] ASF GitHub Bot commented on FLINK-3322: --- Github user ramkrish86 commented on the issue:

[jira] [Created] (FLINK-5159) Improve perfomance of inner joins with a single row input

2016-11-25 Thread Alexander Shoshin (JIRA)
Alexander Shoshin created FLINK-5159: Summary: Improve perfomance of inner joins with a single row input Key: FLINK-5159 URL: https://issues.apache.org/jira/browse/FLINK-5159 Project: Flink

[jira] [Commented] (FLINK-5092) Add integration with Sonarqube and code coverage

2016-11-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15695257#comment-15695257 ] ASF GitHub Bot commented on FLINK-5092: --- Github user zentol commented on the issue:

[GitHub] flink issue #2836: [FLINK-5092] Add maven profile with code coverage report ...

2016-11-25 Thread BorisOsipov
Github user BorisOsipov commented on the issue: https://github.com/apache/flink/pull/2836 @mxm I tried to use late property evaluation approach in `argLine`. Unfortunately, it doesn't work well with different profiles. In some cases it breaks test run by maven without a

[jira] [Commented] (FLINK-5092) Add integration with Sonarqube and code coverage

2016-11-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15695241#comment-15695241 ] ASF GitHub Bot commented on FLINK-5092: --- Github user BorisOsipov commented on the issue:

[GitHub] flink issue #2836: [FLINK-5092] Add maven profile with code coverage report ...

2016-11-25 Thread BorisOsipov
Github user BorisOsipov commented on the issue: https://github.com/apache/flink/pull/2836 You can find report in ${project.basedir}/target/jacoco-report folder. --- 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 issue #2845: [FLINK-5096] Make the RollingSink rescalable.

2016-11-25 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/2845 Hi @zentol ! Thanks for the review. I integrated the comments. --- 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

[GitHub] flink pull request #2845: [FLINK-5096] Make the RollingSink rescalable.

2016-11-25 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/2845#discussion_r89603474 --- Diff: flink-streaming-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/RollingSinkITCase.java --- @@ -638,6

[GitHub] flink issue #2836: [FLINK-5092] Add maven profile with code coverage report ...

2016-11-25 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2836 If i ran this myself, could i see which lines are not covered? --- 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

[jira] [Commented] (FLINK-5092) Add integration with Sonarqube and code coverage

2016-11-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15695554#comment-15695554 ] ASF GitHub Bot commented on FLINK-5092: --- Github user BorisOsipov commented on the issue:

[jira] [Commented] (FLINK-5101) Test CassandraConnectorITCase instable

2016-11-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15695581#comment-15695581 ] ASF GitHub Bot commented on FLINK-5101: --- GitHub user zentol opened a pull request:

[jira] [Commented] (FLINK-5096) Make the RollingSink rescalable.

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

[jira] [Commented] (FLINK-5096) Make the RollingSink rescalable.

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

[jira] [Commented] (FLINK-5092) Add integration with Sonarqube and code coverage

2016-11-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15695446#comment-15695446 ] ASF GitHub Bot commented on FLINK-5092: --- Github user BorisOsipov commented on the issue:

  1   2   >