[jira] [Updated] (FLINK-6457) Clean up ScalarFunction and TableFunction interface

2017-05-05 Thread Ruidong Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruidong Li updated FLINK-6457: -- Description: Motivation: Some methods in ScalarFunction and TableFunction are unnecessary, e.g toString

[jira] [Updated] (FLINK-6457) Clean up ScalarFunction and TableFunction interface

2017-05-05 Thread Ruidong Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruidong Li updated FLINK-6457: -- Description: Motivation: Some methods in ScalarFunction and TableFunction are unnecessary, e.g toString

[jira] [Updated] (FLINK-6457) Clean up ScalarFunction and TableFunction interface

2017-05-05 Thread Ruidong Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruidong Li updated FLINK-6457: -- Description: clean up ScalarFunction interface: Some methods in ScalarFunction and TableFunction are unn

[GitHub] flink issue #3793: flink-6033 Support UNNEST query in the stream SQL API

2017-05-05 Thread suez1224
Github user suez1224 commented on the issue: https://github.com/apache/flink/pull/3793 @twalthr , can you take a look when you have time? I have added the LogicalUnnestRule and unitest for batch as well. Thanks a lot. --- If your project is set up for it, you can reply to this emai

[jira] [Closed] (FLINK-6047) Add support for Retraction in Table API / SQL

2017-05-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6047. Resolution: Implemented Implemented for 1.3.0 > Add support for Retraction in Table API / SQL > ---

[jira] [Updated] (FLINK-6092) Implement and turn on retraction for table source

2017-05-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-6092: - Issue Type: New Feature (was: Sub-task) Parent: (was: FLINK-6047) > Implement and tur

[jira] [Updated] (FLINK-6094) Implement and turn on retraction for stream-stream inner join

2017-05-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-6094: - Issue Type: New Feature (was: Sub-task) Parent: (was: FLINK-6047) > Implement and tur

[jira] [Closed] (FLINK-5884) Integrate time indicators for Table API & SQL

2017-05-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-5884. Resolution: Implemented Implemented with 24bf61ceb332f2db2dc4bab624b73beffae1160a > Integrate time

[jira] [Commented] (FLINK-5884) Integrate time indicators for Table API & SQL

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

[GitHub] flink pull request #3808: [FLINK-5884] [table] Integrate time indicators for...

2017-05-05 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3808 --- 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] [Assigned] (FLINK-6221) Add Promethus support to metrics

2017-05-05 Thread Maximilian Bode (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Bode reassigned FLINK-6221: -- Assignee: Maximilian Bode > Add Promethus support to metrics >

[jira] [Commented] (FLINK-6221) Add Promethus support to metrics

2017-05-05 Thread Maximilian Bode (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999140#comment-15999140 ] Maximilian Bode commented on FLINK-6221: [~hadronzoo] if you don't mind I would li

[GitHub] flink issue #3525: [FLINK-6020]add a random integer suffix to blob key to av...

2017-05-05 Thread netguy204
Github user netguy204 commented on the issue: https://github.com/apache/flink/pull/3525 @StephanEwen Yes, I do have at least objects and classes being stored in a static context. Any easy example (that has also bitten me a few times) is the class cache that Avro maintains:

[jira] [Commented] (FLINK-6020) Blob Server cannot handle multiple job submits (with same content) parallelly

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

[GitHub] flink issue #3802: Add Evenly Graph Generator to Flink Gelly

2017-05-05 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3802 Am working on 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 does not have this feature enabled and

[jira] [Commented] (FLINK-6438) Expand docs home page a little

2017-05-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15998797#comment-15998797 ] ASF GitHub Bot commented on FLINK-6438: --- Github user greghogan commented on a diff i

[jira] [Commented] (FLINK-6438) Expand docs home page a little

2017-05-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15998796#comment-15998796 ] ASF GitHub Bot commented on FLINK-6438: --- Github user greghogan commented on a diff i

[GitHub] flink pull request #3823: [FLINK-6438] Added a few links to the docs home pa...

2017-05-05 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/3823#discussion_r115064578 --- Diff: docs/index.md --- @@ -33,9 +33,13 @@ Apache Flink is an open source platform for distributed stream and batch data pr - **Concepts**:

[GitHub] flink pull request #3823: [FLINK-6438] Added a few links to the docs home pa...

2017-05-05 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/3823#discussion_r115065489 --- Diff: docs/index.md --- @@ -33,9 +33,13 @@ Apache Flink is an open source platform for distributed stream and batch data pr - **Concepts**:

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

2017-05-05 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3831 I would think that default values in `ConfigConstants` should be deprecated as well, as they are generally subsumed by the corresponding `ConfigOption`. --- If your project is set up for it, you can

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

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

[GitHub] flink issue #3803: [FLINK-6394] [runtime] Respect object reuse configuration...

2017-05-05 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3803 Good catch and good changes. Thanks @KurtYoung +1 to merge these --- 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-6394) GroupCombine reuses instances even though object reuse is disabled

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

[jira] [Commented] (FLINK-6443) Add more doc links in concepts sections

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

[jira] [Commented] (FLINK-6447) AWS/EMR docs are out-of-date

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

[GitHub] flink issue #3822: [FLINK-6443] add more links to concepts docs

2017-05-05 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3822 I like these changes, +1 to merge them... --- 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 featur

[jira] [Commented] (FLINK-6438) Expand docs home page a little

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

[GitHub] flink issue #3828: [FLINK-6447] update aws/emr docs

2017-05-05 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3828 +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 feature enabled and wishes so,

[GitHub] flink issue #3823: [FLINK-6438] Added a few links to the docs home page ...

2017-05-05 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3823 I like these additional links. Since some of the links point for example to the blog of a company, would be good to get an opinion from someone else as well (who is not involved with dat

[jira] [Created] (FLINK-6467) Potential lack of synchronization w.r.t. newSstFiles in RocksDBKeyedStateBackend#releaseResources()

2017-05-05 Thread Ted Yu (JIRA)
Ted Yu created FLINK-6467: - Summary: Potential lack of synchronization w.r.t. newSstFiles in RocksDBKeyedStateBackend#releaseResources() Key: FLINK-6467 URL: https://issues.apache.org/jira/browse/FLINK-6467 P

[jira] [Closed] (FLINK-6463) Throw exception when NOT-NEXT is after OPTIONAL

2017-05-05 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-6463. - Resolution: Fixed Merged at 28ab737506aa53248de8f71eed0dcff87d7e6f40 > Throw exception when NOT-N

[jira] [Commented] (FLINK-6466) Build Hadoop 2.8.0 convenience binaries

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

[GitHub] flink pull request #3832: [FLINK-6466] [build] Build Hadoop 2.8.0 convenienc...

2017-05-05 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/3832 [FLINK-6466] [build] Build Hadoop 2.8.0 convenience binaries Add Hadoop 2.8 to the create_release_files.sh script and TravisCI test matrix. Hadoop updated the `httpclient` and `httpcore`

[jira] [Created] (FLINK-6466) Build Hadoop 2.8.0 convenience binaries

2017-05-05 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-6466: - Summary: Build Hadoop 2.8.0 convenience binaries Key: FLINK-6466 URL: https://issues.apache.org/jira/browse/FLINK-6466 Project: Flink Issue Type: New Feature

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

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

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

2017-05-05 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3831 +1 to merge for 1.3.0 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes s

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

2017-05-05 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3831 Are we also deprecating use of the default values in `ConfigConstants`? --- 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 proje

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

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

[jira] [Commented] (FLINK-6465) support FIRST_VALUE and LAST_VALUE on Table API & SQL

2017-05-05 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15998543#comment-15998543 ] Hequn Cheng commented on FLINK-6465: hi radu, Yes. Both first_value and last_value wil

[jira] [Closed] (FLINK-5924) Support asynchronous checkpointing of operator state

2017-05-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-5924. Resolution: Duplicate > Support asynchronous checkpointing of operator state > -

[jira] [Commented] (FLINK-5925) Clean up extracted RocksDB JNI library

2017-05-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15998526#comment-15998526 ] Till Rohrmann commented on FLINK-5925: -- Not sure whether this was addressed by any co

[jira] [Commented] (FLINK-5924) Support asynchronous checkpointing of operator state

2017-05-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15998523#comment-15998523 ] Till Rohrmann commented on FLINK-5924: -- I think I referred to the managed operator st

[jira] [Updated] (FLINK-6465) support FIRST_VALUE and LAST_VALUE on Table API & SQL

2017-05-05 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-6465: --- Description: support `FIRST_VALUE` and `LAST_VALUE` analytic functions > support FIRST_VALUE and LA

[jira] [Commented] (FLINK-5718) Handle JVM Fatal Exceptions in Tasks

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

[jira] [Commented] (FLINK-6465) support FIRST_VALUE and LAST_VALUE on Table API & SQL

2017-05-05 Thread radu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15998517#comment-15998517 ] radu commented on FLINK-6465: - How do you plan to implement this? Will you support retraction

[GitHub] flink issue #3811: [FLINK-5718] [core] TaskManagers exit the JVM on fatal ex...

2017-05-05 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3811 Only for PR which are opened against another branch than `master`. For `master` I can close it. Thanks again for your work. --- If your project is set up for it, you can reply to this email and

[jira] [Updated] (FLINK-6465) support FIRST_VALUE and LAST_VALUE on Table API & SQL

2017-05-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-6465: - Component/s: Tabe > support FIRST_VALUE and LAST_VALUE on Table API & SQL > --

[jira] [Assigned] (FLINK-6465) support FIRST_VALUE and LAST_VALUE on Table API & SQL

2017-05-05 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-6465: -- Assignee: Hequn Cheng > support FIRST_VALUE and LAST_VALUE on Table API & SQL > ---

[jira] [Created] (FLINK-6465) support FIRST_VALUE and LAST_VALUE on Table API & SQL

2017-05-05 Thread Hequn Cheng (JIRA)
Hequn Cheng created FLINK-6465: -- Summary: support FIRST_VALUE and LAST_VALUE on Table API & SQL Key: FLINK-6465 URL: https://issues.apache.org/jira/browse/FLINK-6465 Project: Flink Issue Type: N

[jira] [Commented] (FLINK-6375) Fix LongValue hashCode

2017-05-05 Thread Andrew Psaltis (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15998471#comment-15998471 ] Andrew Psaltis commented on FLINK-6375: --- [~greghogan] Go figure -- I picked it as it

[jira] [Commented] (FLINK-5778) Split FileStateHandle into fileName and basePath

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

[GitHub] flink issue #3442: [FLINK-5778] [savepoints] Add savepoint serializer with r...

2017-05-05 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3442 Are we gonna get this in 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 enabl

[jira] [Created] (FLINK-6464) Metric name is not stable

2017-05-05 Thread Andrey (JIRA)
Andrey created FLINK-6464: - Summary: Metric name is not stable Key: FLINK-6464 URL: https://issues.apache.org/jira/browse/FLINK-6464 Project: Flink Issue Type: Bug Affects Versions: 1.2.0

[jira] [Updated] (FLINK-6198) Update the documentation of the CEP library to include all the new features.

2017-05-05 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6198: -- Priority: Critical (was: Blocker) > Update the documentation of the CEP library to include all

[jira] [Commented] (FLINK-6364) Implement incremental checkpointing in RocksDBStateBackend

2017-05-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15998411#comment-15998411 ] ASF GitHub Bot commented on FLINK-6364: --- Github user StefanRRichter commented on the

[GitHub] flink issue #3801: [FLINK-6364] [checkpoints] Implement incremental checkpoi...

2017-05-05 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/3801 I merged your changes. Please close this PR and the JIRA. --- 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 n

[jira] [Commented] (FLINK-5718) Handle JVM Fatal Exceptions in Tasks

2017-05-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15998389#comment-15998389 ] ASF GitHub Bot commented on FLINK-5718: --- Github user zimmermatt commented on the iss

[GitHub] flink issue #3811: [FLINK-5718] [core] TaskManagers exit the JVM on fatal ex...

2017-05-05 Thread zimmermatt
Github user zimmermatt commented on the issue: https://github.com/apache/flink/pull/3811 Done @tillrohrmann. This is my first github pull request, so I didn't know I needed to do that manually :-) --- If your project is set up for it, you can reply to this email and have your reply a

[jira] [Commented] (FLINK-5718) Handle JVM Fatal Exceptions in Tasks

2017-05-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15998388#comment-15998388 ] ASF GitHub Bot commented on FLINK-5718: --- Github user zimmermatt closed the pull requ

[GitHub] flink pull request #3811: [FLINK-5718] [core] TaskManagers exit the JVM on f...

2017-05-05 Thread zimmermatt
Github user zimmermatt closed the pull request at: https://github.com/apache/flink/pull/3811 --- 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-5718) Handle JVM Fatal Exceptions in Tasks

2017-05-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15998385#comment-15998385 ] ASF GitHub Bot commented on FLINK-5718: --- GitHub user zimmermatt reopened a pull requ

[jira] [Commented] (FLINK-5718) Handle JVM Fatal Exceptions in Tasks

2017-05-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15998383#comment-15998383 ] ASF GitHub Bot commented on FLINK-5718: --- Github user zimmermatt closed the pull requ

[GitHub] flink pull request #3811: [FLINK-5718] [core] TaskManagers exit the JVM on f...

2017-05-05 Thread zimmermatt
GitHub user zimmermatt reopened a pull request: https://github.com/apache/flink/pull/3811 [FLINK-5718] [core] TaskManagers exit the JVM on fatal exceptions. Manually applied and adapted commit dfc6fba5b9830e6a7804a6a0c9f69b36bf772730 for the `release-1.2` branch. You can merge

[GitHub] flink pull request #3811: [FLINK-5718] [core] TaskManagers exit the JVM on f...

2017-05-05 Thread zimmermatt
Github user zimmermatt closed the pull request at: https://github.com/apache/flink/pull/3811 --- 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-5884) Integrate time indicators for Table API & SQL

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

[jira] [Commented] (FLINK-5440) Misleading error message when migrating and scaling down from savepoint

2017-05-05 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15998371#comment-15998371 ] Ufuk Celebi commented on FLINK-5440: Unfortunately, I haven't followed the most recent

[GitHub] flink issue #3808: [FLINK-5884] [table] Integrate time indicators for Table ...

2017-05-05 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3808 Hi @twalthr, I addressed my comments, rebased to current master, and will merge this PR given that all tests pass. Thanks, Fabian --- If your project is set up for it, you can reply to this

[jira] [Commented] (FLINK-5439) Adjust max parallelism when migrating

2017-05-05 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15998369#comment-15998369 ] Ufuk Celebi commented on FLINK-5439: Unfortunately, I haven't followed the most recent

[jira] [Commented] (FLINK-5599) State interface docs often refer to keyed state only

2017-05-05 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15998370#comment-15998370 ] Stefan Richter commented on FLINK-5599: --- This looks like we can close it by now. The

[jira] [Closed] (FLINK-5599) State interface docs often refer to keyed state only

2017-05-05 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-5599. - Resolution: Fixed > State interface docs often refer to keyed state only > ---

[jira] [Commented] (FLINK-5463) RocksDB.disposeInternal does not react to interrupts, blocks task cancellation

2017-05-05 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15998368#comment-15998368 ] Stefan Richter commented on FLINK-5463: --- [~rmetzger] How should we proceed with this

[jira] [Commented] (FLINK-5462) Flink job fails due to java.util.concurrent.CancellationException while snapshotting

2017-05-05 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15998367#comment-15998367 ] Stefan Richter commented on FLINK-5462: --- I think this is just a followup exception o

[jira] [Commented] (FLINK-5439) Adjust max parallelism when migrating

2017-05-05 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15998363#comment-15998363 ] Stefan Richter commented on FLINK-5439: --- [~uce] I think we can close this issue? Cor

[jira] [Commented] (FLINK-5440) Misleading error message when migrating and scaling down from savepoint

2017-05-05 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15998362#comment-15998362 ] Stefan Richter commented on FLINK-5440: --- [~uce] I think we can close this issue? Cor

[jira] [Commented] (FLINK-5924) Support asynchronous checkpointing of operator state

2017-05-05 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15998356#comment-15998356 ] Stefan Richter commented on FLINK-5924: --- Was this issue about the raw (stream-writte

[jira] [Commented] (FLINK-5925) Clean up extracted RocksDB JNI library

2017-05-05 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15998354#comment-15998354 ] Stefan Richter commented on FLINK-5925: --- [~till.rohrmann] is this issue still valid?

[jira] [Assigned] (FLINK-6412) Stream has already been closed during job cancel

2017-05-05 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-6412: - Assignee: Stefan Richter > Stream has already been closed during job cancel > ---

[jira] [Closed] (FLINK-5051) Backwards compatibility for serializers in backend state

2017-05-05 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-5051. - Resolution: Implemented > Backwards compatibility for serializers in backend state > -

[jira] [Closed] (FLINK-5041) Implement savepoint backwards compatibility 1.1 -> 1.2

2017-05-05 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-5041. - Resolution: Implemented Fix Version/s: 1.2.0 > Implement savepoint backwards compatibility

[jira] [Closed] (FLINK-6048) Asynchronous snapshots for heap-based operator state backends

2017-05-05 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-6048. - Resolution: Implemented > Asynchronous snapshots for heap-based operator state backends >

[jira] [Created] (FLINK-6463) Throw exception when NOT-NEXT is after OPTIONAL

2017-05-05 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-6463: - Summary: Throw exception when NOT-NEXT is after OPTIONAL Key: FLINK-6463 URL: https://issues.apache.org/jira/browse/FLINK-6463 Project: Flink Issue Type: B

[jira] [Commented] (FLINK-6456) Mis-Spelling on 'real-word' data-sets description

2017-05-05 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15998244#comment-15998244 ] sunjincheng commented on FLINK-6456: fixed: https://github.com/apache/flink-web/commi

[jira] [Closed] (FLINK-6456) Mis-Spelling on 'real-word' data-sets description

2017-05-05 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-6456. -- Resolution: Fixed > Mis-Spelling on 'real-word' data-sets description >

[jira] [Resolved] (FLINK-3320) Add not operator to CEP's pattern API

2017-05-05 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved FLINK-3320. - Resolution: Fixed > Add not operator to CEP's pattern API > --

[jira] [Commented] (FLINK-3320) Add not operator to CEP's pattern API

2017-05-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15998241#comment-15998241 ] ASF GitHub Bot commented on FLINK-3320: --- Github user dawidwys closed the pull reques

[GitHub] flink pull request #3798: [FLINK-3320] Add not operator to CEP's pattern API

2017-05-05 Thread dawidwys
Github user dawidwys closed the pull request at: https://github.com/apache/flink/pull/3798 --- 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 en

[jira] [Commented] (FLINK-3320) Add not operator to CEP's pattern API

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

[GitHub] flink issue #3798: [FLINK-3320] Add not operator to CEP's pattern API

2017-05-05 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/3798 Hi @dawidwys! I merged this. Could you close the PR and the related JIRA? --- 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] [Updated] (FLINK-5968) Document WindowedStream.aggregate()

2017-05-05 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5968: -- Priority: Critical (was: Blocker) > Document WindowedStream.aggregate() > -

[jira] [Updated] (FLINK-5967) Document AggregatingState

2017-05-05 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5967: -- Priority: Critical (was: Blocker) > Document AggregatingState > - > >

[jira] [Updated] (FLINK-6163) Document per-window state in ProcessWindowFunction

2017-05-05 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6163: -- Priority: Critical (was: Blocker) > Document per-window state in ProcessWindowFunction > --

[jira] [Commented] (FLINK-4545) Flink automatically manages TM network buffer

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

[GitHub] flink issue #3721: [FLINK-4545] replace the network buffers parameter

2017-05-05 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3721 Okay, taking a step back. Looking through the code some more, the internal arithmetric should certainly stay in bytes. However, bytes are tedious to configure. I suggest to add support t

[jira] [Closed] (FLINK-6136) Separate EmbeddedNonHaServices and NonHaServices

2017-05-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-6136. Resolution: Fixed Fixed via a0bb99c70703f6eaf0953b9ea6e70c5dbb9c1c77 > Separate EmbeddedNonHaServic

[jira] [Commented] (FLINK-6136) Separate EmbeddedNonHaServices and NonHaServices

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

[jira] [Commented] (FLINK-6217) ContaineredTaskManagerParameters sets off heap memory size incorrectly

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

[jira] [Closed] (FLINK-6435) AsyncWaitOperator does not handle exceptions properly

2017-05-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-6435. Resolution: Fixed Fix Version/s: 1.3.0 Fixed via 93758082273618d9fdbb3a9b3ed916a4b637760f >

[jira] [Commented] (FLINK-6435) AsyncWaitOperator does not handle exceptions properly

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

[jira] [Commented] (FLINK-5974) Support Mesos DNS

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

[jira] [Resolved] (FLINK-6217) ContaineredTaskManagerParameters sets off heap memory size incorrectly

2017-05-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-6217. -- Resolution: Fixed Fix Version/s: 1.3.0 Fixed via b1f186425c3a15de9d7c0f66e3d3d4d3a7e6b259

  1   2   >