incubator-retired-gearpump.git
4 years ago[GEARPUMP-305][Doc] Use MkDocs plugin to validate html master
manuzhang [Mon, 27 Aug 2018 14:47:34 +0000 (22:47 +0800)] 
[GEARPUMP-305][Doc] Use MkDocs plugin to validate html

Get rid of ruby tools

Author: manuzhang <owenzhang1990@gmail.com>

Closes #252 from manuzhang/html_proofer.

4 years ago[GEARPUMP-305][Doc] Use mkdocs (1.0.1) plugin for templates instead o…
manuzhang [Sun, 26 Aug 2018 13:17:12 +0000 (21:17 +0800)] 
[GEARPUMP-305][Doc] Use mkdocs (1.0.1) plugin for templates instead o…

…f mustache workaround

Author: manuzhang <owenzhang1990@gmail.com>

Closes #251 from manuzhang/improve_doc_build.

4 years ago[GEARPUMP-326] Upgrade Akka to 2.5.13
manuzhang [Mon, 25 Jun 2018 13:45:39 +0000 (21:45 +0800)] 
[GEARPUMP-326] Upgrade Akka to 2.5.13

1. Upgrade Akka
2. Remove akkastream module temporarily

Author: manuzhang <owenzhang1990@gmail.com>

Closes #250 from manuzhang/upgrade_akka_2.5.13.

4 years ago[GEARPUMP-379] Send terminated status to client when an application i…
manuzhang [Sat, 9 Jun 2018 13:42:29 +0000 (21:42 +0800)] 
[GEARPUMP-379] Send terminated status to client when an application i…

…s terminated

Author: manuzhang <owenzhang1990@gmail.com>

Closes #249 from manuzhang/gearpump_379.

4 years ago[GEARPUMP-377] Add TwitterSource and examples
manuzhang [Tue, 8 May 2018 02:22:32 +0000 (10:22 +0800)] 
[GEARPUMP-377] Add TwitterSource and examples

Author: manuzhang <owenzhang1990@gmail.com>

Closes #247 from manuzhang/twitter_source.

4 years agoGEARPUMP-376 Apache Kudu Akka Streaming Sink
Sandish Kumar [Sun, 6 May 2018 07:24:17 +0000 (15:24 +0800)] 
GEARPUMP-376 Apache Kudu Akka Streaming Sink

Author: Sandish Kumar <sany@phdata.io>

Closes #246 from SandishKumarHN/master.

4 years ago[GEARPUMP-373] Don't create hbase configuration at client side
manuzhang [Sun, 29 Apr 2018 11:11:02 +0000 (19:11 +0800)] 
[GEARPUMP-373] Don't create hbase configuration at client side

Author: manuzhang <owenzhang1990@gmail.com>

Closes #244 from manuzhang/hbase.

4 years ago[GEARPUMP-368] Add dedicated trait for commands
karol-brejna-i [Sun, 29 Apr 2018 07:24:11 +0000 (15:24 +0800)] 
[GEARPUMP-368] Add dedicated trait for commands

Author: karol-brejna-i <karol.brejna@intel.com>

Closes #241 from karol-brejna-i/GEARPUMP-368_submit_app_via_ui.

4 years ago[GEARPUMP-339] Fix unknown tag parameter
manuzhang [Sun, 22 Apr 2018 07:35:02 +0000 (15:35 +0800)] 
[GEARPUMP-339] Fix unknown tag parameter

Author: manuzhang <owenzhang1990@gmail.com>

Closes #243 from manuzhang/improve_scaladoc.

4 years ago[GEARPUMP-367] Don't use windowing unnecessarily
manuzhang [Tue, 10 Apr 2018 14:32:12 +0000 (22:32 +0800)] 
[GEARPUMP-367] Don't use windowing unnecessarily

Author: manuzhang <owenzhang1990@gmail.com>

Closes #226 from manuzhang/simplify_dsl.

4 years ago[GEARPUMP-369] Fix configuring number of executors
manuzhang [Thu, 5 Apr 2018 14:57:49 +0000 (22:57 +0800)] 
[GEARPUMP-369] Fix configuring number of executors

Author: manuzhang <owenzhang1990@gmail.com>

Closes #242 from manuzhang/fix_config_executor_num.

4 years ago[GEARPUMP-344] Fix broken links in README
manuzhang [Fri, 16 Mar 2018 05:29:31 +0000 (13:29 +0800)] 
[GEARPUMP-344] Fix broken links in README

Author: manuzhang <owenzhang1990@gmail.com>

Closes #240 from manuzhang/fix_readme.

4 years ago[GEARPUMP-366] Create JarStore dir if not exists on job submit
manuzhang [Fri, 16 Mar 2018 05:28:05 +0000 (13:28 +0800)] 
[GEARPUMP-366] Create JarStore dir if not exists on job submit

Author: manuzhang <owenzhang1990@gmail.com>

Closes #239 from manuzhang/fix_job_submit.

4 years ago[GEARPUMP-350] Fix app clock not started
manuzhang [Wed, 14 Mar 2018 13:31:17 +0000 (21:31 +0800)] 
[GEARPUMP-350] Fix app clock not started

Author: manuzhang <owenzhang1990@gmail.com>

Closes #238 from manuzhang/fix_app_not_started.

4 years ago[GEARPUMP-365]! project upgrade to sbt 0.13.16
kerr [Wed, 14 Feb 2018 09:18:41 +0000 (17:18 +0800)] 
[GEARPUMP-365]! project upgrade to sbt 0.13.16

Be sure to do all of the following to help us incorporate your contribution
quickly and easily:

 - [x] Make sure the commit message is formatted like:
   `[GEARPUMP-<Jira issue #>] Meaningful description of pull request`
 - [x] Make sure tests pass via `sbt clean test`.
 - [x] Make sure old documentation affected by the pull request has been updated and new documentation added for new functionality.

Author: kerr <hepin1989@gmail.com>

Closes #237 from hepin1989/patch-2.

4 years ago[GEARPUMP-361] Build gearpump docker image locally
manuzhang [Sat, 9 Dec 2017 07:38:28 +0000 (15:38 +0800)] 
[GEARPUMP-361] Build gearpump docker image locally

Author: manuzhang <owenzhang1990@gmail.com>

Closes #233 from manuzhang/fix-it.

4 years ago[GEARPUMP-362] Fix bin/gear info shows nothing when there are apps ru…
huafengw [Sat, 28 Oct 2017 05:20:41 +0000 (13:20 +0800)] 
[GEARPUMP-362] Fix bin/gear info shows nothing when there are apps ru…

…nning

Author: huafengw <fvunicorn@gmail.com>

Closes #236 from huafengw/info.

4 years ago[GEARPUMP-359] Fix OutputWatermark advancing logic in Subscription
huafengw [Thu, 26 Oct 2017 22:34:50 +0000 (06:34 +0800)] 
[GEARPUMP-359] Fix OutputWatermark advancing logic in Subscription

Author: huafengw <fvunicorn@gmail.com>

Closes #234 from huafengw/subs.

fix style

4 years ago[GEARPUMP-360] Use alpine-based image for gearpump-runner
karol-brejna-i [Thu, 26 Oct 2017 10:34:55 +0000 (18:34 +0800)] 
[GEARPUMP-360] Use alpine-based image for gearpump-runner

To verify:
1. build the image (`docker build --build-arg HTTP_PROXY=$http_proxy --build-arg HTTPS_PROXY=$https_proxy -t gearpump/gearpump-launcher integrationtest/docker/gearpump/
`)
2. run the master (`docker run -d -h master0 -v /etc/localtime:/etc/localtime:ro -p 8090:8090 -e JAVA_OPTS=-Dgearpump.cluster.masters.0=master0:3000 -v $GEARPUMP_HOME:/opt/gearpump -v /tmp/gearpump:/var/log/gearpump --name master0 gearpump/gearpump-launcher master -ip master0 -port 3000` - please, mind it tries to use the port 8090)
3. run the worker (`docker run -d -h worker0 -v /etc/localtime:/etc/localtime:ro -e JAVA_OPTS=-Dgearpump.cluster.masters.0=master0:3000 -v $GEARPUMP_HOME:/opt/gearpump -v /tmp/gearpump:/var/log/gearpump --link master0 --name worker0 gearpump/gearpump-launcher worker`)
4. verify it works (`docker logs master0`, `docker logs worker0`, open localhost:8090 in the browser)

Author: karol-brejna-i <karol.brejna@intel.com>

Closes #235 from karol-brejna-i/GEARPUMP-360-fix-dockerfile.

4 years ago[GEARPUMP-355] Fix YarnAppMaster address resolution in a kerberized H…
Timea Magyar [Fri, 20 Oct 2017 23:24:13 +0000 (07:24 +0800)] 
[GEARPUMP-355] Fix YarnAppMaster address resolution in a kerberized H…

…adoop/Yarn set-up

Author: Timea Magyar <Timea.Magyar@etas.com>

Closes #231 from titikakatoo/yarn_spnego_authentication.

4 years ago[GEARPUMP-354] Fix the tracking url resolution of a proxied Applicati…
Timea Magyar [Fri, 20 Oct 2017 08:18:56 +0000 (16:18 +0800)] 
[GEARPUMP-354] Fix the tracking url resolution of a proxied Applicati…

…on Master

Be sure to do all of the following to help us incorporate your contribution
quickly and easily:

 - [ ] Make sure the commit message is formatted like:
   `[GEARPUMP-<Jira issue #>] Meaningful description of pull request`
 - [ ] Make sure tests pass via `sbt clean test`.
 - [ ] Make sure old documentation affected by the pull request has been updated and new documentation added for new functionality.

Author: Timea Magyar <Timea.Magyar@etas.com>

Closes #230 from titikakatoo/resolve_app_master.

4 years ago[GEARPUMP-358] Decrease the frequency of watermark calculation
huafengw [Wed, 18 Oct 2017 14:20:51 +0000 (22:20 +0800)] 
[GEARPUMP-358] Decrease the frequency of watermark calculation

Be sure to do all of the following to help us incorporate your contribution
quickly and easily:

 - [ ] Make sure the commit message is formatted like:
   `[GEARPUMP-<Jira issue #>] Meaningful description of pull request`
 - [ ] Make sure tests pass via `sbt clean test`.
 - [ ] Make sure old documentation affected by the pull request has been updated and new documentation added for new functionality.

Author: huafengw <fvunicorn@gmail.com>

Closes #232 from huafengw/regre.

5 years ago[GEARPUMP-349] Optimize Graph topologicalOrderIterator performance
huafengw [Mon, 18 Sep 2017 13:36:08 +0000 (21:36 +0800)] 
[GEARPUMP-349] Optimize Graph topologicalOrderIterator performance

Author: huafengw <fvunicorn@gmail.com>

Closes #223 from huafengw/graph.

5 years ago[GEARPUMP-345] Add getLogger(Class <?>) implementation for Java
Buddhi Ayesha [Wed, 6 Sep 2017 10:51:55 +0000 (18:51 +0800)] 
[GEARPUMP-345] Add getLogger(Class <?>) implementation for Java

Author: Buddhi Ayesha <buddhiayesha.13@cse.mrt.ac.lk>

Closes #224 from buddhiayesha2015/master.

5 years ago[GEARPUMP-348] Allow application total number of retries to be config…
huafengw [Sat, 2 Sep 2017 01:13:25 +0000 (09:13 +0800)] 
[GEARPUMP-348] Allow application total number of retries to be config…

…urable

Author: huafengw <fvunicorn@gmail.com>

Closes #222 from huafengw/restart.

5 years ago[GEARPUMP-217] Add SQL support
Buddhi Ayesha [Wed, 30 Aug 2017 14:00:41 +0000 (22:00 +0800)] 
[GEARPUMP-217] Add SQL support

Author: Buddhi Ayesha <buddhiayesha.13@cse.mrt.ac.lk>
Author: manuzhang <owenzhang1990@gmail.com>

Closes #221 from manuzhang/merge_sql_into_master.

5 years ago[GEARPUMP-343] Fix typo of EmbeddedRuntimeEnvironment
huafengw [Thu, 17 Aug 2017 14:45:39 +0000 (22:45 +0800)] 
[GEARPUMP-343] Fix typo of EmbeddedRuntimeEnvironment

Author: huafengw <fvunicorn@gmail.com>

Closes #215 from huafengw/minor.

5 years ago[GEARPUMP-341] Update processing watermark in DataSinkTask
manuzhang [Wed, 16 Aug 2017 22:34:10 +0000 (06:34 +0800)] 
[GEARPUMP-341] Update processing watermark in DataSinkTask

Author: manuzhang <owenzhang1990@gmail.com>

Closes #214 from manuzhang/fix_datasinktask.

5 years ago[GEARPUMP-339] Add ScalaDoc to window api and impl
manuzhang [Mon, 14 Aug 2017 04:07:06 +0000 (12:07 +0800)] 
[GEARPUMP-339] Add ScalaDoc to window api and impl

Author: manuzhang <owenzhang1990@gmail.com>

Closes #213 from manuzhang/add_window_doc.

5 years ago[GEARPUMP-339] Add ScalaDoc to Streaming DSL
manuzhang [Sun, 6 Aug 2017 22:02:29 +0000 (06:02 +0800)] 
[GEARPUMP-339] Add ScalaDoc to Streaming DSL

Author: manuzhang <owenzhang1990@gmail.com>

Closes #212 from manuzhang/plan_doc.

5 years ago[GEARPUMP-338] Improve time related types and constants
manuzhang [Fri, 4 Aug 2017 02:11:58 +0000 (10:11 +0800)] 
[GEARPUMP-338] Improve time related types and constants

Author: manuzhang <owenzhang1990@gmail.com>

Closes #208 from manuzhang/fix_time.

5 years ago[GEARPUMP-336] Add scalac options and fix warnings
manuzhang [Thu, 3 Aug 2017 12:17:52 +0000 (20:17 +0800)] 
[GEARPUMP-336] Add scalac options and fix warnings

Author: manuzhang <owenzhang1990@gmail.com>

Closes #207 from manuzhang/fix_warnings.

5 years ago[GEARPUMP-335] Set kafka tests log level to ERROR
manuzhang [Wed, 2 Aug 2017 10:10:46 +0000 (18:10 +0800)] 
[GEARPUMP-335] Set kafka tests log level to ERROR

Author: manuzhang <owenzhang1990@gmail.com>

Closes #205 from manuzhang/reduce_logs.

5 years ago[GEARPUMP-334] Fix Java WordCount DSL example
manuzhang [Wed, 2 Aug 2017 09:53:15 +0000 (17:53 +0800)] 
[GEARPUMP-334] Fix Java WordCount DSL example

Author: manuzhang <owenzhang1990@gmail.com>

Closes #204 from manuzhang/fix_wc_java_dsl.

5 years ago[GEARPUMP-333] Fix examples assembling
manuzhang [Wed, 2 Aug 2017 06:20:55 +0000 (14:20 +0800)] 
[GEARPUMP-333] Fix examples assembling

Author: manuzhang <owenzhang1990@gmail.com>

Closes #203 from manuzhang/fix_example_dep.

5 years ago[GEARPUMP-331] Allow applications to be run in IDE
huafengw [Mon, 31 Jul 2017 06:36:38 +0000 (14:36 +0800)] 
[GEARPUMP-331] Allow applications to be run in IDE

Author: huafengw <fvunicorn@gmail.com>

Closes #202 from huafengw/GP331.

5 years ago[GEARPUMP-330] Allow examples to run in `sbt run` and Intellij 201/head
manuzhang [Wed, 26 Jul 2017 02:28:25 +0000 (10:28 +0800)] 
[GEARPUMP-330] Allow examples to run in `sbt run` and Intellij

Author: manuzhang <owenzhang1990@gmail.com>

Closes #200 from manuzhang/run_examples_in_ide.

5 years ago[GEARPUMP-328] FetchThread fetchSleepMS from Int to Long
darionyaphet [Tue, 25 Jul 2017 05:23:14 +0000 (13:23 +0800)] 
[GEARPUMP-328] FetchThread fetchSleepMS from Int to Long

currently *KafkaConfig.FETCH_SLEEP_MS_CONFIG* is a INT parameter , move it into a LONG parameter is better .

Author: darionyaphet <darion.yaphet@gmail.com>

Closes #199 from darionyaphet/GEARPUMP-328.

5 years ago[GEARPUMP-327] Put jarstore and logs under "gearpump.home"
manuzhang [Fri, 21 Jul 2017 01:42:59 +0000 (09:42 +0800)] 
[GEARPUMP-327] Put jarstore and logs under "gearpump.home"

Author: manuzhang <owenzhang1990@gmail.com>

Closes #197 from manuzhang/fix_jarstore_logs.

5 years ago[GEARPUMP-322] Fix multiple SLF4J bindings on classpath
huafengw [Thu, 20 Jul 2017 08:34:50 +0000 (16:34 +0800)] 
[GEARPUMP-322] Fix multiple SLF4J bindings on classpath

Author: huafengw <fvunicorn@gmail.com>

Closes #196 from huafengw/fix322.

5 years ago[GEARPUMP-325] Fix license issues
manuzhang [Mon, 17 Jul 2017 08:02:09 +0000 (16:02 +0800)] 
[GEARPUMP-325] Fix license issues

Author: manuzhang <owenzhang1990@gmail.com>

Closes #194 from manuzhang/fix_licenses.

5 years agoBump up version to 0.8.5-SNAPSHOT
manuzhang [Fri, 14 Jul 2017 05:26:27 +0000 (13:26 +0800)] 
Bump up version to 0.8.5-SNAPSHOT

Author: manuzhang <owenzhang1990@gmail.com>

Closes #193 from manuzhang/bump_up_version.

5 years ago[GEARPUMP-319] Support Sorted Set in Redis
darionyaphet [Tue, 27 Jun 2017 03:58:44 +0000 (11:58 +0800)] 
[GEARPUMP-319] Support Sorted Set in Redis

Sorted Set is similar with Set in Redis with unique values .

Each element storage in Sorted Set is associated with a score that is use to sort the element in order .

Author: darionyaphet <darion.yaphet@gmail.com>

Closes #191 from darionyaphet/GEARPUMP-319.

5 years ago[GEARPUMP-320] Handle stashed messages after onStart
manuzhang [Fri, 23 Jun 2017 01:57:43 +0000 (09:57 +0800)] 
[GEARPUMP-320] Handle stashed messages after onStart

Author: manuzhang <owenzhang1990@gmail.com>

Closes #192 from manuzhang/fix_start.

5 years ago[GEARPUMP-318] Exclude maven-plugin-api dependency from sbt-assembly
manuzhang [Wed, 21 Jun 2017 01:45:02 +0000 (09:45 +0800)] 
[GEARPUMP-318] Exclude maven-plugin-api dependency from sbt-assembly

Be sure to do all of the following to help us incorporate your contribution
quickly and easily:

Author: manuzhang <owenzhang1990@gmail.com>

Closes #188 from manuzhang/sbt-assembly.

5 years ago[GEARPUMP-317] Fix Task minClock
manuzhang [Mon, 19 Jun 2017 03:46:32 +0000 (11:46 +0800)] 
[GEARPUMP-317] Fix Task minClock

Author: manuzhang <owenzhang1990@gmail.com>

Closes #187 from manuzhang/watermark.

5 years ago[GEARPUMP-316] Decouple groupBy from window
manuzhang [Wed, 14 Jun 2017 02:05:32 +0000 (10:05 +0800)] 
[GEARPUMP-316] Decouple groupBy from window

This includes major changes to `Stream DSL` as following

1. Decouple groupBy from window. Previously, `window` is required before `groupBy` now users can write `window.groupBy` or `groupBy.window`, even `window.groupBy.window`.
2. Correspondingly,  `GroupByOp` is split into `GroupByOp` and `WindowOp`. When chaining `Op`s, there will be intermediate `Op`s such as `WindowTransformOp`, `TransformWindowTransformOp` generated before they can be translated into a function (wrapping UDF).
3. The function will be run by a `WindowRunner` in either `DataSourceTask`, `GroupByTask` or `TransformTask`. Messages are  windowed, processed and triggered as defined by window function and triggers.
4. A Stream will implicitly in a global window. Its window only changes when user explicitly defines another window. Hence, `groupBy` equals to `globalWindows.groupBy.globalWindows`, `groupBy.fixedWindows` equals to `globalWindows.groupBy.fixedWindows`.
5. Bug fixes for output time and `Watermark.MAX`

Author: manuzhang <owenzhang1990@gmail.com>

Closes #186 from manuzhang/window.

5 years ago[GEARPUMP-315] Add GlobalWindows and implement groupBy on it
manuzhang [Sat, 27 May 2017 07:39:00 +0000 (15:39 +0800)] 
[GEARPUMP-315] Add GlobalWindows and implement groupBy on it

Author: manuzhang <owenzhang1990@gmail.com>

Closes #185 from manuzhang/global_window.

5 years ago[GEARPUMP-308] Fix TransformTask output time
manuzhang [Fri, 19 May 2017 02:46:32 +0000 (10:46 +0800)] 
[GEARPUMP-308] Fix TransformTask output time

Author: manuzhang <owenzhang1990@gmail.com>

Closes #184 from manuzhang/fix_source_output_time.

5 years ago[GEARPUMP-312] Add Message trait and DefaultMessage impl
manuzhang [Thu, 18 May 2017 06:02:51 +0000 (14:02 +0800)] 
[GEARPUMP-312] Add Message trait and DefaultMessage impl

Author: manuzhang <owenzhang1990@gmail.com>

Closes #183 from manuzhang/message_trait.

5 years ago[GEARPUMP-307] Fix TransformTask$Transform invocation
manuzhang [Wed, 10 May 2017 04:58:23 +0000 (12:58 +0800)] 
[GEARPUMP-307] Fix TransformTask$Transform invocation

Author: manuzhang <owenzhang1990@gmail.com>

Closes #182 from manuzhang/fix_transform.

5 years ago[GEARPUMP-303] add a RabbitMQ sink to integrate with gearpump
vinoyang [Mon, 8 May 2017 07:20:01 +0000 (15:20 +0800)] 
[GEARPUMP-303] add a RabbitMQ sink to integrate with gearpump

Author: vinoyang <yanghua1127@gmail.com>

Closes #180 from yanghua/dev.

5 years ago[GEARPUMP-305] Add Internals section to docs
manuzhang [Mon, 8 May 2017 07:17:22 +0000 (15:17 +0800)] 
[GEARPUMP-305] Add Internals section to docs

Author: manuzhang <owenzhang1990@gmail.com>

Closes #181 from manuzhang/doc.

5 years ago[GEARPUMP-297] Make urls relative
karol brejna [Fri, 28 Apr 2017 08:45:44 +0000 (16:45 +0800)] 
[GEARPUMP-297] Make urls relative

Author: karol brejna <karol.brejna@intel.com>

Closes #177 from karol-brejna-i/GEARPUMP-297-fix-docker-links.

5 years ago[GEARPUMP-295] Fix the failure of getting stalling tasks from clock s…
huafengw [Thu, 20 Apr 2017 07:07:04 +0000 (15:07 +0800)] 
[GEARPUMP-295] Fix the failure of getting stalling tasks from clock s…

…ervice

Author: huafengw <fvunicorn@gmail.com>

Closes #174 from huafengw/stalling.

5 years agoRemove release notes for http://notes.implicit.ly
manuzhang [Thu, 20 Apr 2017 03:46:17 +0000 (11:46 +0800)] 
Remove release notes for http://notes.implicit.ly

Author: manuzhang <owenzhang1990@gmail.com>

Closes #176 from manuzhang/remove_notes.

5 years agoBump version to 0.8.4-SNAPSHOT
karol brejna [Thu, 20 Apr 2017 01:18:22 +0000 (09:18 +0800)] 
Bump version to 0.8.4-SNAPSHOT

Author: karol brejna <karol.brejna@intel.com>

Closes #175 from karol-brejna-i/GEARPUMP-294-version-bump.

5 years ago[GEARPUMP-294] Create RC1 for 0.8.3 release 0.8.3
karol brejna [Wed, 5 Apr 2017 12:12:12 +0000 (20:12 +0800)] 
[GEARPUMP-294] Create RC1 for 0.8.3 release

Author: karol brejna <karol.brejna@intel.com>

Closes #173 from karol-brejna-i/GEARPUMP-294.

5 years ago[GEARPUMP-293] Remove CHANGELOG.md 0.8.3-RC0
manuzhang [Fri, 17 Mar 2017 10:40:01 +0000 (18:40 +0800)] 
[GEARPUMP-293] Remove CHANGELOG.md

Author: manuzhang <owenzhang1990@gmail.com>

Closes #172 from manuzhang/remove_changelog.

5 years ago[GEARPUMP-292] Update wordcount example in the doc
manuzhang [Fri, 17 Mar 2017 10:32:40 +0000 (18:32 +0800)] 
[GEARPUMP-292] Update wordcount example in the doc

Author: manuzhang <owenzhang1990@gmail.com>

Closes #171 from manuzhang/update_example.

5 years ago[GEARPUMP-291] Refactor TaskActor
manuzhang [Fri, 10 Mar 2017 15:02:18 +0000 (23:02 +0800)] 
[GEARPUMP-291] Refactor TaskActor

Author: manuzhang <owenzhang1990@gmail.com>

Closes #170 from manuzhang/refactor_task.

5 years ago[GEARPUMP-285] Fix false alarm of shutting down executor time out
huafengw [Fri, 10 Mar 2017 07:58:28 +0000 (15:58 +0800)] 
[GEARPUMP-285] Fix false alarm of shutting down executor time out

Author: huafengw <fvunicorn@gmail.com>

Closes #169 from huafengw/timeout.

5 years ago[GEARPUMP-290] Setup FunctionRunner properly
manuzhang [Tue, 7 Mar 2017 11:24:01 +0000 (19:24 +0800)] 
[GEARPUMP-290] Setup FunctionRunner properly

Author: manuzhang <owenzhang1990@gmail.com>

Closes #168 from manuzhang/GEARPUMP-290.

5 years ago[GEARPUMP-289] Add FoldFunction
manuzhang [Mon, 6 Mar 2017 14:14:44 +0000 (22:14 +0800)] 
[GEARPUMP-289] Add FoldFunction

Author: manuzhang <owenzhang1990@gmail.com>

Closes #167 from manuzhang/fold.

5 years ago[GEARPUMP-288] Skip getAcyclicCopy on acyclic graph
manuzhang [Fri, 3 Mar 2017 13:07:28 +0000 (21:07 +0800)] 
[GEARPUMP-288] Skip getAcyclicCopy on acyclic graph

Author: manuzhang <owenzhang1990@gmail.com>

Closes #166 from manuzhang/GEARPUMP-288.

5 years ago[GEARPUMP-287] Trigger data process on watermark
manuzhang [Thu, 2 Mar 2017 05:54:33 +0000 (13:54 +0800)] 
[GEARPUMP-287] Trigger data process on watermark

Author: manuzhang <owenzhang1990@gmail.com>

Closes #165 from manuzhang/GEARPUMP-287.

5 years ago[GEARPUMP-279] Fix akka-streams test examples
Kam Kasravi [Thu, 2 Mar 2017 05:46:23 +0000 (13:46 +0800)] 
[GEARPUMP-279] Fix akka-streams test examples

Author: Kam Kasravi <kamkasravi@yahoo.com>

Closes #163 from kkasravi/GEARPUMP-279.

5 years ago[GEARPUMP-281] Using new version of docker images for integration tests
karol brejna [Wed, 1 Mar 2017 13:38:28 +0000 (21:38 +0800)] 
[GEARPUMP-281] Using new version of docker images for integration tests

Closes #162 from karol-brejna-i/GEARPUMP-281.

5 years ago[GEARPUMP-283] Return app exception to client
manuzhang [Tue, 28 Feb 2017 03:00:49 +0000 (11:00 +0800)] 
[GEARPUMP-283] Return app exception to client

Author: manuzhang <owenzhang1990@gmail.com>

Closes #161 from manuzhang/GEARPUMP-283.

5 years ago[GEARPUMP-286] Fix window and group implementation in WindowRunner
manuzhang [Tue, 28 Feb 2017 02:09:00 +0000 (10:09 +0800)] 
[GEARPUMP-286] Fix window and group implementation in WindowRunner

Be sure to do all of the following to help us incorporate your contribution
quickly and easily:

 - [x] Make sure the commit message is formatted like:
   `[GEARPUMP-<Jira issue #>] Meaningful description of pull request`
 - [x] Make sure tests pass via `sbt clean test`.
 - [x] Make sure old documentation affected by the pull request has been updated and new documentation added for new functionality.

Author: manuzhang <owenzhang1990@gmail.com>

Closes #164 from manuzhang/GEARPUMP-286.

5 years ago[GEARPUMP-282] Allow user to configure wait duration for a running app
huafengw [Fri, 24 Feb 2017 11:37:32 +0000 (19:37 +0800)] 
[GEARPUMP-282] Allow user to configure wait duration for a running app

Author: huafengw <fvunicorn@gmail.com>

Closes #160 from huafengw/fix282.

5 years ago[GEARPUMP-280] Set MAX_TIME_MILLIS to Long.MaxValue minus 1
manuzhang [Fri, 24 Feb 2017 04:43:46 +0000 (12:43 +0800)] 
[GEARPUMP-280] Set MAX_TIME_MILLIS to Long.MaxValue minus 1

Author: manuzhang <owenzhang1990@gmail.com>

Closes #159 from manuzhang/GEARPUMP-280.

5 years ago[GEARPUMP-236] Upgrade sbt-assembly version to fix java.lang.VerifyError
karol brejna [Thu, 23 Feb 2017 12:34:17 +0000 (20:34 +0800)] 
[GEARPUMP-236] Upgrade sbt-assembly version to fix java.lang.VerifyError

Author: karol brejna <karol.brejna@intel.com>

Closes #157 from karol-brejna-i/GEARPUMP-236.

5 years ago[GEARPUMP-277] Allow user to configure retry times on app failure
huafengw [Wed, 22 Feb 2017 08:28:33 +0000 (16:28 +0800)] 
[GEARPUMP-277] Allow user to configure retry times on app failure

Author: huafengw <fvunicorn@gmail.com>

Closes #156 from huafengw/fix277.

5 years ago[GEARPUMP-272] Fix app submit exception when no arguments provided
manuzhang [Tue, 21 Feb 2017 09:30:37 +0000 (17:30 +0800)] 
[GEARPUMP-272] Fix app submit exception when no arguments provided

5 years ago[GEARPUMP-278] Check for null before casting stored start clock
manuzhang [Tue, 21 Feb 2017 02:35:02 +0000 (10:35 +0800)] 
[GEARPUMP-278] Check for null before casting stored start clock

Author: manuzhang <owenzhang1990@gmail.com>

Closes #154 from manuzhang/app_data_store.

5 years ago[GEARPUMP-276] Remove ununsed 'shade' folder
huafengw [Tue, 21 Feb 2017 02:15:49 +0000 (10:15 +0800)] 
[GEARPUMP-276] Remove ununsed 'shade' folder

Author: huafengw <fvunicorn@gmail.com>

Closes #153 from huafengw/remove_shade.

5 years ago[GEARPUMP-274] Set lower bound of time to Long.MinValue milliseconds
manuzhang [Tue, 21 Feb 2017 01:45:42 +0000 (09:45 +0800)] 
[GEARPUMP-274] Set lower bound of time to Long.MinValue milliseconds

Author: manuzhang <owenzhang1990@gmail.com>

Closes #151 from manuzhang/time.

5 years ago[GEARPUMP-275] Remove obsolete 'stockcrawler' and 'transport'
huafengw [Tue, 21 Feb 2017 01:34:19 +0000 (09:34 +0800)] 
[GEARPUMP-275] Remove obsolete 'stockcrawler' and 'transport'

Author: huafengw <fvunicorn@gmail.com>

Closes #152 from huafengw/remove.

5 years ago[GEARPUMP-273] Remove java in travis language setting
manuzhang [Thu, 16 Feb 2017 12:42:13 +0000 (20:42 +0800)] 
[GEARPUMP-273] Remove java in travis language setting

Author: manuzhang <owenzhang1990@gmail.com>

Closes #150 from manuzhang/travis.

5 years ago[DOC] Add Karol Brejna to contributors
manuzhang [Thu, 16 Feb 2017 11:46:26 +0000 (19:46 +0800)] 
[DOC] Add Karol Brejna to contributors

Author: manuzhang <owenzhang1990@gmail.com>

Closes #149 from manuzhang/doc.

5 years ago[GEARPUMP-272] Don't warn on classname as first argument
manuzhang [Tue, 14 Feb 2017 08:16:21 +0000 (16:16 +0800)] 
[GEARPUMP-272] Don't warn on classname as first argument

Author: manuzhang <owenzhang1990@gmail.com>

Closes #148 from manuzhang/app_submit.

5 years ago[GEARPUMP-271] Don't count self messages in receiveThroughput
manuzhang [Mon, 13 Feb 2017 22:10:39 +0000 (06:10 +0800)] 
[GEARPUMP-271] Don't count self messages in receiveThroughput

Author: manuzhang <owenzhang1990@gmail.com>

Closes #147 from manuzhang/source.

5 years ago[GEARPUMP-270] Disable 'Kill' button when applciation is not running
huafengw [Mon, 13 Feb 2017 04:44:04 +0000 (12:44 +0800)] 
[GEARPUMP-270] Disable 'Kill' button when applciation is not running

Author: huafengw <fvunicorn@gmail.com>

Closes #146 from huafengw/fix270.

5 years ago[GEARPUMP-53] Output client logs to "logs/gearpump-client.log"
manuzhang [Fri, 10 Feb 2017 11:29:28 +0000 (19:29 +0800)] 
[GEARPUMP-53] Output client logs to "logs/gearpump-client.log"

Author: manuzhang <owenzhang1990@gmail.com>

Closes #145 from manuzhang/log.

5 years ago[GEARPUMP-103] Support finite stream
manuzhang [Fri, 10 Feb 2017 02:46:39 +0000 (10:46 +0800)] 
[GEARPUMP-103] Support finite stream

Author: manuzhang <owenzhang1990@gmail.com>

Closes #143 from manuzhang/finite_stream.

5 years ago[DOC] Fix image link in README
manuzhang [Fri, 10 Feb 2017 01:56:41 +0000 (09:56 +0800)] 
[DOC] Fix image link in README

Author: manuzhang <owenzhang1990@gmail.com>

Closes #144 from manuzhang/doc.

5 years ago[GEARPUMP-268] Accept java.time.Instant in Message
manuzhang [Thu, 9 Feb 2017 12:26:43 +0000 (20:26 +0800)] 
[GEARPUMP-268] Accept java.time.Instant in Message

Author: manuzhang <owenzhang1990@gmail.com>

Closes #142 from manuzhang/instant.

5 years ago[GEARPUMP-266] Add docker file
manuzhang [Wed, 8 Feb 2017 08:45:10 +0000 (16:45 +0800)] 
[GEARPUMP-266] Add docker file

Author: manuzhang <owenzhang1990@gmail.com>

Closes #141 from manuzhang/docker.

5 years ago[GEARPUMP-23] Add SessionWindows
manuzhang [Tue, 7 Feb 2017 13:21:42 +0000 (21:21 +0800)] 
[GEARPUMP-23] Add SessionWindows

Author: manuzhang <owenzhang1990@gmail.com>

Closes #140 from manuzhang/sessions.

5 years ago[GEARPUMP-23] Do not group by windows in GroupByPartitioner
manuzhang [Tue, 7 Feb 2017 12:32:25 +0000 (20:32 +0800)] 
[GEARPUMP-23] Do not group by windows in GroupByPartitioner

Author: manuzhang <owenzhang1990@gmail.com>

Closes #139 from manuzhang/group_by.

5 years ago[GEARPUMP-23] Refactor Window DSL
manuzhang [Mon, 6 Feb 2017 13:00:41 +0000 (21:00 +0800)] 
[GEARPUMP-23] Refactor Window DSL

Be sure to do all of the following to help us incorporate your contribution
quickly and easily:

 - [x] Make sure the commit message is formatted like:
   `[GEARPUMP-<Jira issue #>] Meaningful description of pull request`
 - [x] Make sure tests pass via `sbt clean test`.
 - [x] Make sure old documentation affected by the pull request has been updated and new documentation added for new functionality.

Author: manuzhang <owenzhang1990@gmail.com>

Closes #138 from manuzhang/window_dsl.

5 years ago[GEARPUMP-252] Return application status to client
huafengw [Tue, 24 Jan 2017 04:17:19 +0000 (12:17 +0800)] 
[GEARPUMP-252] Return application status to client

Author: huafengw <fvunicorn@gmail.com>

Closes #134 from huafengw/fix265.

5 years ago[GERAPUMP-22] Merge akka-streams branch into master
manuzhang [Fri, 20 Jan 2017 12:42:42 +0000 (20:42 +0800)] 
[GERAPUMP-22] Merge akka-streams branch into master

Author: manuzhang <owenzhang1990@gmail.com>
Author: Kam Kasravi <kamkasravi@yahoo.com>

Closes #137 from manuzhang/akka-streams.

5 years ago[GEARPUMP-213] Fix EditOnGitHub link and rename docs/docs to docs/con…
manuzhang [Thu, 19 Jan 2017 07:20:51 +0000 (15:20 +0800)] 
[GEARPUMP-213] Fix EditOnGitHub link and rename docs/docs to docs/con…

…tents

Author: manuzhang <owenzhang1990@gmail.com>

Closes #135 from manuzhang/doc.

5 years ago[GEARPUMP-252] Return meaningful result than app id when submitting application in...
huafengw [Wed, 18 Jan 2017 05:43:21 +0000 (13:43 +0800)] 
[GEARPUMP-252] Return meaningful result than app id when submitting application in ClientContext

Author: huafengw <fvunicorn@gmail.com>

Closes #133 from huafengw/refactorClient.

5 years ago[GEARPUMP-262] Invoke setup/teardown methods of SingleInputFunction i…
manuzhang [Sat, 14 Jan 2017 11:56:17 +0000 (19:56 +0800)] 
[GEARPUMP-262] Invoke setup/teardown methods of SingleInputFunction i…

…n all tasks

Author: manuzhang <owenzhang1990@gmail.com>

Closes #132 from manuzhang/setup_teardown.

5 years ago[GEARPUMP-262] Add setup and teardown to user defined functions
manuzhang [Fri, 13 Jan 2017 09:11:54 +0000 (17:11 +0800)] 
[GEARPUMP-262] Add setup and teardown to user defined functions

Author: manuzhang <owenzhang1990@gmail.com>

Closes #131 from manuzhang/setup_teardown.

5 years ago[GEARPUMP-261] Translate ChainableOp to Processor of TransformTask
manuzhang [Mon, 9 Jan 2017 00:57:02 +0000 (08:57 +0800)] 
[GEARPUMP-261] Translate ChainableOp to Processor of TransformTask

Be sure to do all of the following to help us incorporate your contribution
quickly and easily:

 - [x] Make sure the commit message is formatted like:
   `[GEARPUMP-<Jira issue #>] Meaningful description of pull request`
 - [x] Make sure tests pass via `sbt clean test`.
 - [x] Make sure old documentation affected by the pull request has been updated and new documentation added for new functionality.

Author: manuzhang <owenzhang1990@gmail.com>

Closes #130 from manuzhang/chainable_op.

5 years ago[GEARPUMP-259] fix integration test
huafengw [Fri, 6 Jan 2017 08:18:06 +0000 (16:18 +0800)] 
[GEARPUMP-259] fix integration test

Be sure to do all of the following to help us incorporate your contribution
quickly and easily:

 - [x] Make sure the commit message is formatted like:
   `[GEARPUMP-<Jira issue #>] Meaningful description of pull request`
 - [ ] Make sure tests pass via `sbt clean test`.
 - [x] Make sure old documentation affected by the pull request has been updated and new documentation added for new functionality.

Author: huafengw <fvunicorn@gmail.com>

Closes #129 from huafengw/fix259.