[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] [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-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 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-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 #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] [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 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] [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 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

[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-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:

[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: -

[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 #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

[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: -

[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-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] [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-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:

[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)

[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] [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-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:

[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

[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-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:

[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] [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 > - > >

[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] [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] [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-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: -- 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-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:

[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:

[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: -- Fix Version/s: 1.2.0 > Upgrade to Mesos 1.0.1 > -- > >

[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-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-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] [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-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] [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] [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-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-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] [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-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] [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-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] [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

[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

[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] [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 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] [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:

[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-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 @@ +/* + *

[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] [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 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] [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-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 #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] [Created] (FLINK-5164) Hadoop-compat IOFormat tests fail on Windows

2016-11-25 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-5164: --- Summary: Hadoop-compat IOFormat tests fail on Windows Key: FLINK-5164 URL: https://issues.apache.org/jira/browse/FLINK-5164 Project: Flink Issue Type:

[jira] [Commented] (FLINK-5055) Security feature crashes JM for certain Hadoop versions even though using no Kerberos

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

[GitHub] flink pull request #2864: [FLINK-5055][security] skip Hadoop UGI login if un...

2016-11-25 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2864 --- 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-3555) Web interface does not render job information properly

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

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

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

[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=15695886#comment-15695886 ] ASF GitHub Bot commented on FLINK-4565: --- Github user NickolayVasilishin closed the pull request at:

[jira] [Commented] (FLINK-3160) Aggregate operator statistics by TaskManager

2016-11-25 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15695879#comment-15695879 ] Ufuk Celebi commented on FLINK-3160: I just noticed that we overlooked something: currently both the

[jira] [Created] (FLINK-5163) Make the production functions rescalable (apart from the Rolling/Bucketing Sinks)

2016-11-25 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5163: - Summary: Make the production functions rescalable (apart from the Rolling/Bucketing Sinks) Key: FLINK-5163 URL: https://issues.apache.org/jira/browse/FLINK-5163

[GitHub] flink pull request #2868: [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/2868 [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 literals. Two cases are covered: less and great then 20

[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=15695836#comment-15695836 ] ASF GitHub Bot commented on FLINK-4565: --- GitHub user NickolayVasilishin opened a pull request:

[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 Thanks! --- 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

[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=15695816#comment-15695816 ] ASF GitHub Bot commented on FLINK-5096: --- Github user kl0u commented on the issue:

[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=15695815#comment-15695815 ] ASF GitHub Bot commented on FLINK-5096: --- Github user zentol commented on the issue:

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

2016-11-25 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2845 Great, will start 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 feature enabled and

[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=15695811#comment-15695811 ] ASF GitHub Bot commented on FLINK-5092: --- Github user mxm commented on the issue:

  1   2   >