[
https://issues.apache.org/jira/browse/FLINK-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14936625#comment-14936625
]
ASF GitHub Bot commented on FLINK-2613:
---------------------------------------
GitHub user nikste reopened a pull request:
https://github.com/apache/flink/pull/1106
[FLINK-2613] Print usage information for Scala Shell
changed startup of scala shell
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/nikste/flink FLINK-2613-enhanced-help-message
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/1106.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #1106
----
commit 7e20299c4e2d9cc78c36f90bdf0acdbaf72062b0
Author: Stephan Ewen <[email protected]>
Date: 2015-09-23T10:05:54Z
[FLINK-2753] [streaming] [api breaking] Add first parts of new window API
for key grouped windows
This follows the API design outlined in
https://cwiki.apache.org/confluence/display/FLINK/Streams+and+Operations+on+Streams
This is API breaking because it adds new generic type parameters to Java
and Scala classes, breaking binary compatibility.
commit a606c4a9e83e54397c88a70ea80a00e32ca61a93
Author: Aljoscha Krettek <[email protected]>
Date: 2015-09-24T14:30:29Z
Fix some typos and naming inconsistencies in new Windowing Code
commit 05d2138f081ff5fa274dab571b9327f96be693aa
Author: Aljoscha Krettek <[email protected]>
Date: 2015-09-24T14:33:09Z
Move window operators and tests to windowing package
The api package is also called windowing, this harmonizes the package
names.
commit 86c45bfa2c760ca99741fa866f777730514c7986
Author: Aljoscha Krettek <[email protected]>
Date: 2015-09-24T14:40:46Z
Harmonize generic parameter names in Stream API classes
commit 6610caeca4093fced35d478ffc596f935912b4c1
Author: Aljoscha Krettek <[email protected]>
Date: 2015-09-24T15:39:19Z
Add Window parameter to KeyedWindowFunction, move to package windowing
commit bfaad37c0aa8ac43a282a8c9cb2e0d64fdf22f72
Author: Aljoscha Krettek <[email protected]>
Date: 2015-09-24T15:42:15Z
Add Count and Delta WindowPolicy
commit 3be2dc1aaaeae4cbbfaecaf4998a64f1199260eb
Author: Aljoscha Krettek <[email protected]>
Date: 2015-09-25T09:34:10Z
Move delta window functions to package functions.windowing.delta
commit dd51c97741b336d3a11e319183537eef864a84fd
Author: Aljoscha Krettek <[email protected]>
Date: 2015-09-25T10:27:35Z
[FLINK-2677] Add a general-purpose keyed-window operator
commit 0f17755766f2c4ada37bb196981c7dc01016f73c
Author: Maximilian Michels <[email protected]>
Date: 2015-09-28T18:07:18Z
[hotfix][streaming] correct return type of execute(..) method
commit 0b4dc067fee82654fae3292bf6bf7d59157bf5c0
Author: vasia <[email protected]>
Date: 2015-09-24T20:08:10Z
[FLINK-2561] [gelly] add missing methods to Graph:
add-remove edges/vertices, difference, graph creation methods,
validate, getTriplets. Add missing utility mappers.
commit 9e0284efa90561c88b1bc829b800d89e84477caa
Author: vasia <[email protected]>
Date: 2015-09-24T21:31:38Z
[FLINK-2561] [gelly] convert existing tests to use collect instead of files;
add tests for newly added operations.
Add completeness test: fromCsvReader method is missing.
commit 233dab497577f0a9443f772bb10390f6dcc005f1
Author: vasia <[email protected]>
Date: 2015-09-25T09:20:15Z
[FLINK-2561] [gelly] add GraphMetrics Scala example
This closes #1183
commit 8d2289ea6981598ab4d2817192b3f171aa9d414d
Author: Rerngvit Yanggratoke <[email protected]>
Date: 2015-09-28T18:34:46Z
[FLINK-2768] [docs] Fix wrong java version requirement in quickstart (1.6
-> 1.7 and 6.x -> 7.x)
This closes #1188
commit 3b8b4f0f8c0600dc851d676ce1bd7f5ab81cb64f
Author: Ufuk Celebi <[email protected]>
Date: 2015-09-26T12:12:20Z
[FLINK-2769] [dashboard] Remove hard coded job server URL
This closes #1185
commit 40cbf7e4b038c945916fa8843b60bd4a59a4ae31
Author: Fabian Hueske <[email protected]>
Date: 2015-09-25T09:47:27Z
[FLINK-2756] [scripts] Fix start/stop scripts for paths with spaces
This closes #1182
commit e727355e42bd0ad7d403aee703aaf33a68a839d2
Author: Greg Hogan <[email protected]>
Date: 2015-09-21T19:14:09Z
[FLINK-2723] [core] CopyableValue method to copy into new instance
This closes #1169
commit 68912126d73b92a07d15ec3f21f9ac922744fb45
Author: chengxiang li <[email protected]>
Date: 2015-09-24T03:20:10Z
[FLINK-2754] Fixed FixedLengthRecordSorter write to multi memory pages
issue and add more unit tests.
This closes #1178
commit 0a8df6d513fa59d650ff875bdf3a1613d0f14af5
Author: Greg Hogan <[email protected]>
Date: 2015-09-10T13:35:39Z
[FLINK-2653] [runtime] Enable object reuse in MergeIterator
This closes #1115
commit 16afb8ec66a2a07733b9090bffe96af1e913bb63
Author: Sachin Goel <[email protected]>
Date: 2015-09-25T08:13:45Z
[FLINK-2761] [scala-shell] Prevent creation of new environment in Scala
Shell
This closes #1180
commit af477563eb1acaab74da1a508c7e5fa37339c206
Author: Stephan Ewen <[email protected]>
Date: 2015-09-29T12:07:01Z
[FLINK-2763] [runtime] Fix hash table spilling partition selection.
commit bb899f708b536d1056d106bf131e67d9f1e545c7
Author: Liang Chen <[email protected]>
Date: 2015-09-29T15:53:02Z
[FLINK-2777] [docs] Fix Scala API description in programming_guide.html
def createLocalEnvironment(parallelism: Int =
Runtime.getRuntime.availableProcessors()))
//issue1: In the end, there is a extra ")"
def createRemoteEnvironment(host: String, port: String, jarFiles: String*)
def createRemoteEnvironment(host: String, port: String, parallelism: Int,
jarFiles: String*)
//issue2: the parameter of port should be "Int", not "String"
This closes #1193
commit 2598709fa3e011620f980f93dccffa0e687cac8d
Author: chengxiang li <[email protected]>
Date: 2015-09-23T09:42:03Z
[FLINK-2754] Add a new module for micro benchmark.
This closes #1177
commit 136347da8b555475d2ee3e33ab763a73ec827b3b
Author: hsaputra <[email protected]>
Date: 2015-09-29T22:02:00Z
[FLINK-2775] [CLEANUP] Cleanup code as part of theme to be more consistent
on Utils classes
As part of continuing theme and effort to help make the code more
consistent, adding cleanup to Utils classes:
-) Add final class modifier to the XXXUtils and XXXUtil classes to make
sure can not be extended.
-) Add missing Javadoc header classs to some public classes.
-) Add private constructor to Utils classes to avoid instantiation.
-) Remove unused
test/java/org/apache/flink/test/recordJobs/util/ConfigUtils.java class
Author: hsaputra <[email protected]>
Closes #1189 from hsaputra/add_missing_javadocs_class and squashes the
following commits:
0dfba19 [hsaputra] Cleanup code as part of theme to be more consistent: -)
Add final class modifier to the XXXUtils and XXXUtil classes to make sure could
not be extended. -) Add missing Javadoc header classs to some public classes.
-) Add private constructor to Utils classes to avoid instantiation. -) Remove
unused test/java/org/apache/flink/test/recordJobs/util/ConfigUtils.java class
commit 622c1be8c61c3a9a37c30454c717c99982edd236
Author: mjsax <[email protected]>
Date: 2015-09-23T14:21:29Z
[FLINK-2764] [WebClient] WebClient cannot display multiple Jobs
This closes #1181
commit 2ca243f0ce5fe39e75300c608ab25373a7b30785
Author: nikste <[email protected]>
Date: 2015-09-29T07:15:04Z
renamed files
commit 5f8d06b9fe175b3dad9b8cd7bc58eaf7eb373c48
Author: nikste <[email protected]>
Date: 2015-09-29T07:50:17Z
[FLINK-2613] Print usage information for Scala Shell
changed startup of scala shell
user has to specify local or remote mode explicitly now.
----
> Print usage information for Scala Shell
> ---------------------------------------
>
> Key: FLINK-2613
> URL: https://issues.apache.org/jira/browse/FLINK-2613
> Project: Flink
> Issue Type: Improvement
> Components: Scala Shell
> Affects Versions: 0.10
> Reporter: Maximilian Michels
> Assignee: Nikolaas Steenbergen
> Priority: Minor
> Labels: starter
> Fix For: 0.10
>
>
> The Scala Shell startup script starts a {{FlinkMiniCluster}} by default if
> invoked with no arguments.
> We should add a {{--help}} or {{-h}} option to make it easier for people to
> find out how to configure remote execution. Alternatively, we could print a
> notice on the local startup explaining how to start the shell in remote mode.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
