[jira] [Commented] (FLINK-4517) scala code refactoring

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

[GitHub] flink pull request #2428: [FLINK-4517] scala code refactoring

2016-10-24 Thread shijinkui
Github user shijinkui closed the pull request at: https://github.com/apache/flink/pull/2428 --- 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-4864) Shade Calcite dependency in flink-table

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

[GitHub] flink issue #2673: [FLINK-4864] [table] Shade Calcite dependency in flink-ta...

2016-10-24 Thread wuchong
Github user wuchong commented on the issue: https://github.com/apache/flink/pull/2673 Besides the compilation problem , Calcite has a bug [CALCITE-1461](https://issues.apache.org/jira/browse/CALCITE-1461) which will break shading. Maybe we should wait for this issue solved and

[jira] [Commented] (FLINK-4866) Make Trigger.clear() Abstract to Enforce Implementation

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

[jira] [Resolved] (FLINK-4866) Make Trigger.clear() Abstract to Enforce Implementation

2016-10-24 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-4866. - Resolution: Fixed Fix Version/s: 1.2.0 Implemented in

[GitHub] flink issue #2672: [FLINK-4866] [streaming] Make Trigger.clear() Abstract to...

2016-10-24 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2672 I merged this. Could you please close the issue? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this

[GitHub] flink pull request #2685: [FLINK-4884] Eagerly Store MergingWindowSet in Sta...

2016-10-24 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/2685 [FLINK-4884] Eagerly Store MergingWindowSet in State in WindowOperator R: @kl0u for review, please You can merge this pull request into a Git repository by running: $ git pull

[jira] [Commented] (FLINK-4884) Eagerly Store MergingWindowSet in State in WindowOperator

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

[jira] [Commented] (FLINK-4866) Make Trigger.clear() Abstract to Enforce Implementation

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

[GitHub] flink pull request #2672: [FLINK-4866] [streaming] Make Trigger.clear() Abst...

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

[GitHub] flink issue #2672: [FLINK-4866] [streaming] Make Trigger.clear() Abstract to...

2016-10-24 Thread wuchong
Github user wuchong commented on the issue: https://github.com/apache/flink/pull/2672 Sure. I will close 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] [Created] (FLINK-4890) FileInputFormatTest#testExcludeFiles fails on Windows OS

2016-10-24 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-4890: --- Summary: FileInputFormatTest#testExcludeFiles fails on Windows OS Key: FLINK-4890 URL: https://issues.apache.org/jira/browse/FLINK-4890 Project: Flink

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

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

[jira] [Commented] (FLINK-4891) Remove flink-contrib/flink-operator-stats

2016-10-24 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15601406#comment-15601406 ] Ufuk Celebi commented on FLINK-4891:

[jira] [Created] (FLINK-4891) Remove flink-contrib/flink-operator-stats

2016-10-24 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-4891: -- Summary: Remove flink-contrib/flink-operator-stats Key: FLINK-4891 URL: https://issues.apache.org/jira/browse/FLINK-4891 Project: Flink Issue Type: Task

[jira] [Closed] (FLINK-4891) Remove flink-contrib/flink-operator-stats

2016-10-24 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-4891. -- Resolution: Implemented Fix Version/s: 1.2.0 Done in d5b97b0 (master). > Remove

[jira] [Commented] (FLINK-4743) The sqrt/power function not accept the real data types.

2016-10-24 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15601283#comment-15601283 ] Anton Solovev commented on FLINK-4743: -- I reported bug in calcite

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

2016-10-24 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15601278#comment-15601278 ] Stefan Richter commented on FLINK-4883: --- Ok, thanks! I will assign you to this. > Prevent UDFs

[jira] [Commented] (FLINK-4866) Make Trigger.clear() Abstract to Enforce Implementation

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

[GitHub] flink issue #2671: [FLINK-4862] fix Timer register in ContinuousEventTimeTri...

2016-10-24 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2671 @mxm @manuzhang Yes, the timers will be ignored because there is a check in `onEventTime()`. The fix looks good! Will you go ahead and merge, @mxm? --- If your project is set up for it,

[jira] [Commented] (FLINK-4862) NPE on EventTimeSessionWindows with ContinuousEventTimeTrigger

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

[GitHub] flink issue #2646: [FLINK-4843] Test for FsCheckpointStateOutputStream::getP...

2016-10-24 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/2646 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 the

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

2016-10-24 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-4833. -- Resolution: Implemented Fix Version/s: 1.2.0 Fixed in d5b97b0 (master) via removal of the module

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

2016-10-24 Thread vijikarthi
Github user vijikarthi commented on the issue: https://github.com/apache/flink/pull/2425 @mxm - Please take a look when you get a chance? --- 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] [Created] (FLINK-4900) Implement Docker image support

2016-10-24 Thread Eron Wright (JIRA)
Eron Wright created FLINK-4900: --- Summary: Implement Docker image support Key: FLINK-4900 URL: https://issues.apache.org/jira/browse/FLINK-4900 Project: Flink Issue Type: Sub-task

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

2016-10-24 Thread Eron Wright (JIRA)
Eron Wright created FLINK-4899: --- Summary: Implement DCOS package Key: FLINK-4899 URL: https://issues.apache.org/jira/browse/FLINK-4899 Project: Flink Issue Type: Sub-task

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

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

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

2016-10-24 Thread Eron Wright (JIRA)
Eron Wright created FLINK-4897: --- Summary: Implement Dispatcher Key: FLINK-4897 URL: https://issues.apache.org/jira/browse/FLINK-4897 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-4352) Implement new JobClient

2016-10-24 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15603536#comment-15603536 ] Eron Wright commented on FLINK-4352: - This maybe should be moved to be a subtask of FLINK-4897. >

[jira] [Created] (FLINK-4898) Refactor HTTP handlers and Netty server/client

2016-10-24 Thread Eron Wright (JIRA)
Eron Wright created FLINK-4898: --- Summary: Refactor HTTP handlers and Netty server/client Key: FLINK-4898 URL: https://issues.apache.org/jira/browse/FLINK-4898 Project: Flink Issue Type:

[jira] [Updated] (FLINK-1984) Integrate Flink with Apache Mesos

2016-10-24 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright updated FLINK-1984: Description: There are some users asking for an integration of Flink into Mesos. -There also is a

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

2016-10-24 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15603888#comment-15603888 ] Jark Wu commented on FLINK-4469: Agree. I will propose these to Calcite. > Add support for user defined

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

2016-10-24 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15582930#comment-15582930 ] Ted Yu edited comment on FLINK-4848 at 10/25/16 2:21 AM: - There is similar issue

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

2016-10-24 Thread Renkai Ge (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15604147#comment-15604147 ] Renkai Ge commented on FLINK-4883: -- I tried to use object to extend UDF, but I haven't got a failure,

[jira] [Created] (FLINK-4902) Flink Task Chain not getting input in a distributed manner

2016-10-24 Thread Sajeev Ramakrishnan (JIRA)
Sajeev Ramakrishnan created FLINK-4902: -- Summary: Flink Task Chain not getting input in a distributed manner Key: FLINK-4902 URL: https://issues.apache.org/jira/browse/FLINK-4902 Project: Flink

[jira] [Commented] (FLINK-4886) Example in Machine Learning Quickstart Guide causes error

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

[jira] [Commented] (FLINK-4886) Example in Machine Learning Quickstart Guide causes error

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

[GitHub] flink issue #2682: [FLINK-4886] [docs] Update ML quickstart loading svm test...

2016-10-24 Thread ch33hau
Github user ch33hau commented on the issue: https://github.com/apache/flink/pull/2682 Sorry I just noticed that similar PR (https://github.com/apache/flink/pull/2658) has been created, in a way more complete compare to my PR. So I will close mine and sorry for creating

[GitHub] flink pull request #2682: [FLINK-4886] [docs] Update ML quickstart loading s...

2016-10-24 Thread ch33hau
Github user ch33hau closed the pull request at: https://github.com/apache/flink/pull/2682 --- 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] [Created] (FLINK-4901) Build DCOS Docker image

2016-10-24 Thread Eron Wright (JIRA)
Eron Wright created FLINK-4901: --- Summary: Build DCOS Docker image Key: FLINK-4901 URL: https://issues.apache.org/jira/browse/FLINK-4901 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-4902) Flink Task Chain not getting input in a distributed manner

2016-10-24 Thread Sajeev Ramakrishnan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sajeev Ramakrishnan updated FLINK-4902: --- Description: Dear Team, I have the following tasks chained as a single subtask.

[jira] [Updated] (FLINK-4630) add netty tcp/restful pushed source support

2016-10-24 Thread shijinkui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shijinkui updated FLINK-4630: - Description: When source stream get start, listen a provided tcp port, receive stream data from user

[GitHub] flink issue #2448: [FLINK-3030][web frontend] Enhance dashboard to show exec...

2016-10-24 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2448 Okay, I'll run gulp when 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

[GitHub] flink pull request #2688: [FLINK-4762] [table] Use plural in time interval u...

2016-10-24 Thread wuchong
GitHub user wuchong opened a pull request: https://github.com/apache/flink/pull/2688 [FLINK-4762] [table] Use plural in time interval units Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If

[jira] [Commented] (FLINK-4623) Create Physical Execution Plan of a DataStream

2016-10-24 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15601846#comment-15601846 ] Anton Solovev commented on FLINK-4623: -- Do I need to create special getSqlExecutionPlan method for

[GitHub] flink issue #2644: [FLINK-4837] flink-streaming-akka source connector

2016-10-24 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2644 Thank you for opening a pull request for adding a new streaming connector. I also think that this connector is a good candidate to go into Apache Bahir. You find the GitHub repository of Bahir

[jira] [Commented] (FLINK-4837) flink-streaming-akka source connector

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

[jira] [Assigned] (FLINK-3123) Allow setting custom start-offsets for the Kafka consumer

2016-10-24 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-3123: -- Assignee: Tzu-Li (Gordon) Tai > Allow setting custom start-offsets for the

[jira] [Updated] (FLINK-3123) Allow setting custom start-offsets for the Kafka consumer

2016-10-24 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-3123: --- Fix Version/s: 1.2.0 > Allow setting custom start-offsets for the Kafka consumer >

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

2016-10-24 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15601682#comment-15601682 ] Shaoxuan Wang commented on FLINK-4469: -- Thanks for checking this, Fabian. I replied this thread

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

2016-10-24 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15601728#comment-15601728 ] Jark Wu commented on FLINK-4469: Hi [~shaoxuan], Sorry, I didn't notice your reply. I have thought about

[jira] [Commented] (FLINK-4520) Integrate Siddhi as a lightweight CEP Library

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

[GitHub] flink issue #2487: [FLINK-4520][flink-siddhi] Integrate Siddhi as a light-we...

2016-10-24 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2487 Hi @haoch, thanks alot for this contribution. I recently started moving some of the streaming connectors of Flink to Apache Bahir, a community for extensions to Spark, Flink (and maybe

[jira] [Commented] (FLINK-4832) Count/Sum 0 elements

2016-10-24 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15601955#comment-15601955 ] Aljoscha Krettek commented on FLINK-4832: - Counting {{0}} elements using a union with a dummy

[jira] [Closed] (FLINK-4630) add netty tcp/restful pushed source support

2016-10-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-4630. - Resolution: Won't Fix I've closed the issue here in favor of the issue at Bahir:

[GitHub] flink issue #2650: [FLINK-4563] [metrics] scope caching not adjusted for mul...

2016-10-24 Thread ex00
Github user ex00 commented on the issue: https://github.com/apache/flink/pull/2650 Hello. I pushed new changes. --- 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] [Created] (FLINK-4894) Don't block on buffer request after broadcastEvent

2016-10-24 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-4894: -- Summary: Don't block on buffer request after broadcastEvent Key: FLINK-4894 URL: https://issues.apache.org/jira/browse/FLINK-4894 Project: Flink Issue Type:

[GitHub] flink issue #2673: [FLINK-4864] [table] Shade Calcite dependency in flink-ta...

2016-10-24 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2673 Thanks for investigating this and submitting a PR to Calcite, @wuchong! Maybe @rmetzger has an idea of what's going wrong with the shading? --- If your project is set up for it, you can

[jira] [Comment Edited] (FLINK-4623) Create Physical Execution Plan of a DataStream

2016-10-24 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15601846#comment-15601846 ] Anton Solovev edited comment on FLINK-4623 at 10/24/16 12:31 PM: - Do I

[jira] [Commented] (FLINK-4639) Make Calcite features more pluggable

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

[GitHub] flink pull request #2521: [FLINK-4639] [table] Make Calcite features more pl...

2016-10-24 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2521#discussion_r84659763 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/CalciteConfig.scala --- @@ -0,0 +1,146 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-4639) Make Calcite features more pluggable

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

[GitHub] flink issue #2521: [FLINK-4639] [table] Make Calcite features more pluggable

2016-10-24 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2521 PR looks good to me, except for some methods of the added `CalciteConfig`. Will fix these issues and merge the PR. --- If your project is set up for it, you can reply to this email and have your

[jira] [Commented] (FLINK-4864) Shade Calcite dependency in flink-table

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

[GitHub] flink issue #2673: [FLINK-4864] [table] Shade Calcite dependency in flink-ta...

2016-10-24 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2673 I tried reproducing the issue reported by @fhueske. The only issue I got was `Caused by: org.codehaus.commons.compiler.CompileException: Line 8, Column 13: Class

[jira] [Commented] (FLINK-4862) NPE on EventTimeSessionWindows with ContinuousEventTimeTrigger

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

[jira] [Commented] (FLINK-4888) instantiated job manager metrics missing important job statistics

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

[GitHub] flink issue #2683: [FLINK-4888][metrics] instantiated job manager metrics mi...

2016-10-24 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2683 Thank you for opening a pull request. I agree that we should expose all numbers we show in the web interface as a metric as well. --- If your project is set up for it, you can reply to this email

[GitHub] flink issue #2671: [FLINK-4862] fix Timer register in ContinuousEventTimeTri...

2016-10-24 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2671 Thanks for having a look @aljoscha. Thanks again for the PR @manuzhang. 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

[GitHub] flink pull request #2683: [FLINK-4888][metrics] instantiated job manager met...

2016-10-24 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/2683#discussion_r84689406 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -1828,6 +1828,33 @@ class JobManager(

[jira] [Updated] (FLINK-4876) Allow web interface to be bound to a specific ip/interface/inetHost

2016-10-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4876: -- Component/s: Webfrontend > Allow web interface to be bound to a specific ip/interface/inetHost

[GitHub] flink issue #2680: [FLINK-4876] Allow web interface to be bound to a specifi...

2016-10-24 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2680 Thank you for opening a PR for fixing this. +1 to merge. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project

[GitHub] flink issue #2654: [hotfix] [kafka] Fix RackAwareMode instantiation in Kafka...

2016-10-24 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2654 Nice fix, thank you +1 to merge. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature

[jira] [Commented] (FLINK-4832) Count/Sum 0 elements

2016-10-24 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15602184#comment-15602184 ] Fabian Hueske commented on FLINK-4832: -- [~jark] is right. A zero count is only necessary for

[jira] [Commented] (FLINK-4853) Clean up JobManager registration at the ResourceManager

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

[GitHub] flink pull request #2657: [FLINK-4853] [rm] Harden job manager registration ...

2016-10-24 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2657#discussion_r84689078 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java --- @@ -202,101 +205,125 @@ public void shutDown() throws

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

2016-10-24 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2626 Looks like the tests are failing. I quickly scrolled over the changes. +1 to merge. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Updated] (FLINK-4876) Allow web interface to be bound to a specific ip/interface/inetHost

2016-10-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4876: -- Assignee: Bram Vogelaar > Allow web interface to be bound to a specific ip/interface/inetHost >

[jira] [Commented] (FLINK-4876) Allow web interface to be bound to a specific ip/interface/inetHost

2016-10-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15602064#comment-15602064 ] Robert Metzger commented on FLINK-4876: --- Thank you for working on this. I gave you "Contributor"

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

2016-10-24 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-4894: -- Assignee: Ufuk Celebi > Don't block on buffer request after broadcastEvent >

[jira] [Created] (FLINK-4895) Drop support for Hadoop 1

2016-10-24 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-4895: - Summary: Drop support for Hadoop 1 Key: FLINK-4895 URL: https://issues.apache.org/jira/browse/FLINK-4895 Project: Flink Issue Type: Task

[jira] [Commented] (FLINK-2491) Operators are not participating in state checkpointing in some cases

2016-10-24 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15601982#comment-15601982 ] Aljoscha Krettek commented on FLINK-2491: - What source are you using, [~Revy1313]? > Operators

[jira] [Commented] (FLINK-4876) Allow web interface to be bound to a specific ip/interface/inetHost

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

[jira] [Commented] (FLINK-4072) EventTimeWindowCheckpointingITCase.testSlidingTimeWindow fails on Travis

2016-10-24 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15602031#comment-15602031 ] Aljoscha Krettek commented on FLINK-4072: - I saw this problem:

[jira] [Closed] (FLINK-4852) ClassCastException when assigning Watermarks with TimeCharacteristic.ProcessingTime

2016-10-24 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-4852. --- > ClassCastException when assigning Watermarks with > TimeCharacteristic.ProcessingTime >

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

2016-10-24 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-3674. --- > Add an interface for Time aware User Functions > --

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

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

[GitHub] flink pull request #2671: [FLINK-4862] fix Timer register in ContinuousEvent...

2016-10-24 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2671 --- 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 #2678: [FLINK-4879] [Kafka-Connector] class KafkaTableSou...

2016-10-24 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2678 --- 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-4862) NPE on EventTimeSessionWindows with ContinuousEventTimeTrigger

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

[jira] [Commented] (FLINK-4888) instantiated job manager metrics missing important job statistics

2016-10-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15601991#comment-15601991 ] Robert Metzger commented on FLINK-4888: --- Thank you for working on this. I gave you "Contributor"

[jira] [Updated] (FLINK-4888) instantiated job manager metrics missing important job statistics

2016-10-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4888: -- Assignee: Philipp von dem Bussche > instantiated job manager metrics missing important job

[GitHub] flink pull request #2671: [FLINK-4862] fix Timer register in ContinuousEvent...

2016-10-24 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2671#discussion_r84689568 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/ContinuousEventTimeTrigger.java --- @@ -99,8 +111,12 @@ public

[jira] [Commented] (FLINK-4862) NPE on EventTimeSessionWindows with ContinuousEventTimeTrigger

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

[jira] [Resolved] (FLINK-4879) class KafkaTableSource should be public just like KafkaTableSink

2016-10-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-4879. --- Resolution: Fixed Fix Version/s: (was: 1.1.4) 1.2.0 Resolved

[jira] [Commented] (FLINK-4832) Count/Sum 0 elements

2016-10-24 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15602113#comment-15602113 ] Jark Wu commented on FLINK-4832: I have tried to count elements in an empty table in MySQL. Without GROUP

[jira] [Commented] (FLINK-4756) NullPointerException on submiting a job with StreamExecutionEnvironment.createRemoteEnvironment to a flink cluster

2016-10-24 Thread Jose Maria Fuentes Lopez (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15602121#comment-15602121 ] Jose Maria Fuentes Lopez commented on FLINK-4756: - Hi there! Do you have any news on this

[jira] [Commented] (FLINK-4888) instantiated job manager metrics missing important job statistics

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

[jira] [Closed] (FLINK-4866) Make Trigger.clear() Abstract to Enforce Implementation

2016-10-24 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-4866. --- > Make Trigger.clear() Abstract to Enforce Implementation >

  1   2   >