aputra
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: http://git-wip-us.apache.org/repos/asf
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 env
the
programming guide.
Author: Henry Saputra
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 [Henry Saputra] [FLINK-2
Repository: flink
Updated Branches:
refs/heads/master 58ab14b55 -> d38aeaceb
Small update to Javadoc in IterativeDataset.closeWith to add missing param.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d38aeace
Tree: http:/
asier review.
Author: hsaputra
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 Pact from the file names o
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
a/flink-runtime/src/main/java/org/apache/flink/runtime/operators/BatchTask.java
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 --g
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
a/flink-runtime/src/main/java/org/apache/flink/runtime/operators
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
a/flink-runtime/src/main/java/org/apache/flink/runtime/iterati
ava class
Author: hsaputra
Closes #1189 from hsaputra/add_missing_javadocs_class and squashes the
following commits:
0dfba19 [hsaputra] Cleanup code as part of theme to be more consistent: -) Add
final class modifier to the XXXUtils and XXXUtil classes to make sure could not
be extended. -)
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
Closes #1010 from hsaputra/cleanup_yarn_branch and squashes the following
commits:
a6fc9e1 [hsapu
for constants and static variable.
The PR is changing the name of the variable and the usages.
Author: hsaputra
Closes #711 from hsaputra/update_hostname_to_match_conventions and squashes the
following commits:
2a2f3bd [hsaputra] Change FlinkMiniCluster#HOSTNAME to
FlinkMiniCluster#hostname to ma
to read if we wrap it.
Author: hsaputra
Closes #683 from hsaputra/wrap_very_long_line_in_FlatMapOperator and squashes
the following commits:
37d2081 [hsaputra] Wrap very long line in FlatMapOperator class.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-
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
int people to Gelly.
This should help migration to Gelly in the next release.
Author: hsaputra
Closes #618 from hsaputra/FLINK-1693_deprecate_spargel_apis and squashes the
following commits:
4652805 [hsaputra] FLINK-1693 Add DEPRECATED annotations in Spargel APIs and
update the doc to refer
to unnamed branch.
Somehow old PR #548 could not be reopen so submit new one. Sorry
Author: Henry Saputra
Closes #552 from hsaputra/fix_merge_tools_to_get_original_head and squashes the
following commits:
98d2d97 [Henry Saputra] [tools] Add --abbrev-ref to get the right branch name
of HEAD rat
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:
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 ee273dbe0 -> 121a5a0c7
Small clenaup to wrap very long lines in flink-runtime package.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/121a5a0c
Tree: http://git-wip-us.
Repository: flink
Updated Branches:
refs/heads/master c9d29f264 -> 9c0a45398
[FLINK-1790]Remove the redundant import code
Remove the redundant import code in TaskManager
Author: hongsibao
Closes #538 from matadorhong/RemoveRedundantImport and squashes the following
commits:
1f80c0d [hongs
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.htm
of dependencies and first declarations
win.
Seemed like Tachyon brings transitive dependencies of older hadoop versions.
Author: Henry Saputra
Closes #536 from hsaputra/FLINK-1785_add_hadoop_deps_to_test_scope and squashes
the following commits:
f266a6c [Henry Saputra] [FLINK-1785] [test] Mas
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
Closes #515 from mata
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: http://git-wip-us.apache
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 ve
Repository: flink
Updated Branches:
refs/heads/master 7167218fe -> 02459d244
Fix indentation for JobManager ScheduleOrUpdateConsumers and space for if-else.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/02459d24
Tree: ht
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: http://git-wip-us.apach
Author: hsaputra
Date: Wed Mar 18 17:22:41 2015
New Revision: 1667594
URL: http://svn.apache.org/r1667594
Log:
Fix the position for images of the joins options in Flink for the internal
Flink blog post.
Modified:
flink/_posts/2015-03-13-peeking-into-Apache-Flinks-Engine-Room.md
flink
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: http://git-wip-us.apache.org/repos/asf/flink
age() == null ? "." : ":
" + e.getMessage()
to:
"Initializing the input processing failed" + (e.getMessage() == null ? "." : ":
" + e.getMessage())
Extra parentheses needed to make sure ternary operator check on e.getMessage
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/asf/flin
Repository: flink
Updated Branches:
refs/heads/master 27d1e7f81 -> 92b1eb7a1
Simple fix to respect return value return by File APIs.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/92b1eb7a
Tree: http://git-wip-us.apache.o
private methods because it is
redundant.
Author: Henry Saputra
Closes #457 from hsaputra/cleanup_javadoc_and_longlines_1 and squashes the
following commits:
8815302 [Henry Saputra] Some cleanups and doc updates while looking at runtime
package: 1. Remove unnecessary brackets in
Executi
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: fl
Repository: flink
Updated Branches:
refs/heads/master bbe6e8af7 -> 086209cae
Fix typos in iterations.md file
-) Remove extra "solution" word.
-) Change propagete to propagate.
Author: Henry Saputra
Closes #443 from hsaputra/fix_typo_in_iterations_md and squashes the follo
Repository: flink
Updated Branches:
refs/heads/master bfbbbf906 -> 64c302f8f
Fix typo in exception message from assiged to assigned in ExecutionJobVertex.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/64c302f8
Tree: http
Repository: flink
Updated Branches:
refs/heads/master ed8b26bf2 -> bfbbbf906
fixed package statement
package statement was not updated after class movement
also added a missing import
Author: mjsax
Closes #437 from mjsax/bug_fix_package_statement and squashes the following
commits:
1470b0
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:
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/69cba1f1
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/69cba1f1
Diff: http://git
Repository: flink
Updated Branches:
refs/heads/master 0a22b71c8 -> 69cba1f15
Small cleanups to add space between if-else keyword and parentheses to be
consistent
as I found them.
Also fix some comments typos."
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip
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
Closes #373 from hsaputra/remove_unused_enumvalues_from_aggregations
Author: hsaputra
Date: Thu Feb 5 00:12:52 2015
New Revision: 1657447
URL: http://svn.apache.org/r1657447
Log:
Commit missing html update from md file.
Modified:
flink/site/downloads.html
Modified: flink/site/downloads.html
URL:
http://svn.apache.org/viewvc/flink/site/downloads.html?rev
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
Author: hsaputra
Date: Tue Feb 3 23:54:08 2015
New Revision: 1656952
URL: http://svn.apache.org/r1656952
Log:
FLINK-1314 Update website about #flink chat room in freenode IRC
Modified:
flink/community.md
flink/index.html
flink/site/blog/feed.xml
flink/site/community.html
Repository: flink
Updated Branches:
refs/heads/master 9849990d9 -> f7e84c157
[FLINK-1460] fix typos
Fix some typos. Also fix some inconsistent uses of **partition operator** and
**partitioning operator** in the codebase.
Author: Shuo Xiang
Author: Shuo Xiang
Closes #346 from coderxiang/ty
Repository: flink
Updated Branches:
refs/heads/master c28d96cd6 -> 9849990d9
Remove semicolon in Scala files. Fix java doc alignment in
AggregatorsITCase.java
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9849990d
Tree:
Repository: flink
Updated Branches:
refs/heads/master 5c7243c1e -> 7deeda788
Rename coGroupDataSet.scala to CoGroupDataSet.scala, and crossDataSet.scala to
CrossDataSet.scala
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commi
Move the UnfinishedCoGroupOperation class into its own Scala file.
The UnfinishedCoGroupOperation does not relate closely to CoGroupOperation
via sealed modifier so per Scala style guide [1] I propose to move it to
separate file.
[1] http://docs.scala-lang.org/style/files.html
This closes #324.
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: http://git
Repository: flink
Updated Branches:
refs/heads/master 9cdd2b3c5 -> 5c7243c1e
Cleanup missing space =)
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/49a86802
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/49a8680
for easy read.
-) Fix constant typo (from GENRAL_OPTIONS to GENERAL_OPTIONS)
-) Remove some unused imports in Scala and Java code.
Author: Henry Saputra
Closes #302 from hsaputra/cleanup_code_simple_1 and squashes the following
commits:
f98431e [Henry Saputra] Remove not needed semicolons from Sc
ink.
Author: Henry Saputra
Closes #313 from hsaputra/update_flink_repo_name_for_merge_tools and squashes
the following commits:
1af279b [Henry Saputra] Update incubator-flink name in the merge pull tools.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.
Repository: flink
Updated Branches:
refs/heads/master be0359821 -> 9fea951f8
Remove dup code fromRemoteExecutor#executePlan method
Remove dup code by delegating call from RemoteExecutor#executePlan to
RemoteExecutor#executePlanWithJars.
Author: Henry Saputra
Closes #307 from hsapu
54 matches
Mail list logo
