[GitHub] flink issue #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-storm a...

[liuyuzhong]

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 wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] flink pull request #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-...

[liuyuzhong]

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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] flink issue #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-storm a...

[liuyuzhong]

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 appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] flink issue #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-storm a...

[liuyuzhong]

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
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] flink issue #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-storm a...

[liuyuzhong]

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 feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] flink issue #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-storm a...

[liuyuzhong]

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 project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] flink issue #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-storm a...

[liuyuzhong]

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 so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] flink issue #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-storm a...

[liuyuzhong]

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 feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] flink issue #2452: [Flink-4450] add a new module "flink-apache-storm" to sup...

[liuyuzhong]

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 feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] flink pull request #2452: [Flink-4450] add a new module "flink-apache-storm"...

[liuyuzhong]

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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] flink issue #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-storm a...

[liuyuzhong]

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 feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] flink issue #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-storm a...

[liuyuzhong]

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/blob/1.x-branch/pom.xml#L703  
code detail: 
https://github.com/apache/storm/blob/1.x-branch/storm-core/src/clj/org/apache/storm/ui/helpers.clj#L36


---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] flink issue #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-storm a...

[liuyuzhong]

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
[INFO] Finished at: 2016-10-09T12:42:31+00:00
[INFO] Final Memory: 210M/1154M
```

2.finish fail: 
```
[JENKINS] Archiving 
/home/jenkins/jenkins-slave/workspace/flink-github-ci/flink-contrib/flink-streaming-contrib/target/flink-streaming-contrib_2.10-1.2-SNAPSHOT-javadoc.jar
 to 
org.apache.flink/flink-streaming-contrib_2.10/1.2-SNAPSHOT/flink-streaming-contrib_2.10-1.2-SNAPSHOT-javadoc.jar
channel stopped
Putting comment on the pull request
Finished: UNSTABLE
```



---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] flink issue #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-storm a...

[liuyuzhong]

Github user liuyuzhong commented on the issue:

https://github.com/apache/flink/pull/2439
  
Jenkins run successful, but CI fail.


![image](https://cloud.githubusercontent.com/assets/12843176/18897594/2c9e40e2-855e-11e6-8d3c-0397b33d5d8f.png)



---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] flink pull request #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-...

[liuyuzhong]

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 @@
  */
 package org.apache.flink.storm.util;
 
-import backtype.storm.spout.SpoutOutputCollector;
+import org.apache.storm.spout.SpoutOutputCollector;
 
 import org.junit.Assert;
 import org.junit.Test;
 
 import static org.mockito.Mockito.mock;
 
-public class SpoutOutputCollectorObserverTest {
--- End diff --

Fixed.


---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] flink pull request #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-...

[liuyuzhong]

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 testCreateTopologyContext() {
.shuffleGrouping("bolt2", 
TestDummyBolt.groupingStreamId)
.shuffleGrouping("bolt2", 
TestDummyBolt.shuffleStreamId);
 
-   LocalCluster cluster = new LocalCluster();
--- End diff --

It can't work, so delete it first.


---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] flink issue #2452: [Flink-4450] add a new module "flink-apache-storm" to sup...

[liuyuzhong]

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 your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] flink issue #2452: [Flink-4450] add a new module "flink-apache-storm" to sup...

[liuyuzhong]

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 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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] flink pull request #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-...

[liuyuzhong]

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
 
Because Apache Storm version after 1.0.0, the pacakge name was changed from 
"backtype.*" to "org.apache.*", and this change will work for all the storm 
which version higher than 1.0.0

build successfully and run successfully in my test environment.



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/liuyuzhong/flink master

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/flink/pull/2439.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 #2439


commit eeb1fc284d6879404b05eab422ed898a9440cdb5
Author: yuzhongliu <yuzhong...@tencent.com>
Date:   2016-08-29T11:03:15Z

#4450 update storm version to 1.0.0

commit 055743ad65c6213e8fe8d422e929e795c3bad8f1
Author: yuzhongliu <yuzhong...@tencent.com>
Date:   2016-08-30T06:05:08Z

#4450 update storm version to 1.0.0 in flink-storm-examples

commit 409827d8e7ac69743b9c7f98774c001f6551457c
Author: yuzhongliu <yuzhong...@tencent.com>
Date:   2016-08-30T06:10:47Z

#4450 reverse for uncorrect change submit pom.xml

commit eebd8c534933fb2639dc248469ba56a2ed053cb7
Author: yuzhongliu <yuzhong...@tencent.com>
Date:   2016-08-30T06:12:00Z

#4450 reverse for uncorrect change submit pom.xml

commit 8788b0eb2146f3a7bb3d0af2ae61cabc7741f6bf
Author: liuyuzhong <darezh...@qq.com>
Date:   2016-08-30T06:14:44Z

Merge pull request #1 from liuyuzhong/4450

#4450 update storm version to 1.0.0

commit 89d04437c74567fe21949f0b3ac5730e42002db2
Author: yuzhongliu <yuzhong...@tencent.com>
Date:   2016-08-31T03:12:14Z

#4450 exclusion unnecessary dependency in flink-storm

commit 3a20d1957a986daa0eb4758d701cd9cd0ac98839
Author: yuzhongliu <yuzhong...@tencent.com>
Date:   2016-08-31T03:14:21Z

#4450 delete LocalCluster storm topology test

commit 5765f2d51e6e84d82f2697d2c7ad7656ca8708c1
Author: liuyuzhong <darezh...@qq.com>
Date:   2016-08-31T03:26:21Z

Merge pull request #2 from liuyuzhong/4450

4450

commit 33bd4f377074cd680299891a97734cd8658b4129
Author: yuzhongliu <yuzhong...@tencent.com>
Date:   2016-09-01T04:58:56Z

#4450 sync to https://github.com/apache/flink.git

commit 3be5a1b1ec12ffb22eea5695c51723129d566a98
Author: liuyuzhong <darezh...@qq.com>
Date:   2016-09-01T05:02:14Z

Merge pull request #3 from liuyuzhong/4450

#4450 sync to https://github.com/apache/flink.git

commit a0dfde6b70fe5c12bee0a9257cfa0c3a1bb19fac
Author: yuzhongliu <yuzhong...@tencent.com>
Date:   2016-09-01T05:32:43Z

sync to https://github.com/apache/flink.git

commit 3afe545558295e7284974d157d56be4d8829510b
Author: yuzhongliu <yuzhong...@tencent.com>
Date:   2016-09-01T05:33:11Z

Merge branch 'FLINK-4450'

commit c8f63e7cfffc529c4c383ffebc01832b7c480bfa
Author: yuzhongliu <yuzhong...@tencent.com>
Date:   2016-09-05T02:02:56Z

Merge remote-tracking branch 'upstream/master'

commit 5f4cf236609913739b1ce537c22ee64dc205b0f0
Author: yuzhongliu <yuzhong...@tencent.com>
Date:   2016-09-06T04:34:35Z

Merge remote-tracking branch 'upstream/master'

commit 7d67a858277faa4b64b63fa5936bac64ad56449d
Author: yuzhongliu <yuzhong...@tencent.com>
Date:   2016-09-20T06:37:42Z

Merge remote-tracking branch 'upstream/master'




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] flink issue #2452: [Flink-4450] add a new module "flink-apache-storm" to sup...

[liuyuzhong]

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 the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] flink issue #2452: [Flink-4450] add a new module "flink-apache-storm" to sup...

[liuyuzhong]

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 adpate to storm version 
to 1.0.0.  
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] flink issue #2452: [Flink-4450] add a new module "flink-apache-storm" to sup...

[liuyuzhong]

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
Running 
org.apache.flink.test.checkpointing.UdfStreamOperatorCheckpointingITCase
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 40.442 sec 
- in org.apache.flink.test.recovery.FastFailuresITCase
Running org.apache.flink.test.checkpointing.RescalingITCase
ERROR: Maven JVM terminated unexpectedly with exit code 137
Putting comment on the pull request
Finished: 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 and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] flink issue #2452: [Flink-4450] add a new module "flink-apache-storm" to sup...

[liuyuzhong]

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
org.apache.flink.api.scala.runtime.taskmanager.TaskManagerFailsITCase.The 
JobManager should handle gracefully failing task manager
org.apache.flink.api.scala.runtime.taskmanager.TaskManagerFailsITCase.The 
JobManager should handle hard failing task manager
org.apache.flink.api.scala.runtime.taskmanager.TaskManagerFailsITCase.The 
JobManager should go into a clean state in case of a TaskManager failure
org.apache.flink.test.cancelling.MapCancelingITCase.testSlowMapCancelling
org.apache.flink.test.cancelling.MapCancelingITCase.testMapCancelling

org.apache.flink.test.cancelling.MapCancelingITCase.testMapPriorToFirstRecordReading

org.apache.flink.test.cancelling.MapCancelingITCase.testMapWithLongCancellingResponse

org.apache.flink.test.checkpointing.CoStreamCheckpointingITCase.org.apache.flink.test.checkpointing.CoStreamCheckpointingITCase

org.apache.flink.test.checkpointing.EventTimeAllWindowCheckpointingITCase.org.apache.flink.test.checkpointing.EventTimeAllWindowCheckpointingITCase

org.apache.flink.test.checkpointing.SavepointITCase.testTriggerSavepointAndResume

org.apache.flink.test.checkpointing.SavepointITCase.testCheckpointsRemovedWithJobManagerBackendOnShutdown

org.apache.flink.test.classloading.ClassLoaderITCase.testDisposeSavepointWithCustomKvState

org.apache.flink.test.exampleScalaPrograms.WordCountITCase.testJobWithoutObjectReuse

org.apache.flink.test.exampleScalaPrograms.WordCountITCase.testJobWithObjectReuse

org.apache.flink.test.failingPrograms.JobSubmissionFailsITCase.org.apache.flink.test.failingPrograms.JobSubmissionFailsITCase

org.apache.flink.test.recovery.TaskManagerProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure[0]

org.apache.flink.test.web.WebFrontendITCase.org.apache.flink.test.web.WebFrontendITCase
```


---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] flink pull request #2452: [Flink-4450] add a new module "flink-apache-storm"...

[liuyuzhong]

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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] flink issue #2452: [Flink-4450] add a new module "flink-apache-storm" to sup...

[liuyuzhong]

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-09-05T04:07:42+00:00
[INFO] Final Memory: 195M/581M
```

but  Finished: UNSTABLE
```
[JENKINS] Archiving 
/home/jenkins/jenkins-slave/workspace/flink-github-ci/flink-contrib/flink-streaming-contrib/target/flink-streaming-contrib_2.10-1.2-SNAPSHOT-javadoc.jar
 to 
org.apache.flink/flink-streaming-contrib_2.10/1.2-SNAPSHOT/flink-streaming-contrib_2.10-1.2-SNAPSHOT-javadoc.jar
channel stopped
Putting comment on the pull request
Finished: UNSTABLE
```


---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] flink issue #2452: Flink-4450 add a new module "flink-apache-storm" to suppo...

[liuyuzhong]

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 Token(COMMA,,,1674,,)
Saving to 
outputFile=/home/jenkins/jenkins-slave/workspace/flink-github-ci/flink-mesos/target/scalastyle-output.xml
Processed 13 file(s)
Found 1 errors
Found 0 warnings
Found 0 infos
Finished in 209 ms
[INFO] 

[INFO] Reactor Summary:
[INFO] 
[INFO] force-shading .. SUCCESS [  
6.625 s]
[INFO] flink .. SUCCESS [  
6.213 s]
[INFO] flink-annotations .. SUCCESS [  
4.565 s]
[INFO] flink-shaded-hadoop  SUCCESS [  
1.079 s]
[INFO] flink-shaded-hadoop2 ... SUCCESS [ 
27.133 s]
[INFO] flink-shaded-include-yarn-tests  SUCCESS [ 
36.741 s]
[INFO] flink-shaded-curator ... SUCCESS [  
1.054 s]
[INFO] flink-shaded-curator-recipes ... SUCCESS [  
5.945 s]
[INFO] flink-shaded-curator-test .. SUCCESS [  
1.591 s]
[INFO] flink-metrics .. SUCCESS [  
0.888 s]
[INFO] flink-metrics-core . SUCCESS [  
5.857 s]
[INFO] flink-test-utils-parent  SUCCESS [  
1.691 s]
[INFO] flink-test-utils-junit . SUCCESS [ 
19.417 s]
[INFO] flink-core . SUCCESS [01:21 
min]
[INFO] flink-java . SUCCESS [01:03 
min]
[INFO] flink-runtime .. SUCCESS [08:49 
min]
[INFO] flink-optimizer  SUCCESS [ 
28.185 s]
[INFO] flink-clients .. SUCCESS [ 
15.102 s]
[INFO] flink-streaming-java ... SUCCESS [ 
57.792 s]
[INFO] flink-test-utils ... SUCCESS [ 
17.591 s]
[INFO] flink-scala  SUCCESS [01:14 
min]
[INFO] flink-runtime-web .. SUCCESS [ 
32.911 s]
[INFO] flink-examples . SUCCESS [  
1.822 s]
[INFO] flink-examples-batch ... SUCCESS [ 
31.045 s]
[INFO] flink-batch-connectors . SUCCESS [  
1.693 s]
[INFO] flink-hadoop-compatibility . SUCCESS [ 
17.754 s]
[INFO] flink-contrib .. SUCCESS [  
1.082 s]
[INFO] flink-statebackend-rocksdb . SUCCESS [01:15 
min]
[INFO] flink-tests  SUCCESS [08:00 
min]
[INFO] flink-streaming-scala .. SUCCESS [ 
56.492 s]
[INFO] flink-streaming-connectors . SUCCESS [  
2.310 s]
[INFO] flink-connector-flume .. SUCCESS [ 
10.413 s]
[INFO] flink-libraries  SUCCESS [  
1.307 s]
[INFO] flink-table  SUCCESS [03:36 
min]
[INFO] flink-metrics-jmx .. SUCCESS [  
8.609 s]
[INFO] flink-connector-kafka-base . SUCCESS [ 
13.582 s]
[INFO] flink-connector-kafka-0.8 .. SUCCESS [03:42 
min]
[INFO] flink-connector-kafka-0.9 .. SUCCESS [03:53 
min]
[INFO] flink-connector-elasticsearch .. SUCCESS [ 
37.185 s]
[INFO] flink-connector-elasticsearch2 . SUCCESS [ 
46.210 s]
[INFO] flink-connector-rabbitmq ... SUCCESS [  
8.074 s]
[INFO] flink-connector-twitter  SUCCESS [ 
12.098 s]
[INFO] flink-connector-nifi ... SUCCESS [  
6.576 s]
[INFO] flink-connector-cassandra .. SUCCESS [02:32 
min]
[INFO] flink-connector-redis .. SUCCESS [ 
13.672 s]
[INFO] flink-connector-filesystem . SUCCESS [ 
58.438 s]
[INFO] flink-avro . SUCCESS [ 
24.565 s]
[INFO] flink-jdbc . SUCCESS [ 
11.221 s]
[INFO] flink-hbase  SUCCESS [ 
15.708 s]
[INFO] flink-hcatalog . SUCCESS [ 
26.367 s]
[INFO] flink-examples-streaming ... SUCCESS

[GitHub] flink issue #2452: Flink-4450 add a new module "flink-apache-storm" to suppo...

[liuyuzhong]

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







---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] flink pull request #2452: Flink-4450 add a new module "flink-apache-storm" t...

[liuyuzhong]

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-contrib/flink-storm, It support compatibility layer for storm which 
higher than 1.0.0.

2. Create new module "flink-apache-storm-examples" copy from 
flink-contrib/flink-storm-examples, given the examples for storm program which 
version than 1.0.0

3. mvn clean verify: ok

4. Test: ok

- run new storm example   

```
  bin/flink run 
flink/flink-contrib/flink-apache-storm-examples/target/WordCount-StormTopology.jar
  bin/flink run 
flink/flink-contrib/flink-apache-storm-examples/target/WordCount-BoltTokenizer.jar
  bin/flink run 
flink/flink-contrib/flink-apache-storm-examples/target/WordCount-SpoutSource.jar
  
```

- run old storm example:

```  
 bin/flink run 
flink/flink-contrib/flink-storm-examples/target/WordCount-StormTopology.jar
  bin/flink run 
flink/flink-contrib/flink-storm-examples/target/WordCount-BoltTokenizer.jar
  bin/flink run 
flink/flink-contrib/flink-storm-examples/target/WordCount-SpoutSource.jar  
```

You can merge this pull request into a Git repository by running:

$ git pull https://github.com/liuyuzhong/flink FLINK-4450

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/flink/pull/2452.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 #2452


commit eeb1fc284d6879404b05eab422ed898a9440cdb5
Author: yuzhongliu <yuzhong...@tencent.com>
Date:   2016-08-29T11:03:15Z

#4450 update storm version to 1.0.0

commit 055743ad65c6213e8fe8d422e929e795c3bad8f1
Author: yuzhongliu <yuzhong...@tencent.com>
Date:   2016-08-30T06:05:08Z

#4450 update storm version to 1.0.0 in flink-storm-examples

commit 409827d8e7ac69743b9c7f98774c001f6551457c
Author: yuzhongliu <yuzhong...@tencent.com>
Date:   2016-08-30T06:10:47Z

#4450 reverse for uncorrect change submit pom.xml

commit eebd8c534933fb2639dc248469ba56a2ed053cb7
Author: yuzhongliu <yuzhong...@tencent.com>
Date:   2016-08-30T06:12:00Z

#4450 reverse for uncorrect change submit pom.xml

commit 8788b0eb2146f3a7bb3d0af2ae61cabc7741f6bf
Author: liuyuzhong <darezh...@qq.com>
Date:   2016-08-30T06:14:44Z

Merge pull request #1 from liuyuzhong/4450

#4450 update storm version to 1.0.0

commit 89d04437c74567fe21949f0b3ac5730e42002db2
Author: yuzhongliu <yuzhong...@tencent.com>
Date:   2016-08-31T03:12:14Z

#4450 exclusion unnecessary dependency in flink-storm

commit 3a20d1957a986daa0eb4758d701cd9cd0ac98839
Author: yuzhongliu <yuzhong...@tencent.com>
Date:   2016-08-31T03:14:21Z

#4450 delete LocalCluster storm topology test

commit 5765f2d51e6e84d82f2697d2c7ad7656ca8708c1
Author: liuyuzhong <darezh...@qq.com>
Date:   2016-08-31T03:26:21Z

Merge pull request #2 from liuyuzhong/4450

4450

commit 33bd4f377074cd680299891a97734cd8658b4129
Author: yuzhongliu <yuzhong...@tencent.com>
Date:   2016-09-01T04:58:56Z

#4450 sync to https://github.com/apache/flink.git

commit 3be5a1b1ec12ffb22eea5695c51723129d566a98
Author: liuyuzhong <darezh...@qq.com>
Date:   2016-09-01T05:02:14Z

Merge pull request #3 from liuyuzhong/4450

#4450 sync to https://github.com/apache/flink.git

commit a0dfde6b70fe5c12bee0a9257cfa0c3a1bb19fac
Author: yuzhongliu <yuzhong...@tencent.com>
Date:   2016-09-01T05:32:43Z

sync to https://github.com/apache/flink.git

commit 3afe545558295e7284974d157d56be4d8829510b
Author: yuzhongliu <yuzhong...@tencent.com>
Date:   2016-09-01T05:33:11Z

Merge branch 'FLINK-4450'

commit 84f951dfe424a8867454a7b6196abd33d6c4207c
Author: yuzhongliu <yuzhong...@tencent.com>
Date:   2016-09-01T06:12:04Z

FLINK-4450 campable old storm version

commit da783f415d29b503b351d12ed7ada48c5ea1b953
Author: yuzhongliu <yuzhong...@tencent.com>
Date:   2016-09-01T07:10:08Z

FLINK-4450 campable for apache storm which version higher than 1.0.0




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] flink pull request #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-...

[liuyuzhong]

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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] flink issue #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-storm a...

[liuyuzhong]

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 feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] flink issue #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-storm a...

[liuyuzhong]

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 with previous storm 
version. It can change class package name previous storm version jar. 

see the detail: 
https://github.com/apache/storm/tree/master/storm-rename-hack


---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] flink pull request #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-...

[liuyuzhong]

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
 
Because Apache Storm version after 1.0.0, the pacakge name was changed from 
"backtype.*" to "org.apache.*", and this change will work for all the storm 
which version higher than 1.0.0

build successfully and run successfully in my test environment.



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/liuyuzhong/flink master

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/flink/pull/2439.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 #2439


commit eeb1fc284d6879404b05eab422ed898a9440cdb5
Author: yuzhongliu <yuzhong...@tencent.com>
Date:   2016-08-29T11:03:15Z

#4450 update storm version to 1.0.0

commit 055743ad65c6213e8fe8d422e929e795c3bad8f1
Author: yuzhongliu <yuzhong...@tencent.com>
Date:   2016-08-30T06:05:08Z

#4450 update storm version to 1.0.0 in flink-storm-examples

commit 409827d8e7ac69743b9c7f98774c001f6551457c
Author: yuzhongliu <yuzhong...@tencent.com>
Date:   2016-08-30T06:10:47Z

#4450 reverse for uncorrect change submit pom.xml

commit eebd8c534933fb2639dc248469ba56a2ed053cb7
Author: yuzhongliu <yuzhong...@tencent.com>
Date:   2016-08-30T06:12:00Z

#4450 reverse for uncorrect change submit pom.xml

commit 8788b0eb2146f3a7bb3d0af2ae61cabc7741f6bf
Author: liuyuzhong <darezh...@qq.com>
Date:   2016-08-30T06:14:44Z

Merge pull request #1 from liuyuzhong/4450

#4450 update storm version to 1.0.0

commit 89d04437c74567fe21949f0b3ac5730e42002db2
Author: yuzhongliu <yuzhong...@tencent.com>
Date:   2016-08-31T03:12:14Z

#4450 exclusion unnecessary dependency in flink-storm

commit 3a20d1957a986daa0eb4758d701cd9cd0ac98839
Author: yuzhongliu <yuzhong...@tencent.com>
Date:   2016-08-31T03:14:21Z

#4450 delete LocalCluster storm topology test

commit 5765f2d51e6e84d82f2697d2c7ad7656ca8708c1
Author: liuyuzhong <darezh...@qq.com>
Date:   2016-08-31T03:26:21Z

Merge pull request #2 from liuyuzhong/4450

4450




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] flink pull request #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-...

[liuyuzhong]

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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] flink issue #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-storm a...

[liuyuzhong]

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(0xd8b0, 100663296, 0) failed; error='Cannot 
allocate memory' (errno=12)
#
# There is insufficient memory for the Java Runtime Environment to continue.
# Native memory allocation (mmap) failed to map 100663296 bytes for 
committing reserved memory.
# An error report file with more information is saved as:
# 
/home/jenkins/jenkins-slave/workspace/flink-github-ci/flink-tests/target/hs_err_pid9818.log
Running org.apache.flink.test.checkpointing.WindowCheckpointingITCase
ERROR: Maven JVM terminated unexpectedly with exit code 137
Putting comment on the pull request
Finished: FAILURE
```

But I run it successfully in my environment, does it a Jenkins memory 
problem? Rerun it in Jenkins?




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] flink issue #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-storm a...

[liuyuzhong]

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



---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] flink pull request #2439: update storm verion to 1.0.0 in flink-storm and fl...

[liuyuzhong]

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 Storm version after 1.0.0, the pacakge name was changed from 
"backtype.*" to “org.apache.*", and this change will work for all the storm 
which version higher than 1.0.0

build successfully and run successfully in my test environment.



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/liuyuzhong/flink master

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/flink/pull/2439.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 #2439


commit eeb1fc284d6879404b05eab422ed898a9440cdb5
Author: yuzhongliu <yuzhong...@tencent.com>
Date:   2016-08-29T11:03:15Z

#4450 update storm version to 1.0.0

commit 055743ad65c6213e8fe8d422e929e795c3bad8f1
Author: yuzhongliu <yuzhong...@tencent.com>
Date:   2016-08-30T06:05:08Z

#4450 update storm version to 1.0.0 in flink-storm-examples

commit 409827d8e7ac69743b9c7f98774c001f6551457c
Author: yuzhongliu <yuzhong...@tencent.com>
Date:   2016-08-30T06:10:47Z

#4450 reverse for uncorrect change submit pom.xml

commit eebd8c534933fb2639dc248469ba56a2ed053cb7
Author: yuzhongliu <yuzhong...@tencent.com>
Date:   2016-08-30T06:12:00Z

#4450 reverse for uncorrect change submit pom.xml

commit 8788b0eb2146f3a7bb3d0af2ae61cabc7741f6bf
Author: liuyuzhong <darezh...@qq.com>
Date:   2016-08-30T06:14:44Z

Merge pull request #1 from liuyuzhong/4450

#4450 update storm version to 1.0.0




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---