[jira] [Commented] (FLINK-5092) Add integration with Sonarqube and code coverage

2017-02-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15852677#comment-15852677 ] ASF GitHub Bot commented on FLINK-5092: --- Github user BorisOsipov closed the pull req

[jira] [Commented] (FLINK-5092) Add integration with Sonarqube and code coverage

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

[GitHub] flink pull request #2836: [FLINK-5092] Add maven profile with code coverage ...

2017-02-03 Thread BorisOsipov
Github user BorisOsipov closed the pull request at: https://github.com/apache/flink/pull/2836 --- 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 #2836: [FLINK-5092] Add maven profile with code coverage report ...

2017-02-03 Thread BorisOsipov
Github user BorisOsipov commented on the issue: https://github.com/apache/flink/pull/2836 @zentol I've rebased pr and excluded mentioned above flink-examples-streaming and flink-storm-examples modules. --- If your project is set up for it, you can reply to this email and have your re

[jira] [Commented] (FLINK-5219) Add non-grouped session windows for batch tables

2017-02-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15852666#comment-15852666 ] ASF GitHub Bot commented on FLINK-5219: --- GitHub user sunjincheng121 opened a pull re

[GitHub] flink pull request #3266: [FLINK-5219][TableAPI&SQL] Add non-grouped session...

2017-02-03 Thread sunjincheng121
GitHub user sunjincheng121 opened a pull request: https://github.com/apache/flink/pull/3266 [FLINK-5219][TableAPI&SQL] Add non-grouped session windows for batch … …tables Thanks for contributing to Apache Flink. Before you open your pull request, please take the followi

[GitHub] flink issue #3138: #Flink-5522 Storm Local Cluster can't work with powermock

2017-02-03 Thread liuyuzhong7
Github user liuyuzhong7 commented on the issue: https://github.com/apache/flink/pull/3138 OK --- 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 feat

[jira] [Commented] (FLINK-4912) Introduce RECONCILING state in ExecutionGraph

2017-02-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15852640#comment-15852640 ] ASF GitHub Bot commented on FLINK-4912: --- Github user wangzhijiang999 commented on th

[GitHub] flink issue #3113: [FLINK-4912] Introduce RECONCILIATING state in ExecutionG...

2017-02-03 Thread wangzhijiang999
Github user wangzhijiang999 commented on the issue: https://github.com/apache/flink/pull/3113 @StephanEwen , I already created #5703 for further detail recovery process and it may cover your considerations. Wish your further response, thank you! --- If your project is set up for it,

[jira] [Updated] (FLINK-5703) ExecutionGraph recovery based on reconciliation with TaskManager reports

2017-02-03 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang updated FLINK-5703: - Description: The ExecutionGraph structure would be recovered from TaskManager reports during reco

[jira] [Updated] (FLINK-5703) ExecutionGraph recovery based on reconciliation with TaskManager reports

2017-02-03 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang updated FLINK-5703: - Description: The ExecutionGraph structure would be recovered from TaskManager reports during reco

[jira] [Updated] (FLINK-5703) ExecutionGraph recovery based on reconciliation with TaskManager reports

2017-02-03 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang updated FLINK-5703: - Description: The ExecutionGraph structure would be recovered from TaskManager reports during reco

[jira] [Updated] (FLINK-5703) ExecutionGraph recovery based on reconciliation with TaskManager reports

2017-02-03 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang updated FLINK-5703: - Description: The ExecutionGraph structure would be recovered from TaskManager reports during reco

[jira] [Commented] (FLINK-5023) Add get() method in State interface

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

[GitHub] flink issue #2768: [FLINK-5023][FLINK-5024] Add SimpleStateDescriptor to cla...

2017-02-03 Thread shixiaogang
Github user shixiaogang commented on the issue: https://github.com/apache/flink/pull/2768 @StephanEwen Thanks a lot for your comments. **Removing `clear()` from `State`** This change is suggested by @aljoscha who wants to let broadcast states share the same interfac

[jira] [Commented] (FLINK-5711) Deserialization schema that gives has full kafka log information

2017-02-03 Thread Mukesh Jha (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15852351#comment-15852351 ] Mukesh Jha commented on FLINK-5711: --- How can i assign this to me? > Deserialization sch

[jira] [Updated] (FLINK-5711) Deserialization schema that gives has full kafka log information

2017-02-03 Thread Mukesh Jha (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mukesh Jha updated FLINK-5711: -- Flags: (was: Patch) Labels: (was: patch) > Deserialization schema that gives has full kafka log

[jira] [Updated] (FLINK-5711) Deserialization schema that gives has full kafka log information

2017-02-03 Thread Mukesh Jha (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mukesh Jha updated FLINK-5711: -- Description: I want to add a KeyedDeserialization schema that gives has full kafka log information Cur

[jira] [Updated] (FLINK-5711) Deserialization schema that gives has full kafka log information

2017-02-03 Thread Mukesh Jha (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mukesh Jha updated FLINK-5711: -- Priority: Minor (was: Major) > Deserialization schema that gives has full kafka log information > -

[jira] [Commented] (FLINK-1588) Load flink configuration also from classloader

2017-02-03 Thread Patrick Lucas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15852224#comment-15852224 ] Patrick Lucas commented on FLINK-1588: -- Should it search and apply the configuration

[jira] [Commented] (FLINK-5674) Stdout not present in logs files

2017-02-03 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15852104#comment-15852104 ] Greg Hogan commented on FLINK-5674: --- Not sure how much work this would be but could the

[jira] [Assigned] (FLINK-5597) Improve the LocalClusteringCoefficient documentation

2017-02-03 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan reassigned FLINK-5597: - Assignee: Greg Hogan > Improve the LocalClusteringCoefficient documentation > ---

[jira] [Created] (FLINK-5711) Deserialization schema that gives has full kafka log information

2017-02-03 Thread Mukesh Jha (JIRA)
Mukesh Jha created FLINK-5711: - Summary: Deserialization schema that gives has full kafka log information Key: FLINK-5711 URL: https://issues.apache.org/jira/browse/FLINK-5711 Project: Flink Iss

[jira] [Commented] (FLINK-5309) documentation links on the home page point to 1.2-SNAPSHOT

2017-02-03 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15852064#comment-15852064 ] Greg Hogan commented on FLINK-5309: --- Is this still an issue with the project website red

[jira] [Commented] (FLINK-2908) Web interface redraw web plan when browser resized

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

[GitHub] flink issue #3251: [FLINK-2908] [web frontend] Redraw web plan when browser ...

2017-02-03 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3251 @uce thanks for looking at this and my apologies for not including screenshots. I am also using Firefox. An explicit page reload should force page assets to be redownloaded. Currently swit

[jira] [Commented] (FLINK-5090) Expose optionally detailed metrics about network queue lengths

2017-02-03 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15852025#comment-15852025 ] Greg Hogan commented on FLINK-5090: --- [~StephanEwen] is your code ready for a PR? > Expo

[jira] [Assigned] (FLINK-4823) org.apache.flink.types.NullFieldException: Field 0 is null, but expected to hold a value

2017-02-03 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan reassigned FLINK-4823: - Assignee: Greg Hogan > org.apache.flink.types.NullFieldException: Field 0 is null, but expected t

[jira] [Closed] (FLINK-2319) Collect size limitation due to akka.

2017-02-03 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-2319. - Resolution: Later > Collect size limitation due to akka. > > >

[jira] [Closed] (FLINK-2319) Collect size limitation due to akka.

2017-02-03 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-2319. - Resolution: Fixed FLINK-4399 describes a general solution. > Collect size limitation due to akka. > -

[jira] [Reopened] (FLINK-2319) Collect size limitation due to akka.

2017-02-03 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan reopened FLINK-2319: --- > Collect size limitation due to akka. > > > Key: FLI

[jira] [Closed] (FLINK-3954) Installing Flink on EMR using EMR bootstrap action

2017-02-03 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-3954. - Resolution: Fixed Flink is now provided in Amazon EMR. > Installing Flink on EMR using EMR bootstrap acti

[jira] [Closed] (FLINK-3858) Date is wrongly serialized

2017-02-03 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-3858. - Resolution: Fixed Fixed in FLINK-3856 to use {{Long.MIN_VALUE}} instead of {{-1}} to mark null values. >

[jira] [Closed] (FLINK-3795) Cancel button is hidden on MacBook Pro 13''

2017-02-03 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-3795. - Resolution: Fixed > Cancel button is hidden on MacBook Pro 13'' >

[jira] [Updated] (FLINK-3685) Logical error in code for DateSerializer deserialize with reuse

2017-02-03 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-3685: -- Description: There is a logical error in the following function in DateSerializer.java when source read

[jira] [Closed] (FLINK-3501) flink-runtime-0.10.2-hadoop-1 jar problem

2017-02-03 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-3501. - Resolution: Won't Fix The stackoverflow link offers workarounds for case-insensitive filesystems on macOS

[jira] [Closed] (FLINK-5708) we should remove duplicated configuration options

2017-02-03 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-5708. - Resolution: Fixed Fixed in 31e1573460f201e161b2fc74805cd8d706862bba (master) and 28eea24e470d9ddc5fac18c1

[jira] [Updated] (FLINK-5708) we should remove duplicated configuration options

2017-02-03 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-5708: -- Fix Version/s: 1.2.1 > we should remove duplicated configuration options >

[jira] [Commented] (FLINK-5708) we should remove duplicated configuration options

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

[GitHub] flink pull request #3261: [FLINK-5708] [doc] remove duplicated configuration...

2017-02-03 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3261 --- 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-4286) Have Kafka examples that use the Kafka 0.9 connector

2017-02-03 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-4286: Assignee: Dmitrii Kniazev > Have Kafka examples that use the Kafka 0.9 connector >

[jira] [Assigned] (FLINK-2211) Generalize ALS API

2017-02-03 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-2211: Assignee: Till Rohrmann > Generalize ALS API > -- > > Key:

[jira] [Commented] (FLINK-2211) Generalize ALS API

2017-02-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15851888#comment-15851888 ] ASF GitHub Bot commented on FLINK-2211: --- GitHub user tillrohrmann opened a pull requ

[GitHub] flink pull request #3265: [FLINK-2211] [ml] Generalize ALS API

2017-02-03 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/3265 [FLINK-2211] [ml] Generalize ALS API This generalizes the ALS API, because it allows the `users` and `items` to be of type `Long` instead of `Int`. You can merge this pull request into a Git

[jira] [Commented] (FLINK-5652) Memory leak in AsyncDataStream

2017-02-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15851882#comment-15851882 ] ASF GitHub Bot commented on FLINK-5652: --- GitHub user tillrohrmann opened a pull requ

[GitHub] flink pull request #3264: [FLINK-5652] [asyncIO] Cancel timers when completi...

2017-02-03 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/3264 [FLINK-5652] [asyncIO] Cancel timers when completing a StreamRecordQueueEntry Whenever a StreamRecordQueueEntry has been completed we no longer need the registered timeout. Therefore, we h

[jira] [Updated] (FLINK-3457) Link to Apache Flink meetups from the 'Community' section of the website

2017-02-03 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-3457: -- Component/s: (was: Documentation) Project Website > Link to Apache Flink meetups fr

[GitHub] flink issue #3258: Flink job migration 1.1 -> 1.2 documentation

2017-02-03 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/3258 Thanks for your feedback @alpinegizmo! I made another commit that contains the suggested corrections. --- If your project is set up for it, you can reply to this email and have your reply ap

[jira] [Commented] (FLINK-5575) in old releases, warn users and guide them to the latest stable docs

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

[GitHub] flink issue #3242: [FLINK-5575][docs] reworked the mechanism that warns user...

2017-02-03 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/3242 Looks very nice. +1 to the design. Let's merge this as is and decide whether we remove the older pages later then. --- If your project is set up for it, you can reply to this email and have you

[jira] [Commented] (FLINK-5710) Add ProcTime() function to indicate StreamSQL

2017-02-03 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15851742#comment-15851742 ] Fabian Hueske commented on FLINK-5710: -- We have to think a bit more about this functi

[jira] [Commented] (FLINK-5575) in old releases, warn users and guide them to the latest stable docs

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

[GitHub] flink issue #3242: [FLINK-5575][docs] reworked the mechanism that warns user...

2017-02-03 Thread alpinegizmo
Github user alpinegizmo commented on the issue: https://github.com/apache/flink/pull/3242 @uce Some old releases still have strong google power -- especially 0.8. I don't know if replacing those pages with a redirect will cause the page rank to plummet or not. --- If your project is

[GitHub] flink issue #3242: [FLINK-5575][docs] reworked the mechanism that warns user...

2017-02-03 Thread alpinegizmo
Github user alpinegizmo commented on the issue: https://github.com/apache/flink/pull/3242 @uce I tried to choose styling that looks decent with all previous releases. Here's a screenshot against 1.0. ![old-release-warning](https://cloud.githubusercontent.com/assets/43608/22600510/

[jira] [Commented] (FLINK-5575) in old releases, warn users and guide them to the latest stable docs

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

[jira] [Commented] (FLINK-2908) Web interface redraw web plan when browser resized

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

[GitHub] flink issue #3251: [FLINK-2908] [web frontend] Redraw web plan when browser ...

2017-02-03 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/3251 Hey Greg, I checked out the PR and still had the behaviour described in the JIRA (checked with Firefox and Chrome). Note that refreshing the page after resizing does also not change anything for me. Ther

[GitHub] flink pull request #3259: Documentation: Production readiness checklist

2017-02-03 Thread alpinegizmo
Github user alpinegizmo commented on a diff in the pull request: https://github.com/apache/flink/pull/3259#discussion_r99376488 --- Diff: docs/ops/production_ready.md --- @@ -0,0 +1,88 @@ +--- +title: "Production Readiness Checklist" +nav-parent_id: setup +nav-pos: 2

[GitHub] flink pull request #3259: Documentation: Production readiness checklist

2017-02-03 Thread alpinegizmo
Github user alpinegizmo commented on a diff in the pull request: https://github.com/apache/flink/pull/3259#discussion_r99375422 --- Diff: docs/ops/production_ready.md --- @@ -0,0 +1,88 @@ +--- +title: "Production Readiness Checklist" +nav-parent_id: setup +nav-pos: 2

[GitHub] flink pull request #3259: Documentation: Production readiness checklist

2017-02-03 Thread alpinegizmo
Github user alpinegizmo commented on a diff in the pull request: https://github.com/apache/flink/pull/3259#discussion_r99376685 --- Diff: docs/ops/production_ready.md --- @@ -0,0 +1,88 @@ +--- +title: "Production Readiness Checklist" +nav-parent_id: setup +nav-pos: 2

[GitHub] flink pull request #3259: Documentation: Production readiness checklist

2017-02-03 Thread alpinegizmo
Github user alpinegizmo commented on a diff in the pull request: https://github.com/apache/flink/pull/3259#discussion_r99375568 --- Diff: docs/ops/production_ready.md --- @@ -0,0 +1,88 @@ +--- +title: "Production Readiness Checklist" +nav-parent_id: setup +nav-pos: 2

[GitHub] flink pull request #3259: Documentation: Production readiness checklist

2017-02-03 Thread alpinegizmo
Github user alpinegizmo commented on a diff in the pull request: https://github.com/apache/flink/pull/3259#discussion_r99376976 --- Diff: docs/ops/production_ready.md --- @@ -0,0 +1,88 @@ +--- +title: "Production Readiness Checklist" +nav-parent_id: setup +nav-pos: 2

[GitHub] flink pull request #3259: Documentation: Production readiness checklist

2017-02-03 Thread alpinegizmo
Github user alpinegizmo commented on a diff in the pull request: https://github.com/apache/flink/pull/3259#discussion_r99375767 --- Diff: docs/ops/production_ready.md --- @@ -0,0 +1,88 @@ +--- +title: "Production Readiness Checklist" +nav-parent_id: setup +nav-pos: 2

[jira] [Commented] (FLINK-2170) Add OrcTableSource

2017-02-03 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15851712#comment-15851712 ] Robert Metzger commented on FLINK-2170: --- [~owen.omalley] What's your status on this?

[GitHub] flink issue #3242: [FLINK-5575][docs] reworked the mechanism that warns user...

2017-02-03 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/3242 Good addition. Could you post a screenshot of how this looks now? Given that we are very unlikely to provide any fixes for older versions than 1.0.0, I would vote to simply redirect to the latest

[jira] [Commented] (FLINK-5575) in old releases, warn users and guide them to the latest stable docs

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

[jira] [Commented] (FLINK-5024) Add SimpleStateDescriptor to clarify the concepts

2017-02-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15851686#comment-15851686 ] ASF GitHub Bot commented on FLINK-5024: --- Github user uce commented on a diff in the

[GitHub] flink pull request #3243: [FLINK-5024] [core] Refactor the interface of Stat...

2017-02-03 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/3243#discussion_r99374243 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/state/StateDescriptor.java --- @@ -20,34 +20,29 @@ import org.apache.flink.annotation.P

[jira] [Created] (FLINK-5710) Add ProcTime() function to indicate StreamSQL

2017-02-03 Thread Stefano Bortoli (JIRA)
Stefano Bortoli created FLINK-5710: -- Summary: Add ProcTime() function to indicate StreamSQL Key: FLINK-5710 URL: https://issues.apache.org/jira/browse/FLINK-5710 Project: Flink Issue Type: N

[jira] [Commented] (FLINK-5699) Cancel with savepoint fails with a NPE if savepoint target directory not set

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

[GitHub] flink pull request #3263: [FLINK-5699] [savepoints] Check target dir when ca...

2017-02-03 Thread uce
GitHub user uce opened a pull request: https://github.com/apache/flink/pull/3263 [FLINK-5699] [savepoints] Check target dir when cancelling with savepoint When cancelling a job with a savepoint and no savepoint directory is configured, triggering the savepoint fails with an NPE. Thi

[jira] [Commented] (FLINK-5709) Add Max Parallelism to Parallel Execution Doc

2017-02-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15851678#comment-15851678 ] ASF GitHub Bot commented on FLINK-5709: --- Github user aljoscha commented on a diff in

[GitHub] flink pull request #3262: [FLINK-5709] Add Max Parallelism to Parallel Execu...

2017-02-03 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/3262#discussion_r99372586 --- Diff: docs/dev/parallel.md --- @@ -166,10 +177,19 @@ try { -## System Level +### System Level A system-wide default p

[GitHub] flink pull request #3258: Flink job migration 1.1 -> 1.2 documentation

2017-02-03 Thread alpinegizmo
Github user alpinegizmo commented on a diff in the pull request: https://github.com/apache/flink/pull/3258#discussion_r99368591 --- Diff: docs/ops/upgrading.md --- @@ -35,23 +35,105 @@ under the License. ## Upgrading the Flink Framework Version - - Either "in p

[GitHub] flink pull request #3258: Flink job migration 1.1 -> 1.2 documentation

2017-02-03 Thread alpinegizmo
Github user alpinegizmo commented on a diff in the pull request: https://github.com/apache/flink/pull/3258#discussion_r99370751 --- Diff: docs/ops/upgrading.md --- @@ -35,23 +35,105 @@ under the License. ## Upgrading the Flink Framework Version - - Either "in p

[GitHub] flink pull request #3258: Flink job migration 1.1 -> 1.2 documentation

2017-02-03 Thread alpinegizmo
Github user alpinegizmo commented on a diff in the pull request: https://github.com/apache/flink/pull/3258#discussion_r99369716 --- Diff: docs/ops/upgrading.md --- @@ -35,23 +35,105 @@ under the License. ## Upgrading the Flink Framework Version - - Either "in p

[GitHub] flink pull request #3258: Flink job migration 1.1 -> 1.2 documentation

2017-02-03 Thread alpinegizmo
Github user alpinegizmo commented on a diff in the pull request: https://github.com/apache/flink/pull/3258#discussion_r99369468 --- Diff: docs/ops/upgrading.md --- @@ -35,23 +35,105 @@ under the License. ## Upgrading the Flink Framework Version - - Either "in p

[GitHub] flink pull request #3258: Flink job migration 1.1 -> 1.2 documentation

2017-02-03 Thread alpinegizmo
Github user alpinegizmo commented on a diff in the pull request: https://github.com/apache/flink/pull/3258#discussion_r99369845 --- Diff: docs/ops/upgrading.md --- @@ -35,23 +35,105 @@ under the License. ## Upgrading the Flink Framework Version - - Either "in p

[GitHub] flink pull request #3258: Flink job migration 1.1 -> 1.2 documentation

2017-02-03 Thread alpinegizmo
Github user alpinegizmo commented on a diff in the pull request: https://github.com/apache/flink/pull/3258#discussion_r99369385 --- Diff: docs/ops/upgrading.md --- @@ -35,23 +35,105 @@ under the License. ## Upgrading the Flink Framework Version - - Either "in p

[GitHub] flink pull request #3258: Flink job migration 1.1 -> 1.2 documentation

2017-02-03 Thread alpinegizmo
Github user alpinegizmo commented on a diff in the pull request: https://github.com/apache/flink/pull/3258#discussion_r99369329 --- Diff: docs/ops/upgrading.md --- @@ -35,23 +35,105 @@ under the License. ## Upgrading the Flink Framework Version - - Either "in p

[GitHub] flink pull request #3258: Flink job migration 1.1 -> 1.2 documentation

2017-02-03 Thread alpinegizmo
Github user alpinegizmo commented on a diff in the pull request: https://github.com/apache/flink/pull/3258#discussion_r99370939 --- Diff: docs/ops/upgrading.md --- @@ -35,23 +35,105 @@ under the License. ## Upgrading the Flink Framework Version - - Either "in p

[GitHub] flink pull request #3258: Flink job migration 1.1 -> 1.2 documentation

2017-02-03 Thread alpinegizmo
Github user alpinegizmo commented on a diff in the pull request: https://github.com/apache/flink/pull/3258#discussion_r99370593 --- Diff: docs/ops/upgrading.md --- @@ -35,23 +35,105 @@ under the License. ## Upgrading the Flink Framework Version - - Either "in p

[GitHub] flink pull request #3258: Flink job migration 1.1 -> 1.2 documentation

2017-02-03 Thread alpinegizmo
Github user alpinegizmo commented on a diff in the pull request: https://github.com/apache/flink/pull/3258#discussion_r99369022 --- Diff: docs/ops/upgrading.md --- @@ -35,23 +35,105 @@ under the License. ## Upgrading the Flink Framework Version - - Either "in p

[jira] [Commented] (FLINK-5635) Improve Docker tooling to make it easier to build images and launch Flink via Docker tools

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

[GitHub] flink issue #3205: [FLINK-5635] Improve Docker tooling to make it easier to ...

2017-02-03 Thread jgrier
Github user jgrier commented on the issue: https://github.com/apache/flink/pull/3205 @ex00 The `--from-local-dist` flag assumes you've already built Flink locally. If you run `mvn clean package -DskipTests` does this error persist? --- If your project is set up for it, you can reply

[jira] [Closed] (FLINK-1337) Create an Amazon EMR Bootstrap Action

2017-02-03 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1337. --- > Create an Amazon EMR Bootstrap Action > - > > Key: F

[jira] [Commented] (FLINK-1337) Create an Amazon EMR Bootstrap Action

2017-02-03 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15851618#comment-15851618 ] Stephan Ewen commented on FLINK-1337: - Closed it. Since Flink is in EMR, this should n

[jira] [Resolved] (FLINK-1337) Create an Amazon EMR Bootstrap Action

2017-02-03 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1337. - Resolution: Won't Fix > Create an Amazon EMR Bootstrap Action > --

[jira] [Comment Edited] (FLINK-5634) Flink should not always redirect stdout to a file.

2017-02-03 Thread Jamie Grier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15851609#comment-15851609 ] Jamie Grier edited comment on FLINK-5634 at 2/3/17 3:20 PM: Ag

[jira] [Commented] (FLINK-4326) Flink start-up scripts should optionally start services on the foreground

2017-02-03 Thread Jamie Grier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15851616#comment-15851616 ] Jamie Grier commented on FLINK-4326: [~StephanEwen] Yup this will also solve the issue

[jira] [Issue Comment Deleted] (FLINK-5634) Flink should not always redirect stdout to a file.

2017-02-03 Thread Jamie Grier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jamie Grier updated FLINK-5634: --- Comment: was deleted (was: Agreed.. If [FLINK-4326] were merged this would also work fine. Whether

[jira] [Commented] (FLINK-5634) Flink should not always redirect stdout to a file.

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

[GitHub] flink issue #3204: [FLINK-5634] Flink should not always redirect stdout to a...

2017-02-03 Thread jgrier
Github user jgrier commented on the issue: https://github.com/apache/flink/pull/3204 Agreed.. If https://issues.apache.org/jira/browse/FLINK-4326 were merged this would also work fine. Whether or not Flink runs in the background or foreground is orthogonal to where the logs go – as

[jira] [Commented] (FLINK-5552) Make the JMX port available through RESTful API

2017-02-03 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15851611#comment-15851611 ] Chesnay Schepler commented on FLINK-5552: - [~rmetzger] I couldn't think of a good

[jira] [Commented] (FLINK-5634) Flink should not always redirect stdout to a file.

2017-02-03 Thread Jamie Grier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15851609#comment-15851609 ] Jamie Grier commented on FLINK-5634: Agreed.. If [4326] were merged this would also w

[jira] [Commented] (FLINK-5708) we should remove duplicated configuration options

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

[GitHub] flink issue #3261: [FLINK-5708] [doc] remove duplicated configuration option

2017-02-03 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3261 Will merge this along with the formatting issue in between the duplicate entries. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[GitHub] flink pull request #3262: [FLINK-5709] Add Max Parallelism to Parallel Execu...

2017-02-03 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/3262#discussion_r99354689 --- Diff: docs/dev/parallel.md --- @@ -166,10 +177,19 @@ try { -## System Level +### System Level A system-wide default p

[jira] [Commented] (FLINK-5709) Add Max Parallelism to Parallel Execution Doc

2017-02-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15851603#comment-15851603 ] ASF GitHub Bot commented on FLINK-5709: --- Github user aljoscha commented on a diff in

[jira] [Assigned] (FLINK-5699) Cancel with savepoint fails with a NPE if savepoint target directory not set

2017-02-03 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-5699: -- Assignee: Ufuk Celebi > Cancel with savepoint fails with a NPE if savepoint target directory no

  1   2   >