[jira] [Created] (FLINK-8263) Wrong packaging of flink-core in scala quickstarty

2017-12-14 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-8263: --- Summary: Wrong packaging of flink-core in scala quickstarty Key: FLINK-8263 URL: https://issues.apache.org/jira/browse/FLINK-8263 Project: Flink Issue Type:

[jira] [Resolved] (FLINK-8263) Wrong packaging of flink-core in scala quickstarty

2017-12-14 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-8263. - Resolution: Fixed Fixed in - 1.4.1 via 18efbea67169fc2d70de4040bf8c1c4650ce2ab1 - 1.5.0 via

[jira] [Closed] (FLINK-8263) Wrong packaging of flink-core in scala quickstarty

2017-12-14 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-8263. --- > Wrong packaging of flink-core in scala quickstarty > --

[jira] [Commented] (FLINK-8200) RocksDBAsyncSnapshotTest should use temp fold instead of fold with fixed name

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

[GitHub] flink pull request #5122: [FLINK-8200] RocksDBAsyncSnapshotTest should use t...

2017-12-14 Thread wenlong88
Github user wenlong88 closed the pull request at: https://github.com/apache/flink/pull/5122 ---

[GitHub] flink pull request #5091: [FLINK-7956] [flip6] Add support for queued schedu...

2017-12-14 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5091#discussion_r156948978 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotSharingManager.java --- @@ -0,0 +1,722 @@ +/* + *

[GitHub] flink issue #5166: [FLINK-8264] [core] Add 'scala.' to the 'parent-first' cl...

2017-12-14 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5166 @aljoscha I think you may have an opinion on this one ---

[jira] [Created] (FLINK-8262) IndividualRestartsConcurrencyTest.testLocalFailureFailsPendingCheckpoints fails on Travis

2017-12-14 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-8262: Summary: IndividualRestartsConcurrencyTest.testLocalFailureFailsPendingCheckpoints fails on Travis Key: FLINK-8262 URL: https://issues.apache.org/jira/browse/FLINK-8262

[jira] [Commented] (FLINK-8256) Cannot use Scala functions to filter in 1.4 - java.lang.ClassCastException

2017-12-14 Thread Ryan Brideau (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16290846#comment-16290846 ] Ryan Brideau commented on FLINK-8256: - Thanks for looking into this so quickly. I managed to track

[jira] [Resolved] (FLINK-8261) Typos in the shading exclusion for jsr305 in the quickstarts

2017-12-14 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-8261. - Resolution: Fixed Fix Version/s: 1.4.1 1.5.0 Fixe in - 1.4.1 via

[jira] [Closed] (FLINK-8261) Typos in the shading exclusion for jsr305 in the quickstarts

2017-12-14 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-8261. --- > Typos in the shading exclusion for jsr305 in the quickstarts >

[jira] [Closed] (FLINK-8262) IndividualRestartsConcurrencyTest.testLocalFailureFailsPendingCheckpoints fails on Travis

2017-12-14 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8262. Resolution: Fixed Fixed via e80dd8ea3fef0398048a40c3ffd5136bef204b80 >

[jira] [Commented] (FLINK-8264) Add Scala to the parent-first loading patterns

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

[jira] [Commented] (FLINK-8256) Cannot use Scala functions to filter in 1.4 - java.lang.ClassCastException

2017-12-14 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16290789#comment-16290789 ] Stephan Ewen commented on FLINK-8256: - Please see this issue for how we plan improve the behavior for

[jira] [Commented] (FLINK-8264) Add Scala to the parent-first loading patterns

2017-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16290810#comment-16290810 ] ASF GitHub Bot commented on FLINK-8264: --- GitHub user StephanEwen opened a pull request:

[jira] [Commented] (FLINK-8256) Cannot use Scala functions to filter in 1.4 - java.lang.ClassCastException

2017-12-14 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16290970#comment-16290970 ] Stephan Ewen commented on FLINK-8256: - Great to hear! Do you think we should close the issue, with a

[GitHub] flink pull request #5091: [FLINK-7956] [flip6] Add support for queued schedu...

2017-12-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5091 ---

[jira] [Commented] (FLINK-8087) Decouple Slot from SlotPool

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

[jira] [Commented] (FLINK-8089) Fulfil slot requests with unused offered slots

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

[jira] [Commented] (FLINK-8088) Bind logical slots to their request id instead of the slot allocation id

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

[GitHub] flink pull request #4612: [FLINK-7452] [types] Add helper methods for all bu...

2017-12-14 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4612#discussion_r156940309 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/Types.scala --- @@ -25,55 +27,125 @@ import org.apache.flink.types.Row

[GitHub] flink pull request #4612: [FLINK-7452] [types] Add helper methods for all bu...

2017-12-14 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4612#discussion_r156940557 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/stream/table/stringexpr/CorrelateStringExpressionTest.scala --- @@ -34,7

[GitHub] flink pull request #4612: [FLINK-7452] [types] Add helper methods for all bu...

2017-12-14 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4612#discussion_r156937828 --- Diff: flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/Types.scala --- @@ -0,0 +1,371 @@ +/* + * Licensed to the Apache Software

[GitHub] flink issue #5091: [FLINK-7956] [flip6] Add support for queued scheduling wi...

2017-12-14 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5091 Thanks for the review @GJL and @ifndef-SleePy. Travis passed locally. Merging this PR. ---

[jira] [Commented] (FLINK-8256) Cannot use Scala functions to filter in 1.4 - java.lang.ClassCastException

2017-12-14 Thread Ryan Brideau (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16290978#comment-16290978 ] Ryan Brideau commented on FLINK-8256: - That works for me! Thanks again. > Cannot use Scala functions

[GitHub] flink issue #5089: [FLINK-8088] Associate logical slots with the slot reques...

2017-12-14 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5089 Merging this PR. ---

[GitHub] flink issue #5090: [FLINK-8089] Also check for other pending slot requests i...

2017-12-14 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5090 Thanks for the review @GJL. Merging this PR. ---

[GitHub] flink issue #5088: [FLINK-8087] Decouple Slot from AllocatedSlot

2017-12-14 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5088 Thanks for the review @GJL. Merging this PR. ---

[jira] [Commented] (FLINK-7956) Add support for scheduling with slot sharing

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

[jira] [Closed] (FLINK-7956) Add support for scheduling with slot sharing

2017-12-14 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7956. Resolution: Done Fix Version/s: 1.5.0 Added via 0ef7fddeff8430fd40d2d7a1b8a6454fd9416ced >

[GitHub] flink pull request #5128: [FLINK-8120] [flip6] Register Yarn application wit...

2017-12-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5128 ---

[GitHub] flink pull request #5089: [FLINK-8088] Associate logical slots with the slot...

2017-12-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5089 ---

[GitHub] flink pull request #5090: [FLINK-8089] Also check for other pending slot req...

2017-12-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5090 ---

[GitHub] flink pull request #5088: [FLINK-8087] Decouple Slot from AllocatedSlot

2017-12-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5088 ---

[jira] [Commented] (FLINK-7452) Add helper methods for all built-in Flink types to Types

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

[jira] [Commented] (FLINK-7452) Add helper methods for all built-in Flink types to Types

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

[jira] [Commented] (FLINK-7452) Add helper methods for all built-in Flink types to Types

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

[jira] [Commented] (FLINK-7452) Add helper methods for all built-in Flink types to Types

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

[jira] [Commented] (FLINK-7452) Add helper methods for all built-in Flink types to Types

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

[GitHub] flink pull request #4612: [FLINK-7452] [types] Add helper methods for all bu...

2017-12-14 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4612#discussion_r156956706 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/Types.scala --- @@ -116,7 +191,7 @@ object Types { * --- End

[jira] [Commented] (FLINK-7452) Add helper methods for all built-in Flink types to Types

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

[jira] [Commented] (FLINK-7452) Add helper methods for all built-in Flink types to Types

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

[jira] [Commented] (FLINK-7452) Add helper methods for all built-in Flink types to Types

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

[jira] [Commented] (FLINK-7452) Add helper methods for all built-in Flink types to Types

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

[GitHub] flink pull request #4612: [FLINK-7452] [types] Add helper methods for all bu...

2017-12-14 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4612#discussion_r156940963 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/typeinfo/Types.java --- @@ -19,56 +19,422 @@ package

[GitHub] flink pull request #4612: [FLINK-7452] [types] Add helper methods for all bu...

2017-12-14 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4612#discussion_r156956540 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/Types.scala --- @@ -107,7 +180,9 @@ object Types { * @param

[jira] [Commented] (FLINK-7452) Add helper methods for all built-in Flink types to Types

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

[jira] [Commented] (FLINK-7452) Add helper methods for all built-in Flink types to Types

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

[GitHub] flink pull request #4612: [FLINK-7452] [types] Add helper methods for all bu...

2017-12-14 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4612#discussion_r156955846 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/Types.scala --- @@ -25,55 +27,125 @@ import org.apache.flink.types.Row

[jira] [Commented] (FLINK-7452) Add helper methods for all built-in Flink types to Types

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

[jira] [Commented] (FLINK-7452) Add helper methods for all built-in Flink types to Types

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

[GitHub] flink pull request #4612: [FLINK-7452] [types] Add helper methods for all bu...

2017-12-14 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4612#discussion_r156938437 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/typeinfo/Types.java --- @@ -19,56 +19,422 @@ package

[GitHub] flink pull request #4612: [FLINK-7452] [types] Add helper methods for all bu...

2017-12-14 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4612#discussion_r156942641 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/typeinfo/Types.java --- @@ -19,56 +19,422 @@ package

[jira] [Commented] (FLINK-7452) Add helper methods for all built-in Flink types to Types

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

[GitHub] flink pull request #4612: [FLINK-7452] [types] Add helper methods for all bu...

2017-12-14 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4612#discussion_r156958542 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/typeinfo/Types.java --- @@ -19,56 +19,422 @@ package

[GitHub] flink pull request #4612: [FLINK-7452] [types] Add helper methods for all bu...

2017-12-14 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4612#discussion_r156958975 --- Diff: flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/Types.scala --- @@ -0,0 +1,371 @@ +/* + * Licensed to the Apache Software

[jira] [Commented] (FLINK-7452) Add helper methods for all built-in Flink types to Types

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

[jira] [Commented] (FLINK-7452) Add helper methods for all built-in Flink types to Types

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

[jira] [Commented] (FLINK-7452) Add helper methods for all built-in Flink types to Types

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

[GitHub] flink pull request #4612: [FLINK-7452] [types] Add helper methods for all bu...

2017-12-14 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4612#discussion_r156951752 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/typeinfo/Types.java --- @@ -19,56 +19,422 @@ package

[GitHub] flink pull request #4612: [FLINK-7452] [types] Add helper methods for all bu...

2017-12-14 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4612#discussion_r156951434 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/typeinfo/Types.java --- @@ -19,56 +19,422 @@ package

[GitHub] flink pull request #4612: [FLINK-7452] [types] Add helper methods for all bu...

2017-12-14 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4612#discussion_r156949716 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/typeinfo/Types.java --- @@ -19,56 +19,422 @@ package

[GitHub] flink pull request #4612: [FLINK-7452] [types] Add helper methods for all bu...

2017-12-14 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4612#discussion_r156938239 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/typeinfo/Types.java --- @@ -19,56 +19,417 @@ package

[jira] [Commented] (FLINK-7452) Add helper methods for all built-in Flink types to Types

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

[jira] [Commented] (FLINK-7452) Add helper methods for all built-in Flink types to Types

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

[GitHub] flink pull request #4612: [FLINK-7452] [types] Add helper methods for all bu...

2017-12-14 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4612#discussion_r156937819 --- Diff: flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/Types.scala --- @@ -0,0 +1,371 @@ +/* + * Licensed to the Apache Software

[GitHub] flink pull request #4612: [FLINK-7452] [types] Add helper methods for all bu...

2017-12-14 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4612#discussion_r156940261 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/Types.scala --- @@ -25,55 +27,125 @@ import org.apache.flink.types.Row

[GitHub] flink pull request #4612: [FLINK-7452] [types] Add helper methods for all bu...

2017-12-14 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4612#discussion_r156941632 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/typeinfo/Types.java --- @@ -19,56 +19,422 @@ package

[GitHub] flink pull request #4612: [FLINK-7452] [types] Add helper methods for all bu...

2017-12-14 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4612#discussion_r156945371 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/typeinfo/Types.java --- @@ -19,56 +19,408 @@ package

[jira] [Assigned] (FLINK-8234) Cache JobExecutionResult from finished JobManagerRunners

2017-12-14 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-8234: --- Assignee: Gary Yao > Cache JobExecutionResult from finished JobManagerRunners >

[jira] [Commented] (FLINK-8120) Cannot access Web UI from YARN application overview in FLIP-6 mode

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

[jira] [Commented] (FLINK-8088) Bind logical slots to their request id instead of the slot allocation id

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

[jira] [Commented] (FLINK-8087) Decouple Slot from SlotPool

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

[jira] [Commented] (FLINK-8089) Fulfil slot requests with unused offered slots

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

[jira] [Commented] (FLINK-7956) Add support for scheduling with slot sharing

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

[jira] [Commented] (FLINK-8256) Cannot use Scala functions to filter in 1.4 - java.lang.ClassCastException

2017-12-14 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16290780#comment-16290780 ] Stephan Ewen commented on FLINK-8256: - [~till.rohrmann] and me managed to reproduce this by including

[GitHub] flink pull request #5167: [FLINK-8264] [core] Add 'scala.' to the 'parent-fi...

2017-12-14 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/5167 [FLINK-8264] [core] Add 'scala.' to the 'parent-first' classloading patterns **BACKPORT of #5166 to release-1.4** ## What is the purpose of the change Adding `scala.` to the

[jira] [Commented] (FLINK-7956) Add support for scheduling with slot sharing

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

[jira] [Commented] (FLINK-8257) Unify the value checks for setParallelism()

2017-12-14 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16291536#comment-16291536 ] Eron Wright commented on FLINK-8257: - Related: in some cases the parallelism must be equal to that of

[jira] [Commented] (FLINK-8234) Cache JobExecutionResult from finished JobManagerRunners

2017-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16291320#comment-16291320 ] ASF GitHub Bot commented on FLINK-8234: --- Github user GJL commented on a diff in the pull request:

[GitHub] flink pull request #5168: [FLINK-8234][flip6] WIP

2017-12-14 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5168#discussion_r157027881 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/JobExecutionResultCache.java --- @@ -0,0 +1,79 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-8234) Cache JobExecutionResult from finished JobManagerRunners

2017-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16291333#comment-16291333 ] ASF GitHub Bot commented on FLINK-8234: --- Github user GJL commented on a diff in the pull request:

[jira] [Commented] (FLINK-8234) Cache JobExecutionResult from finished JobManagerRunners

2017-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16291334#comment-16291334 ] ASF GitHub Bot commented on FLINK-8234: --- Github user GJL commented on a diff in the pull request:

[GitHub] flink issue #5157: [hotfix] [docs] Consistent capitalization in Mesos docume...

2017-12-14 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/5157 @joerg84 could you file a PR for this change in `docs/ops/config.md` and elsewhere in `docs/ops/deployment/mesos.md`? ---

[GitHub] flink pull request #4911: [FLINK-7878] [api] make resource type extendible i...

2017-12-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4911 ---

[jira] [Commented] (FLINK-7878) Extend the resource type user can define in ResourceSpec

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

[GitHub] flink pull request #5168: [FLINK-8234][flip6] WIP

2017-12-14 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5168#discussion_r157026590 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobExecutionResultHandler.java --- @@ -0,0 +1,107 @@ +/* + * Licensed

[jira] [Commented] (FLINK-8234) Cache JobExecutionResult from finished JobManagerRunners

2017-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16291328#comment-16291328 ] ASF GitHub Bot commented on FLINK-8234: --- Github user GJL commented on a diff in the pull request:

[jira] [Commented] (FLINK-8234) Cache JobExecutionResult from finished JobManagerRunners

2017-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16291325#comment-16291325 ] ASF GitHub Bot commented on FLINK-8234: --- Github user GJL commented on a diff in the pull request:

[GitHub] flink pull request #5168: [FLINK-8234][flip6] WIP

2017-12-14 Thread GJL
GitHub user GJL opened a pull request: https://github.com/apache/flink/pull/5168 [FLINK-8234][flip6] WIP WIP @tillrohrmann You can merge this pull request into a Git repository by running: $ git pull https://github.com/GJL/flink FLINK-8234 Alternatively you can

[jira] [Commented] (FLINK-8234) Cache JobExecutionResult from finished JobManagerRunners

2017-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16291245#comment-16291245 ] ASF GitHub Bot commented on FLINK-8234: --- GitHub user GJL opened a pull request:

[GitHub] flink pull request #5168: [FLINK-8234][flip6] WIP

2017-12-14 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5168#discussion_r157027178 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/util/RestMapperUtils.java --- @@ -33,10 +40,23 @@ objectMapper.enable(

[jira] [Commented] (FLINK-8234) Cache JobExecutionResult from finished JobManagerRunners

2017-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16291332#comment-16291332 ] ASF GitHub Bot commented on FLINK-8234: --- Github user GJL commented on a diff in the pull request:

[GitHub] flink pull request #5168: [FLINK-8234][flip6] WIP

2017-12-14 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5168#discussion_r157026313 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/util/RestMapperUtils.java --- @@ -33,10 +40,23 @@ objectMapper.enable(

[GitHub] flink pull request #5168: [FLINK-8234][flip6] WIP

2017-12-14 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5168#discussion_r157027510 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/JobExecutionResultCache.java --- @@ -0,0 +1,79 @@ +/* + * Licensed to the

[GitHub] flink pull request #5168: [FLINK-8234][flip6] WIP

2017-12-14 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5168#discussion_r157027633 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/messages/JobExecutionResultNotFoundException.java --- @@ -0,0 +1,45 @@ +/* + * Licensed

[jira] [Resolved] (FLINK-7878) Extend the resource type user can define in ResourceSpec

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

[GitHub] flink pull request #5168: [FLINK-8234][flip6] WIP

2017-12-14 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5168#discussion_r157025791 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/JobExecutionResultCache.java --- @@ -0,0 +1,79 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-8234) Cache JobExecutionResult from finished JobManagerRunners

2017-12-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16291336#comment-16291336 ] ASF GitHub Bot commented on FLINK-8234: --- Github user GJL commented on a diff in the pull request:

[jira] [Created] (FLINK-8265) Missing jackson dependency for flink-mesos

2017-12-14 Thread Eron Wright (JIRA)
Eron Wright created FLINK-8265: --- Summary: Missing jackson dependency for flink-mesos Key: FLINK-8265 URL: https://issues.apache.org/jira/browse/FLINK-8265 Project: Flink Issue Type: Bug

  1   2   >