[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology

eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology URL: https://github.com/apache/flink/pull/8446#discussion_r284523692 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adapt

[jira] [Commented] (FLINK-12523) "Kafka 0.11 end-to-end test" failed because it cannot find test-scripts

[ https://issues.apache.org/jira/browse/FLINK-12523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841031#comment-16841031 ] Chesnay Schepler commented on FLINK-12523: -- it failed because the download fail

[GitHub] [flink] R-CodeBoy commented on a change in pull request #8410: [FLINK-11159] Allow configuration whether to fall back to savepoints for restore

R-CodeBoy commented on a change in pull request #8410: [FLINK-11159] Allow configuration whether to fall back to savepoints for restore URL: https://github.com/apache/flink/pull/8410#discussion_r284556960 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint

[jira] [Commented] (FLINK-12422) Remove IN_TESTS for make test code and production code consistent

[ https://issues.apache.org/jira/browse/FLINK-12422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841030#comment-16841030 ] vinoyang commented on FLINK-12422: -- OK, Will remove them now. > Remove IN_TESTS for ma

[jira] [Commented] (FLINK-5621) Flink should provide a mechanism to prevent scheduling tasks on TaskManagers with operational issues

[ https://issues.apache.org/jira/browse/FLINK-5621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841028#comment-16841028 ] vinoyang commented on FLINK-5621: - Hi [~till.rohrmann] Can you tell me what's your opinio

[jira] [Commented] (FLINK-12422) Remove IN_TESTS for make test code and production code consistent

[ https://issues.apache.org/jira/browse/FLINK-12422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841027#comment-16841027 ] Jeff Zhang commented on FLINK-12422: That's correct.  > Remove IN_TESTS for make te

[jira] [Commented] (FLINK-12422) Remove IN_TESTS for make test code and production code consistent

[ https://issues.apache.org/jira/browse/FLINK-12422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841024#comment-16841024 ] vinoyang commented on FLINK-12422: -- [~zjffdu] whether my analysis is right or not? > R

[GitHub] [flink] dawidwys commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs

dawidwys commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs URL: https://github.com/apache/flink/pull/8404#discussion_r284554790 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/catal

[GitHub] [flink] dawidwys commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs

dawidwys commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs URL: https://github.com/apache/flink/pull/8404#discussion_r284554711 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/

[GitHub] [flink] yanghua commented on issue #8459: [FLINK-12476] [State TTL] Consider setting a default background cleanup strategy in StateTtlConfig

yanghua commented on issue #8459: [FLINK-12476] [State TTL] Consider setting a default background cleanup strategy in StateTtlConfig URL: https://github.com/apache/flink/pull/8459#issuecomment-492933495 @azagrebin Can you review this PR?

[GitHub] [flink] WeiZhong94 commented on issue #8401: [FLINK-12407][python] Add all table operators align Java Table API.

WeiZhong94 commented on issue #8401: [FLINK-12407][python] Add all table operators align Java Table API. URL: https://github.com/apache/flink/pull/8401#issuecomment-492933234 @sunjincheng121 Thank you for reminding! I have rebased my code and enabled the completeness tests. --

[jira] [Commented] (FLINK-11970) TableEnvironment#registerFunction should overwrite if the same name function existed.

[ https://issues.apache.org/jira/browse/FLINK-11970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841017#comment-16841017 ] vinoyang commented on FLINK-11970: -- [~zjffdu] I am waiting to listen to the opinion com

[GitHub] [flink] c4emmmm commented on a change in pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib

c4e commented on a change in pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib URL: https://github.com/apache/flink/pull/8402#discussion_r284551342 ## File path: flink-ml/pom.xml ## @@ -0,0 +1,39 @@ + + +http://maven.apache.org/POM/4.0.0

[jira] [Commented] (FLINK-11970) TableEnvironment#registerFunction should overwrite if the same name function existed.

[ https://issues.apache.org/jira/browse/FLINK-11970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841013#comment-16841013 ] Jeff Zhang commented on FLINK-11970: [~yanghua] Any update on this ticket ? > Table

[GitHub] [flink] c4emmmm commented on a change in pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib

c4e commented on a change in pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib URL: https://github.com/apache/flink/pull/8402#discussion_r284548973 ## File path: flink-ml/flink-ml-api/src/main/java/org/apache/flink/ml/util/persist/PipelineStageFa

[GitHub] [flink] JingsongLi closed pull request #8003: [FLINK-11951][table-common] Enhance UserDefinedFunction interface to allow more user defined types

JingsongLi closed pull request #8003: [FLINK-11951][table-common] Enhance UserDefinedFunction interface to allow more user defined types URL: https://github.com/apache/flink/pull/8003 This is an automated message from the Ap

[GitHub] [flink] JingsongLi commented on issue #8397: [FLINK-11421][Table SQL/Runtime]Add compilation options to allow comp…

JingsongLi commented on issue #8397: [FLINK-11421][Table SQL/Runtime]Add compilation options to allow comp… URL: https://github.com/apache/flink/pull/8397#issuecomment-492924721 @liyafan82 The benchmarks results were exciting. Can you use CodeGen's code to build some local benchmarks? Y

[GitHub] [flink] asfgit closed pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

asfgit closed pull request #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime URL: https://github.com/apache/flink/pull/8244 This is an automated message from the Apache Git Servi

[jira] [Updated] (FLINK-12525) Impose invariant StreamExecutionEnvironment.setBufferTimeout > 0

[ https://issues.apache.org/jira/browse/FLINK-12525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Stoll updated FLINK-12525: - Description: The documentation for the [DataStream API|https://github.com/apache/flink/blob/867

[jira] [Created] (FLINK-12525) Impose invariant StreamExecutionEnvironment.setBufferTimeout > 0

Robert Stoll created FLINK-12525: Summary: Impose invariant StreamExecutionEnvironment.setBufferTimeout > 0 Key: FLINK-12525 URL: https://issues.apache.org/jira/browse/FLINK-12525 Project: Flink

[jira] [Closed] (FLINK-11945) Support over aggregation for blink streaming runtime

[ https://issues.apache.org/jira/browse/FLINK-11945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-11945. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in 1.9.0: e6bbc09e6999c08ae087559c365f94d2c1f38efa > Su

[GitHub] [flink] kisimple commented on issue #7757: [FLINK-11630] Triggers the termination of all running Tasks when shutting down TaskExecutor

kisimple commented on issue #7757: [FLINK-11630] Triggers the termination of all running Tasks when shutting down TaskExecutor URL: https://github.com/apache/flink/pull/7757#issuecomment-492920238 @azagrebin I have triggered another build, [it passed](https://travis-ci.org/kisimple/flink/b

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8420: [FLINK-12408][python] Allow to define the data types in Python

sunjincheng121 commented on a change in pull request #8420: [FLINK-12408][python] Allow to define the data types in Python URL: https://github.com/apache/flink/pull/8420#discussion_r284531707 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/api/Ty

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8420: [FLINK-12408][python] Allow to define the data types in Python

sunjincheng121 commented on a change in pull request #8420: [FLINK-12408][python] Allow to define the data types in Python URL: https://github.com/apache/flink/pull/8420#discussion_r284533178 ## File path: flink-python/pyflink/table/types.py ## @@ -15,172 +15,1803 @@ # S

[GitHub] [flink] liyafan82 edited a comment on issue #8397: [FLINK-11421][Table SQL/Runtime]Add compilation options to allow comp…

liyafan82 edited a comment on issue #8397: [FLINK-11421][Table SQL/Runtime]Add compilation options to allow comp… URL: https://github.com/apache/flink/pull/8397#issuecomment-492914042 > Hi @liyafan82 Thank for your nice works~ I think I have a clearer understanding now. > I think your b

[GitHub] [flink] liyafan82 edited a comment on issue #8397: [FLINK-11421][Table SQL/Runtime]Add compilation options to allow comp…

liyafan82 edited a comment on issue #8397: [FLINK-11421][Table SQL/Runtime]Add compilation options to allow comp… URL: https://github.com/apache/flink/pull/8397#issuecomment-492914042 > Hi @liyafan82 Thank for your nice works~ I think I have a clearer understanding now. > I think your b

[GitHub] [flink] liyafan82 edited a comment on issue #8397: [FLINK-11421][Table SQL/Runtime]Add compilation options to allow comp…

liyafan82 edited a comment on issue #8397: [FLINK-11421][Table SQL/Runtime]Add compilation options to allow comp… URL: https://github.com/apache/flink/pull/8397#issuecomment-492914042 > Hi @liyafan82 Thank for your nice works~ I think I have a clearer understanding now. > I think your b

[GitHub] [flink] liyafan82 edited a comment on issue #8397: [FLINK-11421][Table SQL/Runtime]Add compilation options to allow comp…

liyafan82 edited a comment on issue #8397: [FLINK-11421][Table SQL/Runtime]Add compilation options to allow comp… URL: https://github.com/apache/flink/pull/8397#issuecomment-492914042 > Hi @liyafan82 Thank for your nice works~ I think I have a clearer understanding now. > I think your b

[GitHub] [flink] liyafan82 commented on issue #8397: [FLINK-11421][Table SQL/Runtime]Add compilation options to allow comp…

liyafan82 commented on issue #8397: [FLINK-11421][Table SQL/Runtime]Add compilation options to allow comp… URL: https://github.com/apache/flink/pull/8397#issuecomment-492914042 > Hi @liyafan82 Thank for your nice works~ I think I have a clearer understanding now. > I think your benchmar

[GitHub] [flink] JingsongLi commented on a change in pull request #8435: [FLINK-12443][table-planner-blink] Replace InternalType with LogicalType in blink

JingsongLi commented on a change in pull request #8435: [FLINK-12443][table-planner-blink] Replace InternalType with LogicalType in blink URL: https://github.com/apache/flink/pull/8435#discussion_r284531614 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apac

[GitHub] [flink] flinkbot commented on issue #8460: [FLINK-12524] [table-planner-blink] Introduce planner rules about rank

flinkbot commented on issue #8460: [FLINK-12524] [table-planner-blink] Introduce planner rules about rank URL: https://github.com/apache/flink/pull/8460#issuecomment-492906839 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to revi

[GitHub] [flink] godfreyhe opened a new pull request #8460: [FLINK-12524] [table-planner-blink] Introduce planner rules about rank

godfreyhe opened a new pull request #8460: [FLINK-12524] [table-planner-blink] Introduce planner rules about rank URL: https://github.com/apache/flink/pull/8460 ## What is the purpose of the change *Introduce planner rules about rank* ## Brief change log -

[jira] [Updated] (FLINK-12524) Introduce planner rules about rank

[ https://issues.apache.org/jira/browse/FLINK-12524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12524: --- Labels: pull-request-available (was: ) > Introduce planner rules about rank > -

[GitHub] [flink] sunjincheng121 commented on issue #8401: [FLINK-12407][python] Add all table operators align Java Table API.

sunjincheng121 commented on issue #8401: [FLINK-12407][python] Add all table operators align Java Table API. URL: https://github.com/apache/flink/pull/8401#issuecomment-492906499 Thanks for the update @WeiZhong94! I have added the API align check test, So please rebase the code, an open

[GitHub] [flink] wuchong commented on a change in pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib

wuchong commented on a change in pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib URL: https://github.com/apache/flink/pull/8402#discussion_r284530462 ## File path: flink-ml/flink-ml-api/src/main/java/org/apache/flink/ml/api/misc/persist/Persistable

[GitHub] [flink] flinkbot commented on issue #8459: [FLINK-12476] [State TTL] Consider setting a default background cleanup strategy in StateTtlConfig

flinkbot commented on issue #8459: [FLINK-12476] [State TTL] Consider setting a default background cleanup strategy in StateTtlConfig URL: https://github.com/apache/flink/pull/8459#issuecomment-492904258 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I h

[jira] [Updated] (FLINK-12476) [State TTL] Consider setting a default background cleanup strategy in StateTtlConfig

[ https://issues.apache.org/jira/browse/FLINK-12476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12476: --- Labels: pull-request-available (was: ) > [State TTL] Consider setting a default background

[GitHub] [flink] yanghua opened a new pull request #8459: [FLINK-12476] [State TTL] Consider setting a default background cleanup strategy in StateTtlConfig

yanghua opened a new pull request #8459: [FLINK-12476] [State TTL] Consider setting a default background cleanup strategy in StateTtlConfig URL: https://github.com/apache/flink/pull/8459 ## What is the purpose of the change *This pull request sets a default background cleanup strateg

[jira] [Created] (FLINK-12524) Introduce planner rules about rank

godfrey he created FLINK-12524: -- Summary: Introduce planner rules about rank Key: FLINK-12524 URL: https://issues.apache.org/jira/browse/FLINK-12524 Project: Flink Issue Type: New Feature

[GitHub] [flink] c4emmmm commented on a change in pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib

c4e commented on a change in pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib URL: https://github.com/apache/flink/pull/8402#discussion_r284527522 ## File path: flink-ml/flink-ml-api/src/main/java/org/apache/flink/ml/api/misc/persist/Persistable

[GitHub] [flink] wuchong commented on issue #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

wuchong commented on issue #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime URL: https://github.com/apache/flink/pull/8244#issuecomment-492901867 Thanks for the reviewing @KurtYoung and the contribution @XuQianJin-Stars . I will fix th

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology

eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology URL: https://github.com/apache/flink/pull/8446#discussion_r284526200 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adapt

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology

eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology URL: https://github.com/apache/flink/pull/8446#discussion_r284526116 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adapt

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology

eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology URL: https://github.com/apache/flink/pull/8446#discussion_r284525505 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adapt

[GitHub] [flink] lirui-apache commented on issue #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog

lirui-apache commented on issue #8449: [FLINK-12235][hive] Support partition related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8449#issuecomment-492900380 @xuefuz @bowenli86 please take a look. Thanks. --

[GitHub] [flink] wuchong commented on a change in pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib

wuchong commented on a change in pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib URL: https://github.com/apache/flink/pull/8402#discussion_r284518880 ## File path: flink-ml/flink-ml-api/src/main/java/org/apache/flink/ml/api/misc/persist/Persistable

[GitHub] [flink] wuchong commented on a change in pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib

wuchong commented on a change in pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib URL: https://github.com/apache/flink/pull/8402#discussion_r284520281 ## File path: flink-ml/flink-ml-api/src/main/java/org/apache/flink/ml/util/persist/PipelineStageFa

[GitHub] [flink] wuchong commented on a change in pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib

wuchong commented on a change in pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib URL: https://github.com/apache/flink/pull/8402#discussion_r284519816 ## File path: flink-ml/pom.xml ## @@ -0,0 +1,39 @@ + + +http://maven.apache.org/POM/4.0.0

[GitHub] [flink] wuchong commented on a change in pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib

wuchong commented on a change in pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib URL: https://github.com/apache/flink/pull/8402#discussion_r284522966 ## File path: flink-ml/flink-ml-api/pom.xml ## @@ -0,0 +1,45 @@ + + +http://maven.apache.

[GitHub] [flink] wuchong commented on a change in pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib

wuchong commented on a change in pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib URL: https://github.com/apache/flink/pull/8402#discussion_r284518880 ## File path: flink-ml/flink-ml-api/src/main/java/org/apache/flink/ml/api/misc/persist/Persistable

[jira] [Commented] (FLINK-12413) Implement ExecutionFailureHandler

[ https://issues.apache.org/jira/browse/FLINK-12413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16840949#comment-16840949 ] Zhu Zhu commented on FLINK-12413: - I think the restart attempt number might not be enoug

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology

eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology URL: https://github.com/apache/flink/pull/8446#discussion_r284523778 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adapt

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology

eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology URL: https://github.com/apache/flink/pull/8446#discussion_r284523820 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strat

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology

eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology URL: https://github.com/apache/flink/pull/8446#discussion_r284523692 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adapt

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology

eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology URL: https://github.com/apache/flink/pull/8446#discussion_r284523017 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adapt

[jira] [Comment Edited] (FLINK-12372) Implement ExecutionSlotAllocator

[ https://issues.apache.org/jira/browse/FLINK-12372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16840166#comment-16840166 ] shuai.xu edited comment on FLINK-12372 at 5/16/19 2:56 AM: --- Hi

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology

eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology URL: https://github.com/apache/flink/pull/8446#discussion_r284522801 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adapt

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology

eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology URL: https://github.com/apache/flink/pull/8446#discussion_r284522721 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adapt

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology

eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology URL: https://github.com/apache/flink/pull/8446#discussion_r284522579 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adapt

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology

eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology URL: https://github.com/apache/flink/pull/8446#discussion_r284522063 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adapt

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology

eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology URL: https://github.com/apache/flink/pull/8446#discussion_r284520251 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adapt

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology

eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology URL: https://github.com/apache/flink/pull/8446#discussion_r284520251 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adapt

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology

eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology URL: https://github.com/apache/flink/pull/8446#discussion_r284520206 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adapt

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology

eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology URL: https://github.com/apache/flink/pull/8446#discussion_r284519545 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adapt

[jira] [Updated] (FLINK-12362) Remove container number config option for Flink on yarn job cluster mode

[ https://issues.apache.org/jira/browse/FLINK-12362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-12362: - Issue Type: Improvement (was: Bug) > Remove container number config option for Flink on yarn job cluste

[jira] [Commented] (FLINK-12494) JDBCOutputFormat support reconnect when link failure and flush by timeInterval

[ https://issues.apache.org/jira/browse/FLINK-12494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16840929#comment-16840929 ] Quan Shi commented on FLINK-12494: -- Using user define JDBC sink function also has the s

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology

eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology URL: https://github.com/apache/flink/pull/8446#discussion_r284517572 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adapt

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology

eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology URL: https://github.com/apache/flink/pull/8446#discussion_r284517550 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adapt

[jira] [Commented] (FLINK-11561) Translate "Flink Architecture" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16840919#comment-16840919 ] Tom Goong commented on FLINK-11561: --- [~jark] sorry, Can not be separated recently, it'

[jira] [Assigned] (FLINK-11634) Translate "State Backends" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tom Goong reassigned FLINK-11634: - Assignee: (was: Tom Goong) > Translate "State Backends" page into Chinese > ---

[jira] [Assigned] (FLINK-11637) Translate "Checkpoints" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tom Goong reassigned FLINK-11637: - Assignee: (was: Tom Goong) > Translate "Checkpoints" page into Chinese > --

[GitHub] [flink] flinkbot edited a comment on issue #8321: [FLINK-12351][DataStream] Fix AsyncWaitOperator to deep copy StreamElement when object reuse is enabled

flinkbot edited a comment on issue #8321: [FLINK-12351][DataStream] Fix AsyncWaitOperator to deep copy StreamElement when object reuse is enabled URL: https://github.com/apache/flink/pull/8321#issuecomment-487935686 Thanks a lot for your contribution to the Apache Flink project. I'm the @f

[GitHub] [flink] wuchong commented on issue #8321: [FLINK-12351][DataStream] Fix AsyncWaitOperator to deep copy StreamElement when object reuse is enabled

wuchong commented on issue #8321: [FLINK-12351][DataStream] Fix AsyncWaitOperator to deep copy StreamElement when object reuse is enabled URL: https://github.com/apache/flink/pull/8321#issuecomment-492885480 @flinkbot attention @tillrohrmann ---

[jira] [Commented] (FLINK-11561) Translate "Flink Architecture" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16840910#comment-16840910 ] Jark Wu commented on FLINK-11561: - Hi [~Tom Goong], do you still have time to translate

[GitHub] [flink] yanghua commented on issue #8322: [FLINK-12364] Introduce a CheckpointFailureManager to centralized manage checkpoint failure

yanghua commented on issue #8322: [FLINK-12364] Introduce a CheckpointFailureManager to centralized manage checkpoint failure URL: https://github.com/apache/flink/pull/8322#issuecomment-492885118 Now, it seems Travis's failure is not related to this PR.

[GitHub] [flink] danny0405 commented on a change in pull request #8324: [FLINK-11921][table] Upgrade to calcite 1.19

danny0405 commented on a change in pull request #8324: [FLINK-11921][table] Upgrade to calcite 1.19 URL: https://github.com/apache/flink/pull/8324#discussion_r284510849 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/calcite/avatica/util/DateTimeUtils.java #

[GitHub] [flink] danny0405 commented on a change in pull request #8324: [FLINK-11921][table] Upgrade to calcite 1.19

danny0405 commented on a change in pull request #8324: [FLINK-11921][table] Upgrade to calcite 1.19 URL: https://github.com/apache/flink/pull/8324#discussion_r284511058 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/calcite/avatica/util/DateTimeUtils.java #

[GitHub] [flink] danny0405 commented on a change in pull request #8324: [FLINK-11921][table] Upgrade to calcite 1.19

danny0405 commented on a change in pull request #8324: [FLINK-11921][table] Upgrade to calcite 1.19 URL: https://github.com/apache/flink/pull/8324#discussion_r284510849 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/calcite/avatica/util/DateTimeUtils.java #

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

[ https://issues.apache.org/jira/browse/FLINK-11010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken closed FLINK-11010. -- Resolution: Won't Fix > Flink SQL timestamp is inconsistent with currentProcessingTime() > ---

[GitHub] [flink] lamber-ken closed pull request #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime()

lamber-ken closed pull request #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime() URL: https://github.com/apache/flink/pull/7180 This is an automated message from the Apache Git Ser

[GitHub] [flink] asfgit closed pull request #8457: [FLINK-12511][table][hive] make variable 'comment' in all catalog metadata classes final

asfgit closed pull request #8457: [FLINK-12511][table][hive] make variable 'comment' in all catalog metadata classes final URL: https://github.com/apache/flink/pull/8457 This is an automated message from the Apache Git Servi

[jira] [Closed] (FLINK-12511) make variable "comment" in all catalog metadata classes final

[ https://issues.apache.org/jira/browse/FLINK-12511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-12511. Resolution: Fixed merged in 1.9.0: 2b2c0641c107afa4f3e35908e64368fa95e61fc9 > make variable "comment" in

[GitHub] [flink] bowenli86 commented on issue #8457: [FLINK-12511][table][hive] make variable 'comment' in all catalog metadata classes final

bowenli86 commented on issue #8457: [FLINK-12511][table][hive] make variable 'comment' in all catalog metadata classes final URL: https://github.com/apache/flink/pull/8457#issuecomment-492865383 merging... This is an automate

[GitHub] [flink] bowenli86 commented on a change in pull request #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type

bowenli86 commented on a change in pull request #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type URL: https://github.com/apache/flink/pull/8458#discussion_r284489117 ## File path: flink-connectors/flink-connector

[GitHub] [flink] bowenli86 commented on a change in pull request #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type

bowenli86 commented on a change in pull request #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type URL: https://github.com/apache/flink/pull/8458#discussion_r284485777 ## File path: flink-connectors/flink-connector

[GitHub] [flink] bowenli86 commented on a change in pull request #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type

bowenli86 commented on a change in pull request #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type URL: https://github.com/apache/flink/pull/8458#discussion_r284485777 ## File path: flink-connectors/flink-connector

[GitHub] [flink] bowenli86 commented on a change in pull request #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type

bowenli86 commented on a change in pull request #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type URL: https://github.com/apache/flink/pull/8458#discussion_r284488385 ## File path: flink-table/flink-table-api-java

[GitHub] [flink] bowenli86 commented on a change in pull request #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type

bowenli86 commented on a change in pull request #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type URL: https://github.com/apache/flink/pull/8458#discussion_r284488368 ## File path: flink-table/flink-table-api-java

[GitHub] [flink] asfgit closed pull request #8456: [FLINK-12436][hive] Differentiate Flink database properties from Hive database properties

asfgit closed pull request #8456: [FLINK-12436][hive] Differentiate Flink database properties from Hive database properties URL: https://github.com/apache/flink/pull/8456 This is an automated message from the Apache Git Serv

[jira] [Closed] (FLINK-12436) Differentiate Flink database properties from Hive database properties

[ https://issues.apache.org/jira/browse/FLINK-12436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-12436. Resolution: Fixed merged in 1.9.0: 83324ec7df34f87dd95309a82da470ea7a35d1da > Differentiate Flink databas

[GitHub] [flink] xuefuz commented on a change in pull request #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type

xuefuz commented on a change in pull request #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type URL: https://github.com/apache/flink/pull/8458#discussion_r284478663 ## File path: flink-table/flink-table-api-java/sr

[GitHub] [flink] xuefuz commented on a change in pull request #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type

xuefuz commented on a change in pull request #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type URL: https://github.com/apache/flink/pull/8458#discussion_r284478663 ## File path: flink-table/flink-table-api-java/sr

[GitHub] [flink] xuefuz commented on a change in pull request #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type

xuefuz commented on a change in pull request #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type URL: https://github.com/apache/flink/pull/8458#discussion_r284478411 ## File path: flink-table/flink-table-api-java/sr

[GitHub] [flink] xuefuz commented on a change in pull request #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type

xuefuz commented on a change in pull request #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type URL: https://github.com/apache/flink/pull/8458#discussion_r284477579 ## File path: flink-connectors/flink-connector-hi

[jira] [Created] (FLINK-12523) "Kafka 0.11 end-to-end test" failed because it cannot find test-scripts

Bowen Li created FLINK-12523: Summary: "Kafka 0.11 end-to-end test" failed because it cannot find test-scripts Key: FLINK-12523 URL: https://issues.apache.org/jira/browse/FLINK-12523 Project: Flink

[GitHub] [flink] xuefuz commented on a change in pull request #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type

xuefuz commented on a change in pull request #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type URL: https://github.com/apache/flink/pull/8458#discussion_r284477298 ## File path: flink-connectors/flink-connector-hi

[GitHub] [flink] xuefuz commented on a change in pull request #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type

xuefuz commented on a change in pull request #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type URL: https://github.com/apache/flink/pull/8458#discussion_r284477042 ## File path: flink-connectors/flink-connector-hi

[GitHub] [flink] xuefuz commented on a change in pull request #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type

xuefuz commented on a change in pull request #8458: [FLINK-12452][table][hive] alterTable() should ensure existing base table and the new one are of the same type URL: https://github.com/apache/flink/pull/8458#discussion_r284474839 ## File path: flink-connectors/flink-connector-hi

[jira] [Commented] (FLINK-12522) Error While Initializing S3A FileSystem

[ https://issues.apache.org/jira/browse/FLINK-12522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16840816#comment-16840816 ] Manish Bellani commented on FLINK-12522: Thanks Ken, will do. > Error While Ini

[jira] [Commented] (FLINK-12522) Error While Initializing S3A FileSystem

[ https://issues.apache.org/jira/browse/FLINK-12522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16840806#comment-16840806 ] Ken Krugler commented on FLINK-12522: - Hi Manish Bellani - please post to the Flink

  1   2   3   4   >