{"action":"created","issue":{"url":"https://api.github.com/repos/apache/beam/issues/7031","repository_url":"https://api.github.com/repos/apache/beam","labels_url":"https://api.github.com/repos/apache/beam/issues/7031/labels{/name}","comments_url":"https://api.github.com/repos/apache/beam/issues/7031/comments","events_url":"https://api.github.com/repos/apache/beam/issues/7031/events","html_url":"https://github.com/apache/beam/pull/7031","id":380510707,"node_id":"MDExOlB1bGxSZXF1ZXN0MjMwNjkxNjYw","number":7031,"title":"[BEAM-6058] Adding option for flink configuration directory and setting config in exectution environment","user":{"login":"angoenka","id":38219,"node_id":"MDQ6VXNlcjM4MjE5","avatar_url":"https://avatars3.githubusercontent.com/u/38219?v=4","gravatar_id":"","url":"https://api.github.com/users/angoenka","html_url":"https://github.com/angoenka","followers_url":"https://api.github.com/users/angoenka/followers","following_url":"https://api.github.com/users/angoenka/following{/other_user}","gists_url":"https://api.github.com/users/angoenka/gists{/gist_id}","starred_url":"https://api.github.com/users/angoenka/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/angoenka/subscriptions","organizations_url":"https://api.github.com/users/angoenka/orgs","repos_url":"https://api.github.com/users/angoenka/repos","events_url":"https://api.github.com/users/angoenka/events{/privacy}","received_events_url":"https://api.github.com/users/angoenka/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":7,"created_at":"2018-11-14T02:38:45Z","updated_at":"2018-11-14T18:52:03Z","closed_at":null,"author_association":"CONTRIBUTOR","pull_request":{"url":"https://api.github.com/repos/apache/beam/pulls/7031","html_url":"https://github.com/apache/beam/pull/7031","diff_url":"https://github.com/apache/beam/pull/7031.diff","patch_url":"https://github.com/apache/beam/pull/7031.patch"},"body":"This is needed as when submitting to remote execution environment, client config from the request is used.\r\n\r\n------------------------\r\n\r\nFollow this checklist to help us incorporate your contribution quickly and easily:\r\n\r\n - [ ] Format the pull request title like `[BEAM-XXX] Fixes bug in ApproximateQuantiles`, where you replace `BEAM-XXX` with the appropriate JIRA issue, if applicable. This will automatically link the pull request to the issue.\r\n - [ ] If this contribution is large, please file an Apache [Individual Contributor License Agreement](https://www.apache.org/licenses/icla.pdf).\r\n\r\nIt will help us expedite review of your Pull Request if you tag someone (e.g. `@username`) to look at it.\r\n\r\nPost-Commit Tests Status (on master branch)\r\n------------------------------------------------------------------------------------------------\r\n\r\nLang | SDK | Apex | Dataflow | Flink | Gearpump | Samza | Spark\r\n--- | --- | --- | --- | --- | --- | --- | ---\r\nGo | [![Build Status](https://builds.apache.org/job/beam_PostCommit_Go_GradleBuild/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Go_GradleBuild/lastCompletedBuild/) | --- | --- | --- | --- | --- | ---\r\nJava | [![Build Status](https://builds.apache.org/job/beam_PostCommit_Java_GradleBuild/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Java_GradleBuild/lastCompletedBuild/) | [![Build Status](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Apex_Gradle/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Apex_Gradle/lastCompletedBuild/) | [![Build Status](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow_Gradle/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow_Gradle/lastCompletedBuild/) | [![Build Status](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/lastCompletedBuild/) [![Build Status](https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/lastCompletedBuild/) | [![Build Status](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/lastCompletedBuild/) | [![Build Status](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Samza_Gradle/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Samza_Gradle/lastCompletedBuild/) | [![Build Status](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Spark_Gradle/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Spark_Gradle/lastCompletedBuild/)\r\nPython | [![Build Status](https://builds.apache.org/job/beam_PostCommit_Python_Verify/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Python_Verify/lastCompletedBuild/) | --- | [![Build Status](https://builds.apache.org/job/beam_PostCommit_Py_VR_Dataflow/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Py_VR_Dataflow/lastCompletedBuild/) </br> [![Build Status](https://builds.apache.org/job/beam_PostCommit_Py_ValCont/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Py_ValCont/lastCompletedBuild/) | [![Build Status](https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/lastCompletedBuild/) | --- | --- | ---\r\n\r\n\r\n\r\n\r\n"},"comment":{"url":"https://api.github.com/repos/apache/beam/issues/comments/438775803","html_url":"https://github.com/apache/beam/pull/7031#issuecomment-438775803","issue_url":"https://api.github.com/repos/apache/beam/issues/7031","id":438775803,"node_id":"MDEyOklzc3VlQ29tbWVudDQzODc3NTgwMw==","user":{"login":"angoenka","id":38219,"node_id":"MDQ6VXNlcjM4MjE5","avatar_url":"https://avatars3.githubusercontent.com/u/38219?v=4","gravatar_id":"","url":"https://api.github.com/users/angoenka","html_url":"https://github.com/angoenka","followers_url":"https://api.github.com/users/angoenka/followers","following_url":"https://api.github.com/users/angoenka/following{/other_user}","gists_url":"https://api.github.com/users/angoenka/gists{/gist_id}","starred_url":"https://api.github.com/users/angoenka/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/angoenka/subscriptions","organizations_url":"https://api.github.com/users/angoenka/orgs","repos_url":"https://api.github.com/users/angoenka/repos","events_url":"https://api.github.com/users/angoenka/events{/privacy}","received_events_url":"https://api.github.com/users/angoenka/received_events","type":"User","site_admin":false},"created_at":"2018-11-14T18:52:03Z","updated_at":"2018-11-14T18:52:03Z","author_association":"CONTRIBUTOR","body":"Properties like taskmanager.runtime.large-record-handler are read from the submitted JobGraph and are not read by cluster when using RemoteEnvironment. Hence we need to read and set the properties in the job graph. Many of these properties are not even exposed via ExecutionConfig so we need to read these properties directly. \r\nReading from a config dir seems be the right way as we are already doing it for parallelism.\r\n"}}
{"actor":{"display_login":"angoenka"}}