reef
reef copied to clipboard
Mirror of Apache REEF
Bumps jsch from 0.1.53 to 0.1.54. [](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores) Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a...
Bumps hadoop-common from 3.2.1 to 3.2.3. [](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores) Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a...
This PR introduces the new elastic group communication framework. For the moment only the broadcast operator with flat topology is implemented. Further operators and topologies will be added in successive...
The current state did not handle serializing out a list when a list was set in the configuration. This now adds that functionality along with unit tests. JIRA: [REEF-2044](https://issues.apache.org/jira/browse/REEF-2044) Closes...
This addressed the issue by: * Using the Yarn allocation ID API that was introduced in hadoop 2.9.1 in the Yarn Runtime. * Adding a corresponding property in the `EvaluatorRequest`...
[REEF-2036] Add IFileSystem api to check if uri is a directory Currently, there is no way to check if a location specified by a uri is a directory or not....
* Adding IMRUCheckpointHandler to handle task state persistent * Added configuration module for IMRUCheckpointHandler * Update IMRUJobDefination to all client to set checkpoint configuration * Add UpdateTaskStateCodec implementation * Update...
Additional implementation for Wake via HTTP * ~new package `org.apache.reef.wake.remote.transport.netty.http`~ * no new package created. * followed default implementation of netty * Added TransportHttpTest * currently tested only for HTTP...