<hsapu...@apache.org>
Closes #2001 from hsaputra/simple_text_fix_taskmanager and squashes the
following commits:
861cbb4 [Henry Saputra] Simple fix of typo from JobManager to TaskManager in
taskmanager.sh file.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: ht
Repository: flink
Updated Branches:
refs/heads/master 09433032d -> 8801cbcf7
[FLINK-3009] Add dockerized jekyll environment
This is not to fulfill what FLINK-3009 is originally asking,
but I'm piggybacking to contribute a docker environment with jekyll
so that users won't have to deal with
doc in the
programming guide.
Author: Henry Saputra <hsapu...@apache.org>
Closes #1268 from hsaputra/add_readFileOfPrimitives_scala_guide and squashes
the following commits:
f543436 [Henry Saputra] Add variant of
ExecutionEnvironment.readFileOfPrimitives in Java with additional delimiter.
1209019 [Henr
review.
Author: hsaputra <hsapu...@apache.org>
Closes #1218 from hsaputra/remove_pact_name and squashes the following commits:
b3c55b4 [hsaputra] Rename RegularTask to BatchTask per review.
e278fac [hsaputra] Address review comments from chiwanpark (good catch).
9f92f33 [hsaputra] Remove Pac
http://git-wip-us.apache.org/repos/asf/flink/blob/b08669ab/flink-runtime/src/main/java/org/apache/flink/runtime/operators/BatchTask.java
--
diff --git
http://git-wip-us.apache.org/repos/asf/flink/blob/b08669ab/flink-runtime/src/main/java/org/apache/flink/runtime/iterative/task/IterationHeadPactTask.java
--
diff --git
http://git-wip-us.apache.org/repos/asf/flink/blob/b08669ab/flink-runtime/src/main/java/org/apache/flink/runtime/operators/GroupReduceCombineDriver.java
--
diff --git
Repository: flink
Updated Branches:
refs/heads/master e494c2795 -> b08669abf
http://git-wip-us.apache.org/repos/asf/flink/blob/b08669ab/flink-runtime/src/main/java/org/apache/flink/runtime/operators/TaskContext.java
--
diff
for readability in yarn module for readability.
Use StringBuilder instad of StringBuffer in FlinkYarnClient since the String
materializes immediately, so no need synchronize protection.
Author: hsaputra hsapu...@apache.org
Closes #1010 from hsaputra/cleanup_yarn_branch and squashes the following
commits
for constants and static variable.
The PR is changing the name of the variable and the usages.
Author: hsaputra hsapu...@apache.org
Closes #711 from hsaputra/update_hostname_to_match_conventions and squashes the
following commits:
2a2f3bd [hsaputra] Change FlinkMiniCluster#HOSTNAME to
FlinkMiniCluster
Repository: flink
Updated Branches:
refs/heads/asf_master [deleted] aac2dc09d
Repository: flink
Updated Branches:
refs/heads/asf_master [created] aac2dc09d
Small update on TypeInfoParser JavaDoc to make the li elements in the same
alignments
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/aac2dc09
Repository: flink
Updated Branches:
refs/heads/master b8aa49ce7 - 224fa94c6
[FLINK-1805]The class IOManagerAsync should use its own Log instance
Although class 'IOManagerAsync' is extended from 'IOManager' in package
'org.apache.flink.runtime.io.disk.iomanager', but I think it should has its
Repository: flink
Updated Branches:
refs/heads/master 224fa94c6 - d8c74d209
[FLINK-1766]Fix the bug of equals function of FSKey
The equals function in org.apache.flink.core.fs.FileSystem.FSKey should first
confirm whether obj == this, if obj is the same object.It should return true
Author:
Author: hsaputra
Date: Fri Mar 27 05:38:26 2015
New Revision: 1669515
URL: http://svn.apache.org/r1669515
Log:
Update missing link in Community's IRC.
Modified:
flink/index.html
flink/site/index.html
Modified: flink/index.html
URL:
http://svn.apache.org/viewvc/flink/index.html?rev
of dependencies and first declarations
win.
Seemed like Tachyon brings transitive dependencies of older hadoop versions.
Author: Henry Saputra hsapu...@apache.org
Closes #536 from hsaputra/FLINK-1785_add_hadoop_deps_to_test_scope and squashes
the following commits:
f266a6c [Henry Saputra] [FLINK
Repository: flink
Updated Branches:
refs/heads/master de45c06f1 - ed1b30f3a
Update Javadoc from Nephele task manager to Task Manager; add missing Javadoc
params in RegularPactTask#getOutputCollector.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
Repository: flink
Updated Branches:
refs/heads/master ed1b30f3a - b566e484a
[FLINK-1770]Rename the variable 'contentAdressable' to 'contentAddressable'
Rename the variable 'contentAdressable' to 'contentAddressable' in order to
better understanding.
Author: hongsibao hongsi...@huawei.com
Repository: flink
Updated Branches:
refs/heads/master 79000c85b - 3838dd19c
Small changes to make code more consistent.
Change System.err to System.out calls for regular flow messages in
FlinkYarnSessionCli.
Code style add spaces between if-else and open parentheses and curly braces.
Wrap
Repository: flink
Updated Branches:
refs/heads/master e93e0cb86 - 7167218fe
Quick fix to fix compile error due to change class name of
MultipleProgramsTestBase.TextExecutionMode in GroupCombineITCase.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
Repository: flink
Updated Branches:
refs/heads/master 92e809d1b - 378b487c4
Remove unused imports from RichMapPartitionFunction. Wrap way too long
statements in NetworkBufferPool.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
...@gmail.com
Closes #460 from hsaputra/FLINK-1651_fix_jobmanager_fail_test and squashes the
following commits:
5d46716 [Henry Saputra] [FLINK-1651] Fix test case at JobManagerStartupTest
should not assume user could not create /does-not-exist-no-sir dir.
Project: http://git-wip-us.apache.org/repos
Author: hsaputra
Date: Wed Mar 4 18:45:04 2015
New Revision: 1664108
URL: http://svn.apache.org/r1664108
Log:
Fix typo in the Team page. From Forner to Former
Modified:
flink/community.md
flink/site/blog/feed.xml
flink/site/community.html
Modified: flink/community.md
URL:
http
Repository: flink
Updated Branches:
refs/heads/master 1230bcaa0 - 4883af675
Small cleanup to truncate some lines that are too long for easy read of the
code.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4883af67
Tree:
Repository: flink
Updated Branches:
refs/heads/master 46e052619 - bfb611f3e
Remove unused enum values from Aggregations enum.
SImple cleanup to remove unused enum values from Aggregations enum.
Author: Henry Saputra henry.sapu...@gmail.com
Closes #373 from hsaputra
Author: hsaputra
Date: Thu Feb 5 00:12:27 2015
New Revision: 1657446
URL: http://svn.apache.org/r1657446
Log:
Add link to hsaputra Github avatar
Modified:
flink/community.md
flink/site/blog/feed.xml
flink/site/community.html
Modified: flink/community.md
URL:
http://svn.apache.org
Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/flink into
asf_master
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5c7243c1
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5c7243c1
Diff:
27 matches
Mail list logo