[GitHub] flink pull request #3858: [FLINK-6513][docs] cleaned up some typos and gramm...

2017-05-09 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/3858#discussion_r115538538 --- Diff: docs/dev/best_practices.md --- @@ -31,13 +31,13 @@ This page contains a collection of best practices for Flink programmers on how t ##

[GitHub] flink pull request #3858: [FLINK-6513][docs] cleaned up some typos and gramm...

2017-05-09 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/3858#discussion_r115543214 --- Diff: docs/dev/best_practices.md --- @@ -284,30 +284,30 @@ Change your projects `pom.xml` file like this: The following changes were done in

[GitHub] flink pull request #3858: [FLINK-6513][docs] cleaned up some typos and gramm...

2017-05-09 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/3858#discussion_r115544603 --- Diff: docs/dev/stream/checkpointing.md --- @@ -124,8 +124,8 @@ env.getCheckpointConfig.setMaxConcurrentCheckpoints(1) ## Selecting a State

[jira] [Commented] (FLINK-6513) various typos and grammatical flaws

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

[GitHub] flink pull request #3858: [FLINK-6513][docs] cleaned up some typos and gramm...

2017-05-09 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/3858#discussion_r115541319 --- Diff: docs/dev/best_practices.md --- @@ -31,13 +31,13 @@ This page contains a collection of best practices for Flink programmers on how t ##

[GitHub] flink issue #3669: [FLINK-6215] Make the StatefulSequenceSource scalable.

2017-05-09 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3669 @kl0u how important is this for 1.3? --- 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-6273) Client can't connect to jobmanager whose hostname contains capital letters

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

[jira] [Created] (FLINK-6513) various typos and grammatical flaws

2017-05-09 Thread David Anderson (JIRA)
David Anderson created FLINK-6513: - Summary: various typos and grammatical flaws Key: FLINK-6513 URL: https://issues.apache.org/jira/browse/FLINK-6513 Project: Flink Issue Type: Improvement

[GitHub] flink issue #3831: [FLINK-5978][FLINK-6459][FLINK-6461] Move web-related con...

2017-05-09 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3831 Will this also be merged to 1.3.0? If not, 1.4 will need to replace and deprecate `JOB_MANAGER_WEB_ACCESS_CONTROL_ALLOW_ORIGIN`. --- If your project is set up for it, you can reply to this email

[jira] [Commented] (FLINK-6479) Fix IndexOutOfBoundsException bug

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

[jira] [Commented] (FLINK-6486) Pass RowTypeInfo to CodeGenerator instead of CRowTypeInfo

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

[jira] [Commented] (FLINK-6215) Make the StatefulSequenceSource scalable.

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

[jira] [Commented] (FLINK-6513) various typos and grammatical flaws

2017-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16002920#comment-16002920 ] ASF GitHub Bot commented on FLINK-6513: --- GitHub user alpinegizmo opened a pull request:

[jira] [Created] (FLINK-6515) KafkaConsumer checkpointing fails because of ClassLoader issues

2017-05-09 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-6515: --- Summary: KafkaConsumer checkpointing fails because of ClassLoader issues Key: FLINK-6515 URL: https://issues.apache.org/jira/browse/FLINK-6515 Project: Flink

[GitHub] flink issue #3669: [FLINK-6215] Make the StatefulSequenceSource scalable.

2017-05-09 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/3669 @greghogan Not sure. In my understanding that was made for testing (this is why the old implementation was not efficient) but there may be also some more serious users. Any comments @aljoscha ? ---

[GitHub] flink issue #3751: [FLINK-6330] [docs] Add basic Docker, K8s docs

2017-05-09 Thread patricklucas
Github user patricklucas commented on the issue: https://github.com/apache/flink/pull/3751 @greghogan we're waiting patiently for @tianon to complete his review of docker-library/official-images#2895. :) As far as I know, we've done everything we need to do to get the images

[jira] [Commented] (FLINK-6514) Cannot start Flink Cluster in standalone mode

2017-05-09 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16002949#comment-16002949 ] Aljoscha Krettek commented on FLINK-6514: - Proposed solution (that has other possible

[jira] [Created] (FLINK-6514) Cannot start Flink Cluster in standalone mode

2017-05-09 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-6514: --- Summary: Cannot start Flink Cluster in standalone mode Key: FLINK-6514 URL: https://issues.apache.org/jira/browse/FLINK-6514 Project: Flink Issue

[jira] [Commented] (FLINK-6512) some code examples are poorly formatted

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

[jira] [Closed] (FLINK-6486) Pass RowTypeInfo to CodeGenerator instead of CRowTypeInfo

2017-05-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6486. Resolution: Done Fix Version/s: 1.4.0 1.3.0 Done for 1.3

[jira] [Closed] (FLINK-6476) Table environment register row data stream

2017-05-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6476. Resolution: Implemented Fix Version/s: 1.4.0 1.3.0 Implemented for 1.3

[GitHub] flink issue #3830: Optimize aggregate function get type

2017-05-09 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3830 Is there a [JIRA](https://issues.apache.org/jira/browse/FLINK) associated with this PR? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Commented] (FLINK-6330) Improve Docker documentation

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

[jira] [Commented] (FLINK-6472) BoundedOutOfOrdernessTimestampExtractor does not bound out of orderliness

2017-05-09 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16002961#comment-16002961 ] Elias Levy commented on FLINK-6472: --- Ideally Flink would make available an abstract class similar to

[GitHub] flink pull request #3857: [FLINK-6512][docs] improved code formatting in som...

2017-05-09 Thread alpinegizmo
GitHub user alpinegizmo opened a pull request: https://github.com/apache/flink/pull/3857 [FLINK-6512][docs] improved code formatting in some examples Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration.

[GitHub] flink issue #3751: [FLINK-6330] [docs] Add basic Docker, K8s docs

2017-05-09 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3751 @patricklucas when will the link be available? It would be great to have this merged for 1.3. --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-6330) Improve Docker documentation

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

[jira] [Commented] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

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

[GitHub] flink pull request #3673: [FLINK-5256] Extend DataSetSingleRowJoin to suppor...

2017-05-09 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3673#discussion_r115536343 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetSingleRowJoin.scala --- @@ -138,33 +144,60 @@ class

[GitHub] flink pull request #3673: [FLINK-5256] Extend DataSetSingleRowJoin to suppor...

2017-05-09 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3673#discussion_r115536596 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/batch/sql/DataSetSingleRowJoinTest.scala --- @@ -187,9 +187,155 @@

[jira] [Commented] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

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

[GitHub] flink pull request #3673: [FLINK-5256] Extend DataSetSingleRowJoin to suppor...

2017-05-09 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3673#discussion_r115536870 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/batch/sql/DataSetSingleRowJoinTest.scala --- @@ -187,9 +187,155 @@

[jira] [Commented] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

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

[jira] [Commented] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

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

[GitHub] flink pull request #3673: [FLINK-5256] Extend DataSetSingleRowJoin to suppor...

2017-05-09 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3673#discussion_r115535989 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/MapJoinLeftRunner.scala --- @@ -31,7 +32,19 @@ class

[jira] [Commented] (FLINK-6303) Documentation support build in docker on OSX

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

[jira] [Commented] (FLINK-6215) Make the StatefulSequenceSource scalable.

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

[GitHub] flink issue #3831: [FLINK-5978][FLINK-6459][FLINK-6461] Move web-related con...

2017-05-09 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3831 Good point, Ill merge the access-control-origin commit to 1.3 as well. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project

[jira] [Commented] (FLINK-5978) JM WebFrontend address ConfigOption is defined in ConfigConstants

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

[jira] [Commented] (FLINK-5978) JM WebFrontend address ConfigOption is defined in ConfigConstants

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

[GitHub] flink issue #3831: [FLINK-5978][FLINK-6459][FLINK-6461] Move web-related con...

2017-05-09 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3831 I guess this also means i now have to worry about hte order in which i merge things to the branches, urgh. --- If your project is set up for it, you can reply to this email and have your reply

[GitHub] flink issue #3858: [FLINK-6513][docs] cleaned up some typos and grammatical ...

2017-05-09 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3858 +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

[jira] [Commented] (FLINK-6513) various typos and grammatical flaws

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

[jira] [Commented] (FLINK-6436) Bug in CommonCorrelate's generateCollector method when using udtf with udf

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

[GitHub] flink pull request #3841: [FLINK-6479][table]Fix IndexOutOfBoundsException b...

2017-05-09 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3841 --- 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-6476) Table environment register row data stream

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

[GitHub] flink issue #3719: [FLINK-6303] Documentation support build in docker on OSX

2017-05-09 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3719 @mtunique please manually close this PR since it is subsumed by #3751. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your

[jira] [Commented] (FLINK-6468) release 1.2.1 tag in git

2017-05-09 Thread Petr Novotnik (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16002143#comment-16002143 ] Petr Novotnik commented on FLINK-6468: -- Thank you! > release 1.2.1 tag in git >

[jira] [Created] (FLINK-6502) Support writing data in DataSet to ElasticSearch

2017-05-09 Thread wyp (JIRA)
wyp created FLINK-6502: -- Summary: Support writing data in DataSet to ElasticSearch Key: FLINK-6502 URL: https://issues.apache.org/jira/browse/FLINK-6502 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-6476) Table environment register row data stream

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

[GitHub] flink issue #3849: [FLINK-6476] - Table environment register row data stream

2017-05-09 Thread rtudoran
Github user rtudoran commented on the issue: https://github.com/apache/flink/pull/3849 @fhueske thanks for the review. I will have make another pass and resubmit 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

[jira] [Commented] (FLINK-6500) RowSerialization problem

2017-05-09 Thread radu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16002131#comment-16002131 ] radu commented on FLINK-6500: - [~fhueske] Thanks for the info. Considering the workaround - should i close

[jira] [Updated] (FLINK-5070) Unable to use Scala's BeanProperty with classes

2017-05-09 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-5070: -- Fix Version/s: 1.4.0 1.3.0 > Unable to use Scala's BeanProperty with classes >

[jira] [Commented] (FLINK-5070) Unable to use Scala's BeanProperty with classes

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

[jira] [Commented] (FLINK-6157) Make TypeInformation fully serializable

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

[GitHub] flink issue #3736: [FLINK-6013][metrics] Add Datadog HTTP metrics reporter

2017-05-09 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3736 @zentol @StephanEwen why not also merge this into 1.3? There are literally no modified or removed lines of code. --- If your project is set up for it, you can reply to this email and have your

[jira] [Commented] (FLINK-6013) Add Datadog HTTP metrics reporter

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

[GitHub] flink issue #2742: [FLINK-4944] Replace Akka's death watch with own heartbea...

2017-05-09 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2742 @StephanEwen @tillrohrmann is this ready for 1.3? --- 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-4944) Replace Akka's death watch with own heartbeat on the TM side

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

[GitHub] flink issue #2705: [FLINK-2597][FLINK-4050] Add wrappers for Kafka serialize...

2017-05-09 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2705 @rmetzger is this feature still desired for a rebase and review? --- 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 #2422: FLINK-4499: [WIP] Introduce findbugs maven plugin

2017-05-09 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2422 @smarthi are you still able to work on this PR? We could enable in a profile when `TRAVIS_EVENT_TYPE=cron` is set in the [environment](https://docs.travis-ci.com/user/environment-variables/).

[GitHub] flink pull request #3318: [FLINK-5070] [types] Unable to use Scala's BeanPro...

2017-05-09 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3318 --- 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-6157) Make TypeInformation fully serializable

2017-05-09 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-6157. - Resolution: Implemented master: 6cf4a93ebbf36f6c1dd4cc2c9b17dd58880c17c2 release-1.3:

[jira] [Closed] (FLINK-5070) Unable to use Scala's BeanProperty with classes

2017-05-09 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-5070. - Resolution: Fixed master: c90b6da5ff845e55c52150a3c6f0b7192959a40e release-1.3:

[jira] [Updated] (FLINK-6157) Make TypeInformation fully serializable

2017-05-09 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-6157: -- Fix Version/s: 1.4.0 1.3.0 > Make TypeInformation fully serializable >

[jira] [Closed] (FLINK-5069) Pending checkpoint statistics gauge

2017-05-09 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5069. --- Resolution: Fixed > Pending checkpoint statistics gauge > ---

[GitHub] flink pull request #3619: [FLINK-6157] [core] Make TypeInformation fully ser...

2017-05-09 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3619 --- 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-6303) Documentation support build in docker on OSX

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

[GitHub] flink pull request #3043: [FLINK-5392] flink-dist build failed when change s...

2017-05-09 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3043 --- 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 #2809: [FLINK-5069] [Metrics] Pending checkpoint statisti...

2017-05-09 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2809 --- 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-3758) Add possibility to register accumulators in custom triggers

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

[jira] [Commented] (FLINK-2814) DeltaIteration: DualInputPlanNode cannot be cast to SingleInputPlanNode

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

[GitHub] flink pull request #1944: Timer coalescing across keys and cleanup of unused...

2017-05-09 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1944 --- 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 #1979: [FLINK-3758] Add possibility to register accumulat...

2017-05-09 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1979 --- 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 #2029: [FLINK-2814] Fix for DualInputPlanNode cannot be c...

2017-05-09 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2029 --- 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-5069) Pending checkpoint statistics gauge

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

[jira] [Commented] (FLINK-5392) flink-dist build failed when change scala version to 2.11

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

[jira] [Commented] (FLINK-2597) Add a test for Avro-serialized Kafka messages

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

[jira] [Commented] (FLINK-4499) Introduce findbugs maven plugin

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

[GitHub] flink pull request #3719: [FLINK-6303] Documentation support build in docker...

2017-05-09 Thread mtunique
Github user mtunique closed the pull request at: https://github.com/apache/flink/pull/3719 --- 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 #1033: Add Scala version of GraphAlgorithm

2017-05-09 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1033 --- 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 #3627: Release 0.4 alpha.0

2017-05-09 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3627 --- 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-6397) MultipleProgramsTestBase does not reset ContextEnvironment

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

[jira] [Commented] (FLINK-6381) Unnecessary synchronizing object in BucketingSink

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

[jira] [Commented] (FLINK-6476) Table environment register row data stream

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

[jira] [Commented] (FLINK-4395) Eager processing of late arrivals in CEP operator

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

[jira] [Updated] (FLINK-6474) Potential loss of precision in 32 bit integer multiplication

2017-05-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6474: -- Fix Version/s: 1.3.0 > Potential loss of precision in 32 bit integer multiplication >

[jira] [Updated] (FLINK-6505) Proactively cleanup local FS for RocksDBKeyedStateBackend on startup

2017-05-09 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-6505: -- Description: In {{RocksDBKeyedStateBackend}}, the {{instanceBasePath}} is cleared on

[GitHub] flink pull request #2361: [FLINK-3318][cep] Add support for quantifiers to C...

2017-05-09 Thread mushketyk
Github user mushketyk closed the pull request at: https://github.com/apache/flink/pull/2361 --- 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 #2361: [FLINK-3318][cep] Add support for quantifiers to CEP's pa...

2017-05-09 Thread mushketyk
Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2361 Closed. --- 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

[GitHub] flink issue #3820: [FLINK-6381] [connector] Unnecessary synchronizing object...

2017-05-09 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/3820 Hi @zhangminglei ! I will have a look during this week. Sorry for the delay. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your

[jira] [Updated] (FLINK-6504) Lack of synchronization on materializedSstFiles in RocksDBKEyedStateBackend

2017-05-09 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-6504: -- Affects Version/s: 1.3.0 Component/s: State Backends, Checkpointing > Lack of

[jira] [Commented] (FLINK-6288) FlinkKafkaProducer's custom Partitioner is always invoked with number of partitions of default topic

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

[jira] [Assigned] (FLINK-6504) Lack of synchronization on materializedSstFiles in RocksDBKEyedStateBackend

2017-05-09 Thread Xiaogang Shi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiaogang Shi reassigned FLINK-6504: --- Assignee: Xiaogang Shi > Lack of synchronization on materializedSstFiles in

[GitHub] flink issue #2361: [FLINK-3318][cep] Add support for quantifiers to CEP's pa...

2017-05-09 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/2361 Hi @mushketyk could you close 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 have this feature enabled

[jira] [Created] (FLINK-6506) Some tests in flink-tests exceed memory the resources in containerized Travis builds

2017-05-09 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-6506: - Summary: Some tests in flink-tests exceed memory the resources in containerized Travis builds Key: FLINK-6506 URL: https://issues.apache.org/jira/browse/FLINK-6506

[jira] [Commented] (FLINK-6247) Build a jar-with-dependencies for flink-table and put it into ./opt

2017-05-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16002226#comment-16002226 ] Fabian Hueske commented on FLINK-6247: -- Hi [~xccui], thanks for reporting this. I agree, the examples

[jira] [Updated] (FLINK-6503) Refactor KinesisDataFetcher to separate concerns for shard discovery

2017-05-09 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6503: --- Description: Currently, shard discovery is done within the {{KinesisDataFetcher}} 's

[jira] [Created] (FLINK-6504) Lack of synchronization on materializedSstFiles in RocksDBKEyedStateBackend

2017-05-09 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-6504: - Summary: Lack of synchronization on materializedSstFiles in RocksDBKEyedStateBackend Key: FLINK-6504 URL: https://issues.apache.org/jira/browse/FLINK-6504 Project:

[jira] [Created] (FLINK-6505) Proactively cleanup local FS for RocksDBKeyedStateBackend on startup

2017-05-09 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-6505: - Summary: Proactively cleanup local FS for RocksDBKeyedStateBackend on startup Key: FLINK-6505 URL: https://issues.apache.org/jira/browse/FLINK-6505 Project: Flink

  1   2   3   >