GitHub user cfmcgrady opened a pull request:
https://github.com/apache/flink/pull/1295
Mesos
- remoe httpserver
- add make-distribution.sh - tool for making binary distributions of flink
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/cfmcgrady/flink mesos
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/1295.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 #1295
----
commit d5d7b225f137f08f72bd13a0aa13fbe94da544dd
Author: Ankur Chauhan <[email protected]>
Date: 2015-07-20T08:45:41Z
wip
commit bc62e47cbf3b82b6173ed1726bd53654993067b9
Author: Ankur Chauhan <[email protected]>
Date: 2015-07-25T19:18:42Z
WIP - flink mesos integration initial commit
commit ca46a26ae5af30efe52577eaef137bb468647376
Author: Ankur Chauhan <[email protected]>
Date: 2015-07-25T19:33:57Z
Add todo for config changes/issues
commit d6d045b269184525d611640ca53f796a2229856a
Author: Ankur Chauhan <[email protected]>
Date: 2015-07-27T00:03:12Z
Fix some stuff
commit 09a3f75b686177e130ef78eb20ca5fbf55f607cf
Author: Ankur Chauhan <[email protected]>
Date: 2015-07-28T01:41:20Z
Add flink-mesos to dist, update scheduler and executor code
commit 25fed5fc36012eef986ae3368df8849a758ac4d0
Author: Ankur Chauhan <[email protected]>
Date: 2015-07-28T03:14:16Z
Clean up code + codestyle changes
commit 1d7dfbc393ddafb2fa407753d5b25f654af25d65
Author: Ankur Chauhan <[email protected]>
Date: 2015-07-28T07:12:55Z
Clean up executor, adjust resource defaults
commit 057705750602ed055d302387a9e56fdd0c7e7b25
Author: Ankur Chauhan <[email protected]>
Date: 2015-07-28T20:56:24Z
Remove status pinging and fix logging level in TaskManagerExecutor
commit 5269ad1a6490ae8a98af3c5eb404664d57df1ca1
Author: Ankur Chauhan <[email protected]>
Date: 2015-07-28T22:33:54Z
Code cleanup and refactoring of the conf classes
commit 61b28fef345dfc0390df7911a68ed8e0764d5f32
Author: Ankur Chauhan <[email protected]>
Date: 2015-07-28T22:36:04Z
Remove unused dependencies and plugins
commit 038c74b59951c5b33fbcdeae0f224ef36d3016a8
Author: Ankur Chauhan <[email protected]>
Date: 2015-07-28T22:40:50Z
Use tab based indents in pom files
commit cd793892c8ac939824f675ab293af947ad66b211
Author: Ankur Chauhan <[email protected]>
Date: 2015-07-28T23:06:30Z
Add comments for each of the properties
commit 5a701eaab144d03146ed356097b96fb4b8a39992
Author: Ankur Chauhan <[email protected]>
Date: 2015-07-28T23:22:57Z
Fix pom + Add flink-mesos entry to travis CI confiuration
commit f75c3202e0a2589bde9af9d2c6388d9458977946
Author: Ankur Chauhan <[email protected]>
Date: 2015-07-28T23:54:29Z
Remove unussed method
commit 30efe5f0e4d18d452a3505c6f101d4322bc0af6c
Author: Ankur Chauhan <[email protected]>
Date: 2015-07-30T23:40:52Z
Remove yarn features while building for mesos
commit 59f6e3995362461f4877aa037087e4f7d3aefa37
Author: Ankur Chauhan <[email protected]>
Date: 2015-08-02T04:50:42Z
Revert changes to .travis.yml
commit f6b20e74d3aead76abcc1acf2829a7e294e8453e
Author: Ankur Chauhan <[email protected]>
Date: 2015-08-31T02:22:56Z
[Review updates] Use http server to host log4j properties, added apache
spark attribution
commit 7486347187e5e73e4f800c3026131ed3ef4f8aab
Author: Ankur Chauhan <[email protected]>
Date: 2015-08-31T02:39:01Z
Compile failure with httpServer
commit 4da1732249780b8604aabf2c899ff9754788952d
Author: Ankur Chauhan <[email protected]>
Date: 2015-08-31T02:44:54Z
Handle exceptions during driver startup of Scheduler
commit 2f19c522a1b6f2ec0d6c11070667f42519561220
Author: Ankur Chauhan <[email protected]>
Date: 2015-08-31T02:47:19Z
Update mesos java library
commit 4d5f147da6ab4fd6c6f2f79d160ab4942ebe90dc
Author: Ankur Chauhan <[email protected]>
Date: 2015-09-08T01:58:56Z
Merge branch 'master' into flink-mesos
* master: (27 commits)
[FLINK-2372] Add new FlinkKafkaProducer bases on the new producer API
[FLINK-2626] [core] Minor cleanups in AverageAccumulator and
AverageAccumulatorTest
[FLINK-2626] [core] Add an average accumulator
[hotfix] [tests] Increase zookeeper session timeouts in tests them more
robust
[FLINK-2628] [tests] CoStreamCheckpointingITCase prints a warning when
test is inconclusive
[FLINK-2625] Pass configuration properly to JobGraphGenerator
[FLINK-2605] [runtime] Unclosed RandomAccessFile may leak resource in
StaticFileServerHandler
[FLINK-2161] [scala shell] Modify start script to take additional
argument (-a <path/to/class> or --addclasspath <path/to/class>) for external
libraries
[FLINK-2475] Rename Flink Client log file
[FLINK-2614][scala-shell] scala shell's default execution mode is broken
[FLINK-2607][quickstart] ignore signature files when creating fat jar
[hotfix][docs] Update Kafka section in streaming guide to match the
renamed class names
[hotfix] [gelly] Remove unintended calls to getExecutionEnvironment in
VertexCentricIteration and GatherSumApplyIteration
[FLINK-2448] [tests] Create new Test Environments on every call to
getExecutionEnvironment and allow sharing of job execution results
[FLINK-2545] add bucket member verification while build bloom filter.
[FLINK-2601] [runtime] Install shutdown hook at the end of I/O manager
initialization
[FLINK-2604] [runtime] Adds synchronization to stop method of
ZooKeeperLeaderElectionService
[FLINK-2590] Fixes Scala's DataSetUtilsITCase
[FLINK-2590] fixing DataSetUtils.zipWithUniqueId() and
DataSetUtils.zipWithIndex()
[FLINK-2584] Check for unshaded classes in fat jar and shade curator
...
commit abf2292f32ee0768fa4f293cca169fc496ec19a3
Author: Ankur Chauhan <[email protected]>
Date: 2015-09-08T03:03:00Z
Add guava
commit c83806fb0449081f5483f52edd5cfa40c46940bd
Author: Ankur Chauhan <[email protected]>
Date: 2015-09-24T05:17:51Z
Merge branch 'master' into flink-mesos
* master: (133 commits)
Adjust Netty version in flink-dist/LICENSE
[jobmanager] Fix indentation
[FLINK-2675] [streaming] Integrate Timer Service with StreamTask
Bump Netty version to 4.0.31.Final
[FLINK-2651] Add Netty to dependency management
[tests] Harden SocketClientSinkTest
[hotfix] [streaming] Improve error message for key operations on
non-composite types
[FLINK-2734] [streaming] Fix ArrayKeySelector
[tests] Improve Kafka concurrent produce/consumer test by allowing
retries when connecting to non-leader broker.
[FLINK-2744] [kafka connector] Reduce number of concurrent test forks to
improce test stability on CI environment.
[FLINK-2746] [tests] Add RetryOnException annotation for tests
[FLINK-2705] [yarn] Excludes commons-codec:1.3 from aws-java-jdk
dependency to resolve dependency ambiguity
[FLINK-2694] [test-stability] Hardens the
JobManagerProcessReapingTest.testReapProcessOnFailure test case by letting the
JobManager choose its port instead of predetermining it via the
NetUtils.getAvailablePort.
[FLINK-2696] [test-stability] Hardens ZookeeperOffsetHandlerTest by
letting Curator's TestingServer select the port to bind to instead of using
NetUtils.getAvailablePort.
[tests] Add RetryOnFailure annotation
[FLINK-2729] [web-dashboard] Add TaskManager overview
[test-stability] Replaces Curator's TestingCluster with TestingServer in
ZooKeeperElection/RetrievalTests. Increased the timeout to 200s in
ZooKeeperLeaderElectionTest.
[FLINK-2097] temporarily disable session management API
[FLINK-2097][core] implement a job session management
[Maven] fix order of parent module information
...
commit a927da3f980b6931968619b39ab5799557f52dc1
Author: Ankur Chauhan <[email protected]>
Date: 2015-09-24T06:23:13Z
Fix bugs and add option to override host and port for the scheduler http
server
commit d905af0558baf23c312bb71e82372cea2a79d665
Author: Ankur Chauhan <[email protected]>
Date: 2015-10-06T19:37:22Z
Add more javadoc to clarify intention of classes and traits
commit 9f66dc09bea98b0178b1f0de234615f8824a197f
Author: Fu Chen <[email protected]>
Date: 2015-10-23T06:18:57Z
remove httpserver
commit e8ce40512b6d3927577884ac5969416b543460eb
Author: Fu Chen <[email protected]>
Date: 2015-10-23T06:19:53Z
add make-distribution.sh - tool for making binary distributions of flink
----
---
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 [email protected] or file a JIRA ticket
with INFRA.
---
