[jira] [Commented] (FLINK-8413) Snapshot state of aggregated data is not maintained in flink's checkpointing

2018-01-11 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16323645#comment-16323645 ] Fabian Hueske commented on FLINK-8413: -- This might also an issue with Beam's Flink runner. In this

[jira] [Commented] (FLINK-3089) State API Should Support Data Expiration (State TTL)

2018-01-11 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16323611#comment-16323611 ] Bowen Li commented on FLINK-3089: - [~xfournet] yes, supporting only TTL in processing time would be

[jira] [Comment Edited] (FLINK-8413) Snapshot state of aggregated data is not maintained in flink's checkpointing

2018-01-11 Thread suganya (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16323546#comment-16323546 ] suganya edited comment on FLINK-8413 at 1/12/18 5:09 AM: - The following code is

[jira] [Commented] (FLINK-8413) Snapshot state of aggregated data is not maintained in flink's checkpointing

2018-01-11 Thread suganya (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16323546#comment-16323546 ] suganya commented on FLINK-8413: The following code is using apache beam libraries to create a

[GitHub] flink issue #5280: [hotfix] Fix typo in AbstractMetricGroup.java

2018-01-11 Thread maqingxiang
Github user maqingxiang commented on the issue: https://github.com/apache/flink/pull/5280 Done, sorry. ---

[jira] [Commented] (FLINK-8162) Kinesis Connector to report millisBehindLatest metric

2018-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16323447#comment-16323447 ] ASF GitHub Bot commented on FLINK-8162: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #5182: [FLINK-8162] [kinesis-connector] Emit Kinesis' millisBehi...

2018-01-11 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5182 Thanks @casidiablo. Merging ... ---

[jira] [Commented] (FLINK-3296) DataStream.write*() methods are not flushing properly

2018-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16323442#comment-16323442 ] ASF GitHub Bot commented on FLINK-3296: --- Github user coveralls commented on the issue:

[GitHub] flink issue #1563: [FLINK-3296] Remove 'flushing' behavior of the OutputForm...

2018-01-11 Thread coveralls
Github user coveralls commented on the issue: https://github.com/apache/flink/pull/1563 [![Coverage Status](https://coveralls.io/builds/15015307/badge)](https://coveralls.io/builds/15015307) Changes Unknown when pulling **df49d5bb8ba778cdd17b94318c4bf48c6d1747ad on

[jira] [Commented] (FLINK-8306) FlinkKafkaConsumerBaseTest has invalid mocks on final methods

2018-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16323429#comment-16323429 ] ASF GitHub Bot commented on FLINK-8306: --- GitHub user tzulitai opened a pull request:

[jira] [Commented] (FLINK-8306) FlinkKafkaConsumerBaseTest has invalid mocks on final methods

2018-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16323430#comment-16323430 ] ASF GitHub Bot commented on FLINK-8306: --- Github user tzulitai commented on the issue:

[jira] [Commented] (FLINK-8306) FlinkKafkaConsumerBaseTest has invalid mocks on final methods

2018-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16323431#comment-16323431 ] ASF GitHub Bot commented on FLINK-8306: --- Github user tzulitai closed the pull request at:

[GitHub] flink pull request #5200: [FLINK-8306] [kafka] Introduce KafkaOffsetCommitte...

2018-01-11 Thread tzulitai
Github user tzulitai closed the pull request at: https://github.com/apache/flink/pull/5200 ---

[GitHub] flink issue #5200: [FLINK-8306] [kafka] Introduce KafkaOffsetCommitter inter...

2018-01-11 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5200 Subsumed be re-opened PR: #5284 ---

[GitHub] flink pull request #5284: [FLINK-8306] [kafka, tests] Fix invalid mock verif...

2018-01-11 Thread tzulitai
GitHub user tzulitai opened a pull request: https://github.com/apache/flink/pull/5284 [FLINK-8306] [kafka, tests] Fix invalid mock verifications on final method ## What is the purpose of the change This is a reworked version of #5200. Instead of introducing a new

[jira] [Created] (FLINK-8419) Kafka consumer's offset metrics are not registered for dynamically discovered partitions

2018-01-11 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-8419: -- Summary: Kafka consumer's offset metrics are not registered for dynamically discovered partitions Key: FLINK-8419 URL:

[jira] [Closed] (FLINK-8092) Makes no difference if python script is found or not

2018-01-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8092. --- Resolution: Duplicate Fix Version/s: 1.4.0 > Makes no difference if python script is

[jira] [Reopened] (FLINK-8092) Makes no difference if python script is found or not

2018-01-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-8092: - > Makes no difference if python script is found or not >

[jira] [Closed] (FLINK-8092) Makes no difference if python script is found or not

2018-01-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8092. --- Resolution: Fixed > Makes no difference if python script is found or not >

[jira] [Closed] (FLINK-8102) Formatting issues in Mesos documentation.

2018-01-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8102. --- Resolution: Fixed Fix Version/s: 1.4.0 1.4: 28b3115d23ab6844583578f7f2c7c37316c199be

[jira] [Closed] (FLINK-7787) Remove guava dependency in the cassandra connector

2018-01-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7787. --- Resolution: Won't Fix > Remove guava dependency in the cassandra connector >

[jira] [Closed] (FLINK-7927) Different Netty Versions in dependencies of flink-runtime make it impossible to use 3rd party libraries using netty

2018-01-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7927. --- Resolution: Fixed Fix Version/s: 1.4.0 All netty dependencies have been relocated and

[jira] [Comment Edited] (FLINK-7746) move ResultPartitionWriter#writeBufferToAllChannels up into ResultPartition

2018-01-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16323354#comment-16323354 ] Chesnay Schepler edited comment on FLINK-7746 at 1/12/18 1:18 AM: --

[jira] [Commented] (FLINK-7746) move ResultPartitionWriter#writeBufferToAllChannels up into ResultPartition

2018-01-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16323354#comment-16323354 ] Chesnay Schepler commented on FLINK-7746: - [~NicoK] can this be closed? > move

[jira] [Closed] (FLINK-7364) Log exceptions from user code in streaming jobs

2018-01-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7364. --- Resolution: Cannot Reproduce > Log exceptions from user code in streaming jobs >

[jira] [Updated] (FLINK-6375) Fix LongValue hashCode

2018-01-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6375: Issue Type: Sub-task (was: Improvement) Parent: FLINK-3957 > Fix LongValue

[GitHub] flink issue #5280: Fix typo in AbstractMetricGroup.java

2018-01-11 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5280 Thanks, merging this. Do note that you should include the `[hotfix]` and `[doc]` tags to the commit message. All our commit requires proper tags to indicate the issue id (or `hotfix` for

[jira] [Closed] (FLINK-6234) HTTP/HTTPS WebServer Extension

2018-01-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6234. --- Resolution: Invalid Fix Version/s: (was: 2.0.0) Not enough information was

[jira] [Updated] (FLINK-6206) Log task state transitions as warn/error for FAILURE scenarios

2018-01-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6206: Summary: Log task state transitions as warn/error for FAILURE scenarios (was: As an

[GitHub] flink issue #5283: [hotfix][doc] Fixed doc typo in DataStream API

2018-01-11 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5283 Merging .. ---

[jira] [Closed] (FLINK-5848) make Flink Web Backend a little bit more restful

2018-01-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5848. --- Resolution: Later Fix Version/s: 1.5.0 Subsumed by the REST backend rework. > make

[jira] [Closed] (FLINK-5746) Add acceptEither and applyToEither to Flink's Future

2018-01-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5746. --- Resolution: Won't Fix Our Future class has been replaced with Java8 {{CompletableFuture}}s.

[jira] [Closed] (FLINK-5691) Creating Reporter for elasticsearch 5.1.X causing conflicts of io.netty library

2018-01-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5691. --- Resolution: Fixed Fix Version/s: 1.4.0 We have relocated our netty dependency to

[jira] [Closed] (FLINK-5453) REST API request reference incomplete

2018-01-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5453. --- Resolution: Later Will be fixed in 1.5 as part of FLINK-8133. > REST API request reference

[jira] [Closed] (FLINK-5403) Apache Flink Snapshot 1.2 Javadocs link does not have files like index.html, overview-summary.html or index-all.html

2018-01-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5403. --- Resolution: Cannot Reproduce > Apache Flink Snapshot 1.2 Javadocs link does not have files

[jira] [Updated] (FLINK-8335) Upgrade hbase connector dependency to 1.4.0

2018-01-11 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-8335: -- Component/s: Batch Connectors and Input/Output Formats > Upgrade hbase connector dependency to 1.4.0 >

[jira] [Created] (FLINK-8418) Kafka08ITCase.testStartFromLatest() times out on Travis

2018-01-11 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-8418: -- Summary: Kafka08ITCase.testStartFromLatest() times out on Travis Key: FLINK-8418 URL: https://issues.apache.org/jira/browse/FLINK-8418 Project: Flink

[jira] [Updated] (FLINK-8418) Kafka08ITCase.testStartFromLatestOffsets() times out on Travis

2018-01-11 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-8418: --- Summary: Kafka08ITCase.testStartFromLatestOffsets() times out on Travis (was:

[jira] [Commented] (FLINK-8073) Test instability FlinkKafkaProducer011ITCase.testScaleDownBeforeFirstCheckpoint()

2018-01-11 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16323281#comment-16323281 ] Tzu-Li (Gordon) Tai commented on FLINK-8073: Another instance:

[jira] [Updated] (FLINK-8417) Support STSAssumeRoleSessionCredentialsProvider in FlinkKinesisConsumer

2018-01-11 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-8417: --- Description: As discussed in ML:

[jira] [Created] (FLINK-8417) Support STSAssumeRoleSessionCredentialsProvider in FlinkKinesisConsumer

2018-01-11 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-8417: -- Summary: Support STSAssumeRoleSessionCredentialsProvider in FlinkKinesisConsumer Key: FLINK-8417 URL: https://issues.apache.org/jira/browse/FLINK-8417

[jira] [Created] (FLINK-8416) Kinesis consumer doc examples should demonstrate preferred default credentials provider

2018-01-11 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-8416: -- Summary: Kinesis consumer doc examples should demonstrate preferred default credentials provider Key: FLINK-8416 URL: https://issues.apache.org/jira/browse/FLINK-8416

[jira] [Commented] (FLINK-8296) Rework FlinkKafkaConsumerBestTest to not use Java reflection for dependency injection

2018-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16323208#comment-16323208 ] ASF GitHub Bot commented on FLINK-8296: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #5188: [FLINK-8296] [kafka] Rework FlinkKafkaConsumerBaseTest to...

2018-01-11 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5188 Thanks! Merging this ... ---

[jira] [Closed] (FLINK-8333) Split command options from deployment options in CliFrontend

2018-01-11 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8333. Resolution: Fixed Fixed via 12396f19851e74310c9b5f28870a8de9794511fc > Split command options from

[jira] [Commented] (FLINK-8299) Retrieve ExecutionResult by REST polling

2018-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16323194#comment-16323194 ] ASF GitHub Bot commented on FLINK-8299: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-8333) Split command options from deployment options in CliFrontend

2018-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16323192#comment-16323192 ] ASF GitHub Bot commented on FLINK-8333: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #5225: [FLINK-8339] [flip6] Let CustomCommandLine return ...

2018-01-11 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5225 ---

[jira] [Commented] (FLINK-8338) Make CustomCommandLines non static in CliFrontend

2018-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16323193#comment-16323193 ] ASF GitHub Bot commented on FLINK-8338: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #5207: [FLINK-8299][flip6] Poll JobExecutionResult after ...

2018-01-11 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5207 ---

[jira] [Closed] (FLINK-8338) Make CustomCommandLines non static in CliFrontend

2018-01-11 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8338. Resolution: Fixed Fixed via aff43768f3285a5f2bc5593369a7fec3ed77a2af > Make CustomCommandLines non

[jira] [Commented] (FLINK-8339) Let CustomCommandLine return a ClusterDescriptor

2018-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16323191#comment-16323191 ] ASF GitHub Bot commented on FLINK-8339: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #5224: [FLINK-8338] [flip6] Make CustomCommandLines non s...

2018-01-11 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5224 ---

[GitHub] flink pull request #5220: [FLINK-8333] [flip6] Separate deployment options f...

2018-01-11 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5220 ---

[jira] [Closed] (FLINK-8339) Let CustomCommandLine return a ClusterDescriptor

2018-01-11 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8339. Resolution: Fixed Fixed via e2f1ba92decdb27f3aea4e21a7cad7dcc98cea1a > Let CustomCommandLine

[jira] [Resolved] (FLINK-8299) Retrieve ExecutionResult by REST polling

2018-01-11 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-8299. -- Resolution: Fixed Fixed via 06922753a55dc322b96919ebb407d531e2b79d3e > Retrieve

[jira] [Commented] (FLINK-8347) Make Cluster id typesafe

2018-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16323107#comment-16323107 ] ASF GitHub Bot commented on FLINK-8347: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #5232: [FLINK-8347] [flip6] Make cluster id used by Clust...

2018-01-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5232#discussion_r161094149 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java --- @@ -367,40 +366,31 @@ public ClusterClient

[jira] [Commented] (FLINK-8343) Add support for job cluster deployment

2018-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16323104#comment-16323104 ] ASF GitHub Bot commented on FLINK-8343: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #5229: [FLINK-8343] [flip6] Remove Yarn specific commands from Y...

2018-01-11 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5229 Thanks for the review @GJL. Merged onto the latest master. ---

[GitHub] flink pull request #5229: [FLINK-8343] [flip6] Remove Yarn specific commands...

2018-01-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5229#discussion_r161089633 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java --- @@ -534,215 +557,235 @@ private Configuration

[jira] [Commented] (FLINK-8343) Add support for job cluster deployment

2018-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16323060#comment-16323060 ] ASF GitHub Bot commented on FLINK-8343: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #5229: [FLINK-8343] [flip6] Remove Yarn specific commands...

2018-01-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5229#discussion_r161090177 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java --- @@ -534,215 +557,235 @@ private Configuration

[jira] [Commented] (FLINK-8343) Add support for job cluster deployment

2018-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16323054#comment-16323054 ] ASF GitHub Bot commented on FLINK-8343: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #5228: [FLINK-8342] [flip6] Remove generic type parameter...

2018-01-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5228#discussion_r161087011 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java --- @@ -99,7 +99,7 @@ /** * The descriptor with

[jira] [Commented] (FLINK-8342) Remove ClusterClient generic type parameter from ClusterDescriptor

2018-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16323041#comment-16323041 ] ASF GitHub Bot commented on FLINK-8342: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-8341) Remove unneeded CommandLineOptions

2018-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16323034#comment-16323034 ] ASF GitHub Bot commented on FLINK-8341: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #5227: [FLINK-8341] [flip6] Remove not needed options from Comma...

2018-01-11 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5227 Thanks for the review @GJL. Addressing comments and merging once Travis gives green light. ---

[jira] [Commented] (FLINK-8299) Retrieve ExecutionResult by REST polling

2018-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322854#comment-16322854 ] ASF GitHub Bot commented on FLINK-8299: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #5207: [FLINK-8299][flip6] Poll JobExecutionResult after job sub...

2018-01-11 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5207 Merging this PR. Thanks for your contribution @GJL. ---

[jira] [Created] (FLINK-8415) Unprotected access to recordsToSend in LongRecordWriterThread#shutdown()

2018-01-11 Thread Ted Yu (JIRA)
Ted Yu created FLINK-8415: - Summary: Unprotected access to recordsToSend in LongRecordWriterThread#shutdown() Key: FLINK-8415 URL: https://issues.apache.org/jira/browse/FLINK-8415 Project: Flink

[jira] [Commented] (FLINK-7935) Metrics with user supplied scope variables

2018-01-11 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322789#comment-16322789 ] Elias Levy commented on FLINK-7935: --- So it seems the DD reporter needs to switch from

[jira] [Commented] (FLINK-8299) Retrieve ExecutionResult by REST polling

2018-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322541#comment-16322541 ] ASF GitHub Bot commented on FLINK-8299: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #5207: [FLINK-8299][flip6] Poll JobExecutionResult after ...

2018-01-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5207#discussion_r161010273 --- Diff: flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java --- @@ -148,6 +181,39 @@ private void

[GitHub] flink pull request #5194: [FLINK-8233][flip6] Add JobExecutionResultHandler

2018-01-11 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5194 ---

[jira] [Commented] (FLINK-8233) Expose JobExecutionResult via HTTP

2018-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322480#comment-16322480 ] ASF GitHub Bot commented on FLINK-8233: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-8328) Pull Yarn ApplicationStatus polling out of YarnClusterClient

2018-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322477#comment-16322477 ] ASF GitHub Bot commented on FLINK-8328: --- Github user asfgit closed the pull request at:

[jira] [Closed] (FLINK-8329) Move YarnClient out of YarnClusterClient

2018-01-11 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8329. Resolution: Fixed Fixed via 156b8935ef76eb53456cea1d40fd528ccefa21d8 > Move YarnClient out of

[jira] [Commented] (FLINK-8329) Move YarnClient out of YarnClusterClient

2018-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322478#comment-16322478 ] ASF GitHub Bot commented on FLINK-8329: --- Github user asfgit closed the pull request at:

[jira] [Closed] (FLINK-8328) Pull Yarn ApplicationStatus polling out of YarnClusterClient

2018-01-11 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8328. Resolution: Fixed Fixed via 2ce5b98da04cb3850ff91757cc4b74a98b8ce082 > Pull Yarn ApplicationStatus

[GitHub] flink pull request #5216: [FLINK-8329] [flip6] Move YarnClient to AbstractYa...

2018-01-11 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5216 ---

[GitHub] flink pull request #5219: [FLINK-8332] [flip6] Move savepoint dispose into C...

2018-01-11 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5219 ---

[jira] [Closed] (FLINK-8332) Move dispose savepoint into ClusterClient

2018-01-11 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8332. Resolution: Fixed Fixed via c2492e9b220c6c9a64b47bcdc76a2194d9f4d669 > Move dispose savepoint into

[jira] [Commented] (FLINK-8332) Move dispose savepoint into ClusterClient

2018-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322479#comment-16322479 ] ASF GitHub Bot commented on FLINK-8332: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #5215: [FLINK-8328] [flip6] Move Yarn ApplicationStatus p...

2018-01-11 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5215 ---

[jira] [Closed] (FLINK-8233) Expose JobExecutionResult via HTTP

2018-01-11 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8233. Resolution: Fixed Fixed via 86892b8e76a4e4b26cedf38c0695c53814a7f04f > Expose JobExecutionResult

[GitHub] flink pull request #5207: [FLINK-8299][flip6] Poll JobExecutionResult after ...

2018-01-11 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5207#discussion_r160997382 --- Diff: flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java --- @@ -148,6 +181,39 @@ private void submitJob(JobGraph

[jira] [Commented] (FLINK-8299) Retrieve ExecutionResult by REST polling

2018-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322467#comment-16322467 ] ASF GitHub Bot commented on FLINK-8299: --- Github user GJL commented on a diff in the pull request:

[GitHub] flink pull request #5225: [FLINK-8339] [flip6] Let CustomCommandLine return ...

2018-01-11 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5225#discussion_r160995333 --- Diff: flink-clients/src/main/java/org/apache/flink/client/cli/DefaultCLI.java --- @@ -51,45 +45,23 @@ public String getId() { }

[jira] [Commented] (FLINK-8339) Let CustomCommandLine return a ClusterDescriptor

2018-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322459#comment-16322459 ] ASF GitHub Bot commented on FLINK-8339: --- Github user GJL commented on a diff in the pull request:

[jira] [Commented] (FLINK-8233) Expose JobExecutionResult via HTTP

2018-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322452#comment-16322452 ] ASF GitHub Bot commented on FLINK-8233: --- Github user tillrohrmann commented on the issue:

[jira] [Commented] (FLINK-8339) Let CustomCommandLine return a ClusterDescriptor

2018-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322453#comment-16322453 ] ASF GitHub Bot commented on FLINK-8339: --- Github user GJL commented on a diff in the pull request:

[GitHub] flink pull request #5225: [FLINK-8339] [flip6] Let CustomCommandLine return ...

2018-01-11 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5225#discussion_r160994352 --- Diff: flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java --- @@ -457,7 +499,19 @@ protected int stop(String[] args) throws Exception {

[GitHub] flink issue #5194: [FLINK-8233][flip6] Add JobExecutionResultHandler

2018-01-11 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5194 Travis passed. Merging this PR. Thanks for your contribution. ---

[jira] [Commented] (FLINK-8339) Let CustomCommandLine return a ClusterDescriptor

2018-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322425#comment-16322425 ] ASF GitHub Bot commented on FLINK-8339: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #5225: [FLINK-8339] [flip6] Let CustomCommandLine return Cluster...

2018-01-11 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5225 Thanks for the review @GJL. I've addressed most of your comments and rebased onto the latest master. ---

[jira] [Commented] (FLINK-6892) Add L/RPAD supported in SQL

2018-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322397#comment-16322397 ] ASF GitHub Bot commented on FLINK-6892: --- Github user sunjincheng121 commented on the issue:

[GitHub] flink issue #4127: [FLINK-6892][table]Add L/RPAD supported in SQL

2018-01-11 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/4127 @twalthr Thanks for the review! I have update the PR. I will be very grateful if you can review again. Thanks, Jincheng ---

[jira] [Commented] (FLINK-8339) Let CustomCommandLine return a ClusterDescriptor

2018-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322396#comment-16322396 ] ASF GitHub Bot commented on FLINK-8339: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #5225: [FLINK-8339] [flip6] Let CustomCommandLine return ...

2018-01-11 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5225#discussion_r160985701 --- Diff: flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java --- @@ -457,7 +499,19 @@ protected int stop(String[] args) throws

  1   2   3   >