[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&focusedCommentId=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 setNumbe

[jira] [Commented] (FLINK-4280) New Flink-specific option to set starting position of Kafka consumer without respecting external offsets in ZK / Broker

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

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

[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&focusedCommentId=15696363#comment-15696363 ] ASF GitHub Bot commented on FLINK-3551: --- Github user thvasilo commented on a diff in

[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&focusedCommentId=15696350#comment-15696350 ] ASF GitHub Bot commented on FLINK-5146: --- Github user StefanRRichter commented on the

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

[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&focusedCommentId=15696338#comment-15696338 ] ASF GitHub Bot commented on FLINK-3551: --- Github user ch33hau commented on a diff in

[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&focusedCommentId=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 enabled

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

[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&focusedCommentId=15696288#comment-15696288 ] ASF GitHub Bot commented on FLINK-4975: --- Github user StephanEwen closed the pull req

[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&focusedCommentId=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&focusedCommentId=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 re

[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&focusedCommentId=15696217#comment-15696217 ] ASF GitHub Bot commented on FLINK-5158: --- GitHub user tillrohrmann opened a pull requ

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

[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&focusedCommentId=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&focusedCommentId=15696191#comment-15696191 ] ASF GitHub Bot commented on FLINK-4798: --- Github user BorisOsipov commented on the is

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

[GitHub] flink pull request #2872: [FLINK-5158] [ckPtCoord] Handle exceptions from Co...

2016-11-25 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/2872 [FLINK-5158] [ckPtCoord] Handle exceptions from CompletedCheckpointStore in CheckpointCoordinator Handle exceptions from the CompletedCheckpointStore properly in the CheckpointCoordinator. Thi

[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&focusedCommentId=15696175#comment-15696175 ] ASF GitHub Bot commented on FLINK-5158: --- GitHub user tillrohrmann opened a pull requ

[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&focusedCommentId=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) `FromEleme

[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&focusedCommentId=15696167#comment-15696167 ] ASF GitHub Bot commented on FLINK-5159: --- Github user fhueske commented on a diff in

[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&focusedCommentId=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 as

[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 5bd47012e50516d45a6b50d47f347e

[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&focusedCommentId=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 ena

[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&focusedCommentId=15696129#comment-15696129 ] Maximilian Michels commented on FLINK-3903: --- Thanks for the formula! Updating th

[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&focusedCommentId=15696125#comment-15696125 ] Maximilian Michels commented on FLINK-3883: --- +1 for the proposed renaming. All

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

[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&focusedCommentId=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 p

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

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

[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] [Created] (FLINK-5165) Checkpointing tests using FsStatebackend fail on Windows

2016-11-25 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-5165: --- Summary: Checkpointing tests using FsStatebackend fail on Windows Key: FLINK-5165 URL: https://issues.apache.org/jira/browse/FLINK-5165 Project: Flink

[jira] [Updated] (FLINK-4897) Implement Dispatcher

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

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

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

[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&focusedCommentId=15696107#comment-15696107 ] Nikolay Vasilishin commented on FLINK-4565: --- [~fhueske], I've finally opened the

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

[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 @uce can you close the PR? I forgot that pushes to a branch different then master don't close a PR. --- If your project is set up for it, you can reply to this email and have your reply appear on G

[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&focusedCommentId=15696100#comment-15696100 ] Maximilian Michels commented on FLINK-4950: --- Could you backport your changes par

[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&focusedCommentId=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 confi

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

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

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

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

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

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

[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&focusedCommentId=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&focusedCommentId=15696057#comment-15696057 ] ASF GitHub Bot commented on FLINK-4565: --- GitHub user NickolayVasilishin opened a pul

[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 literals.

[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&focusedCommentId=15696048#comment-15696048 ] ASF GitHub Bot commented on FLINK-5159: --- Github user AlexanderShoshin commented on a

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

[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&focusedCommentId=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 this

[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&focusedCommentId=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 Git

[jira] [Assigned] (FLINK-4825) Implement a RexExecutor that uses Flink's code generation

2016-11-25 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-4825: --- Assignee: Timo Walther > Implement a RexExecutor that uses Flink's code generation >

[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&focusedCommentId=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 doe

[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] [Resolved] (FLINK-5055) Security feature crashes JM for certain Hadoop versions even though using no Kerberos

2016-11-25 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-5055. --- Resolution: Fixed Fixed via 1b2f3c06d2296d5e628b66a3c13126a546958d74. > Security feat

[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&focusedCommentId=15695931#comment-15695931 ] ASF GitHub Bot commented on FLINK-5055: --- Github user asfgit closed the pull request

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

[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&focusedCommentId=15695905#comment-15695905 ] ASF GitHub Bot commented on FLINK-3555: --- GitHub user bitchelov opened a pull request

[GitHub] flink pull request #2869: [FLINK-3555] Web interface does not render job inf...

2016-11-25 Thread bitchelov
GitHub user bitchelov opened a pull request: https://github.com/apache/flink/pull/2869 [FLINK-3555] Web interface does not render job information properly Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into considerat

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

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

  1   2   >