[jira] [Created] (FLINK-8337) GatherSumApplyITCase.testConnectedComponentsWithObjectReuseDisabled instable

2018-01-02 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-8337: Summary: GatherSumApplyITCase.testConnectedComponentsWithObjectReuseDisabled instable Key: FLINK-8337 URL: https://issues.apache.org/jira/browse/FLINK-8337 Project:

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

2018-01-02 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8333: - Issue Type: Sub-task (was: Improvement) Parent: FLINK-4352 > Split command options from

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

2018-01-02 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8332: - Issue Type: Sub-task (was: Improvement) Parent: FLINK-4352 > Move dispose savepoint into

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

2018-01-02 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8329: - Issue Type: Sub-task (was: Improvement) Parent: FLINK-4352 > Move YarnClient out of

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

2018-01-02 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8328: - Issue Type: Sub-task (was: Improvement) Parent: FLINK-4352 > Pull Yarn ApplicationStatus

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

2018-01-02 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-8338: Summary: Make CustomCommandLines non static in CliFrontend Key: FLINK-8338 URL: https://issues.apache.org/jira/browse/FLINK-8338 Project: Flink Issue Type:

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

2018-01-02 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8338: - Labels: flip-6 (was: ) > Make CustomCommandLines non static in CliFrontend >

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

2018-01-02 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5224 [FLINK-8338] [flip6] Make CustomCommandLines non static in CliFrontend ## What is the purpose of the change This commit changes how CustomCommandLines are registered at the

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

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

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

2018-01-02 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-8339: Summary: Let CustomCommandLine return a ClusterDescriptor Key: FLINK-8339 URL: https://issues.apache.org/jira/browse/FLINK-8339 Project: Flink Issue Type:

[GitHub] flink pull request #5141: [FLINK-8226] [cep] Dangling reference generated af...

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

[jira] [Commented] (FLINK-8226) Dangling reference generated after NFA clean up timed out SharedBufferEntry

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

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

2018-01-02 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5225 [FLINK-8339] [flip6] Let CustomCommandLine return ClusterDescriptor ## What is the purpose of the change Instead of directly retrieving or deploying a Flink cluster, the

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

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

[jira] [Created] (FLINK-8340) Do not pass Configuration and configuration directory to CustomCommandLine methods

2018-01-02 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-8340: Summary: Do not pass Configuration and configuration directory to CustomCommandLine methods Key: FLINK-8340 URL: https://issues.apache.org/jira/browse/FLINK-8340

[GitHub] flink pull request #5226: [FLINK-8340] [flip6] Remove passing of Configurati...

2018-01-02 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5226 [FLINK-8340] [flip6] Remove passing of Configuration to CustomCommandLine ## What is the purpose of the change Since the Configuration does not change over the lifetime of a

[jira] [Commented] (FLINK-8340) Do not pass Configuration and configuration directory to CustomCommandLine methods

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

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

2018-01-02 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-8341: Summary: Remove unneeded CommandLineOptions Key: FLINK-8341 URL: https://issues.apache.org/jira/browse/FLINK-8341 Project: Flink Issue Type: Sub-task

[GitHub] flink pull request #5227: [FLINK-8341] [flip6] Remove not needed options fro...

2018-01-02 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5227 [FLINK-8341] [flip6] Remove not needed options from CommandLineOptions ## What is the purpose of the change Remove not needed options from `CommandLineOptions` This PR is

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

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

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

2018-01-02 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8342: - Summary: Remove ClusterClient generic type parameter from ClusterDescriptor (was: Remove

[jira] [Created] (FLINK-8342) Remove ClusterClient generic type argument from ClusterDescriptor

2018-01-02 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-8342: Summary: Remove ClusterClient generic type argument from ClusterDescriptor Key: FLINK-8342 URL: https://issues.apache.org/jira/browse/FLINK-8342 Project: Flink

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

2018-01-02 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5228 [FLINK-8342] [flip6] Remove generic type parameter from ClusterDescriptor ## What is the purpose of the change Remove generic type parameter from `ClusterDescriptor`. ## Does

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

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

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

2018-01-02 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5229 [FLINK-8343] [flip6] Remove Yarn specific commands from YarnClusterDescriptor ## What is the purpose of the change Remove Yarn specific commands from YarnClusterDescriptor. This is a

[jira] [Commented] (FLINK-8292) Remove unnecessary force cast in DataStreamSource

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

[GitHub] flink pull request #5180: [FLINK-8292] Remove unnecessary force cast in Data...

2018-01-02 Thread Matrix42
Github user Matrix42 closed the pull request at: https://github.com/apache/flink/pull/5180 ---

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

2018-01-02 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-8343: Summary: Add support for job cluster deployment Key: FLINK-8343 URL: https://issues.apache.org/jira/browse/FLINK-8343 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-8344) Add support for HA to RestClusterClient

2018-01-02 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-8344: Summary: Add support for HA to RestClusterClient Key: FLINK-8344 URL: https://issues.apache.org/jira/browse/FLINK-8344 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-8269) Set netRuntime in JobExecutionResult

2018-01-02 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-8269: --- Assignee: Gary Yao > Set netRuntime in JobExecutionResult > > >

[jira] [Commented] (FLINK-6206) As an Engineer, I want task state transition log to be warn/error for FAILURE scenarios

2018-01-02 Thread Ashwin Sinha (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16307865#comment-16307865 ] Ashwin Sinha commented on FLINK-6206: - Is this relevant? If yes then I can raise a PR. > As an

[jira] [Created] (FLINK-8345) Iterate over keyed state on broadcast side of connect with broadcast.

2018-01-02 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-8345: - Summary: Iterate over keyed state on broadcast side of connect with broadcast. Key: FLINK-8345 URL: https://issues.apache.org/jira/browse/FLINK-8345 Project: Flink

[jira] [Commented] (FLINK-8345) Iterate over keyed state on broadcast side of connect with broadcast.

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

[GitHub] flink pull request #5230: [FLINK-8345] Add iterator of keyed state on broadc...

2018-01-02 Thread kl0u
GitHub user kl0u opened a pull request: https://github.com/apache/flink/pull/5230 [FLINK-8345] Add iterator of keyed state on broadcast side of connected streams. *Thank you very much for contributing to Apache Flink - we are happy that you want to help us improve Flink. To help

[GitHub] flink issue #5140: [FLINK-7797] [table] Add support for windowed outer joins...

2018-01-02 Thread xccui
Github user xccui commented on the issue: https://github.com/apache/flink/pull/5140 Hi @fhueske, thanks for your review. I've made the following changes to the PR. 1. Fixes the "wrong sides" problem in `TimeBoundedStreamJoin`. 2. Adds the logic for outer-joins with negative

[jira] [Commented] (FLINK-7797) Add support for windowed outer joins for streaming tables

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

[GitHub] flink pull request #5175: [FLINK-8280][checkstyle] fix checkstyle in BlobSer...

2018-01-02 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/5175#discussion_r159209751 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobUtils.java --- @@ -150,8 +150,7 @@ static File initLocalStorageDirectory(String

[jira] [Commented] (FLINK-8280) Enable checkstyle for org.apache.flink.runtime.blob

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

[GitHub] flink issue #5112: [FLINK-8175] [DataStream API java/scala] remove flink-str...

2018-01-02 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/5112 @StephanEwen let me know if you have more concerns ---

[jira] [Commented] (FLINK-7475) support update() in ListState

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

[jira] [Commented] (FLINK-8217) Properly annotate APIs of flink-connector-kinesis

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

[GitHub] flink issue #4963: [FLINK-7475] [core][DataStream API] support update() in L...

2018-01-02 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4963 @yunfan123 @aljoscha @StefanRRichter feedbacks are appreciated ---

[GitHub] flink issue #5112: [FLINK-8175] [DataStream API java/scala] remove flink-str...

2018-01-02 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/5112 @StephanEwen @tillrohrmann let me know if you have more concerns ---

[GitHub] flink issue #5138: [FLINK-8217] [Kinesis connector] Properly annotate APIs o...

2018-01-02 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/5138 @tzulitai The PR has been updated ---

[jira] [Commented] (FLINK-8175) remove flink-streaming-contrib and migrate its classes to flink-streaming-java/scala

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

[jira] [Commented] (FLINK-8175) remove flink-streaming-contrib and migrate its classes to flink-streaming-java/scala

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

[jira] [Created] (FLINK-8352) Flink UI Reports No Error on Job Submission Failures

2018-01-02 Thread Elias Levy (JIRA)
Elias Levy created FLINK-8352: - Summary: Flink UI Reports No Error on Job Submission Failures Key: FLINK-8352 URL: https://issues.apache.org/jira/browse/FLINK-8352 Project: Flink Issue Type: Bug

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

2018-01-02 Thread Wei-Che Wei (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16309048#comment-16309048 ] Wei-Che Wei commented on FLINK-7935: Hi [~elevy] Since FLINK-7692 was solved, user can use

[GitHub] flink pull request #5171: [FLINK-8271][Kinesis connector] upgrade deprecated...

2018-01-02 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/5171#discussion_r159362925 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/AWSUtil.java --- @@ -30,37 +30,44 @@

[jira] [Commented] (FLINK-8271) upgrade from deprecated classes to AmazonKinesis

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

[jira] [Commented] (FLINK-8271) upgrade from deprecated classes to AmazonKinesis

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

[GitHub] flink pull request #5171: [FLINK-8271][Kinesis connector] upgrade deprecated...

2018-01-02 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/5171#discussion_r159363827 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/AWSUtil.java --- @@ -30,37 +30,44 @@

[jira] [Closed] (FLINK-8272) 1.4 & Scala: Exception when querying the state

2018-01-02 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-8272. --- Resolution: Not A Problem Fix Version/s: (was: 1.4.0) > 1.4 & Scala: Exception

[jira] [Commented] (FLINK-6206) As an Engineer, I want task state transition log to be warn/error for FAILURE scenarios

2018-01-02 Thread Dan Bress (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16308303#comment-16308303 ] Dan Bress commented on FLINK-6206: -- This is definitely relevant in 1.2.0, without this is very hard to

[jira] [Comment Edited] (FLINK-8334) Elasticsearch Connector throwing java.lang.ClassNotFoundException: org.jboss.netty.channel.socket.nio.SocketSendBufferPool$GatheringSendBuffer

2018-01-02 Thread Bhaskar Divya (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16308330#comment-16308330 ] Bhaskar Divya edited comment on FLINK-8334 at 1/2/18 4:37 PM: -- Thanks

[jira] [Created] (FLINK-8346) add S3 signature v4 workaround to docs

2018-01-02 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-8346: -- Summary: add S3 signature v4 workaround to docs Key: FLINK-8346 URL: https://issues.apache.org/jira/browse/FLINK-8346 Project: Flink Issue Type: Improvement

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

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

[jira] [Commented] (FLINK-8326) CheckpointCoordinatorTest#testRestoreLatestCheckpointedStateScaleOut() didn't use the correct parameter to trigger test function

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

[jira] [Commented] (FLINK-8284) Custom metrics not being exposed for Prometheus

2018-01-02 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16308280#comment-16308280 ] Aljoscha Krettek commented on FLINK-8284: - [~Zentol] Could you please have a look at this? >

[jira] [Reopened] (FLINK-8272) 1.4 & Scala: Exception when querying the state

2018-01-02 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-8272: - Reopen to change resolution. > 1.4 & Scala: Exception when querying the state >

[jira] [Created] (FLINK-8350) replace "taskmanager.tmp.dirs" with "env.io.tmp.dirs" for all components

2018-01-02 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-8350: -- Summary: replace "taskmanager.tmp.dirs" with "env.io.tmp.dirs" for all components Key: FLINK-8350 URL: https://issues.apache.org/jira/browse/FLINK-8350 Project: Flink

[jira] [Commented] (FLINK-8282) Transformation with TwoInputStreamOperator fails

2018-01-02 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16308293#comment-16308293 ] Aljoscha Krettek commented on FLINK-8282: - In my opinion, there is no good separation of concerns

[jira] [Commented] (FLINK-8334) Elasticsearch Connector throwing java.lang.ClassNotFoundException: org.jboss.netty.channel.socket.nio.SocketSendBufferPool$GatheringSendBuffer

2018-01-02 Thread Bhaskar Divya (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16308330#comment-16308330 ] Bhaskar Divya commented on FLINK-8334: -- Thanks [~aljoscha]. I think I got it working now.(no more

[jira] [Commented] (FLINK-8265) Missing jackson dependency for flink-mesos

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

[GitHub] flink issue #5208: [FLINK-8265] [Mesos] Missing jackson dependency for flink...

2018-01-02 Thread jaredstehler
Github user jaredstehler commented on the issue: https://github.com/apache/flink/pull/5208 looks good to me, thanks! ---

[jira] [Commented] (FLINK-8297) RocksDBListState stores whole list in single byte[]

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

[jira] [Created] (FLINK-8349) Remove Yarn specific commands from YarnClusterClient

2018-01-02 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-8349: Summary: Remove Yarn specific commands from YarnClusterClient Key: FLINK-8349 URL: https://issues.apache.org/jira/browse/FLINK-8349 Project: Flink Issue

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

2018-01-02 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5216#discussion_r159243077 --- Diff: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java --- @@ -272,6 +275,7 @@ public void testJavaAPI() throws Exception {

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

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

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

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

[GitHub] flink pull request #5223: [FLINK-8317][flip6] Implement Triggering of Savepo...

2018-01-02 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5223#discussion_r159247245 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/RpcUtils.java --- @@ -27,11 +27,16 @@ import java.util.concurrent.TimeoutException;

[jira] [Commented] (FLINK-8314) Add support for Kinesis Firehose

2018-01-02 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16308230#comment-16308230 ] Aljoscha Krettek commented on FLINK-8314: - So this would essentially be another connector that is

[jira] [Commented] (FLINK-8315) Use AWSCredentialsProvider to get AWS credentials

2018-01-02 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16308225#comment-16308225 ] Aljoscha Krettek commented on FLINK-8315: - I think this makes sense, but I'm not too familiar with

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

2018-01-02 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5219#discussion_r159249258 --- Diff: flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java --- @@ -659,128 +655,107 @@ protected int savepoint(String[] args) {

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

2018-01-02 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-8347: Summary: Make Cluster id typesafe Key: FLINK-8347 URL: https://issues.apache.org/jira/browse/FLINK-8347 Project: Flink Issue Type: Sub-task

[GitHub] flink issue #5176: [FLINK-8279][blob] fall back to TaskManager temp director...

2018-01-02 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/5176 @EronWright this PR originated from a user problem at https://lists.apache.org/thread.html/177644ad38af34fb7ae7fb12a3bfcef3a70cd70dfccb6f7008a24eb6@%3Cuser.flink.apache.org%3E And yes, this

[jira] [Commented] (FLINK-8279) Use Mesos/YARN temp directories as fallback for BlobServer/Cache temp directories

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

[GitHub] flink issue #5185: [FLINK-8297] [flink-rocksdb] optionally use RocksDBMapSta...

2018-01-02 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5185 The concept of this looks good. However, if we want to merge it I think we have to make this a standalone thing and not depend on other states because this can have unforeseen consequences for

[jira] [Commented] (FLINK-8268) Test instability for 'TwoPhaseCommitSinkFunctionTest'

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

[jira] [Commented] (FLINK-8268) Test instability for 'TwoPhaseCommitSinkFunctionTest'

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

[GitHub] flink pull request #5193: [FLINK-8268][tests] Improve tests stability

2018-01-02 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/5193#discussion_r159220879 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/functions/sink/ContentDump.java --- @@ -0,0 +1,134 @@ +/* + *

[jira] [Commented] (FLINK-8268) Test instability for 'TwoPhaseCommitSinkFunctionTest'

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

[jira] [Commented] (FLINK-8268) Test instability for 'TwoPhaseCommitSinkFunctionTest'

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

[jira] [Commented] (FLINK-8268) Test instability for 'TwoPhaseCommitSinkFunctionTest'

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

[GitHub] flink pull request #5193: [FLINK-8268][tests] Improve tests stability

2018-01-02 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/5193#discussion_r159229650 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/util/AbstractStreamOperatorTestHarness.java --- @@ -492,6 +503,10 @@ public void

[GitHub] flink pull request #5193: [FLINK-8268][tests] Improve tests stability

2018-01-02 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/5193#discussion_r159235730 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/util/SourceFunctionUtil.java --- @@ -42,22 +41,32 @@ public class

[jira] [Commented] (FLINK-8268) Test instability for 'TwoPhaseCommitSinkFunctionTest'

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

[jira] [Commented] (FLINK-8268) Test instability for 'TwoPhaseCommitSinkFunctionTest'

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

[GitHub] flink pull request #5193: [FLINK-8268][tests] Improve tests stability

2018-01-02 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/5193#discussion_r15950 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/operators/testutils/TaskTestBase.java --- @@ -145,19 +145,7 @@ public MemoryManager

[GitHub] flink pull request #5193: [FLINK-8268][tests] Improve tests stability

2018-01-02 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/5193#discussion_r159221102 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/functions/sink/ContentDump.java --- @@ -0,0 +1,134 @@ +/* + *

[GitHub] flink pull request #5193: [FLINK-8268][tests] Improve tests stability

2018-01-02 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/5193#discussion_r159221837 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/functions/sink/ContentDump.java --- @@ -0,0 +1,134 @@ +/* + *

[GitHub] flink pull request #5193: [FLINK-8268][tests] Improve tests stability

2018-01-02 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/5193#discussion_r159224671 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunctionTest.java --- @@ -179,9 +179,6 @@

[jira] [Closed] (FLINK-8326) CheckpointCoordinatorTest#testRestoreLatestCheckpointedStateScaleOut() didn't use the correct parameter to trigger test function

2018-01-02 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-8326. --- Resolution: Fixed Fix Version/s: 1.5.0 Fixed on master in

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

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

[jira] [Commented] (FLINK-8326) CheckpointCoordinatorTest#testRestoreLatestCheckpointedStateScaleOut() didn't use the correct parameter to trigger test function

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

[GitHub] flink issue #5211: [FLINK-8326] [checkpoints] CheckpointCoordinatorTest#test...

2018-01-02 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5211 Thanks a lot for catching this! 👍 I merged, could you please close this PR? ---

[jira] [Commented] (FLINK-8322) support getting number of existing timers in TimerService

2018-01-02 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16308201#comment-16308201 ] Aljoscha Krettek commented on FLINK-8322: - Yes, I think one (maybe the best) solution is to keep

[jira] [Commented] (FLINK-8346) add S3 signature v4 workaround to docs

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

[GitHub] flink pull request #5231: [FLINK-8346][docs] add v4 signature workaround for...

2018-01-02 Thread NicoK
GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/5231 [FLINK-8346][docs] add v4 signature workaround for manual S3 setups ## What is the purpose of the change As per

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

2018-01-02 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5215#discussion_r159227421 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java --- @@ -660,7 +570,25 @@ public int run(

  1   2   >