[GitHub] KarmaGYZ opened a new pull request #7211: [hotfix][docs] Add and update description of local-recovery config op…

KarmaGYZ opened a new pull request #7211: [hotfix][docs] Add and update description of local-recovery config op… URL: https://github.com/apache/flink/pull/7211 …tions ## What is the purpose of the change This pr update the javadoc of "state.backend.local-recovery" and

[jira] [Commented] (FLINK-10775) Quarantined address [akka.tcp://flink@flink-jobmanager:6123] is still unreachable or has not been restarted. Keeping it quarantined.

[ https://issues.apache.org/jira/browse/FLINK-10775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16706252#comment-16706252 ] miki haiat commented on FLINK-10775: I had this issue as well on 1.4.x . I can confirm that on

[GitHub] KarmaGYZ opened a new pull request #7212: [hotfix][docs] Fix invalid link in schema_evolution doc

KarmaGYZ opened a new pull request #7212: [hotfix][docs] Fix invalid link in schema_evolution doc URL: https://github.com/apache/flink/pull/7212 ## What is the purpose of the change Fix an invalid link in schema_evolution doc ## Brief change log - correct link to

[GitHub] walterddr commented on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime()

walterddr commented on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime() URL: https://github.com/apache/flink/pull/7180#issuecomment-443522584 Hi @lamber-ken . the minimum reproduction result should be a good starting point for adding

[jira] [Commented] (FLINK-11046) ElasticSearch6Connector cause thread blocked when index failed with retry

[ https://issues.apache.org/jira/browse/FLINK-11046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16706243#comment-16706243 ] miki haiat commented on FLINK-11046: HI , Can you please share the elastic connection properties .

[jira] [Created] (FLINK-11047) CoGroupGroupSortTranslationTest does not compile with scala 2.12

Chesnay Schepler created FLINK-11047: Summary: CoGroupGroupSortTranslationTest does not compile with scala 2.12 Key: FLINK-11047 URL: https://issues.apache.org/jira/browse/FLINK-11047 Project:

[jira] [Commented] (FLINK-11010) Flink SQL timestamp is inconsistent with currentProcessingTime()

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

[GitHub] walterddr edited a comment on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime()

walterddr edited a comment on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime() URL: https://github.com/apache/flink/pull/7180#issuecomment-443522584 Hi @lamber-ken . the minimum reproduction example should be a good starting point for

[jira] [Commented] (FLINK-11010) Flink SQL timestamp is inconsistent with currentProcessingTime()

[ https://issues.apache.org/jira/browse/FLINK-11010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16706398#comment-16706398 ] Rong Rong commented on FLINK-11010: --- Based on the discussion in the mailing list:

[jira] [Commented] (FLINK-11010) Flink SQL timestamp is inconsistent with currentProcessingTime()

[ https://issues.apache.org/jira/browse/FLINK-11010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16706399#comment-16706399 ] ASF GitHub Bot commented on FLINK-11010: walterddr commented on issue #7180: [FLINK-11010]

[jira] [Commented] (FLINK-11048) Ability to programmatically execute streaming pipeline with savepoint restore

[ https://issues.apache.org/jira/browse/FLINK-11048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16706517#comment-16706517 ] Thomas Weise commented on FLINK-11048: -- Related: 

[jira] [Created] (FLINK-11048) Ability to programmatically execute streaming pipeline with savepoint restore

Thomas Weise created FLINK-11048: Summary: Ability to programmatically execute streaming pipeline with savepoint restore Key: FLINK-11048 URL: https://issues.apache.org/jira/browse/FLINK-11048

[jira] [Commented] (FLINK-11020) Reorder joins only to eliminate cross joins

[ https://issues.apache.org/jira/browse/FLINK-11020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16706580#comment-16706580 ] Hequn Cheng commented on FLINK-11020: - Maybe we can implement cross join with parallelism of 1? For

[GitHub] liu-zhaokun commented on issue #7193: [FLINK-11024]Overwrite yarn configuration by setting configuration started with "flink.yarn." in flink-conf.yaml

liu-zhaokun commented on issue #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#issuecomment-443566938 I think this failing check does not related to my PR, is there anyone

[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=16706591#comment-16706591 ] ASF GitHub Bot commented on FLINK-11024: liu-zhaokun commented on issue #7193:

[jira] [Commented] (FLINK-7208) Refactor build-in agg(MaxWithRetractAccumulator and MinWithRetractAccumulator) using the DataView

[ https://issues.apache.org/jira/browse/FLINK-7208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16706592#comment-16706592 ] ASF GitHub Bot commented on FLINK-7208: --- dianfu commented on issue #7201: [FLINK-7208] [table]

[GitHub] dianfu commented on issue #7201: [FLINK-7208] [table] Optimize Min/MaxWithRetractAggFunction with DataView

dianfu commented on issue #7201: [FLINK-7208] [table] Optimize Min/MaxWithRetractAggFunction with DataView URL: https://github.com/apache/flink/pull/7201#issuecomment-443566996 Hi @walterddr ， thanks a lot for your review. Make sense to me and have added an IT case.

[jira] [Updated] (FLINK-11046) ElasticSearch6Connector cause thread blocked when index failed with retry

[ https://issues.apache.org/jira/browse/FLINK-11046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoguohao updated FLINK-11046: -- Description: When i'm using es6 sink to index into es, bulk process with some exception catched, and 

[jira] [Updated] (FLINK-11045) UserCodeClassLoader has not been set correctly for RuntimeUDFContext in CollectionExecutor

[ https://issues.apache.org/jira/browse/FLINK-11045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11045: --- Labels: pull-request-available (was: ) > UserCodeClassLoader has not been set correctly

[jira] [Commented] (FLINK-11045) UserCodeClassLoader has not been set correctly for RuntimeUDFContext in CollectionExecutor

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

[GitHub] hequn8128 opened a new pull request #7213: [FLINK-11045][table] Set correct UserCodeClassLoader for RuntimeUDFContext in CollectionExecutor

hequn8128 opened a new pull request #7213: [FLINK-11045][table] Set correct UserCodeClassLoader for RuntimeUDFContext in CollectionExecutor URL: https://github.com/apache/flink/pull/7213 ## What is the purpose of the change Currently, a system classloader is been used when

[GitHub] tzulitai commented on issue #7026: [FLINK-10798] Add the version number of Flink 1.7 to MigrationVersion

tzulitai commented on issue #7026: [FLINK-10798] Add the version number of Flink 1.7 to MigrationVersion URL: https://github.com/apache/flink/pull/7026#issuecomment-443592846 +1 LGTM, will merge this now. This is an

[jira] [Commented] (FLINK-10798) Add the version number of Flink 1.7 to MigrationVersion

[ https://issues.apache.org/jira/browse/FLINK-10798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16706670#comment-16706670 ] ASF GitHub Bot commented on FLINK-10798: tzulitai commented on issue #7026: [FLINK-10798] Add

[jira] [Created] (FLINK-11050) When IntervalJoin, get left or right buffer's entries more quickly by assigning lowerBound

Liu created FLINK-11050: --- Summary: When IntervalJoin, get left or right buffer's entries more quickly by assigning lowerBound Key: FLINK-11050 URL: https://issues.apache.org/jira/browse/FLINK-11050 Project:

[jira] [Closed] (FLINK-10798) Add the version number of Flink 1.7 to MigrationVersion

[ https://issues.apache.org/jira/browse/FLINK-10798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-10798. --- Resolution: Fixed Merged to master for 1.8.0: 

[GitHub] asfgit closed pull request #7026: [FLINK-10798] Add the version number of Flink 1.7 to MigrationVersion

asfgit closed pull request #7026: [FLINK-10798] Add the version number of Flink 1.7 to MigrationVersion URL: https://github.com/apache/flink/pull/7026 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] [Commented] (FLINK-10776) Update migration tests for Flink 1.7

[ https://issues.apache.org/jira/browse/FLINK-10776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16706678#comment-16706678 ] Tzu-Li (Gordon) Tai commented on FLINK-10776: - [~yanghua] I've merged FLINK-10798 to unblock

[jira] [Commented] (FLINK-10798) Add the version number of Flink 1.7 to MigrationVersion

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

[jira] [Comment Edited] (FLINK-10776) Update migration tests for Flink 1.7

[ https://issues.apache.org/jira/browse/FLINK-10776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16706678#comment-16706678 ] Tzu-Li (Gordon) Tai edited comment on FLINK-10776 at 12/3/18 5:30 AM:

[jira] [Updated] (FLINK-11050) When IntervalJoin, get left or right buffer's entries more quickly by assigning lowerBound

[ https://issues.apache.org/jira/browse/FLINK-11050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-11050: Description:     When IntervalJoin, it is very slow to get left or right buffer's entries. Because we have to 

[jira] [Updated] (FLINK-10798) Add the version number of Flink 1.7 to MigrationVersion

[ https://issues.apache.org/jira/browse/FLINK-10798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-10798: Fix Version/s: 1.8.0 > Add the version number of Flink 1.7 to MigrationVersion >

[jira] [Commented] (FLINK-10996) Enable state ttl in cep

[ https://issues.apache.org/jira/browse/FLINK-10996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16706685#comment-16706685 ] aitozi commented on FLINK-10996: Hi, [~StephanEwen] I think it can be resolved by supporting the api to

[GitHub] sunjincheng121 commented on issue #7181: [FLINK-11013] [table] Fix distinct aggregates for group window in Table API

sunjincheng121 commented on issue #7181: [FLINK-11013] [table] Fix distinct aggregates for group window in Table API URL: https://github.com/apache/flink/pull/7181#issuecomment-443595531 @dianfu @walterddr Thanks for the review and update! will merging..

[jira] [Commented] (FLINK-11013) Fix distinct aggregates for group window in Table API

[ https://issues.apache.org/jira/browse/FLINK-11013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16706688#comment-16706688 ] ASF GitHub Bot commented on FLINK-11013: sunjincheng121 commented on issue #7181: [FLINK-11013]

[GitHub] zjffdu opened a new pull request #7214: FLINK-11409

zjffdu opened a new pull request #7214: FLINK-11409 URL: https://github.com/apache/flink/pull/7214 ## What is the purpose of the change This PR allow user to run partial dag which is associated to certain sinks instead of all sinks. ## Brief change log It add new api

[jira] [Commented] (FLINK-11039) LogicalExchange and HashPartitioner realization

[ https://issues.apache.org/jira/browse/FLINK-11039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16706717#comment-16706717 ] ambition commented on FLINK-11039: -- It was originally implemented as 

[jira] [Updated] (FLINK-11050) When IntervalJoin, get left or right buffer's entries more quickly by assigning lowerBound

[ https://issues.apache.org/jira/browse/FLINK-11050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-11050: Description:     When IntervalJoin, it is very slow to get left or right buffer's entries. Because we have to 

[GitHub] zhijiangW commented on a change in pull request #7185: [FLINK-10884] [yarn/mesos] adjust container memory param to set a safe margin from offheap memory

zhijiangW commented on a change in 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#discussion_r238154920 ## File path:

[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=16706723#comment-16706723 ] ASF GitHub Bot commented on FLINK-10884: zhijiangW commented on a change in pull request #7185:

[jira] [Commented] (FLINK-6441) Improve the UDTF

[ https://issues.apache.org/jira/browse/FLINK-6441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16706574#comment-16706574 ] Hequn Cheng commented on FLINK-6441: I tested it in an ITCase. It seems the issue has not been fixed?

[jira] [Commented] (FLINK-8739) Optimize runtime support for distinct filter

[ https://issues.apache.org/jira/browse/FLINK-8739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16706595#comment-16706595 ] Dian Fu commented on FLINK-8739: [~walterddr] Thanks a lot. I'll provide a PR ASAP and looking forward to

[jira] [Commented] (FLINK-10149) Fink Mesos allocates extra port when not configured to do so.

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

[jira] [Commented] (FLINK-10134) UTF-16 support for TextInputFormat

[ https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16706598#comment-16706598 ] ASF GitHub Bot commented on FLINK-10134: XuQianJin-Stars closed pull request #7157:

[GitHub] XuQianJin-Stars closed pull request #7157: [FLINK-10134] UTF-16 support for TextInputFormat bug

XuQianJin-Stars closed pull request #7157: [FLINK-10134] UTF-16 support for TextInputFormat bug URL: https://github.com/apache/flink/pull/7157 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

[jira] [Updated] (FLINK-11046) ElasticSearch6Connector cause thread blocked when index failed with retry

[ https://issues.apache.org/jira/browse/FLINK-11046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoguohao updated FLINK-11046: -- Description: When i'm using es6 sink to index into es, bulk process with some exception catched, and 

[jira] [Commented] (FLINK-6441) Improve the UDTF

[ https://issues.apache.org/jira/browse/FLINK-6441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16706587#comment-16706587 ] Ruidong Li commented on FLINK-6441: --- Thanks for [~twalthr] and [~hequn8128], This issue has not been

[jira] [Assigned] (FLINK-8739) Optimize runtime support for distinct filter

[ https://issues.apache.org/jira/browse/FLINK-8739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-8739: -- Assignee: Dian Fu > Optimize runtime support for distinct filter >

[jira] [Commented] (FLINK-11046) ElasticSearch6Connector cause thread blocked when index failed with retry

[ https://issues.apache.org/jira/browse/FLINK-11046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16706611#comment-16706611 ] luoguohao commented on FLINK-11046: --- sorry for missing that, here are all my settings for the ES sink:

[jira] [Created] (FLINK-11049) Unable to execute partial DAG

Jeff Zhang created FLINK-11049: -- Summary: Unable to execute partial DAG Key: FLINK-11049 URL: https://issues.apache.org/jira/browse/FLINK-11049 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-11049) Unable to execute partial DAG

[ https://issues.apache.org/jira/browse/FLINK-11049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang reassigned FLINK-11049: -- Assignee: Jeff Zhang > Unable to execute partial DAG > - > >

[GitHub] asfgit closed pull request #7203: [FLINK-10149[mesos] Don't allocate extra mesos port for TM unless configured to do so

asfgit closed pull request #7203: [FLINK-10149[mesos] Don't allocate extra mesos port for TM unless configured to do so URL: https://github.com/apache/flink/pull/7203 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the

[GitHub] kisimple opened a new pull request #7215: [hotfix][test][streaming] Fix invalid testNotSideOutputXXX in WindowOperatorTest

kisimple opened a new pull request #7215: [hotfix][test][streaming] Fix invalid testNotSideOutputXXX in WindowOperatorTest URL: https://github.com/apache/flink/pull/7215 `lateOutputTag` should not be `null` when testing side output.

[GitHub] tzanko-matev commented on issue #1668: [FLINK-3257] Add Exactly-Once Processing Guarantees for Iterative DataStream Jobs

tzanko-matev commented on issue #1668: [FLINK-3257] Add Exactly-Once Processing Guarantees for Iterative DataStream Jobs URL: https://github.com/apache/flink/pull/1668#issuecomment-443545153 Hi, are there any updates on this feature?

[jira] [Commented] (FLINK-3257) Add Exactly-Once Processing Guarantees in Iterative DataStream Jobs

[ https://issues.apache.org/jira/browse/FLINK-3257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16706487#comment-16706487 ] ASF GitHub Bot commented on FLINK-3257: --- tzanko-matev commented on issue #1668: [FLINK-3257] Add

[jira] [Updated] (FLINK-3257) Add Exactly-Once Processing Guarantees in Iterative DataStream Jobs

[ https://issues.apache.org/jira/browse/FLINK-3257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-3257: -- Labels: pull-request-available (was: ) > Add Exactly-Once Processing Guarantees in Iterative

[jira] [Closed] (FLINK-10149) Fink Mesos allocates extra port when not configured to do so.

[ https://issues.apache.org/jira/browse/FLINK-10149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-10149. Resolution: Fixed fixed via 1.8: 529288dfac1fb82b3c15d5acaeec2e54676a930d