Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/247
+1
---
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/247
What will happen if the app has multiple source tasks? Will each task have
the same output?
---
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/244
+1
---
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/243
+1
---
Github user huafengw closed the pull request at:
https://github.com/apache/incubator-gearpump/pull/227
---
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/240
+1
---
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/239
+1
---
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/238
+1
---
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/233
+1
---
GitHub user huafengw opened a pull request:
https://github.com/apache/incubator-gearpump/pull/236
[GEARPUMP-362] Fix bin/gear info shows nothing when there are apps ruâ¦
â¦nning
Be sure to do all of the following to help us incorporate your contribution
quickly
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/233
1. I have to build with explicit proxies like
`docker build --build-arg HTTP_PROXY=... --build-arg HTTPS_PROXY=...`.
If not, building step
`fetch
http://dl
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/227#discussion_r147065810
--- Diff:
streaming/src/main/scala/org/apache/gearpump/streaming/task/TaskActor.scala ---
@@ -361,10 +358,11 @@ class TaskActor
GitHub user huafengw opened a pull request:
https://github.com/apache/incubator-gearpump/pull/234
[GEARPUMP-359] Fix OutputWatermark advancing logic in Subscription
Be sure to do all of the following to help us incorporate your contribution
quickly and easily
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/233
Verified on centos, the updated image can be launched successfully.
---
GitHub user huafengw opened a pull request:
https://github.com/apache/incubator-gearpump/pull/232
[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
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/231
Hi @titikakatoo, thanks for your response. I'd like to know how you set up
your cluster. I just got a single-node secured yarn cluster but found the
command you posted goes well
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/231
Hi @titikakatoo , thanks for your contribution!
Can you briefly describe how to reproduce the problem you found? I'm
setting up a secured cluster and try to verify your pull request
GitHub user huafengw opened a pull request:
https://github.com/apache/incubator-gearpump/pull/227
[GEARPUMP-350] Fix the not started app clock
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the commit
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/227
Verified streaming examples including complex dag, SOL, word count dsl and
wordcount java.
---
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/226#discussion_r141637090
--- Diff:
streaming/src/main/scala/org/apache/gearpump/streaming/dsl/window/impl/WindowRunner.scala
---
@@ -73,6 +73,25 @@ case class AndThen
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/223#discussion_r139345072
--- Diff: core/src/main/scala/org/apache/gearpump/util/Graph.scala ---
@@ -318,12 +360,8 @@ class Graph[N, E](vertexList: List[N], edgeList
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/223#discussion_r138880775
--- Diff: core/src/main/scala/org/apache/gearpump/util/Graph.scala ---
@@ -81,28 +86,35 @@ class Graph[N, E](vertexList: List[N], edgeList
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/223#discussion_r138881132
--- Diff: core/src/main/scala/org/apache/gearpump/util/Graph.scala ---
@@ -243,13 +259,34 @@ class Graph[N, E](vertexList: List[N], edgeList
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/223#discussion_r138880939
--- Diff: core/src/main/scala/org/apache/gearpump/util/Graph.scala ---
@@ -165,7 +181,7 @@ class Graph[N, E](vertexList: List[N], edgeList
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/223#discussion_r138882103
--- Diff: core/src/main/scala/org/apache/gearpump/util/Graph.scala ---
@@ -355,19 +393,7 @@ class Graph[N, E](vertexList: List[N], edgeList
GitHub user huafengw opened a pull request:
https://github.com/apache/incubator-gearpump/pull/223
[GEARPUMP-349] Optimize Graph topologicalOrderIterator performance
Be sure to do all of the following to help us incorporate your contribution
quickly and easily
GitHub user huafengw opened a pull request:
https://github.com/apache/incubator-gearpump/pull/222
[GEARPUMP-348] Allow application total number of retries to be configâ¦
â¦urable
Be sure to do all of the following to help us incorporate your contribution
quickly
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/221
+1
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/215
```
The job exceeded the maximum time limit for jobs, and has been terminated.
```
---
If your project is set up for it, you can reply to this email and have your
reply appear
GitHub user huafengw opened a pull request:
https://github.com/apache/incubator-gearpump/pull/215
[GEARPUMP-343] Fix typo of EmbeddedRuntimeEnvironment
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/214
+1
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/213
+1
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/213#discussion_r132863041
--- Diff:
streaming/src/main/scala/org/apache/gearpump/streaming/dsl/window/impl/WindowRunner.scala
---
@@ -137,11 +156,14 @@ class
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/213
No unit test failed, so where does the failure come from?
---
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
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/212#discussion_r131545040
--- Diff:
streaming/src/main/scala/org/apache/gearpump/streaming/dsl/scalaapi/StreamApp.scala
---
@@ -62,6 +62,17 @@ class StreamApp
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/212
Generally LGTM
---
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
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/210
LGTM
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/208
LGTM
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/207
LGTM, is the failure related?
---
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
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/205
Good, please go ahead.
---
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
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/204
+1
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/205
+1
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/203
+1
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/203
It's a random failure
---
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
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/202#discussion_r130015303
--- Diff: docs/contents/dev/dev-write-1st-app.md ---
@@ -9,7 +9,7 @@ We'll use the classical
[wordcount](https://github.com/apache/incubator
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/202#discussion_r130030700
--- Diff: docs/contents/dev/dev-write-1st-app.md ---
@@ -9,7 +9,7 @@ We'll use the classical
[wordcount](https://github.com/apache/incubator
GitHub user huafengw opened a pull request:
https://github.com/apache/incubator-gearpump/pull/202
[GEARPUMP-331] Allow applications can be ran in IDE
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/200
LGTM
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/200
Document update?
---
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
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/197
+1
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/196#discussion_r128453676
--- Diff: project/BuildExperiments.scala ---
@@ -46,7 +46,8 @@ object BuildExperiments extends sbt.Build {
"org.apache.h
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/194
+1
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/193
+1
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/192
+1
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/190#discussion_r123429407
--- Diff:
streaming/src/main/scala/org/apache/gearpump/streaming/refactor/state/StatefulTask.scala
---
@@ -0,0 +1,179
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/190#discussion_r123429421
--- Diff:
streaming/src/main/scala/org/apache/gearpump/streaming/refactor/state/StatefulTask.scala
---
@@ -0,0 +1,179
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/190#discussion_r123428717
--- Diff:
streaming/src/main/scala/org/apache/gearpump/streaming/refactor/state/StateSpecs.scala
---
@@ -0,0 +1,208
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/190#discussion_r123428767
--- Diff:
streaming/src/main/scala/org/apache/gearpump/streaming/refactor/state/StateSpecs.scala
---
@@ -0,0 +1,208
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/190#discussion_r123428739
--- Diff:
streaming/src/main/scala/org/apache/gearpump/streaming/refactor/state/StateSpecs.scala
---
@@ -0,0 +1,208
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/190#discussion_r123428752
--- Diff:
streaming/src/main/scala/org/apache/gearpump/streaming/refactor/state/StateSpecs.scala
---
@@ -0,0 +1,208
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/190#discussion_r123429442
--- Diff:
streaming/src/main/scala/org/apache/gearpump/streaming/refactor/state/StatefulTask.scala
---
@@ -0,0 +1,179
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/190#discussion_r123430323
--- Diff:
streaming/src/main/scala/org/apache/gearpump/streaming/refactor/state/heap/HeapStateInternals.scala
---
@@ -0,0 +1,316
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/190#discussion_r123429491
--- Diff:
streaming/src/main/scala/org/apache/gearpump/streaming/refactor/state/StatefulTask.scala
---
@@ -0,0 +1,179
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/190#discussion_r123430243
--- Diff:
streaming/src/main/scala/org/apache/gearpump/streaming/refactor/state/InMemoryGlobalStateInternals.scala
---
@@ -0,0 +1,276
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/189
Hi @yanghua , thanks for your contribution! This is a huge pull request so
I think it would take a while to fully review this one, and also, can you give
some description of this pull
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/188
+1
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/187#discussion_r122588303
--- Diff:
streaming/src/main/scala/org/apache/gearpump/streaming/dsl/window/impl/WindowRunner.scala
---
@@ -118,25 +126,34 @@ class
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/187#discussion_r122588434
--- Diff:
streaming/src/main/scala/org/apache/gearpump/streaming/task/Subscription.scala
---
@@ -40,7 +41,7 @@ class Subscription
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/186#discussion_r120526897
--- Diff:
streaming/src/main/scala/org/apache/gearpump/streaming/dsl/window/api/WindowFunction.scala
---
@@ -32,35 +32,34 @@ object
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/186
First I got an irrelevant comment, there is a
`org.apache.gearpump.streaming.dsl.partitioner.GroupByPartitioner`, which looks
like in a wrong place.
---
If your project is set up
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/186#discussion_r120526614
--- Diff:
streaming/src/main/scala/org/apache/gearpump/streaming/dsl/task/GroupByTask.scala
---
@@ -0,0 +1,72 @@
+/*
+ * Licensed
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/185
+1
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/184
+1
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/183#discussion_r117160623
--- Diff:
integrationtest/core/src/it/scala/org/apache/gearpump/integrationtest/checklist/DefaultMessageDeliverySpec.scala
---
@@ -28,7 +28,7
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/183
+1
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/183
Document update?
---
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
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/183
Can we and should we add an apply function in trait Message's companion
object which returns a `DefaultMessage`?
---
If your project is set up for it, you can reply to this email
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/182
+1
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/181
+1
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/180#discussion_r115162272
--- Diff:
experiments/rabbitmq/src/test/scala/org/apache/gearpump/experimental/rabbitmq/RabbitmqSinkSpec.scala
---
@@ -0,0 +1,53
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/180#discussion_r115161088
--- Diff:
experiments/rabbitmq/src/main/scala/org/apache/gearpump/experimental/rabbitmq/RMQSink.scala
---
@@ -0,0 +1,182
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/178
Hi @yanghua , maybe you can close this one now:)
---
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
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/178#discussion_r114961959
--- Diff:
external/rabbitmq/src/main/scala/org/apache/gearpump/external/rabbitmq/RMQSink.scala
---
@@ -0,0 +1,177 @@
+/*
+ * Licensed
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/178#discussion_r114962623
--- Diff: external/rabbitmq/README.md ---
@@ -0,0 +1,21 @@
+# Gearpump RabbitMQ
+
+Gearpump integration for [RabbitMQ](https
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/178#discussion_r114962293
--- Diff:
external/rabbitmq/src/test/scala/org/apache/gearpump/external/rabbitmq/RabbitmqSinkSpec.scala
---
@@ -0,0 +1,51
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/174
@manuzhang
---
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
GitHub user huafengw opened a pull request:
https://github.com/apache/incubator-gearpump/pull/174
[GEARPUMP-295] Fix the failure of getting stalling tasks from clock sâ¦
â¦ervice
Be sure to do all of the following to help us incorporate your contribution
quickly
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/170
+1
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/169
@manuzhang
---
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
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/169
I'll refactor status implementation to simple state machine
---
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
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/169
Test pass:
https://travis-ci.org/huafengw/incubator-gearpump/builds/209307018
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
GitHub user huafengw opened a pull request:
https://github.com/apache/incubator-gearpump/pull/169
[GEARPUMP-285] fix false alarm of shutting down executor time out
Be sure to do all of the following to help us incorporate your contribution
quickly and easily
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/165
+1
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/162
Hi Karol, would you mind do some code modification in
org.apache.gearpump.integrationtest.Docker.scala, change the implementation of
`getNetworkGateway` to
```
final def
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/162
+1 Merging
Thanks Karol!
---
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
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/158
Hi Karol, this pull request includes the former GEARPUMP-236 and it's also
covered by your another pr, so maybe we can close this one?
---
If your project is set up for it, you can
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/162#discussion_r103382701
--- Diff: integrationtest/docker/README.md ---
@@ -1,28 +1,23 @@
-# Gearpump Launcher Docker Image
-
-The image helps developer
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/162#discussion_r103382851
--- Diff: integrationtest/docker/java/README.md ---
@@ -0,0 +1,18 @@
+A minimalistic Oracle JDK 8 container on top of busybox.
+
+We
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/162#discussion_r103385452
--- Diff: integrationtest/docker/kafka/README.md ---
@@ -0,0 +1,89 @@
+Kafka in Docker
+===
+
+**This is a fork spotify/kafka
Github user huafengw commented on the issue:
https://github.com/apache/incubator-gearpump/pull/161
+1
---
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
1 - 100 of 221 matches
Mail list logo
