GitHub user liuyuzhong opened a pull request:
https://github.com/apache/flink/pull/2439
update storm verion to 1.0.0 in flink-storm and flink-storm-examples
This pull is for update storm version to 1.0.0
https://issues.apache.org/jira/browse/FLINK-4450
Because Apache
Github user liuyuzhong commented on the issue:
https://github.com/apache/flink/pull/2439
mvn clean verify : ok
test flink-storm-examples: ok
bin/flink run WordCount-StormTopology.jar
bin/flink run WordCount-BoltTokenizer.jar
bin/flink run WordCount-SpoutSource.jar
Github user liuyuzhong commented on the issue:
https://github.com/apache/flink/pull/2439
Jenkins run error:
```
Running
org.apache.flink.test.checkpointing.PartitionedStateCheckpointingITCase
SUREFIRE-859: Java HotSpot(TM) 64-Bit Server VM warning: INFO:
os::commit_memory
Github user liuyuzhong closed the pull request at:
https://github.com/apache/flink/pull/2439
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user liuyuzhong reopened a pull request:
https://github.com/apache/flink/pull/2439
[FLINK-4450]update storm verion to 1.0.0 in flink-storm and
flink-storm-examples
This pull is for update storm version to 1.0.0
https://issues.apache.org/jira/browse/FLINK-4450
Github user liuyuzhong commented on the issue:
https://github.com/apache/flink/pull/2439
@StephanEwen
If we merge this, flink-storm will compatible with all the storm which
version higher than 1.0.0
And we can import "storm-rename-hack" to compatible wit
Github user liuyuzhong commented on the issue:
https://github.com/apache/flink/pull/2439
close it, and will open new pull request later
---
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
Github user liuyuzhong closed the pull request at:
https://github.com/apache/flink/pull/2439
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user liuyuzhong opened a pull request:
https://github.com/apache/flink/pull/2452
Flink-4450 add a new module "flink-apache-storm" to support new storm
verion(higher than 1.0.0)
@StephanEwen
1. Create new module "flink-apache-storm" copy from
flink
Github user liuyuzhong commented on the issue:
https://github.com/apache/flink/pull/2452
flink-apache-storm copy from flink-storm, and update storm version to 1.0.0
flink-apache-storm-examples copy from flink-storm-examples, and update
storm version to 1.0.0
Github user liuyuzhong commented on the issue:
https://github.com/apache/flink/pull/2452
Jenkins run error:
```
error
file=/home/jenkins/jenkins-slave/workspace/flink-github-ci/flink-mesos/src/test/scala/org/apache/flink/mesos/Utils.scala
message=Expected identifier, but got
Github user liuyuzhong commented on the issue:
https://github.com/apache/flink/pull/2452
build success
```
[INFO] BUILD SUCCESS
[INFO]
[INFO] Total time: 01:28 h
[INFO] Finished at: 2016
GitHub user liuyuzhong reopened a pull request:
https://github.com/apache/flink/pull/2452
[Flink-4450] add a new module "flink-apache-storm" to support new storm
verion program (higher than 1.0.0)
@StephanEwen
1. Create new module "flink-apache-storm&qu
Github user liuyuzhong closed the pull request at:
https://github.com/apache/flink/pull/2452
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
Github user liuyuzhong commented on the issue:
https://github.com/apache/flink/pull/2452
Test Result (失败)
```
org.apache.flink.api.scala.runtime.taskmanager.TaskManagerFailsITCase.The
JobManager should detect a failing task manager
Github user liuyuzhong commented on the issue:
https://github.com/apache/flink/pull/2452
Jenkins run error:
```
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 30.585 sec
- in
org.apache.flink.test.recovery.TaskManagerProcessFailureStreamingRecoveryITCase
Github user liuyuzhong commented on the issue:
https://github.com/apache/flink/pull/2452
@mxm
Yes, all of this code are copy from old code adapted to Strom 1.0.0. So we
close this pull request and wait for decision?
Actually, I was submit a pull request for old code
Github user liuyuzhong commented on the issue:
https://github.com/apache/flink/pull/2452
@mxm OK.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if
GitHub user liuyuzhong reopened a pull request:
https://github.com/apache/flink/pull/2439
[FLINK-4450]update storm verion to 1.0.0 in flink-storm and
flink-storm-examples
This pull is for update storm version to 1.0.0
https://issues.apache.org/jira/browse/FLINK-4450
Github user liuyuzhong commented on the issue:
https://github.com/apache/flink/pull/2452
OK, how about reopen pull requests #2439 ? Just update storm version to
1.0, and it can support storm 1.0+ version program.
---
If your project is set up for it, you can reply to this email and
Github user liuyuzhong commented on the issue:
https://github.com/apache/flink/pull/2452
That's OK. I understand.
It's not so easy to make a decesion.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If yo
Github user liuyuzhong commented on the issue:
https://github.com/apache/flink/pull/2439
Complie error is fixed. But how to squash all commits into one commit?
---
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 liuyuzhong commented on the issue:
https://github.com/apache/flink/pull/2439
Sorry, something was wrong when I am rebase.
---
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
Github user liuyuzhong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2439#discussion_r80458706
--- Diff:
flink-contrib/flink-storm/src/test/java/org/apache/flink/storm/wrappers/WrapperSetupHelperTest.java
---
@@ -186,15 +177,15 @@ public void
Github user liuyuzhong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2439#discussion_r80458736
--- Diff:
flink-contrib/flink-storm/src/test/java/org/apache/flink/storm/util/SpoutOutputCollectorObserverTest.java
---
@@ -17,14 +17,15
Github user liuyuzhong commented on the issue:
https://github.com/apache/flink/pull/2439
Jenkins run successful, but CI fail.
---
If your project is set up for
Github user liuyuzhong commented on the issue:
https://github.com/apache/flink/pull/2439
**Jenkins run error**
1.build success
```
[INFO] BUILD SUCCESS
[INFO]
[INFO] Total time: 01:18 h
Github user liuyuzhong commented on the issue:
https://github.com/apache/flink/pull/2439
@StephanEwen Actually, I'm not very clear about Clojure Web FrameWork, but
it's web framework are using "ring.ring-core".
import: https://github.com/apache/storm/blo
Github user liuyuzhong commented on the issue:
https://github.com/apache/flink/pull/2439
Sorry.forget to check it. I will do it tomorrow.
---
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
Github user liuyuzhong closed the pull request at:
https://github.com/apache/flink/pull/2452
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
Github user liuyuzhong commented on the issue:
https://github.com/apache/flink/pull/2452
ok.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the
Github user liuyuzhong commented on the issue:
https://github.com/apache/flink/pull/2439
@StephanEwen Fixed. Help me to review it please.
---
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
Github user liuyuzhong commented on the issue:
https://github.com/apache/flink/pull/2439
Fixed complie error.
---
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 liuyuzhong commented on the issue:
https://github.com/apache/flink/pull/2439
@StephanEwen Sorry, I can't continue with this pull request. I will use
another githup account to pull.
---
If your project is set up for it, you can reply to this email and have your
Github user liuyuzhong commented on the issue:
https://github.com/apache/flink/pull/2439
@StephanEwen I use new githup account make a new pull request #3037, help
me to review it please.Thanks.
---
If your project is set up for it, you can reply to this email and have your
reply
Github user liuyuzhong closed the pull request at:
https://github.com/apache/flink/pull/2439
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
Github user liuyuzhong commented on the issue:
https://github.com/apache/flink/pull/2439
#3037 has merged. done.
---
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
37 matches
Mail list logo
