[jira] [Closed] (FLINK-5452) Make table unit tests pass under cluster mode

2017-01-19 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-5452. Resolution: Fixed Fix Version/s: 1.3.0 1.2.0 Fixed for 1.2.0 with

[jira] [Reopened] (FLINK-5452) Make table unit tests pass under cluster mode

2017-01-19 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reopened FLINK-5452: -- > Make table unit tests pass under cluster mode > - > >

[jira] [Commented] (FLINK-5386) Refactoring Window Clause

2017-01-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15831354#comment-15831354 ] ASF GitHub Bot commented on FLINK-5386: --- Github user sunjincheng121 commented on the issue:

[jira] [Closed] (FLINK-5520) Disable outer joins with non-equality predicates

2017-01-19 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-5520. Resolution: Done Fix Version/s: 1.3.0 Fixed for 1.2.0 with

[GitHub] flink issue #3046: [FLINK-5386][Table API & SQL] refactoring Window Clause

2017-01-19 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/3046 Hi, @fhueske thanks a lot for the review. I have updated the PR according to your comments. Let me know if I miss something,thanks again!! --- If your project is set up for it, you can

[jira] [Commented] (FLINK-5580) Kerberos keytabs not working for YARN deployment mode

2017-01-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15831322#comment-15831322 ] ASF GitHub Bot commented on FLINK-5580: --- GitHub user tzulitai opened a pull request:

[GitHub] flink pull request #3177: [FLINK-5580] [security] Fix path setting of shippe...

2017-01-19 Thread tzulitai
GitHub user tzulitai opened a pull request: https://github.com/apache/flink/pull/3177 [FLINK-5580] [security] Fix path setting of shipped Kerberos keytabs in YARN mode Previously, the local path of the shipped keytab was set _after_ `SecurityConfiguration` was created, causing the

[jira] [Commented] (FLINK-5571) add open and close methods for UserDefinedFunction in TableAPI & SQL

2017-01-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15831296#comment-15831296 ] ASF GitHub Bot commented on FLINK-5571: --- GitHub user godfreyhe opened a pull request:

[GitHub] flink pull request #3176: [FLINK-5571] [table] add open and close methods fo...

2017-01-19 Thread godfreyhe
GitHub user godfreyhe opened a pull request: https://github.com/apache/flink/pull/3176 [FLINK-5571] [table] add open and close methods for UserDefinedFunction Currently, a User Defined Function (UDF) in table API & SQL works on zero, one, or multiple values in custom evaluation

[jira] [Closed] (FLINK-5452) Make table unit tests pass under cluster mode

2017-01-19 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-5452. - > Make table unit tests pass under cluster mode > - > >

[jira] [Resolved] (FLINK-5452) Make table unit tests pass under cluster mode

2017-01-19 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young resolved FLINK-5452. --- Resolution: Fixed > Make table unit tests pass under cluster mode >

[jira] [Closed] (FLINK-5493) FlinkDistributionOverlay does not properly display missing environment variables

2017-01-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5493. --- Resolution: Fixed Fix Version/s: 1.2.0 master:

[jira] [Updated] (FLINK-5493) FlinkDistributionOverlay does not properly display missing environment variables

2017-01-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5493: Assignee: Boris Osipov > FlinkDistributionOverlay does not properly display missing

[jira] [Closed] (FLINK-5113) Make all Testing Functions implement CheckpointedFunction Interface.

2017-01-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5113. --- Resolution: Fixed Fix Version/s: 1.3.0 master:

[jira] [Closed] (FLINK-4920) Add a Scala Function Gauge

2017-01-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4920. --- Resolution: Fixed Fix Version/s: 1.3.0 master:

[jira] [Updated] (FLINK-5113) Make all Testing Functions implement CheckpointedFunction Interface.

2017-01-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5113: Affects Version/s: 1.3.0 > Make all Testing Functions implement CheckpointedFunction

[jira] [Closed] (FLINK-5321) FlinkMiniCluster does not start Jobmanager MetricQueryService

2017-01-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5321. --- Resolution: Fixed Fix Version/s: 1.3.0 master:

[jira] [Closed] (FLINK-5417) Fix the wrong config file name

2017-01-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5417. --- Resolution: Fixed Fix Version/s: 1.3.0 1.2.0 master:

[jira] [Updated] (FLINK-5321) FlinkMiniCluster does not start Jobmanager MetricQueryService

2017-01-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5321: Affects Version/s: 1.3.0 > FlinkMiniCluster does not start Jobmanager MetricQueryService >

[jira] [Updated] (FLINK-5417) Fix the wrong config file name

2017-01-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5417: Affects Version/s: 1.3.0 1.2.0 > Fix the wrong config file name >

[jira] [Closed] (FLINK-5424) Improve Restart Strategy Logging

2017-01-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5424. --- Resolution: Fixed Fix Version/s: 1.3.0 1.2.0 master:

[jira] [Closed] (FLINK-5419) Taskmanager metrics not accessible via REST

2017-01-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5419. --- Resolution: Fixed master: c93e04c16a7865dbbc90d89799b46f91831e0a55 1.2:

[jira] [Closed] (FLINK-5434) Remove unsupported project() transformation from Scala DataStream docs

2017-01-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5434. --- Resolution: Fixed Fix Version/s: 1.3.0 1.2.0 master:

[jira] [Updated] (FLINK-5434) Remove unsupported project() transformation from Scala DataStream docs

2017-01-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5434: Affects Version/s: 1.3.0 1.2.0 > Remove unsupported project()

[jira] [Updated] (FLINK-5434) Remove unsupported project() transformation from Scala DataStream docs

2017-01-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5434: Priority: Minor (was: Major) > Remove unsupported project() transformation from Scala

[jira] [Updated] (FLINK-5329) Metric list is being cut off in the WebFrontend

2017-01-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5329: Fix Version/s: 1.3.0 > Metric list is being cut off in the WebFrontend >

[jira] [Assigned] (FLINK-5329) Metric list is being cut off in the WebFrontend

2017-01-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-5329: --- Assignee: Chesnay Schepler > Metric list is being cut off in the WebFrontend >

[jira] [Updated] (FLINK-5434) Remove unsupported project() transformation from Scala DataStream docs

2017-01-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5434: Assignee: GaoLun > Remove unsupported project() transformation from Scala DataStream docs >

[jira] [Closed] (FLINK-5329) Metric list is being cut off in the WebFrontend

2017-01-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5329. --- Resolution: Fixed master: b8c34d455029907a237230e2f8c49a8b6b651970 1.2:

[jira] [Closed] (FLINK-5380) Number of outgoing records not reported in web interface

2017-01-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5380. --- Resolution: Fixed master: cb05915759b1d5ea4dbfcdd3ff76dcfd9cebe601 1.2:

[jira] [Updated] (FLINK-5329) Metric list is being cut off in the WebFrontend

2017-01-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5329: Affects Version/s: 1.3.0 > Metric list is being cut off in the WebFrontend >

[jira] [Updated] (FLINK-5432) ContinuousFileMonitoringFunction is not monitoring nested files

2017-01-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5432: Affects Version/s: 1.3.0 > ContinuousFileMonitoringFunction is not monitoring nested files

[jira] [Closed] (FLINK-5432) ContinuousFileMonitoringFunction is not monitoring nested files

2017-01-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5432. --- Resolution: Fixed master: 9945904e2251e7c0e218e2766bf07778d1307277 1.2:

[jira] [Closed] (FLINK-5150) WebUI metric-related resource leak

2017-01-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5150. --- Resolution: Fixed master: cbd933bd1def789d1978be5349005dd7d9de3082 1.2:

[jira] [Updated] (FLINK-5150) WebUI metric-related resource leak

2017-01-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5150: Fix Version/s: 1.3.0 > WebUI metric-related resource leak >

[jira] [Commented] (FLINK-5321) FlinkMiniCluster does not start Jobmanager MetricQueryService

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

[jira] [Commented] (FLINK-4920) Add a Scala Function Gauge

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

[jira] [Commented] (FLINK-5329) Metric list is being cut off in the WebFrontend

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

[jira] [Commented] (FLINK-5424) Improve Restart Strategy Logging

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

[jira] [Updated] (FLINK-5150) WebUI metric-related resource leak

2017-01-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5150: Affects Version/s: (was: 1.1.3) > WebUI metric-related resource leak >

[jira] [Commented] (FLINK-5432) ContinuousFileMonitoringFunction is not monitoring nested files

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

[jira] [Commented] (FLINK-5150) WebUI metric-related resource leak

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

[GitHub] flink pull request #3068: [FLINK-5380] Fix task metrics reuse for single-ope...

2017-01-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3068 --- 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 #3092: [FLINK-5419] Make full TM metrics available throug...

2017-01-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3092 --- 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 #3071: [FLINK-5417][DOCUMENTATION]correct the wrong confi...

2017-01-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3071 --- 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 #2939: [FLINK-5113] Ports all functions in the tests to t...

2017-01-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2939 --- 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-5417) Fix the wrong config file name

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

[jira] [Updated] (FLINK-5150) WebUI metric-related resource leak

2017-01-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5150: Affects Version/s: 1.3.0 1.2.0 > WebUI metric-related resource leak

[GitHub] flink pull request #3080: [FLINK-4920] Add a Scala Function Gauge

2017-01-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3080 --- 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-5113) Make all Testing Functions implement CheckpointedFunction Interface.

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

[jira] [Commented] (FLINK-5380) Number of outgoing records not reported in web interface

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

[GitHub] flink pull request #2991: [FLINK-5321] [metrics] LocalFlinkMiniCluster start...

2017-01-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2991 --- 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-5419) Taskmanager metrics not accessible via REST

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

[GitHub] flink pull request #3137: [hotfix] [doc] Fix several broken "Linking with Fl...

2017-01-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3137 --- 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 #3109: [FLINK-5329] Fix metric list being cut off

2017-01-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3109 --- 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 #3090: [FLINK-5432] Fix nested files enumeration in Conti...

2017-01-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3090 --- 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 #3079: [FLINK-5424] Improve Restart Strategy Logging

2017-01-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3079 --- 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 #3010: [minor] Fix String formats in FlinkDistributionOve...

2017-01-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3010 --- 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 #3104: [FLINK-5150] [webui] Store metrics in sessionStora...

2017-01-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3104 --- 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 #3149: FLINK-2168 Add HBaseTableSource

2017-01-19 Thread ramkrish86
Github user ramkrish86 commented on a diff in the pull request: https://github.com/apache/flink/pull/3149#discussion_r97015379 --- Diff: flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBaseTableSourceInputFormat.java --- @@ -0,0 +1,322 @@ +/* + *

[GitHub] flink pull request #3149: FLINK-2168 Add HBaseTableSource

2017-01-19 Thread ramkrish86
Github user ramkrish86 commented on a diff in the pull request: https://github.com/apache/flink/pull/3149#discussion_r97015321 --- Diff: flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBaseTableSource.java --- @@ -0,0 +1,75 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-2168) Add HBaseTableSource

2017-01-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15831223#comment-15831223 ] ASF GitHub Bot commented on FLINK-2168: --- Github user ramkrish86 commented on a diff in the pull

[GitHub] flink pull request #3149: FLINK-2168 Add HBaseTableSource

2017-01-19 Thread ramkrish86
Github user ramkrish86 commented on a diff in the pull request: https://github.com/apache/flink/pull/3149#discussion_r97015267 --- Diff: flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBaseTableSourceInputFormat.java --- @@ -0,0 +1,322 @@ +/* + *

[jira] [Commented] (FLINK-2168) Add HBaseTableSource

2017-01-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15831221#comment-15831221 ] ASF GitHub Bot commented on FLINK-2168: --- Github user ramkrish86 commented on a diff in the pull

[jira] [Commented] (FLINK-2168) Add HBaseTableSource

2017-01-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15831218#comment-15831218 ] ASF GitHub Bot commented on FLINK-2168: --- Github user ramkrish86 commented on a diff in the pull

[GitHub] flink issue #3150: [FLINK-4693][tableApi] Add session group-windows for batc...

2017-01-19 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/3150 @fhueske I have updated the PR according to your comments.The change information is as follows: 1. Fix "remember and read input objects across method calls". 2. Amend some code

[jira] [Commented] (FLINK-4693) Add session group-windows for batch tables

2017-01-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15831151#comment-15831151 ] ASF GitHub Bot commented on FLINK-4693: --- Github user sunjincheng121 commented on the issue:

[jira] [Commented] (FLINK-5584) Support Sliding-count row-window on streaming sql

2017-01-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15831133#comment-15831133 ] ASF GitHub Bot commented on FLINK-5584: --- Github user sunjincheng121 commented on the issue:

[GitHub] flink issue #3175: [FLINK-5584]support sliding-count row-window on streaming...

2017-01-19 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/3175 Hi, @hongyuhong , thank your for your job. Agree with @wuchong 's comments. I add same database OVER example for you: ``` Example data: select * from PeopleInfo ID

[GitHub] flink issue #3153: [hotfix] [docs] Insert closing parentheses on "Flink Data...

2017-01-19 Thread keijiyoshida
Github user keijiyoshida commented on the issue: https://github.com/apache/flink/pull/3153 Thanks for your checking and 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

[jira] [Commented] (FLINK-5584) Support Sliding-count row-window on streaming sql

2017-01-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15831112#comment-15831112 ] ASF GitHub Bot commented on FLINK-5584: --- Github user wuchong commented on the issue:

[GitHub] flink issue #3175: [FLINK-5584]support sliding-count row-window on streaming...

2017-01-19 Thread wuchong
Github user wuchong commented on the issue: https://github.com/apache/flink/pull/3175 Hi @hongyuhong , thank your for your job. But it seems that you misunderstand the SQL OVER syntax. The OVER clause defines a window or user-specified set of rows within a query result set. A

[jira] [Commented] (FLINK-5584) Support Sliding-count row-window on streaming sql

2017-01-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15831036#comment-15831036 ] ASF GitHub Bot commented on FLINK-5584: --- GitHub user hongyuhong opened a pull request:

[GitHub] flink pull request #3175: [FLINK-5584]support sliding-count row-window on st...

2017-01-19 Thread hongyuhong
GitHub user hongyuhong opened a pull request: https://github.com/apache/flink/pull/3175 [FLINK-5584]support sliding-count row-window on streaming sql Calcite has already support sliding-count row-window, the grammar look like: select sum(amount) over (rows 10 preceding) from

[jira] [Created] (FLINK-5584) Support Sliding-count row-window on streaming sql

2017-01-19 Thread Yuhong Hong (JIRA)
Yuhong Hong created FLINK-5584: -- Summary: Support Sliding-count row-window on streaming sql Key: FLINK-5584 URL: https://issues.apache.org/jira/browse/FLINK-5584 Project: Flink Issue Type: New

[GitHub] flink pull request #3141: [FLINK-5520] [table] Disable outer joins with non-...

2017-01-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3141 --- 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-5520) Disable outer joins with non-equality predicates

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

[GitHub] flink pull request #3095: [FLINK-5452] [table] Fix SortITCase which will fai...

2017-01-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3095 --- 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-5452) Make table unit tests pass under cluster mode

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

[GitHub] flink pull request #3153: [hotfix] [docs] Insert closing parentheses on "Fli...

2017-01-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3153 --- 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] [Assigned] (FLINK-3679) DeserializationSchema should handle zero or more outputs for every input

2017-01-19 Thread Haohui Mai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai reassigned FLINK-3679: - Assignee: Haohui Mai > DeserializationSchema should handle zero or more outputs for every input

[jira] [Closed] (FLINK-5557) Fix link in library methods

2017-01-19 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-5557. - Resolution: Fixed Fixed in master: 4833e74e7a8b514e8dfa243f3f196ce443cf1c50 1.2:

[jira] [Commented] (FLINK-5557) Fix link in library methods

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

[GitHub] flink pull request #3163: [FLINK-5557] [gelly] Fix link in library methods

2017-01-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3163 --- 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] [Closed] (FLINK-5579) Kerberos not working for Kafka connector using ticket cache

2017-01-19 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-5579. -- Resolution: Not A Bug > Kerberos not working for Kafka connector using ticket cache >

[jira] [Commented] (FLINK-5579) Kerberos not working for Kafka connector using ticket cache

2017-01-19 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15830523#comment-15830523 ] Tzu-Li (Gordon) Tai commented on FLINK-5579: This actually isn't a bug. With YARN, Kerberos

[jira] [Created] (FLINK-5583) Support flexible error handling in the Kafka consumer

2017-01-19 Thread Haohui Mai (JIRA)
Haohui Mai created FLINK-5583: - Summary: Support flexible error handling in the Kafka consumer Key: FLINK-5583 URL: https://issues.apache.org/jira/browse/FLINK-5583 Project: Flink Issue Type:

[jira] [Updated] (FLINK-5459) Add documentation how to debug classloading and event time issues

2017-01-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5459: -- Description: {{docs/monitoring/debugging_classloading.md}} was:

[jira] [Updated] (FLINK-5459) Add documentation how to debug classloading

2017-01-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5459: -- Summary: Add documentation how to debug classloading (was: Add documentation how to debug

[jira] [Updated] (FLINK-5459) Add documentation how to debug classloading issues

2017-01-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5459: -- Summary: Add documentation how to debug classloading issues (was: Add documentation how to

[jira] [Resolved] (FLINK-5555) Add documentation about debugging watermarks

2017-01-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-. --- Resolution: Fixed Fix Version/s: 1.3.0 Resolved for 1.3 in master:

[jira] [Commented] (FLINK-5459) Add documentation how to debug classloading and event time issues

2017-01-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15830408#comment-15830408 ] Robert Metzger commented on FLINK-5459: --- Event time debugging has been addressed in FLINK-

[jira] [Commented] (FLINK-5555) Add documentation about debugging watermarks

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

[GitHub] flink pull request #3170: [FLINK-5555] Document how to debug event time usin...

2017-01-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3170 --- 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-5555) Add documentation about debugging watermarks

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

[GitHub] flink issue #3170: [FLINK-5555] Document how to debug event time using water...

2017-01-19 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/3170 Thanks a lot for the quick review. I'll merge it. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this

[jira] [Commented] (FLINK-5355) Handle AmazonKinesisException gracefully in Kinesis Streaming Connector

2017-01-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15830326#comment-15830326 ] ASF GitHub Bot commented on FLINK-5355: --- Github user skidder commented on the issue:

[GitHub] flink issue #3078: [FLINK-5355] Handle AmazonKinesisException gracefully in ...

2017-01-19 Thread skidder
Github user skidder commented on the issue: https://github.com/apache/flink/pull/3078 Thank you @tzulitai for the feedback on the styling! I've pushed a commit that addresses your comments. --- If your project is set up for it, you can reply to this email and have your reply appear

[jira] [Commented] (FLINK-5452) Make table unit tests pass under cluster mode

2017-01-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15830287#comment-15830287 ] ASF GitHub Bot commented on FLINK-5452: --- Github user fhueske commented on the issue:

[GitHub] flink issue #3095: [FLINK-5452] [table] Fix SortITCase which will fail under...

2017-01-19 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3095 Thanks for fixing the tests @KurtYoung! +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

  1   2   3   >