[jira] [Created] (FLINK-5500) Error when created array literals

2017-01-16 Thread Yuhong Hong (JIRA)
Yuhong Hong created FLINK-5500: -- Summary: Error when created array literals Key: FLINK-5500 URL: https://issues.apache.org/jira/browse/FLINK-5500 Project: Flink Issue Type: Bug Compon

[jira] [Commented] (FLINK-4988) Elasticsearch 5.x support

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

[GitHub] flink issue #3112: [FLINK-4988] [elasticsearch] Add Elasticsearch 5.x Connec...

2017-01-16 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3112 Hi @rmetzger, I've addressed your review comments. I still have some problems however, on the following: 1. I can't really reproduce the problem with the conflicts in `META-INF/services` de

[GitHub] flink issue #3068: [FLINK-5380] Fix task metrics reuse for single-operator c...

2017-01-16 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3068 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 fea

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

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

[jira] [Commented] (FLINK-5110) Remove the AbstractAlignedProcessingTimeWindowOperator.

2017-01-16 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823661#comment-15823661 ] Kostas Kloudas commented on FLINK-5110: --- Instead of deleting these operators, we exp

[GitHub] flink issue #3106: [FLINK-5118] Fix inconsistent numBytesIn/Out metrics

2017-01-16 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3106 The code checks for null since there is no *technical* contract that the returned value is null. They aren't strictly necessary, and are only meant to guard against programming errors in the metrics s

[jira] [Closed] (FLINK-5110) Remove the AbstractAlignedProcessingTimeWindowOperator.

2017-01-16 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-5110. - Resolution: Invalid > Remove the AbstractAlignedProcessingTimeWindowOperator. > --

[jira] [Commented] (FLINK-5118) Inconsistent records sent/received metrics

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

[jira] [Commented] (FLINK-5500) Error when created array literals

2017-01-16 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823670#comment-15823670 ] Jark Wu commented on FLINK-5500: Hi [~Yuhong_kyo] , sorry, I can't reproduce your errors

[GitHub] flink pull request #3125: [FLINK-5499][JobManager]Reuse the resource locatio...

2017-01-16 Thread wangzhijiang999
GitHub user wangzhijiang999 opened a pull request: https://github.com/apache/flink/pull/3125 [FLINK-5499][JobManager]Reuse the resource location of prior executio… Currently when schedule execution to request to allocate slot from **SlotPool**, the **TaskManagerLocation** paramete

[jira] [Commented] (FLINK-5499) Try to reuse the resource location of prior execution attempt in allocating slot

2017-01-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823681#comment-15823681 ] ASF GitHub Bot commented on FLINK-5499: --- GitHub user wangzhijiang999 opened a pull r

[jira] [Created] (FLINK-5501) Determine whether the job starts from last JobManager failure

2017-01-16 Thread Zhijiang Wang (JIRA)
Zhijiang Wang created FLINK-5501: Summary: Determine whether the job starts from last JobManager failure Key: FLINK-5501 URL: https://issues.apache.org/jira/browse/FLINK-5501 Project: Flink

[jira] [Assigned] (FLINK-5501) Determine whether the job starts from last JobManager failure

2017-01-16 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang reassigned FLINK-5501: Assignee: Zhijiang Wang > Determine whether the job starts from last JobManager failure > -

[GitHub] flink issue #3112: [FLINK-4988] [elasticsearch] Add Elasticsearch 5.x Connec...

2017-01-16 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/3112 Gordon and I had a quick offline chat about this and decided the following: 1. We'll use the `ServiceResourceTransformer` because that's the correct way of solving the problem 2. There is a l

[jira] [Commented] (FLINK-4988) Elasticsearch 5.x support

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

[GitHub] flink issue #3081: [FLINK-5426] Clean up the Flink Machine Learning library

2017-01-16 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3081 Changes look good to me. Thanks a lot for your contributions @Fokko. Merging this PR. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as w

[jira] [Commented] (FLINK-5426) Clean up the Flink Machine Learning library

2017-01-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823731#comment-15823731 ] ASF GitHub Bot commented on FLINK-5426: --- Github user tillrohrmann commented on the i

[GitHub] flink pull request #3126: [FLINK-5447] [table] Sync documentation of built-i...

2017-01-16 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/3126 [FLINK-5447] [table] Sync documentation of built-in functions for Table API with SQL This PR restructures the documentation of built-in functions. It ensures: - All supported functions are

[jira] [Commented] (FLINK-5447) Sync documentation of built-in functions for Table API with SQL

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

[jira] [Created] (FLINK-5502) Add documentation about migrating from 1.1 to 1.2

2017-01-16 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5502: - Summary: Add documentation about migrating from 1.1 to 1.2 Key: FLINK-5502 URL: https://issues.apache.org/jira/browse/FLINK-5502 Project: Flink Issue Type:

[jira] [Updated] (FLINK-5502) Add documentation about migrating functions from 1.1 to 1.2

2017-01-16 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-5502: -- Summary: Add documentation about migrating functions from 1.1 to 1.2 (was: Add documentation ab

[jira] [Updated] (FLINK-5501) Determine whether the job starts from last JobManager failure

2017-01-16 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang updated FLINK-5501: - Description: When the {{JobManagerRunner}} grants leadership, it should check whether the current

[jira] [Updated] (FLINK-5501) Determine whether the job starts from last JobManager failure

2017-01-16 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang updated FLINK-5501: - Description: When the {{JobManagerRunner}} grants leadership, it should check whether the current

[GitHub] flink issue #3109: [FLINK-5329] Fix metric list being cut off

2017-01-16 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/3109 +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 enabled and wishes so, or if th

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

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

[jira] [Commented] (FLINK-5500) Error when created array literals

2017-01-16 Thread Yuhong Hong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823750#comment-15823750 ] Yuhong Hong commented on FLINK-5500: Yes, i'm using the latest calcite, but i test wit

[jira] [Commented] (FLINK-4692) Add tumbling group-windows for batch tables

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

[GitHub] flink issue #2938: [FLINK-4692] [tableApi] Add tumbling group-windows for ba...

2017-01-16 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/2938 Thanks for the update @wuchong. I will test it again and 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

[jira] [Commented] (FLINK-5502) Add documentation about migrating functions from 1.1 to 1.2

2017-01-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823757#comment-15823757 ] Stephan Ewen commented on FLINK-5502: - Can you record this as a sub-issue of the paren

[jira] [Commented] (FLINK-5456) Add docs about new state and checkpointing interfaces

2017-01-16 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823766#comment-15823766 ] Nico Kruber commented on FLINK-5456: Looks like some of the existing documentation got

[jira] [Commented] (FLINK-5423) Implement Stochastic Outlier Selection

2017-01-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823772#comment-15823772 ] ASF GitHub Bot commented on FLINK-5423: --- Github user tillrohrmann commented on a dif

[GitHub] flink issue #3109: [FLINK-5329] Fix metric list being cut off

2017-01-16 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3109 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 fea

[GitHub] flink pull request #3077: [FLINK-5423] Implement Stochastic Outlier Selectio...

2017-01-16 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3077#discussion_r96202871 --- Diff: flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/outlier/StochasticOutlierSelection.scala --- @@ -0,0 +1,367 @@ +/* + * Lic

[jira] [Commented] (FLINK-5423) Implement Stochastic Outlier Selection

2017-01-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823771#comment-15823771 ] ASF GitHub Bot commented on FLINK-5423: --- Github user tillrohrmann commented on a dif

[jira] [Resolved] (FLINK-5457) Create documentation for Asynchronous I/O

2017-01-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5457. - Resolution: Fixed Assignee: Stephan Ewen Done in - 1.2.0 via f4869a66d10468b804908dfe25641

[jira] [Closed] (FLINK-5457) Create documentation for Asynchronous I/O

2017-01-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5457. --- > Create documentation for Asynchronous I/O > - > >

[GitHub] flink pull request #3077: [FLINK-5423] Implement Stochastic Outlier Selectio...

2017-01-16 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3077#discussion_r96202060 --- Diff: flink-libraries/flink-ml/src/test/scala/org/apache/flink/ml/outlier/StochasticOutlierSelectionITSuite.scala --- @@ -0,0 +1,240 @@ +/*

[jira] [Commented] (FLINK-5423) Implement Stochastic Outlier Selection

2017-01-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823773#comment-15823773 ] ASF GitHub Bot commented on FLINK-5423: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #3077: [FLINK-5423] Implement Stochastic Outlier Selectio...

2017-01-16 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3077#discussion_r96202972 --- Diff: flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/outlier/StochasticOutlierSelection.scala --- @@ -0,0 +1,367 @@ +/* + * Lic

[jira] [Commented] (FLINK-5423) Implement Stochastic Outlier Selection

2017-01-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823774#comment-15823774 ] ASF GitHub Bot commented on FLINK-5423: --- Github user tillrohrmann commented on a dif

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

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

[GitHub] flink pull request #3077: [FLINK-5423] Implement Stochastic Outlier Selectio...

2017-01-16 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3077#discussion_r96203398 --- Diff: flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/outlier/StochasticOutlierSelection.scala --- @@ -0,0 +1,367 @@ +/* + * Lic

[GitHub] flink issue #3077: [FLINK-5423] Implement Stochastic Outlier Selection

2017-01-16 Thread Fokko
Github user Fokko commented on the issue: https://github.com/apache/flink/pull/3077 Thanks @tillrohrmann, excellent idea regarding the documentation. I'll also process the code comments, good feedback. Somewhere today or tomorrow I will fix this. Cheers, Fokko --- If your p

[jira] [Updated] (FLINK-5498) Fix JoinITCase and add support for filter expressions on the On clause in left/right outer joins

2017-01-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5498: - Priority: Critical (was: Major) > Fix JoinITCase and add support for filter expressions on the On

[jira] [Commented] (FLINK-5423) Implement Stochastic Outlier Selection

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

[jira] [Updated] (FLINK-5498) Fix JoinITCase and add support for filter expressions on the On clause in left/right outer joins

2017-01-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5498: - Affects Version/s: 1.3.0 1.2.0 > Fix JoinITCase and add support for filter

[jira] [Commented] (FLINK-5498) Fix JoinITCase and add support for filter expressions on the On clause in left/right outer joins

2017-01-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823786#comment-15823786 ] Fabian Hueske commented on FLINK-5498: -- Thanks for reporting this issue, [~lincoln.86

[jira] [Updated] (FLINK-5498) Fix JoinITCase and add support for filter expressions on the On clause in left/right outer joins

2017-01-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5498: - Description: I found the expected result of a unit test case incorrect compare to that in a RDMBS

[jira] [Updated] (FLINK-5498) OuterJoins with non-equality predicates compute wrong results

2017-01-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5498: - Summary: OuterJoins with non-equality predicates compute wrong results (was: Fix JoinITCase and a

[GitHub] flink pull request #3127: [FLINK-5481] Add type extraction from collection

2017-01-16 Thread tonycox
GitHub user tonycox opened a pull request: https://github.com/apache/flink/pull/3127 [FLINK-5481] Add type extraction from collection Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If your chan

[jira] [Commented] (FLINK-5481) Cannot create Collection of Row

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

[jira] [Created] (FLINK-5503) mesos-appmaster.sh script could print return value message

2017-01-16 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-5503: Summary: mesos-appmaster.sh script could print return value message Key: FLINK-5503 URL: https://issues.apache.org/jira/browse/FLINK-5503 Project: Flink Issu

[GitHub] flink pull request #2938: [FLINK-4692] [tableApi] Add tumbling group-windows...

2017-01-16 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2938 --- 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-4692) Add tumbling group-windows for batch tables

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

[jira] [Created] (FLINK-5504) mesos-appmaster.sh logs to wrong directory

2017-01-16 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-5504: Summary: mesos-appmaster.sh logs to wrong directory Key: FLINK-5504 URL: https://issues.apache.org/jira/browse/FLINK-5504 Project: Flink Issue Type: Bug

[jira] [Resolved] (FLINK-4692) Add tumbling group-windows for batch tables

2017-01-16 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-4692. - Resolution: Fixed Fix Version/s: 1.3.0 Fixed in 1.3.0: 88576a0eebafde06fe63688d9c4c07ea67fb

[jira] [Commented] (FLINK-5500) Error when created array literals

2017-01-16 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823805#comment-15823805 ] Jark Wu commented on FLINK-5500: Yes. I have noticed the problems when upgrading Calcite.

[jira] [Created] (FLINK-5505) Rename recovery.zookeeper.path.mesos-workers into high-availability.zookeeper.path.mesos-workers

2017-01-16 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-5505: Summary: Rename recovery.zookeeper.path.mesos-workers into high-availability.zookeeper.path.mesos-workers Key: FLINK-5505 URL: https://issues.apache.org/jira/browse/FLINK-5505

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

2017-01-16 Thread ramkrishna.s.vasudevan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823811#comment-15823811 ] ramkrishna.s.vasudevan commented on FLINK-2168: --- Few questions on the packag

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

2017-01-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823818#comment-15823818 ] Fabian Hueske commented on FLINK-2168: -- TableSources should go into the respective co

[jira] [Created] (FLINK-5506) Java 8 - CommunityDetection.java:158 - java.lang.NullPointerException

2017-01-16 Thread Miguel Carvalho Valente Esaguy Coimbra (JIRA)
Miguel Carvalho Valente Esaguy Coimbra created FLINK-5506: - Summary: Java 8 - CommunityDetection.java:158 - java.lang.NullPointerException Key: FLINK-5506 URL: https://issues.apache.org/jir

[jira] [Updated] (FLINK-5506) Java 8 - CommunityDetection.java:158 - java.lang.NullPointerException

2017-01-16 Thread Miguel Carvalho Valente Esaguy Coimbra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Miguel Carvalho Valente Esaguy Coimbra updated FLINK-5506: -- Description: Reporting this here as per Vasia's

[jira] [Updated] (FLINK-5506) Java 8 - CommunityDetection.java:158 - java.lang.NullPointerException

2017-01-16 Thread Miguel Carvalho Valente Esaguy Coimbra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Miguel Carvalho Valente Esaguy Coimbra updated FLINK-5506: -- Description: Reporting this here as per Vasia's

[jira] [Updated] (FLINK-5506) Java 8 - CommunityDetection.java:158 - java.lang.NullPointerException

2017-01-16 Thread Miguel Carvalho Valente Esaguy Coimbra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Miguel Carvalho Valente Esaguy Coimbra updated FLINK-5506: -- Description: Reporting this here as per Vasia's

[jira] [Updated] (FLINK-5506) Java 8 - CommunityDetection.java:158 - java.lang.NullPointerException

2017-01-16 Thread Miguel Carvalho Valente Esaguy Coimbra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Miguel Carvalho Valente Esaguy Coimbra updated FLINK-5506: -- Description: Reporting this here as per Vasia's

[GitHub] flink issue #3089: [FLINK-5497] remove duplicated tests

2017-01-16 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3089 Thanks you for the effort to increase testing performance. I think we have to look very closely here, because it may easily decrease the test coverage. I think there were subtle differen

[jira] [Updated] (FLINK-5506) Java 8 - CommunityDetection.java:158 - java.lang.NullPointerException

2017-01-16 Thread Miguel Carvalho Valente Esaguy Coimbra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Miguel Carvalho Valente Esaguy Coimbra updated FLINK-5506: -- Description: Reporting this here as per Vasia's

[jira] [Updated] (FLINK-5506) Java 8 - CommunityDetection.java:158 - java.lang.NullPointerException

2017-01-16 Thread Miguel Carvalho Valente Esaguy Coimbra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Miguel Carvalho Valente Esaguy Coimbra updated FLINK-5506: -- Description: Reporting this here as per Vasia's

[jira] [Commented] (FLINK-5497) remove duplicated tests

2017-01-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823826#comment-15823826 ] ASF GitHub Bot commented on FLINK-5497: --- Github user StephanEwen commented on the is

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

2017-01-16 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/2983 @sunjincheng121 I have merged #2938. You can update this 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 h

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

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

[jira] [Commented] (FLINK-5426) Clean up the Flink Machine Learning library

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

[jira] [Resolved] (FLINK-5426) Clean up the Flink Machine Learning library

2017-01-16 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-5426. -- Resolution: Fixed Fixed via 1753b1d25b4d943c1ffbe7c3fb40e56b840c4f7d > Clean up the Flink Machi

[GitHub] flink pull request #3081: [FLINK-5426] Clean up the Flink Machine Learning l...

2017-01-16 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3081 --- 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] [Updated] (FLINK-4959) Write Documentation for ProcessFunction

2017-01-16 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4959: -- Priority: Critical (was: Blocker) > Write Documentation for ProcessFunction > -

[jira] [Updated] (FLINK-4959) Write Documentation for ProcessFunction

2017-01-16 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4959: -- Issue Type: Sub-task (was: Improvement) Parent: FLINK-5430 > Write Documentation for Pr

[jira] [Created] (FLINK-5507) remove queryable list state sink

2017-01-16 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-5507: -- Summary: remove queryable list state sink Key: FLINK-5507 URL: https://issues.apache.org/jira/browse/FLINK-5507 Project: Flink Issue Type: Improvement

[GitHub] flink pull request #3037: Flink-4450 update storm version to 1.0

2017-01-16 Thread liuyuzhong7
Github user liuyuzhong7 commented on a diff in the pull request: https://github.com/apache/flink/pull/3037#discussion_r96218769 --- Diff: flink-contrib/flink-storm/src/test/java/org/apache/flink/storm/wrappers/WrapperSetupHelperTest.java --- @@ -186,15 +186,15 @@ public void testC

[jira] [Commented] (FLINK-5464) MetricQueryService throws NullPointerException on JobManager

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

[GitHub] flink pull request #3128: [FLINK-5464] Improve MetricDumpSerialization error...

2017-01-16 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/3128 [FLINK-5464] Improve MetricDumpSerialization error handling Rework of #3103. The key change introduced in the previous PR remains; if a gauge returns null it is not serialized. Howe

[GitHub] flink issue #3089: [FLINK-5497] remove duplicated tests

2017-01-16 Thread xhumanoid
Github user xhumanoid commented on the issue: https://github.com/apache/flink/pull/3089 @StephanEwen Hi, I did check more than double time This two part of code fully equals: ```java Tuple2 record; final Tuple2 recordReuse = new Tuple2<>(); if (re

[jira] [Commented] (FLINK-5497) remove duplicated tests

2017-01-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823884#comment-15823884 ] ASF GitHub Bot commented on FLINK-5497: --- Github user xhumanoid commented on the issu

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

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

[GitHub] flink issue #3121: [FLINK-5434] Remove unsupported project() transformation ...

2017-01-16 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3121 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 fea

[jira] [Commented] (FLINK-5507) remove queryable list state sink

2017-01-16 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823895#comment-15823895 ] Ufuk Celebi commented on FLINK-5507: +1 Would you like to do that and open a PR? > r

[jira] [Commented] (FLINK-5461) Remove Superflous TypeInformation Declaration

2017-01-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823900#comment-15823900 ] ASF GitHub Bot commented on FLINK-5461: --- Github user StephanEwen commented on the is

[GitHub] flink issue #3096: [FLINK-5461] [gelly] Remove Superflous TypeInformation De...

2017-01-16 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3096 Looks good, thanks. +1 to merge 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 fe

[GitHub] flink pull request #3037: Flink-4450 update storm version to 1.0

2017-01-16 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/3037#discussion_r96221118 --- Diff: flink-contrib/flink-storm/src/test/java/org/apache/flink/storm/wrappers/WrapperSetupHelperTest.java --- @@ -186,15 +186,15 @@ public void testC

[jira] [Commented] (FLINK-5480) User-provided hashes for operators

2017-01-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823902#comment-15823902 ] ASF GitHub Bot commented on FLINK-5480: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #3117: [FLINK-5480] Introduce user-provided hash for JobV...

2017-01-16 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3117#discussion_r96220999 --- Diff: flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java --- @@ -95,6 +95,28 @@ p

[GitHub] flink issue #3037: Flink-4450 update storm version to 1.0

2017-01-16 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3037 Discussions have been resolved, thanks! Merging this... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project do

[GitHub] flink issue #3087: [FLINK-4917] Deprecate "CheckpointedAsynchronously" inter...

2017-01-16 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3087 I think this needs to also talk about the asynchrony, and the short cut replacement via `ListCheckpointed` etc. --- If your project is set up for it, you can reply to this email and have your re

[GitHub] flink issue #3092: [FLINK-5419] Make full TM metrics available through REST ...

2017-01-16 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3092 +1 to merge this Looks like the web UI files need to be rebuilt when merging this... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHu

[jira] [Commented] (FLINK-5480) User-provided hashes for operators

2017-01-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823913#comment-15823913 ] ASF GitHub Bot commented on FLINK-5480: --- Github user zentol commented on a diff in t

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

2017-01-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823912#comment-15823912 ] ASF GitHub Bot commented on FLINK-5419: --- Github user StephanEwen commented on the is

[GitHub] flink issue #3097: [FLINK-5448] Fix typo in StateAssignmentOperation Excepti...

2017-01-16 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3097 Thanks for this fix! 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 enab

[GitHub] flink pull request #3117: [FLINK-5480] Introduce user-provided hash for JobV...

2017-01-16 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3117#discussion_r96222455 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/graph/StreamingJobGraphGeneratorNodeHashTest.java --- @@ -422,6 +425,43 @@ public void

[jira] [Commented] (FLINK-4917) Deprecate "CheckpointedAsynchronously" interface

2017-01-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823911#comment-15823911 ] ASF GitHub Bot commented on FLINK-4917: --- Github user StephanEwen commented on the is

[jira] [Commented] (FLINK-5448) Fix typo in StateAssignmentOperation Exception

2017-01-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823914#comment-15823914 ] ASF GitHub Bot commented on FLINK-5448: --- Github user StephanEwen commented on the is

  1   2   3   4   >