[jira] [Commented] (FLINK-7147) Support greedy quantifier in CEP

[ https://issues.apache.org/jira/browse/FLINK-7147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16113946#comment-16113946 ] ASF GitHub Bot commented on FLINK-7147: --- Github user dianfu commented on the issue:

[GitHub] flink issue #4296: [FLINK-7147] [cep] Support greedy quantifier in CEP

Github user dianfu commented on the issue: https://github.com/apache/flink/pull/4296 @dawidwys Regarding to the times().greedy(), the result is not expected and have fixed the issue in the latest PR. Also updated the doc. --- If your project is set up for it, you can reply to this

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

[ https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16113916#comment-16113916 ] ASF GitHub Bot commented on FLINK-7367: --- Github user bowenli86 commented on the issue:

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

[ https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16113914#comment-16113914 ] ASF GitHub Bot commented on FLINK-7367: --- GitHub user bowenli86 opened a pull request:

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

Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4473 @tzulitai Hi Gordon, shall we add more explanation of these keys in Flink docs, or do you think the java doc is sufficient? --- If your project is set up for it, you can reply to this email and

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

GitHub user bowenli86 opened a pull request: https://github.com/apache/flink/pull/4473 [FLINK-7367][kinesis connector] Parameterize more configs for FlinkKinesisProducer (RecordMaxBufferedTime, MaxConnections, RequestTimeout, etc) ## What is the purpose of the change

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

[ https://issues.apache.org/jira/browse/FLINK-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Chen updated FLINK-7368: - Description: Flink's `MetricStore` is not thread-safe. multi-treads may acess java' hashmap inside

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

[ https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-7367: Summary: Parameterize more configs for FlinkKinesisProducer (RecordMaxBufferedTime, MaxConnections,

[jira] [Updated] (FLINK-7367) Parameterize FlinkKinesisProducer on RecordMaxBufferedTime, MaxConnections, RequestTimeout, and more

[ https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-7367: Description: Right now, FlinkKinesisProducer only expose two configs for the underlying KinesisProducer:

[jira] [Updated] (FLINK-7367) Parameterize FlinkKinesisProducer on RecordMaxBufferedTime, MaxConnections, RequestTimeout, and more

[ https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-7367: Description: Right now, FlinkKinesisProducer only expose two configs for the underlying KinesisProducer:

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

[ https://issues.apache.org/jira/browse/FLINK-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Chen updated FLINK-7368: - Description: Flink's `MetricStore` is not thread-safe. multi-treads may acess java' hashmap inside

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

[ https://issues.apache.org/jira/browse/FLINK-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Chen updated FLINK-7368: - Attachment: MyHashMap.java MyHashMapInfiniteLoopTest.java MyHashMap is a copy of Java

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

[ https://issues.apache.org/jira/browse/FLINK-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Chen updated FLINK-7368: - Description: Flink's `MetricStore` is not thread-safe. multi-treads may acess java' hashmap inside

[jira] [Resolved] (FLINK-7356) misleading s3 file uri in configuration file

[ https://issues.apache.org/jira/browse/FLINK-7356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-7356. Resolution: Fixed Thanks for the contribution [~phoenixjiangnan]. Fixed in master

[jira] [Resolved] (FLINK-7127) Remove unnecessary null check or add null check

[ https://issues.apache.org/jira/browse/FLINK-7127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-7127. Resolution: Fixed Assignee: Dmitrii Kniazev Fix Version/s: 1.3.3

[jira] [Resolved] (FLINK-6493) Ineffective null check in RegisteredOperatorBackendStateMetaInfo#equals()

[ https://issues.apache.org/jira/browse/FLINK-6493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-6493. Resolution: Fixed Fix Version/s: 1.3.3 Thanks for the contribution

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

[ https://issues.apache.org/jira/browse/FLINK-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16113865#comment-16113865 ] ASF GitHub Bot commented on FLINK-7368: --- GitHub user nicochen opened a pull request:

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

GitHub user nicochen opened a pull request: https://github.com/apache/flink/pull/4472 FLINK-7368: MetricStore makes cpu spin at 100% Flink's `MetricStore` is not thread-safe. multi-treads may acess java' hashmap inside `MetricStore` and can tirgger hashmap's infinte loop.

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

[ https://issues.apache.org/jira/browse/FLINK-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Chen updated FLINK-7368: - Attachment: jm-jstack.log > MetricStore makes cpu spin at 100% > -- > >

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

[ https://issues.apache.org/jira/browse/FLINK-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Chen updated FLINK-7368: - Description: Flink's `MetricStore` is not thread-safe. multi-treads may acess java' hashmap inside

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

Nico Chen created FLINK-7368: Summary: MetricStore makes cpu spin at 100% Key: FLINK-7368 URL: https://issues.apache.org/jira/browse/FLINK-7368 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-6429) Bump up Calcite version to 1.13

[ https://issues.apache.org/jira/browse/FLINK-6429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16113850#comment-16113850 ] ASF GitHub Bot commented on FLINK-6429: --- Github user wuchong commented on a diff in the pull

[GitHub] flink pull request #4373: [FLINK-6429] [table] Bump up Calcite version to 1....

Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/4373#discussion_r131302891 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/stream/sql/JoinTest.scala --- @@ -55,12 +55,13 @@ class JoinTest extends

[GitHub] flink pull request #4349: [FLINK-7127] [runtime] Remove unnecessary null che...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4349 --- 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 is

[jira] [Commented] (FLINK-1234) Make Hadoop2 profile default

[ https://issues.apache.org/jira/browse/FLINK-1234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16113834#comment-16113834 ] ASF GitHub Bot commented on FLINK-1234: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-7127) Remove unnecessary null check or add null check

[ https://issues.apache.org/jira/browse/FLINK-7127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16113833#comment-16113833 ] ASF GitHub Bot commented on FLINK-7127: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #4408: Release 1.3

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4408 --- 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 is

[jira] [Commented] (FLINK-6493) Ineffective null check in RegisteredOperatorBackendStateMetaInfo#equals()

[ https://issues.apache.org/jira/browse/FLINK-6493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16113832#comment-16113832 ] ASF GitHub Bot commented on FLINK-6493: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-7356) misleading s3 file uri in configuration file

[ https://issues.apache.org/jira/browse/FLINK-7356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16113831#comment-16113831 ] ASF GitHub Bot commented on FLINK-7356: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #4466: [FLINK-7356][configuration] misleading s3 file uri...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4466 --- 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 is

[GitHub] flink pull request #4328: [FLINK-6493] Fix ineffective null check in Registe...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4328 --- 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 is

[jira] [Commented] (FLINK-6493) Ineffective null check in RegisteredOperatorBackendStateMetaInfo#equals()

[ https://issues.apache.org/jira/browse/FLINK-6493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16113827#comment-16113827 ] ASF GitHub Bot commented on FLINK-6493: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #4328: [FLINK-6493] Fix ineffective null check in RegisteredOper...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4328 Thanks for that @zhangminglei. However, I've already finished testing a batch of commits with this fix included, and would like to merge that now. Sometimes I collect a batch of commits and run

[jira] [Commented] (FLINK-6493) Ineffective null check in RegisteredOperatorBackendStateMetaInfo#equals()

[ https://issues.apache.org/jira/browse/FLINK-6493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16113808#comment-16113808 ] ASF GitHub Bot commented on FLINK-6493: --- Github user zhangminglei commented on the issue:

[GitHub] flink issue #4328: [FLINK-6493] Fix ineffective null check in RegisteredOper...

Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/4328 Hi, @tzulitai I have removed the extra most-outer wrapping parenthesis by myself. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Commented] (FLINK-7293) Support custom order by in PatternStream

[ https://issues.apache.org/jira/browse/FLINK-7293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16113804#comment-16113804 ] ASF GitHub Bot commented on FLINK-7293: --- Github user dianfu commented on the issue:

[GitHub] flink issue #4418: [FLINK-7293] [cep] Support custom order by in PatternStre...

Github user dianfu commented on the issue: https://github.com/apache/flink/pull/4418 @dawidwys Updated the contribution checklist. --- 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

[jira] [Created] (FLINK-7367) Parameterize FlinkKinesisProducer on RecordMaxBufferedTime, MaxConnections, RequestTimeout, and more

Bowen Li created FLINK-7367: --- Summary: Parameterize FlinkKinesisProducer on RecordMaxBufferedTime, MaxConnections, RequestTimeout, and more Key: FLINK-7367 URL: https://issues.apache.org/jira/browse/FLINK-7367

[jira] [Updated] (FLINK-7366) Upgrade kinesis-producer-library in flink-connector-kinesis from 0.10.2 to 0.12.5

[ https://issues.apache.org/jira/browse/FLINK-7366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-7366: Description: flink-connector-kinesis currently uses kinesis-producer-library 0.10.2, which is released in

[jira] [Created] (FLINK-7366) Upgrade kinesis-producer-library in flink-connector-kinesis from 0.10.2 to 0.12.5

Bowen Li created FLINK-7366: --- Summary: Upgrade kinesis-producer-library in flink-connector-kinesis from 0.10.2 to 0.12.5 Key: FLINK-7366 URL: https://issues.apache.org/jira/browse/FLINK-7366 Project: Flink

[jira] [Updated] (FLINK-7365) warning of attempt to override final parameter: fs.s3.buffer.dir

[ https://issues.apache.org/jira/browse/FLINK-7365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-7365: Affects Version/s: 1.3.0 Component/s: Configuration > warning of attempt to override final

[jira] [Created] (FLINK-7365) warning of attempt to override final parameter: fs.s3.buffer.dir

Bowen Li created FLINK-7365: --- Summary: warning of attempt to override final parameter: fs.s3.buffer.dir Key: FLINK-7365 URL: https://issues.apache.org/jira/browse/FLINK-7365 Project: Flink Issue

[jira] [Assigned] (FLINK-7357) HOP_START() HOP_END() does not work when using HAVING clause with GROUP BY HOP window

[ https://issues.apache.org/jira/browse/FLINK-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai reassigned FLINK-7357: - Assignee: Haohui Mai > HOP_START() HOP_END() does not work when using HAVING clause with GROUP

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

Elias Levy created FLINK-7364: - Summary: Log exceptions from user code in streaming jobs Key: FLINK-7364 URL: https://issues.apache.org/jira/browse/FLINK-7364 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-6493) Ineffective null check in RegisteredOperatorBackendStateMetaInfo#equals()

[ https://issues.apache.org/jira/browse/FLINK-6493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16112899#comment-16112899 ] ASF GitHub Bot commented on FLINK-6493: --- Github user zhangminglei commented on the issue:

[GitHub] flink issue #4328: [FLINK-6493] Fix ineffective null check in RegisteredOper...

Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/4328 Sorry, Sir. I'll pay attention to the details of the next time. --- 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

[jira] [Updated] (FLINK-3347) TaskManager (or its ActorSystem) need to restart in case they notice quarantine

[ https://issues.apache.org/jira/browse/FLINK-3347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-3347: --- Fix Version/s: (was: 1.2.0) 1.2.1 > TaskManager (or its ActorSystem) need to

[jira] [Commented] (FLINK-6094) Implement stream-stream proctime non-window inner join

[ https://issues.apache.org/jira/browse/FLINK-6094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16112882#comment-16112882 ] ASF GitHub Bot commented on FLINK-6094: --- GitHub user hequn8128 opened a pull request:

[GitHub] flink pull request #4471: [FLINK-6094] [table] Implement stream-stream proct...

GitHub user hequn8128 opened a pull request: https://github.com/apache/flink/pull/4471 [FLINK-6094] [table] Implement stream-stream proctime non-window inner join ## What is the purpose of the change Implement stream-stream proctime non-window inner join for

[jira] [Commented] (FLINK-6493) Ineffective null check in RegisteredOperatorBackendStateMetaInfo#equals()

[ https://issues.apache.org/jira/browse/FLINK-6493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16112878#comment-16112878 ] ASF GitHub Bot commented on FLINK-6493: --- Github user tzulitai commented on the issue:

[jira] [Commented] (FLINK-6493) Ineffective null check in RegisteredOperatorBackendStateMetaInfo#equals()

[ https://issues.apache.org/jira/browse/FLINK-6493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16112877#comment-16112877 ] ASF GitHub Bot commented on FLINK-6493: --- Github user tzulitai commented on a diff in the pull

[GitHub] flink issue #4328: [FLINK-6493] Fix ineffective null check in RegisteredOper...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4328 Thanks! Alright, this looks good now, merging (will address my final own comment while merging)! --- If your project is set up for it, you can reply to this email and have your reply appear on

[GitHub] flink pull request #4328: [FLINK-6493] Fix ineffective null check in Registe...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4328#discussion_r131167537 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/RegisteredOperatorBackendStateMetaInfo.java --- @@ -175,14 +176,17 @@ public boolean

[jira] [Commented] (FLINK-7309) NullPointerException in CodeGenUtils.timePointToInternalCode() generated code

[ https://issues.apache.org/jira/browse/FLINK-7309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16112834#comment-16112834 ] Liangliang Chen commented on FLINK-7309: hi, [~twalthr], I'm not very familiar with Scala-Lang, so

[GitHub] flink issue #4356: [FLINK-5486] Fix lacking of synchronization in BucketingS...

Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/4356 ``` Tests run: 6, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 91.985 sec <<< FAILURE! - in org.apache.flink.test.checkpointing.ExternalizedCheckpointITCase

[jira] [Commented] (FLINK-5486) Lack of synchronization in BucketingSink#handleRestoredBucketState()

[ https://issues.apache.org/jira/browse/FLINK-5486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16112770#comment-16112770 ] ASF GitHub Bot commented on FLINK-5486: --- Github user zhangminglei commented on the issue:

[jira] [Commented] (FLINK-7293) Support custom order by in PatternStream

[ https://issues.apache.org/jira/browse/FLINK-7293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16112705#comment-16112705 ] ASF GitHub Bot commented on FLINK-7293: --- Github user dawidwys commented on the issue:

[GitHub] flink issue #4418: [FLINK-7293] [cep] Support custom order by in PatternStre...

Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/4418 +1 from my side. Let's just wait a bit more to see if @kl0u wants to add some comments, as he commented on the JIRA. As a side note for the future, please fill in the new

[jira] [Commented] (FLINK-5720) Deprecate "Folding" in all of DataStream API

[ https://issues.apache.org/jira/browse/FLINK-5720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16112702#comment-16112702 ] ASF GitHub Bot commented on FLINK-5720: --- Github user NicoK commented on the issue:

[GitHub] flink issue #3816: [FLINK-5720] Deprecate DataStream#fold()

Github user NicoK commented on the issue: https://github.com/apache/flink/pull/3816 Actually, `KeyedStream.aggregate` is protected and thus not accessible. You may, however, access `WindowedStream#aggregate(AggregateFunction) ` and

[jira] [Commented] (FLINK-7147) Support greedy quantifier in CEP

[ https://issues.apache.org/jira/browse/FLINK-7147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16112698#comment-16112698 ] ASF GitHub Bot commented on FLINK-7147: --- Github user dawidwys commented on the issue:

[GitHub] flink issue #4296: [FLINK-7147] [cep] Support greedy quantifier in CEP

Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/4296 I think we are getting close to the final version. Good job! Still though have two higher level comments: - is current times().greedy() behaviour intended? For pattern `a{2, 5} b` and

[GitHub] flink issue #4349: [FLINK-7127] [runtime] Remove unnecessary null check or a...

Github user mylog00 commented on the issue: https://github.com/apache/flink/pull/4349 Thanks for the advice. I will not repeat this mistake again in the future :) --- 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

[jira] [Commented] (FLINK-7127) Remove unnecessary null check or add null check

[ https://issues.apache.org/jira/browse/FLINK-7127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16112659#comment-16112659 ] ASF GitHub Bot commented on FLINK-7127: --- Github user mylog00 commented on the issue:

[jira] [Commented] (FLINK-7343) Kafka010ProducerITCase instability

[ https://issues.apache.org/jira/browse/FLINK-7343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16112654#comment-16112654 ] ASF GitHub Bot commented on FLINK-7343: --- GitHub user pnowojski opened a pull request:

[GitHub] flink pull request #4470: [FLINK-7343] Simulate network failures in kafka at...

GitHub user pnowojski opened a pull request: https://github.com/apache/flink/pull/4470 [FLINK-7343] Simulate network failures in kafka at-least-once test We shouldn't fail KafkaServers directly, because they might not be able to flush the data (`log.flush.interval.***` properties).

[jira] [Commented] (FLINK-6493) Ineffective null check in RegisteredOperatorBackendStateMetaInfo#equals()

[ https://issues.apache.org/jira/browse/FLINK-6493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16112653#comment-16112653 ] ASF GitHub Bot commented on FLINK-6493: --- Github user zhangminglei commented on the issue:

[GitHub] flink issue #4328: [FLINK-6493] Fix ineffective null check in RegisteredOper...

Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/4328 Hello, @tzulitai Code have been updated. Please check it out. :) --- 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

[jira] [Commented] (FLINK-6493) Ineffective null check in RegisteredOperatorBackendStateMetaInfo#equals()

[ https://issues.apache.org/jira/browse/FLINK-6493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16112647#comment-16112647 ] ASF GitHub Bot commented on FLINK-6493: --- Github user zhangminglei commented on a diff in the pull

[GitHub] flink pull request #4328: [FLINK-6493] Fix ineffective null check in Registe...

Github user zhangminglei commented on a diff in the pull request: https://github.com/apache/flink/pull/4328#discussion_r131127614 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/RegisteredOperatorBackendStateMetaInfo.java --- @@ -175,14 +176,19 @@ public

[jira] [Commented] (FLINK-6493) Ineffective null check in RegisteredOperatorBackendStateMetaInfo#equals()

[ https://issues.apache.org/jira/browse/FLINK-6493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16112636#comment-16112636 ] ASF GitHub Bot commented on FLINK-6493: --- Github user zhangminglei commented on a diff in the pull

[GitHub] flink pull request #4328: [FLINK-6493] Fix ineffective null check in Registe...

Github user zhangminglei commented on a diff in the pull request: https://github.com/apache/flink/pull/4328#discussion_r131125429 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/RegisteredOperatorBackendStateMetaInfo.java --- @@ -175,14 +176,19 @@ public

[jira] [Commented] (FLINK-7076) Implement container release to support dynamic scaling

[ https://issues.apache.org/jira/browse/FLINK-7076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16112624#comment-16112624 ] Till Rohrmann commented on FLINK-7076: -- Hi [~yuemeng], let's first tackle the second problem which is

[jira] [Commented] (FLINK-7335) Remove Flink's own future implementation

[ https://issues.apache.org/jira/browse/FLINK-7335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16112618#comment-16112618 ] ASF GitHub Bot commented on FLINK-7335: --- Github user asfgit closed the pull request at:

[jira] [Resolved] (FLINK-7252) Remove Flink Futures or back them by CompletableFutures

[ https://issues.apache.org/jira/browse/FLINK-7252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-7252. -- Resolution: Fixed Flink's own future implementation has been removed and its usage has been

[jira] [Closed] (FLINK-7335) Remove Flink's own future implementation

[ https://issues.apache.org/jira/browse/FLINK-7335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7335. Resolution: Done Removed via 1fabe0cd04306fd5bd607729bf9ad9f22cc25ed2 > Remove Flink's own future

[GitHub] flink pull request #4463: [FLINK-7335] [futures] Remove Flink's own Future i...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4463 --- 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 is

[jira] [Commented] (FLINK-7335) Remove Flink's own future implementation

[ https://issues.apache.org/jira/browse/FLINK-7335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16112616#comment-16112616 ] ASF GitHub Bot commented on FLINK-7335: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #4463: [FLINK-7335] [futures] Remove Flink's own Future i...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4463#discussion_r131120916 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -21,7 +21,7 @@ package

[jira] [Commented] (FLINK-7334) Replace Flink's futures by CompletableFuture in RpcGateway

[ https://issues.apache.org/jira/browse/FLINK-7334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16112611#comment-16112611 ] ASF GitHub Bot commented on FLINK-7334: --- Github user asfgit closed the pull request at:

[jira] [Updated] (FLINK-7356) misleading s3 file uri in configuration file

[ https://issues.apache.org/jira/browse/FLINK-7356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7356: Fix Version/s: (was: 1.3.2) 1.3.3 > misleading s3 file uri in

[GitHub] flink pull request #4462: [FLINK-7334] [futures] Replace Flink's futures wit...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4462 --- 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 is

[jira] [Closed] (FLINK-7334) Replace Flink's futures by CompletableFuture in RpcGateway

[ https://issues.apache.org/jira/browse/FLINK-7334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7334. Resolution: Done Done via eddafc1ac9e4d787df44b63809f0d6dfd1f3def7 > Replace Flink's futures by

[jira] [Updated] (FLINK-7265) FileSystems should describe their kind and consistency level

[ https://issues.apache.org/jira/browse/FLINK-7265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7265: Fix Version/s: (was: 1.3.2) 1.3.3 > FileSystems should describe

[jira] [Updated] (FLINK-7100) TaskManager metrics are registered twice

[ https://issues.apache.org/jira/browse/FLINK-7100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7100: Fix Version/s: (was: 1.3.2) 1.3.3 > TaskManager metrics are

[jira] [Updated] (FLINK-5486) Lack of synchronization in BucketingSink#handleRestoredBucketState()

[ https://issues.apache.org/jira/browse/FLINK-5486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5486: Fix Version/s: (was: 1.3.2) > Lack of synchronization in

[jira] [Updated] (FLINK-6900) Limit size of indiivual components in DropwizardReporter

[ https://issues.apache.org/jira/browse/FLINK-6900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6900: Fix Version/s: (was: 1.3.2) 1.3.3 > Limit size of indiivual

[jira] [Commented] (FLINK-7266) Don't attempt to delete parent directory on S3

[ https://issues.apache.org/jira/browse/FLINK-7266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16112606#comment-16112606 ] Aljoscha Krettek commented on FLINK-7266: - This is actually resolved on {{release-1.3}} for the s3

[jira] [Commented] (FLINK-7335) Remove Flink's own future implementation

[ https://issues.apache.org/jira/browse/FLINK-7335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16112605#comment-16112605 ] ASF GitHub Bot commented on FLINK-7335: --- Github user tillrohrmann commented on the issue:

[jira] [Commented] (FLINK-7334) Replace Flink's futures by CompletableFuture in RpcGateway

[ https://issues.apache.org/jira/browse/FLINK-7334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16112604#comment-16112604 ] ASF GitHub Bot commented on FLINK-7334: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #4463: [FLINK-7335] [futures] Remove Flink's own Future implemen...

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4463 Thanks for the review @zentol. Merging this PR after merging #4462. --- 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 #4462: [FLINK-7334] [futures] Replace Flink's futures with Java ...

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4462 Thanks for reviewing @zentol. I'll address your comments and then merge this PR. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[jira] [Created] (FLINK-7363) add hashes and signatures to the download page

Nico Kruber created FLINK-7363: -- Summary: add hashes and signatures to the download page Key: FLINK-7363 URL: https://issues.apache.org/jira/browse/FLINK-7363 Project: Flink Issue Type:

[jira] [Comment Edited] (FLINK-7361) flink-web doesn't build with ruby 2.4

[ https://issues.apache.org/jira/browse/FLINK-7361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16112572#comment-16112572 ] Nico Kruber edited comment on FLINK-7361 at 8/3/17 11:08 AM: - The linked PR

[GitHub] flink pull request #4328: [FLINK-6493] Fix ineffective null check in Registe...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4328#discussion_r131107598 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/RegisteredOperatorBackendStateMetaInfo.java --- @@ -175,14 +176,19 @@ public boolean

[jira] [Commented] (FLINK-6493) Ineffective null check in RegisteredOperatorBackendStateMetaInfo#equals()

[ https://issues.apache.org/jira/browse/FLINK-6493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16112555#comment-16112555 ] ASF GitHub Bot commented on FLINK-6493: --- Github user tzulitai commented on a diff in the pull

[jira] [Commented] (FLINK-6493) Ineffective null check in RegisteredOperatorBackendStateMetaInfo#equals()

[ https://issues.apache.org/jira/browse/FLINK-6493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16112553#comment-16112553 ] ASF GitHub Bot commented on FLINK-6493: --- Github user tzulitai commented on a diff in the pull

[GitHub] flink pull request #4328: [FLINK-6493] Fix ineffective null check in Registe...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4328#discussion_r131107573 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/RegisteredOperatorBackendStateMetaInfo.java --- @@ -175,14 +176,19 @@ public boolean

[jira] [Commented] (FLINK-6493) Ineffective null check in RegisteredOperatorBackendStateMetaInfo#equals()

[ https://issues.apache.org/jira/browse/FLINK-6493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16112551#comment-16112551 ] ASF GitHub Bot commented on FLINK-6493: --- Github user tzulitai commented on a diff in the pull

[GitHub] flink pull request #4328: [FLINK-6493] Fix ineffective null check in Registe...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4328#discussion_r131107143 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/RegisteredOperatorBackendStateMetaInfo.java --- @@ -175,14 +176,19 @@ public boolean

  1   2   3   >