[GitHub] klion26 commented on issue #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS

klion26 commented on issue #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS URL: https://github.com/apache/flink/pull/6777#issuecomment-442356732 @azagrebin thanks for your review, I've just addressed all your comments and created[

[jira] [Commented] (FLINK-10461) Speed up download file procedure when restore

[ https://issues.apache.org/jira/browse/FLINK-10461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701508#comment-16701508 ] ASF GitHub Bot commented on FLINK-10461: klion26 commented on issue #6777: [FLINK-10461] [State

[jira] [Commented] (FLINK-10941) Slots prematurely released which still contain unconsumed data

[ https://issues.apache.org/jira/browse/FLINK-10941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701668#comment-16701668 ] ASF GitHub Bot commented on FLINK-10941: QiLuo-BD opened a new pull request #7186: [FLINK-10941]

[jira] [Updated] (FLINK-10941) Slots prematurely released which still contain unconsumed data

[ https://issues.apache.org/jira/browse/FLINK-10941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10941: --- Labels: pull-request-available (was: ) > Slots prematurely released which still contain

[GitHub] QiLuo-BD opened a new pull request #7186: [FLINK-10941] Keep slots which contain unconsumed result partitions

QiLuo-BD opened a new pull request #7186: [FLINK-10941] Keep slots which contain unconsumed result partitions URL: https://github.com/apache/flink/pull/7186 ## What is the purpose of the change This PR fixes the issue described in [1] that slots will be prematurely released

[jira] [Created] (FLINK-11017) Time interval for window aggregations in SQL is wrongly translated if specified with YEAR_MONTH resolution

Dawid Wysakowicz created FLINK-11017: Summary: Time interval for window aggregations in SQL is wrongly translated if specified with YEAR_MONTH resolution Key: FLINK-11017 URL:

[jira] [Updated] (FLINK-11019) Expose the queryable proxy server port in taskinfo api

[ https://issues.apache.org/jira/browse/FLINK-11019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi Liao updated FLINK-11019: --- Affects Version/s: 1.6.2 > Expose the queryable proxy server port in taskinfo api >

[jira] [Updated] (FLINK-11019) Expose the queryable proxy server port in taskinfo api

[ https://issues.apache.org/jira/browse/FLINK-11019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi Liao updated FLINK-11019: --- Fix Version/s: 1.8.0 > Expose the queryable proxy server port in taskinfo api >

[jira] [Commented] (FLINK-10820) Simplify the RebalancePartitioner implementation

[ https://issues.apache.org/jira/browse/FLINK-10820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701565#comment-16701565 ] ASF GitHub Bot commented on FLINK-10820: zhijiangW commented on issue #7051:

[jira] [Commented] (FLINK-8577) Implement proctime DataStream to Table upsert conversion.

[ https://issues.apache.org/jira/browse/FLINK-8577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701655#comment-16701655 ] ASF GitHub Bot commented on FLINK-8577: --- pnowojski commented on a change in pull request #6787:

[jira] [Commented] (FLINK-8577) Implement proctime DataStream to Table upsert conversion.

[ https://issues.apache.org/jira/browse/FLINK-8577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701656#comment-16701656 ] ASF GitHub Bot commented on FLINK-8577: --- pnowojski commented on a change in pull request #6787:

[jira] [Commented] (FLINK-8577) Implement proctime DataStream to Table upsert conversion.

[ https://issues.apache.org/jira/browse/FLINK-8577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701654#comment-16701654 ] ASF GitHub Bot commented on FLINK-8577: --- pnowojski commented on a change in pull request #6787:

[GitHub] pnowojski commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion

pnowojski commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion URL: https://github.com/apache/flink/pull/6787#discussion_r237004073 ## File path:

[GitHub] pnowojski commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion

pnowojski commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion URL: https://github.com/apache/flink/pull/6787#discussion_r237018239 ## File path:

[GitHub] pnowojski commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion

pnowojski commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion URL: https://github.com/apache/flink/pull/6787#discussion_r237017454 ## File path:

[GitHub] pnowojski commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion

pnowojski commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion URL: https://github.com/apache/flink/pull/6787#discussion_r237008338 ## File path:

[jira] [Commented] (FLINK-8577) Implement proctime DataStream to Table upsert conversion.

[ https://issues.apache.org/jira/browse/FLINK-8577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701653#comment-16701653 ] ASF GitHub Bot commented on FLINK-8577: --- pnowojski commented on a change in pull request #6787:

[jira] [Commented] (FLINK-8577) Implement proctime DataStream to Table upsert conversion.

[ https://issues.apache.org/jira/browse/FLINK-8577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701652#comment-16701652 ] ASF GitHub Bot commented on FLINK-8577: --- pnowojski commented on a change in pull request #6787:

[jira] [Commented] (FLINK-10820) Simplify the RebalancePartitioner implementation

[ https://issues.apache.org/jira/browse/FLINK-10820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701711#comment-16701711 ] ASF GitHub Bot commented on FLINK-10820: asfgit closed pull request #7051:

[GitHub] pnowojski commented on issue #7051: [FLINK-10820][network] Simplify the RebalancePartitioner implementation

pnowojski commented on issue #7051: [FLINK-10820][network] Simplify the RebalancePartitioner implementation URL: https://github.com/apache/flink/pull/7051#issuecomment-442408774 Thanks @zhijiangW for the contribution :) I have reordered commits and merged the to master.

[jira] [Commented] (FLINK-10820) Simplify the RebalancePartitioner implementation

[ https://issues.apache.org/jira/browse/FLINK-10820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701713#comment-16701713 ] ASF GitHub Bot commented on FLINK-10820: pnowojski commented on issue #7051:

[jira] [Commented] (FLINK-11015) Remove deprecated methods and classes about table from all the Kafka connectors

[ https://issues.apache.org/jira/browse/FLINK-11015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701531#comment-16701531 ] ASF GitHub Bot commented on FLINK-11015: yanghua commented on issue #7182: [FLINK-11015] Remove

[GitHub] yanghua commented on issue #7182: [FLINK-11015] Remove deprecated methods and classes about table from all the Kafka connectors

yanghua commented on issue #7182: [FLINK-11015] Remove deprecated methods and classes about table from all the Kafka connectors URL: https://github.com/apache/flink/pull/7182#issuecomment-442363596 cc @pnowojski This is an

[jira] [Commented] (FLINK-11004) Wrong ProcessWindowFunction.process argument in example of Incremental Window Aggregation with ReduceFunction

[ https://issues.apache.org/jira/browse/FLINK-11004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701564#comment-16701564 ] ASF GitHub Bot commented on FLINK-11004: shaoxuan-wang commented on issue #7175:

[GitHub] shaoxuan-wang commented on issue #7175: [FLINK-11004][Documentation] wrong ProcessWindowFunction.process argument in window document

shaoxuan-wang commented on issue #7175: [FLINK-11004][Documentation] wrong ProcessWindowFunction.process argument in window document URL: https://github.com/apache/flink/pull/7175#issuecomment-442372337 Hi @yuanyangwu , thanks for the contribution. It is always good to rebase the master

[GitHub] zhijiangW commented on issue #7051: [FLINK-10820][network] Simplify the RebalancePartitioner implementation

zhijiangW commented on issue #7051: [FLINK-10820][network] Simplify the RebalancePartitioner implementation URL: https://github.com/apache/flink/pull/7051#issuecomment-442372490 Yeah, thanks for above specific explanations which all make sense in my opinion. I just want to confirm whether

[jira] [Commented] (FLINK-10884) Flink on yarn TM container will be killed by nodemanager because of the exceeded physical memory.

[ https://issues.apache.org/jira/browse/FLINK-10884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701574#comment-16701574 ] wgcn commented on FLINK-10884: -- https://github.com/apache/flink/pull/7185 > Flink on yarn TM container

[jira] [Updated] (FLINK-10584) Add support for state retention to the Event Time versioned joins.

[ https://issues.apache.org/jira/browse/FLINK-10584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-10584: --- Description: Open PR [here|https://github.com/apache/flink/pull/6871] (was: [Open

[jira] [Commented] (FLINK-11015) Remove deprecated methods and classes about table from all the Kafka connectors

[ https://issues.apache.org/jira/browse/FLINK-11015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701617#comment-16701617 ] ASF GitHub Bot commented on FLINK-11015: yanghua commented on a change in pull request #7182:

[GitHub] yanghua commented on a change in pull request #7182: [FLINK-11015] Remove deprecated methods and classes about table from all the Kafka connectors

yanghua commented on a change in pull request #7182: [FLINK-11015] Remove deprecated methods and classes about table from all the Kafka connectors URL: https://github.com/apache/flink/pull/7182#discussion_r237006592 ## File path:

[GitHub] yanghua commented on issue #7182: [FLINK-11015] Remove deprecated methods and classes about table from all the Kafka connectors

yanghua commented on issue #7182: [FLINK-11015] Remove deprecated methods and classes about table from all the Kafka connectors URL: https://github.com/apache/flink/pull/7182#issuecomment-442383678 @twalthr thanks for your suggestion. I have checked the list you gave. I found the builder

[jira] [Commented] (FLINK-2491) Checkpointing only works if all operators/tasks are still running

[ https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701630#comment-16701630 ] Lin Canhuang commented on FLINK-2491: - I also came across this problem when setting the source

[jira] [Commented] (FLINK-10941) Slots prematurely released which still contain unconsumed data

[ https://issues.apache.org/jira/browse/FLINK-10941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701679#comment-16701679 ] Qi commented on FLINK-10941: Hi [~till.rohrmann] and [~zjwang], Before the external shuffle service is

[jira] [Commented] (FLINK-10820) Simplify the RebalancePartitioner implementation

[ https://issues.apache.org/jira/browse/FLINK-10820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701511#comment-16701511 ] ASF GitHub Bot commented on FLINK-10820: pnowojski commented on issue #7051:

[GitHub] pnowojski edited a comment on issue #7051: [FLINK-10820][network] Simplify the RebalancePartitioner implementation

pnowojski edited a comment on issue #7051: [FLINK-10820][network] Simplify the RebalancePartitioner implementation URL: https://github.com/apache/flink/pull/7051#issuecomment-442358466 Personally I do not mind that much about separating PRs or creating separate Jira issues - but that's my

[jira] [Commented] (FLINK-10820) Simplify the RebalancePartitioner implementation

[ https://issues.apache.org/jira/browse/FLINK-10820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701513#comment-16701513 ] ASF GitHub Bot commented on FLINK-10820: pnowojski edited a comment on issue #7051:

[GitHub] pnowojski commented on issue #7051: [FLINK-10820][network] Simplify the RebalancePartitioner implementation

pnowojski commented on issue #7051: [FLINK-10820][network] Simplify the RebalancePartitioner implementation URL: https://github.com/apache/flink/pull/7051#issuecomment-442358466 Personally I do not mind that much about separating PRs or creating separate Jira issues - but that's my

[jira] [Commented] (FLINK-10884) Flink on yarn TM container will be killed by nodemanager because of the exceeded physical memory.

[jira] [Commented] (FLINK-11015) Remove deprecated methods and classes about table from all the Kafka connectors

[ https://issues.apache.org/jira/browse/FLINK-11015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701616#comment-16701616 ] ASF GitHub Bot commented on FLINK-11015: yanghua commented on issue #7182: [FLINK-11015] Remove

[GitHub] pnowojski commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion

pnowojski commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion URL: https://github.com/apache/flink/pull/6787#discussion_r237008957 ## File path:

[jira] [Commented] (FLINK-11015) Remove deprecated methods and classes about table from all the Kafka connectors

[ https://issues.apache.org/jira/browse/FLINK-11015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701662#comment-16701662 ] ASF GitHub Bot commented on FLINK-11015: twalthr commented on a change in pull request #7182:

[GitHub] asfgit closed pull request #7051: [FLINK-10820][network] Simplify the RebalancePartitioner implementation

asfgit closed pull request #7051: [FLINK-10820][network] Simplify the RebalancePartitioner implementation URL: https://github.com/apache/flink/pull/7051 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of

[jira] [Closed] (FLINK-10820) Simplify the RebalancePartitioner implementation

[ https://issues.apache.org/jira/browse/FLINK-10820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-10820. -- Resolution: Fixed Fix Version/s: 1.8.0 Merged as 2d511b0624 into the master. >

[jira] [Created] (FLINK-11018) Flink ignores logback.xml

prathamesh created FLINK-11018: -- Summary: Flink ignores logback.xml Key: FLINK-11018 URL: https://issues.apache.org/jira/browse/FLINK-11018 Project: Flink Issue Type: Bug Components:

[jira] [Updated] (FLINK-2491) Checkpointing only works if all operators/tasks are still running

[ https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lin Canhuang updated FLINK-2491: Attachment: fix_checkpoint_not_working_if_tasks_are_finished.patch > Checkpointing only works if

[jira] [Commented] (FLINK-10963) Cleanup small objects uploaded to S3 as independent objects

[ https://issues.apache.org/jira/browse/FLINK-10963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701721#comment-16701721 ] ASF GitHub Bot commented on FLINK-10963: igalshilman commented on a change in pull request

[jira] [Commented] (FLINK-10963) Cleanup small objects uploaded to S3 as independent objects

[ https://issues.apache.org/jira/browse/FLINK-10963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701719#comment-16701719 ] ASF GitHub Bot commented on FLINK-10963: igalshilman commented on a change in pull request

[jira] [Commented] (FLINK-10963) Cleanup small objects uploaded to S3 as independent objects

[ https://issues.apache.org/jira/browse/FLINK-10963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701723#comment-16701723 ] ASF GitHub Bot commented on FLINK-10963: igalshilman commented on a change in pull request

[jira] [Commented] (FLINK-10963) Cleanup small objects uploaded to S3 as independent objects

[ https://issues.apache.org/jira/browse/FLINK-10963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701722#comment-16701722 ] ASF GitHub Bot commented on FLINK-10963: igalshilman commented on a change in pull request

[jira] [Commented] (FLINK-11004) Wrong ProcessWindowFunction.process argument in example of Incremental Window Aggregation with ReduceFunction

[ https://issues.apache.org/jira/browse/FLINK-11004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701580#comment-16701580 ] ASF GitHub Bot commented on FLINK-11004: asfgit closed pull request #7175:

[GitHub] asfgit closed pull request #7175: [FLINK-11004][Documentation] wrong ProcessWindowFunction.process argument in window document

asfgit closed pull request #7175: [FLINK-11004][Documentation] wrong ProcessWindowFunction.process argument in window document URL: https://github.com/apache/flink/pull/7175 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below

[jira] [Closed] (FLINK-11003) Document of Java Lambda Expressions has a mistake

[ https://issues.apache.org/jira/browse/FLINK-11003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-11003. Resolution: Fixed Fix Version/s: 1.7.0 master:

[jira] [Commented] (FLINK-10966) Optimize the release blocking logic in BarrierBuffer

[ https://issues.apache.org/jira/browse/FLINK-10966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701732#comment-16701732 ] vinoyang commented on FLINK-10966: -- [~StephanEwen]  Yes, adding timeouts for blocking is one of the

[jira] [Closed] (FLINK-11004) Wrong ProcessWindowFunction.process argument in example of Incremental Window Aggregation with ReduceFunction

[ https://issues.apache.org/jira/browse/FLINK-11004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang closed FLINK-11004. - Resolution: Fixed Fixed and merged into master > Wrong ProcessWindowFunction.process argument

[jira] [Updated] (FLINK-10584) Add support for state retention to the Event Time versioned joins.

[ https://issues.apache.org/jira/browse/FLINK-10584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-10584: --- Labels: pull-request-available (was: ) > Add support for state retention to the Event Time

[GitHub] igalshilman commented on a change in pull request #7161: [FLINK-10963][fs-connector, s3] Cleanup tmp S3 objects uploaded as backups of in-progress files.

igalshilman commented on a change in pull request #7161: [FLINK-10963][fs-connector, s3] Cleanup tmp S3 objects uploaded as backups of in-progress files. URL: https://github.com/apache/flink/pull/7161#discussion_r237005998 ## File path:

[GitHub] igalshilman commented on a change in pull request #7161: [FLINK-10963][fs-connector, s3] Cleanup tmp S3 objects uploaded as backups of in-progress files.

igalshilman commented on a change in pull request #7161: [FLINK-10963][fs-connector, s3] Cleanup tmp S3 objects uploaded as backups of in-progress files. URL: https://github.com/apache/flink/pull/7161#discussion_r237006486 ## File path:

[GitHub] igalshilman commented on a change in pull request #7161: [FLINK-10963][fs-connector, s3] Cleanup tmp S3 objects uploaded as backups of in-progress files.

igalshilman commented on a change in pull request #7161: [FLINK-10963][fs-connector, s3] Cleanup tmp S3 objects uploaded as backups of in-progress files. URL: https://github.com/apache/flink/pull/7161#discussion_r237021819 ## File path:

[GitHub] igalshilman commented on a change in pull request #7161: [FLINK-10963][fs-connector, s3] Cleanup tmp S3 objects uploaded as backups of in-progress files.

igalshilman commented on a change in pull request #7161: [FLINK-10963][fs-connector, s3] Cleanup tmp S3 objects uploaded as backups of in-progress files. URL: https://github.com/apache/flink/pull/7161#discussion_r237028468 ## File path:

[jira] [Commented] (FLINK-10963) Cleanup small objects uploaded to S3 as independent objects

[ https://issues.apache.org/jira/browse/FLINK-10963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701720#comment-16701720 ] ASF GitHub Bot commented on FLINK-10963: igalshilman commented on a change in pull request

[jira] [Commented] (FLINK-10963) Cleanup small objects uploaded to S3 as independent objects

[ https://issues.apache.org/jira/browse/FLINK-10963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701718#comment-16701718 ] ASF GitHub Bot commented on FLINK-10963: igalshilman commented on a change in pull request

[jira] [Commented] (FLINK-10963) Cleanup small objects uploaded to S3 as independent objects

[ https://issues.apache.org/jira/browse/FLINK-10963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701724#comment-16701724 ] ASF GitHub Bot commented on FLINK-10963: igalshilman commented on a change in pull request

[GitHub] igalshilman commented on a change in pull request #7161: [FLINK-10963][fs-connector, s3] Cleanup tmp S3 objects uploaded as backups of in-progress files.

igalshilman commented on a change in pull request #7161: [FLINK-10963][fs-connector, s3] Cleanup tmp S3 objects uploaded as backups of in-progress files. URL: https://github.com/apache/flink/pull/7161#discussion_r237008022 ## File path:

[GitHub] igalshilman commented on a change in pull request #7161: [FLINK-10963][fs-connector, s3] Cleanup tmp S3 objects uploaded as backups of in-progress files.

igalshilman commented on a change in pull request #7161: [FLINK-10963][fs-connector, s3] Cleanup tmp S3 objects uploaded as backups of in-progress files. URL: https://github.com/apache/flink/pull/7161#discussion_r237019573 ## File path:

[GitHub] igalshilman commented on a change in pull request #7161: [FLINK-10963][fs-connector, s3] Cleanup tmp S3 objects uploaded as backups of in-progress files.

igalshilman commented on a change in pull request #7161: [FLINK-10963][fs-connector, s3] Cleanup tmp S3 objects uploaded as backups of in-progress files. URL: https://github.com/apache/flink/pull/7161#discussion_r237019983 ## File path:

[GitHub] twalthr commented on a change in pull request #7182: [FLINK-11015] Remove deprecated methods and classes about table from all the Kafka connectors

twalthr commented on a change in pull request #7182: [FLINK-11015] Remove deprecated methods and classes about table from all the Kafka connectors URL: https://github.com/apache/flink/pull/7182#discussion_r236982074 ## File path:

[jira] [Commented] (FLINK-11015) Remove deprecated methods and classes about table from all the Kafka connectors

[ https://issues.apache.org/jira/browse/FLINK-11015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701534#comment-16701534 ] ASF GitHub Bot commented on FLINK-11015: twalthr commented on a change in pull request #7182:

[jira] [Updated] (FLINK-10884) Flink on yarn TM container will be killed by nodemanager because of the exceeded physical memory.

[ https://issues.apache.org/jira/browse/FLINK-10884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10884: --- Labels: pull-request-available yarn (was: yarn) > Flink on yarn TM container will be

[GitHub] wg1026688210 opened a new pull request #7185: [FLINK-10884] [yarn/mesos] adjust container memory param to set a safe margin from offheap memory

wg1026688210 opened a new pull request #7185: [FLINK-10884] [yarn/mesos] adjust container memory param to set a safe margin from offheap memory URL: https://github.com/apache/flink/pull/7185 What is the purpose of the change This pull request adjust yarn container memory parameters/

[jira] [Created] (FLINK-11016) flink chain have a bug？？？

Wong created FLINK-11016: Summary: flink chain have a bug？？？ Key: FLINK-11016 URL: https://issues.apache.org/jira/browse/FLINK-11016 Project: Flink Issue Type: Bug Components: Core

[jira] [Commented] (FLINK-10583) Add support for state retention to the Processing Time versioned joins.

[ https://issues.apache.org/jira/browse/FLINK-10583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701611#comment-16701611 ] ASF GitHub Bot commented on FLINK-10583: kl0u edited a comment on issue #6871:

[jira] [Commented] (FLINK-10584) Add support for state retention to the Event Time versioned joins.

[ https://issues.apache.org/jira/browse/FLINK-10584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701613#comment-16701613 ] Kostas Kloudas commented on FLINK-10584: There is an open PR for this here:

[GitHub] kl0u edited a comment on issue #6871: [FLINK-10583][FLINK-10584][table] Add State Retention to temporal joins.

kl0u edited a comment on issue #6871: [FLINK-10583][FLINK-10584][table] Add State Retention to temporal joins. URL: https://github.com/apache/flink/pull/6871#issuecomment-442382181 @pnowojski and @twalthr I updated the PR to expose the state retention logic to the joins. Please review and

[GitHub] kl0u commented on issue #6871: [FLINK-10583][FLINK-10584][table] Add State Retention to temporal joins.

kl0u commented on issue #6871: [FLINK-10583][FLINK-10584][table] Add State Retention to temporal joins. URL: https://github.com/apache/flink/pull/6871#issuecomment-442382181 @pnowojski and @twalthr I updated the PR to expose the state retention logic to the joins. Please review and let me

[jira] [Commented] (FLINK-11003) Document of Java Lambda Expressions has a mistake

[ https://issues.apache.org/jira/browse/FLINK-11003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701623#comment-16701623 ] ASF GitHub Bot commented on FLINK-11003: zentol closed pull request #7174: [FLINK-11003][docs]

[GitHub] zentol closed pull request #7174: [FLINK-11003][docs] Fix mistake in java_lambda doc

zentol closed pull request #7174: [FLINK-11003][docs] Fix mistake in java_lambda doc URL: https://github.com/apache/flink/pull/7174 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this is a

[jira] [Commented] (FLINK-10583) Add support for state retention to the Processing Time versioned joins.

[ https://issues.apache.org/jira/browse/FLINK-10583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701610#comment-16701610 ] ASF GitHub Bot commented on FLINK-10583: kl0u commented on issue #6871:

[jira] [Updated] (FLINK-10584) Add support for state retention to the Event Time versioned joins.

[ https://issues.apache.org/jira/browse/FLINK-10584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-10584: --- Description: [Open RP|https://github.com/apache/flink/pull/6871] > Add support for state

[GitHub] twalthr commented on a change in pull request #7182: [FLINK-11015] Remove deprecated methods and classes about table from all the Kafka connectors

twalthr commented on a change in pull request #7182: [FLINK-11015] Remove deprecated methods and classes about table from all the Kafka connectors URL: https://github.com/apache/flink/pull/7182#discussion_r237019737 ## File path:

[jira] [Commented] (FLINK-10963) Cleanup small objects uploaded to S3 as independent objects

[ https://issues.apache.org/jira/browse/FLINK-10963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701688#comment-16701688 ] ASF GitHub Bot commented on FLINK-10963: kl0u commented on issue #7161:

[GitHub] kl0u commented on issue #7161: [FLINK-10963][fs-connector, s3] Cleanup tmp S3 objects uploaded as backups of in-progress files.

kl0u commented on issue #7161: [FLINK-10963][fs-connector, s3] Cleanup tmp S3 objects uploaded as backups of in-progress files. URL: https://github.com/apache/flink/pull/7161#issuecomment-442403581 @azagrebin This is an

[jira] [Created] (FLINK-11019) Expose the queryable proxy server port in taskinfo api

Jiayi Liao created FLINK-11019: -- Summary: Expose the queryable proxy server port in taskinfo api Key: FLINK-11019 URL: https://issues.apache.org/jira/browse/FLINK-11019 Project: Flink Issue

[jira] [Commented] (FLINK-8577) Implement proctime DataStream to Table upsert conversion.

[ https://issues.apache.org/jira/browse/FLINK-8577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16702617#comment-16702617 ] ASF GitHub Bot commented on FLINK-8577: --- hequn8128 commented on a change in pull request #6787:

[jira] [Commented] (FLINK-8577) Implement proctime DataStream to Table upsert conversion.

[ https://issues.apache.org/jira/browse/FLINK-8577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16702619#comment-16702619 ] ASF GitHub Bot commented on FLINK-8577: --- hequn8128 commented on a change in pull request #6787:

[jira] [Closed] (FLINK-11016) flink chain have a bug？？？

[ https://issues.apache.org/jira/browse/FLINK-11016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wong closed FLINK-11016. Resolution: Not A Bug > flink chain have a bug？？？ > - > > Key:

[jira] [Commented] (FLINK-10665) Port YARNSessionFIFOITCase#testJavaAPI to new codebase

[ https://issues.apache.org/jira/browse/FLINK-10665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16702680#comment-16702680 ] ASF GitHub Bot commented on FLINK-10665: TisonKun removed a comment on issue #6917:

[GitHub] TisonKun removed a comment on issue #6917: [FLINK-10665] [tests] Port YARNSessionFIFOITCase#testJavaAPI to new c…

TisonKun removed a comment on issue #6917: [FLINK-10665] [tests] Port YARNSessionFIFOITCase#testJavaAPI to new c… URL: https://github.com/apache/flink/pull/6917#issuecomment-440876707 cc @GJL @StefanRRichter This is an

[GitHub] TisonKun removed a comment on issue #6917: [FLINK-10665] [tests] Port YARNSessionFIFOITCase#testJavaAPI to new c…

TisonKun removed a comment on issue #6917: [FLINK-10665] [tests] Port YARNSessionFIFOITCase#testJavaAPI to new c… URL: https://github.com/apache/flink/pull/6917#issuecomment-433074450 @zentol I fix the checkstyle issue. Can you review this?

[GitHub] TisonKun commented on issue #6917: [FLINK-10665] [tests] Port YARNSessionFIFOITCase#testJavaAPI to new c…

TisonKun commented on issue #6917: [FLINK-10665] [tests] Port YARNSessionFIFOITCase#testJavaAPI to new c… URL: https://github.com/apache/flink/pull/6917#issuecomment-442696454 @zentol I have resolved travis issue. Could you review this when you're free? There are little changes though.

[jira] [Commented] (FLINK-10665) Port YARNSessionFIFOITCase#testJavaAPI to new codebase

[ https://issues.apache.org/jira/browse/FLINK-10665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16702682#comment-16702682 ] ASF GitHub Bot commented on FLINK-10665: TisonKun removed a comment on issue #6917:

[jira] [Commented] (FLINK-11024) Overwrite yarn configuration by setting configuration started with "flink.yarn." in flink-conf.yaml

[ https://issues.apache.org/jira/browse/FLINK-11024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16702768#comment-16702768 ] ASF GitHub Bot commented on FLINK-11024: liu-zhaokun opened a new pull request #7193:

[jira] [Created] (FLINK-11024) Overwrite yarn configuration by setting configuration started with "flink.yarn." in flink-conf.yaml

liuzhaokun created FLINK-11024: -- Summary: Overwrite yarn configuration by setting configuration started with "flink.yarn." in flink-conf.yaml Key: FLINK-11024 URL: https://issues.apache.org/jira/browse/FLINK-11024

[jira] [Assigned] (FLINK-11022) Update LICENSE and NOTICE files for older releases

[ https://issues.apache.org/jira/browse/FLINK-11022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-11022: Assignee: vinoyang > Update LICENSE and NOTICE files for older releases >

[jira] [Assigned] (FLINK-11023) Update LICENSE and NOTICE files for flink-connectors

[ https://issues.apache.org/jira/browse/FLINK-11023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-11023: Assignee: vinoyang > Update LICENSE and NOTICE files for flink-connectors >

[jira] [Commented] (FLINK-10999) Adding time multiple times causes Runtime : java.sql.Timestamp cannot be cast to java.lang.Long

[ https://issues.apache.org/jira/browse/FLINK-10999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16702784#comment-16702784 ] xuqianjin commented on FLINK-10999: --- hi [~harbby] After tracking, two problems were found: 1.Proctime

[GitHub] liu-zhaokun opened a new pull request #7193: [FLINK-11024]Overwrite yarn configuration by setting configuration started with "flink.yarn." in flink-conf.yaml

liu-zhaokun opened a new pull request #7193: [FLINK-11024]Overwrite yarn configuration by setting configuration started with "flink.yarn." in flink-conf.yaml URL: https://github.com/apache/flink/pull/7193

[jira] [Updated] (FLINK-11024) Overwrite yarn configuration by setting configuration started with "flink.yarn." in flink-conf.yaml

[ https://issues.apache.org/jira/browse/FLINK-11024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11024: --- Labels: pull-request-available (was: ) > Overwrite yarn configuration by setting

[GitHub] yanghua commented on issue #7182: [FLINK-11015] Remove deprecated methods and classes about table from all the Kafka connectors

yanghua commented on issue #7182: [FLINK-11015] Remove deprecated methods and classes about table from all the Kafka connectors URL: https://github.com/apache/flink/pull/7182#issuecomment-442730853 @twalthr Any other changes? If not, I look forward to merging it as soon as possible to

[GitHub] Matrix42 opened a new pull request #7194: [doc] fix missing comma in cep sql

Matrix42 opened a new pull request #7194: [doc] fix missing comma in cep sql URL: https://github.com/apache/flink/pull/7194 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we

[jira] [Commented] (FLINK-11015) Remove deprecated methods and classes about table from all the Kafka connectors

[ https://issues.apache.org/jira/browse/FLINK-11015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16702802#comment-16702802 ] ASF GitHub Bot commented on FLINK-11015: yanghua commented on issue #7182: [FLINK-11015] Remove

  1   2   3   >