Github user qmlmoon closed the pull request at:
https://github.com/apache/flink/pull/439
---
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 qmlmoon closed the pull request at:
https://github.com/apache/flink/pull/248
---
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 qmlmoon commented on the pull request:
https://github.com/apache/flink/pull/35#issuecomment-95876902
I rebased the PR on the current master and removed the annoying merge
commits.
---
If your project is set up for it, you can reply to this email and have your
reply
Github user qmlmoon closed the pull request at:
https://github.com/apache/flink/pull/48
---
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 qmlmoon commented on the pull request:
https://github.com/apache/flink/pull/439#issuecomment-95523387
That would be a nice way, but
1) key/value pairs are not always distinguished by _KEY suffix, we have to
format all the fields in ConfigConstants
2) some values
Github user qmlmoon commented on the pull request:
https://github.com/apache/flink/pull/439#issuecomment-85207647
The default key value pairs are added manually. It seems that some of the
keys in `ConfigConstant` is deleted recently.
---
If your project is set up for it, you can
Github user qmlmoon commented on the pull request:
https://github.com/apache/flink/pull/439#issuecomment-77739274
The configuration view is separated into user and default now:
You can merge this pull
Github user qmlmoon commented on the pull request:
https://github.com/apache/flink/pull/424#issuecomment-75197699
As a user I would expect the system could carry on quickly after server
socket is reinitiated. A large limit of exponentially increase may lead to
potential long wait and
GitHub user qmlmoon opened a pull request:
https://github.com/apache/flink/pull/424
[FLINK-1582][streaming]Allow SocketStream to reconnect when socket closes
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/qmlmoon/incubator
Github user qmlmoon commented on the pull request:
https://github.com/apache/flink/pull/202#issuecomment-72749480
Great. Now it works for me
---
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
Github user qmlmoon commented on the pull request:
https://github.com/apache/flink/pull/202#issuecomment-72734478
I got the same issue as fabian on OS X. The problem may result from
different tmp files created by java and that used in python.
In java you created a file under
Github user qmlmoon commented on the pull request:
https://github.com/apache/flink/pull/202#issuecomment-72668635
I would also like to try out some examples. I'm starting with TPCH queries:D
---
If your project is set up for it, you can reply to this email and have your
reply a
Github user qmlmoon commented on a diff in the pull request:
https://github.com/apache/flink/pull/248#discussion_r23610509
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -519,6 +519,12 @@ object JobManager
Github user qmlmoon commented on a diff in the pull request:
https://github.com/apache/flink/pull/248#discussion_r23607815
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -519,6 +519,12 @@ object JobManager
Github user qmlmoon commented on the pull request:
https://github.com/apache/flink/pull/248#issuecomment-71645508
ok. I rebased the PR and modified it with scala implementation.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
GitHub user qmlmoon opened a pull request:
https://github.com/apache/flink/pull/332
[FLINK-1381] Allow multiple output splitters for single stream operator
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/qmlmoon/incubator-flink
GitHub user qmlmoon opened a pull request:
https://github.com/apache/flink/pull/303
[FLINK-1231] Add test for streaming remote execution
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/qmlmoon/incubator-flink stream-test
GitHub user qmlmoon opened a pull request:
https://github.com/apache/flink/pull/291
[FLINK-1229][FLINK-1206] Synchronize webclient arguments with command line
and add default parallelism option
You can merge this pull request into a Git repository by running:
$ git pull
20 matches
Mail list logo
