[jira] [Created] (FLINK-7374) Type Erasure in GraphUtils$MapTo

2017-08-06 Thread Matthias Kricke (JIRA)
Matthias Kricke created FLINK-7374: -- Summary: Type Erasure in GraphUtils$MapTo Key: FLINK-7374 URL: https://issues.apache.org/jira/browse/FLINK-7374 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-7374) Type Erasure in GraphUtils$MapTo

2017-08-06 Thread Matthias Kricke (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Kricke updated FLINK-7374: --- Description: I got the following exception when executing ConnectedComponents or GSAConnected

[jira] [Updated] (FLINK-7374) Type Erasure in GraphUtils$MapTo

2017-08-06 Thread Matthias Kricke (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Kricke updated FLINK-7374: --- Description: I got the following exception when executing ConnectedComponents or GSAConnected

[jira] [Commented] (FLINK-7240) Externalized RocksDB can fail with stackoverflow

2017-08-06 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16115815#comment-16115815 ] Till Rohrmann commented on FLINK-7240: -- Another instance: https://travis-ci.org/tillr

[jira] [Updated] (FLINK-7240) Externalized RocksDB can fail with stackoverflow

2017-08-06 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7240: - Labels: test-stability (was: ) > Externalized RocksDB can fail with stackoverflow > -

[jira] [Commented] (FLINK-7240) Externalized RocksDB can fail with stackoverflow

2017-08-06 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16115817#comment-16115817 ] Till Rohrmann commented on FLINK-7240: -- The problem has been introduced with a hotfix

[jira] [Commented] (FLINK-7372) Remove ActorGateway from JobGraph

2017-08-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16115819#comment-16115819 ] ASF GitHub Bot commented on FLINK-7372: --- GitHub user tillrohrmann opened a pull requ

[GitHub] flink pull request #4483: [FLINK-7372] [JobGraph] Remove ActorGateway from J...

2017-08-06 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4483 [FLINK-7372] [JobGraph] Remove ActorGateway from JobGraph ## What is the purpose of the change The JobGraph has an unncessary dependency on the ActorGateway via its JobGraph#uploadUser

[jira] [Commented] (FLINK-7240) Externalized RocksDB can fail with stackoverflow

2017-08-06 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16115821#comment-16115821 ] Till Rohrmann commented on FLINK-7240: -- My guess with the current solution would be t

[jira] [Created] (FLINK-7375) Remove ActorGateway from JobClient

2017-08-06 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7375: Summary: Remove ActorGateway from JobClient Key: FLINK-7375 URL: https://issues.apache.org/jira/browse/FLINK-7375 Project: Flink Issue Type: Improvement

[GitHub] flink issue #4469: [hotfix][docs] Updated required Java version for standalo...

2017-08-06 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4469 +1 --- 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 i

[GitHub] flink issue #4075: [FLINK-6494] Migrate ResourceManager/Yarn/Mesos configura...

2017-08-06 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4075 I'll try to get this in this week. --- 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 an

[jira] [Commented] (FLINK-6494) Migrate ResourceManager configuration options

2017-08-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16115907#comment-16115907 ] ASF GitHub Bot commented on FLINK-6494: --- Github user zentol commented on the issue:

[jira] [Created] (FLINK-7376) Cleanup options class and test classes in flink-clients

2017-08-06 Thread Hai Zhou (JIRA)
Hai Zhou created FLINK-7376: --- Summary: Cleanup options class and test classes in flink-clients Key: FLINK-7376 URL: https://issues.apache.org/jira/browse/FLINK-7376 Project: Flink Issue Type: Impr

[jira] [Commented] (FLINK-5778) Split FileStateHandle into fileName and basePath

2017-08-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16115911#comment-16115911 ] ASF GitHub Bot commented on FLINK-5778: --- Github user zentol commented on the issue:

[GitHub] flink issue #3442: [FLINK-5778] [savepoints] Add savepoint serializer with r...

2017-08-06 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3442 What's the status of this PR @uce @tillrohrmann @StefanRRichter @StephanEwen ? --- 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

[GitHub] flink issue #2992: [FLINK-5325] Splitting user/system-facing API of Closeabl...

2017-08-06 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2992 What's the status of this PR @StefanRRichter ? --- 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 featur

[jira] [Commented] (FLINK-5325) Introduce interface for CloseableRegistry to separate user from system-facing functionality

2017-08-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16115913#comment-16115913 ] ASF GitHub Bot commented on FLINK-5325: --- Github user zentol commented on the issue:

[GitHub] flink pull request #4484: Client clean code

2017-08-06 Thread yew1eb
GitHub user yew1eb opened a pull request: https://github.com/apache/flink/pull/4484 Client clean code ## What is the purpose of the change Keeping code clean. ## Brief change log - Move the `args` field to the `CommandLineOptions`(parent class) -

[jira] [Created] (FLINK-7377) Implement FixedBufferPool for floating buffers in SingleInputGate

2017-08-06 Thread zhijiang (JIRA)
zhijiang created FLINK-7377: --- Summary: Implement FixedBufferPool for floating buffers in SingleInputGate Key: FLINK-7377 URL: https://issues.apache.org/jira/browse/FLINK-7377 Project: Flink Issue

[jira] [Created] (FLINK-7378) Implement the FixedBufferPool for floating buffers of SingleInputGate

2017-08-06 Thread zhijiang (JIRA)
zhijiang created FLINK-7378: --- Summary: Implement the FixedBufferPool for floating buffers of SingleInputGate Key: FLINK-7378 URL: https://issues.apache.org/jira/browse/FLINK-7378 Project: Flink Is

[jira] [Closed] (FLINK-7377) Implement FixedBufferPool for floating buffers in SingleInputGate

2017-08-06 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang closed FLINK-7377. --- Resolution: Duplicate > Implement FixedBufferPool for floating buffers in SingleInputGate > --

[jira] [Commented] (FLINK-7377) Implement FixedBufferPool for floating buffers in SingleInputGate

2017-08-06 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16116017#comment-16116017 ] zhijiang commented on FLINK-7377: - repeated in [FLINK-7378|https://issues.apache.org/jira/

[GitHub] flink issue #4472: FLINK-7368: MetricStore makes cpu spin at 100%

2017-08-06 Thread nicochen
Github user nicochen commented on the issue: https://github.com/apache/flink/pull/4472 @zentol Thanks for replying. Indeed, the problem is caused by MetricFetcher isn't synchronizing on the `MetricStore` object in MetricFetcher#addMetrics(). But in my opinion, synchronizing on the `Me

[jira] [Commented] (FLINK-7368) MetricStore makes cpu spin at 100%

2017-08-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16116034#comment-16116034 ] ASF GitHub Bot commented on FLINK-7368: --- Github user nicochen commented on the issue

[GitHub] flink issue #4368: [FLINK-7210] Introduce TwoPhaseCommitSinkFunction

2017-08-06 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4368 Alright, this looks good to merge now! Merging .. --- 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 th

[jira] [Commented] (FLINK-7210) Add TwoPhaseCommitSinkFunction (implementing exactly-once semantic in generic way)

2017-08-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16116064#comment-16116064 ] ASF GitHub Bot commented on FLINK-7210: --- Github user tzulitai commented on the issue

[GitHub] flink issue #4469: [hotfix][docs] Updated required Java version for standalo...

2017-08-06 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4469 +1, @dawidwys feel free to merge :) --- 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

[jira] [Commented] (FLINK-6995) Add a warning to outdated documentation

2017-08-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16116099#comment-16116099 ] ASF GitHub Bot commented on FLINK-6995: --- Github user tzulitai commented on the issue

[GitHub] flink issue #4480: [FLINK-6995] [docs] Enable is_latest attribute to false

2017-08-06 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4480 LGTM, I'll merge this to `release-1.2`. It seems like we need to add this true -> false toggle somewhere in our release procedure. --- If your project is set up for it, you can reply to this em

[GitHub] flink issue #4480: [FLINK-6995] [docs] Enable is_latest attribute to false

2017-08-06 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/4480 If we release flink1.4, then we will mark true->false in flink1.3 release also. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. I

[jira] [Commented] (FLINK-6995) Add a warning to outdated documentation

2017-08-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16116106#comment-16116106 ] ASF GitHub Bot commented on FLINK-6995: --- Github user zhangminglei commented on the i

[GitHub] flink pull request #4473: [FLINK-7367][kinesis connector] Parameterize more ...

2017-08-06 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4473#discussion_r131577895 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java --- @@ -169,14 +16

[GitHub] flink pull request #4473: [FLINK-7367][kinesis connector] Parameterize more ...

2017-08-06 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4473#discussion_r131578056 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ProducerConfigConstants.java --- @@ -

[jira] [Commented] (FLINK-7367) Parameterize more configs for FlinkKinesisProducer (RecordMaxBufferedTime, MaxConnections, RequestTimeout, etc)

2017-08-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16116108#comment-16116108 ] ASF GitHub Bot commented on FLINK-7367: --- Github user tzulitai commented on a diff in

[jira] [Commented] (FLINK-7367) Parameterize more configs for FlinkKinesisProducer (RecordMaxBufferedTime, MaxConnections, RequestTimeout, etc)

2017-08-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16116109#comment-16116109 ] ASF GitHub Bot commented on FLINK-7367: --- Github user tzulitai commented on a diff in

[GitHub] flink issue #4473: [FLINK-7367][kinesis connector] Parameterize more configs...

2017-08-06 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4473 One other thing: Also need to add validation for these new configurations. That should be placed in `KinesisConfigUtil.validateProducerConfigs` --- If your project is set up for it, you can

[jira] [Commented] (FLINK-7367) Parameterize more configs for FlinkKinesisProducer (RecordMaxBufferedTime, MaxConnections, RequestTimeout, etc)

2017-08-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16116112#comment-16116112 ] ASF GitHub Bot commented on FLINK-7367: --- Github user tzulitai commented on the issue