[GitHub] [flink] zhuzhurk commented on a change in pull request #10082: [FLINK-14164][runtime] Add a counter ‘numberOfRestarts’ to show number of restarts

zhuzhurk commented on a change in pull request #10082: [FLINK-14164][runtime] Add a counter ‘numberOfRestarts’ to show number of restarts URL: https://github.com/apache/flink/pull/10082#discussion_r343515851 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/schedul

[GitHub] [flink] wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#discussion_r343516296 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache

[GitHub] [flink] wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#discussion_r343516557 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache

[GitHub] [flink] wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#discussion_r343516837 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache

[GitHub] [flink] JingsongLi commented on issue #9433: [FLINK-13708] [table-planner-blink] transformations should be cleared after execution in blink planner

JingsongLi commented on issue #9433: [FLINK-13708] [table-planner-blink] transformations should be cleared after execution in blink planner URL: https://github.com/apache/flink/pull/9433#issuecomment-550970032 > when/what/why is buffered? I will list from my understanding: > > 1. ope

[GitHub] [flink] flinkbot edited a comment on issue #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator

flinkbot edited a comment on issue #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator URL: https://github.com/apache/flink/pull/9516#issuecomment-524185347 ## CI report: * bde14e569d1d3c7ada5054bcf1acea1c8b41bc2d : FAILURE [Build](https://travis-ci.com/flink-ci/fl

[GitHub] [flink] wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#discussion_r343519642 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache

[GitHub] [flink] flinkbot edited a comment on issue #10039: [FLINK-14262][table] Support referencing function with fully/partially qualified names in SQL

flinkbot edited a comment on issue #10039: [FLINK-14262][table] Support referencing function with fully/partially qualified names in SQL URL: https://github.com/apache/flink/pull/10039#issuecomment-547774074 ## CI report: * 5539c384788ae03243a246a891d1700e2f0be719 : FAILURE [Bu

[GitHub] [flink] flinkbot edited a comment on issue #9801: [FLINK-13983][runtime] Launch task executor with new memory calculation logics

flinkbot edited a comment on issue #9801: [FLINK-13983][runtime] Launch task executor with new memory calculation logics URL: https://github.com/apache/flink/pull/9801#issuecomment-536259410 ## CI report: * 3ea28aa2186b964a7405fbd1367186db8e143836 : SUCCESS [Build](https://travi

[GitHub] [flink] flinkbot edited a comment on issue #10082: [FLINK-14164][runtime] Add a counter ‘numberOfRestarts’ to show number of restarts

flinkbot edited a comment on issue #10082: [FLINK-14164][runtime] Add a counter ‘numberOfRestarts’ to show number of restarts URL: https://github.com/apache/flink/pull/10082#issuecomment-549698167 ## CI report: * 9ad21545cdce68c8892941e8f33a89147bddb1f6 : SUCCESS [Build](https:/

[GitHub] [flink] flinkbot edited a comment on issue #10112: [FLINK-14640] Change Type of Field currentExecutions from ConcurrentHashMap to HashMap

flinkbot edited a comment on issue #10112: [FLINK-14640] Change Type of Field currentExecutions from ConcurrentHashMap to HashMap URL: https://github.com/apache/flink/pull/10112#issuecomment-550964937 ## CI report: * 13118777453ff58976b17b9aa1b7a4590ce86d5c : PENDING [Build](htt

[GitHub] [flink] flinkbot commented on issue #10113: [FLINK-13749][client] Make PackagedProgram respect classloading policy

flinkbot commented on issue #10113: [FLINK-13749][client] Make PackagedProgram respect classloading policy URL: https://github.com/apache/flink/pull/10113#issuecomment-550973543 ## CI report: * fd65bc500b5539da9560f364ab6e8b1b71b2c1a8 : UNKNOWN Bot commands The @f

[GitHub] [flink] wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#discussion_r343522162 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache

[GitHub] [flink] wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#discussion_r343522517 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache

[GitHub] [flink] wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#discussion_r343524388 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache

[jira] [Commented] (FLINK-14433) Move generated Jaas conf file from /tmp directory to Job specific directory

[ https://issues.apache.org/jira/browse/FLINK-14433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16969033#comment-16969033 ] Congxian Qiu(klion26) commented on FLINK-14433: --- Since you introduced/modi

[jira] [Comment Edited] (FLINK-14433) Move generated Jaas conf file from /tmp directory to Job specific directory

[ https://issues.apache.org/jira/browse/FLINK-14433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16969033#comment-16969033 ] Congxian Qiu(klion26) edited comment on FLINK-14433 at 11/7/19 8:27 AM: --

[GitHub] [flink] GJL commented on a change in pull request #10082: [FLINK-14164][runtime] Add a counter ‘numberOfRestarts’ to show number of restarts

GJL commented on a change in pull request #10082: [FLINK-14164][runtime] Add a counter ‘numberOfRestarts’ to show number of restarts URL: https://github.com/apache/flink/pull/10082#discussion_r343526368 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/Sc

[GitHub] [flink] GJL commented on a change in pull request #10082: [FLINK-14164][runtime] Add a counter ‘numberOfRestarts’ to show number of restarts

GJL commented on a change in pull request #10082: [FLINK-14164][runtime] Add a counter ‘numberOfRestarts’ to show number of restarts URL: https://github.com/apache/flink/pull/10082#discussion_r343526447 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongra

[GitHub] [flink] wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#discussion_r343526852 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache

[GitHub] [flink] KurtYoung commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

KurtYoung commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#discussion_r343528277 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apac

[GitHub] [flink] wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#discussion_r343528827 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/

[GitHub] [flink] flinkbot edited a comment on issue #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator

flinkbot edited a comment on issue #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator URL: https://github.com/apache/flink/pull/9516#issuecomment-524185347 ## CI report: * bde14e569d1d3c7ada5054bcf1acea1c8b41bc2d : FAILURE [Build](https://travis-ci.com/flink-ci/fl

[GitHub] [flink] flinkbot edited a comment on issue #9801: [FLINK-13983][runtime] Launch task executor with new memory calculation logics

flinkbot edited a comment on issue #9801: [FLINK-13983][runtime] Launch task executor with new memory calculation logics URL: https://github.com/apache/flink/pull/9801#issuecomment-536259410 ## CI report: * 3ea28aa2186b964a7405fbd1367186db8e143836 : SUCCESS [Build](https://travi

[GitHub] [flink] GJL commented on a change in pull request #10082: [FLINK-14164][runtime] Add a counter ‘numberOfRestarts’ to show number of restarts

GJL commented on a change in pull request #10082: [FLINK-14164][runtime] Add a counter ‘numberOfRestarts’ to show number of restarts URL: https://github.com/apache/flink/pull/10082#discussion_r343530922 ## File path: docs/monitoring/metrics.md ## @@ -1276,9 +1276,17 @@ Met

[GitHub] [flink] pnowojski commented on a change in pull request #9885: [FLINK-14344][checkpointing] A preparation for snapshotting master hook state asynchronously

pnowojski commented on a change in pull request #9885: [FLINK-14344][checkpointing] A preparation for snapshotting master hook state asynchronously URL: https://github.com/apache/flink/pull/9885#discussion_r343529308 ## File path: flink-runtime/src/main/java/org/apache/flink/runti

[GitHub] [flink] pnowojski commented on a change in pull request #9885: [FLINK-14344][checkpointing] A preparation for snapshotting master hook state asynchronously

pnowojski commented on a change in pull request #9885: [FLINK-14344][checkpointing] A preparation for snapshotting master hook state asynchronously URL: https://github.com/apache/flink/pull/9885#discussion_r343530956 ## File path: flink-runtime/src/main/java/org/apache/flink/runti

[GitHub] [flink] flinkbot edited a comment on issue #10106: [FLINK-11463][e2e] Design the e2e java framework so that at least the Kafka streaming tests can run on it

flinkbot edited a comment on issue #10106: [FLINK-11463][e2e] Design the e2e java framework so that at least the Kafka streaming tests can run on it URL: https://github.com/apache/flink/pull/10106#issuecomment-550309075 ## CI report: * 9817ef9c8be75fd02ccef3825e706497f3e6c1b6 : S

[GitHub] [flink] wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#discussion_r343532832 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache

[GitHub] [flink] flinkbot edited a comment on issue #10113: [FLINK-13749][client] Make PackagedProgram respect classloading policy

flinkbot edited a comment on issue #10113: [FLINK-13749][client] Make PackagedProgram respect classloading policy URL: https://github.com/apache/flink/pull/10113#issuecomment-550973543 ## CI report: * fd65bc500b5539da9560f364ab6e8b1b71b2c1a8 : PENDING [Build](https://travis-ci.c

[GitHub] [flink] link3280 commented on issue #10113: [FLINK-13749][client] Make PackagedProgram respect classloading policy

link3280 commented on issue #10113: [FLINK-13749][client] Make PackagedProgram respect classloading policy URL: https://github.com/apache/flink/pull/10113#issuecomment-550983227 cc @TisonKun This is an automated message from

[GitHub] [flink] yanghua commented on issue #10112: [FLINK-14640] Change Type of Field currentExecutions from ConcurrentHashMap to HashMap

yanghua commented on issue #10112: [FLINK-14640] Change Type of Field currentExecutions from ConcurrentHashMap to HashMap URL: https://github.com/apache/flink/pull/10112#issuecomment-550984397 cc @GJL This is an automated me

[GitHub] [flink] zhuzhurk commented on a change in pull request #10082: [FLINK-14164][runtime] Add a counter ‘numberOfRestarts’ to show number of restarts

zhuzhurk commented on a change in pull request #10082: [FLINK-14164][runtime] Add a counter ‘numberOfRestarts’ to show number of restarts URL: https://github.com/apache/flink/pull/10082#discussion_r343536568 ## File path: docs/monitoring/metrics.md ## @@ -1276,9 +1276,17 @

[GitHub] [flink] pnowojski commented on a change in pull request #10009: [FLINK-14304] Avoid task starvation with mailbox

pnowojski commented on a change in pull request #10009: [FLINK-14304] Avoid task starvation with mailbox URL: https://github.com/apache/flink/pull/10009#discussion_r343536096 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/MailboxOperat

[jira] [Assigned] (FLINK-13846) Implement benchmark case on MapState#isEmpty

[ https://issues.apache.org/jira/browse/FLINK-13846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-13846: -- Assignee: Yun Tang > Implement benchmark case on MapState#isEmpty > -

[jira] [Commented] (FLINK-13846) Implement benchmark case on MapState#isEmpty

[ https://issues.apache.org/jira/browse/FLINK-13846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16969058#comment-16969058 ] Piotr Nowojski commented on FLINK-13846: Done. site note, I think the benchmar

[GitHub] [flink] WeiZhong94 commented on a change in pull request #10061: [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs

WeiZhong94 commented on a change in pull request #10061: [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs on yarn. URL: https://github.com/apache/flink/pull/10061#discussion_r343538840 ## File path: flink

[GitHub] [flink] danny0405 commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

danny0405 commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#discussion_r343539652 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apac

[GitHub] [flink] WeiZhong94 commented on a change in pull request #10061: [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs

WeiZhong94 commented on a change in pull request #10061: [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs on yarn. URL: https://github.com/apache/flink/pull/10061#discussion_r343540345 ## File path: flink

[GitHub] [flink] dawidwys commented on issue #10110: [FLINK-14301][doc] add documentation for functions categories and new function resolution orders

dawidwys commented on issue #10110: [FLINK-14301][doc] add documentation for functions categories and new function resolution orders URL: https://github.com/apache/flink/pull/10110#issuecomment-550988838 @flinkbot attention @fhueske @sjwiesman -

[GitHub] [flink] danny0405 commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

danny0405 commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#discussion_r343540237 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apach

[GitHub] [flink] WeiZhong94 commented on issue #10061: [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs on yarn.

WeiZhong94 commented on issue #10061: [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs on yarn. URL: https://github.com/apache/flink/pull/10061#issuecomment-550989184 @hequn8128 Thanks for your review! I have addr

[GitHub] [flink] flinkbot edited a comment on issue #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator

flinkbot edited a comment on issue #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator URL: https://github.com/apache/flink/pull/9516#issuecomment-524185347 ## CI report: * bde14e569d1d3c7ada5054bcf1acea1c8b41bc2d : FAILURE [Build](https://travis-ci.com/flink-ci/fl

[GitHub] [flink] flinkbot edited a comment on issue #10039: [FLINK-14262][table] Support referencing function with fully/partially qualified names in SQL

flinkbot edited a comment on issue #10039: [FLINK-14262][table] Support referencing function with fully/partially qualified names in SQL URL: https://github.com/apache/flink/pull/10039#issuecomment-547774074 ## CI report: * 5539c384788ae03243a246a891d1700e2f0be719 : FAILURE [Bu

[GitHub] [flink] flinkbot edited a comment on issue #10061: [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs on yarn.

flinkbot edited a comment on issue #10061: [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs on yarn. URL: https://github.com/apache/flink/pull/10061#issuecomment-548335375 ## CI report: * 6f081dffc4e0da

[GitHub] [flink] flinkbot edited a comment on issue #9801: [FLINK-13983][runtime] Launch task executor with new memory calculation logics

flinkbot edited a comment on issue #9801: [FLINK-13983][runtime] Launch task executor with new memory calculation logics URL: https://github.com/apache/flink/pull/9801#issuecomment-536259410 ## CI report: * 3ea28aa2186b964a7405fbd1367186db8e143836 : SUCCESS [Build](https://travi

[GitHub] [flink] dawidwys commented on a change in pull request #10039: [FLINK-14262][table] Support referencing function with fully/partially qualified names in SQL

dawidwys commented on a change in pull request #10039: [FLINK-14262][table] Support referencing function with fully/partially qualified names in SQL URL: https://github.com/apache/flink/pull/10039#discussion_r343542036 ## File path: flink-table/flink-table-planner-blink/src/main/j

[GitHub] [flink] dawidwys commented on a change in pull request #10039: [FLINK-14262][table] Support referencing function with fully/partially qualified names in SQL

dawidwys commented on a change in pull request #10039: [FLINK-14262][table] Support referencing function with fully/partially qualified names in SQL URL: https://github.com/apache/flink/pull/10039#discussion_r343542386 ## File path: flink-table/flink-table-planner-blink/src/main/j

[GitHub] [flink] flinkbot edited a comment on issue #10082: [FLINK-14164][runtime] Add a counter ‘numberOfRestarts’ to show number of restarts

flinkbot edited a comment on issue #10082: [FLINK-14164][runtime] Add a counter ‘numberOfRestarts’ to show number of restarts URL: https://github.com/apache/flink/pull/10082#issuecomment-549698167 ## CI report: * 9ad21545cdce68c8892941e8f33a89147bddb1f6 : SUCCESS [Build](https:/

[jira] [Created] (FLINK-14651) Set default value of config option jobmanager.scheduler to "ng"

Gary Yao created FLINK-14651: Summary: Set default value of config option jobmanager.scheduler to "ng" Key: FLINK-14651 URL: https://issues.apache.org/jira/browse/FLINK-14651 Project: Flink Issu

[jira] [Updated] (FLINK-14651) Set default value of config option jobmanager.scheduler to "ng"

[ https://issues.apache.org/jira/browse/FLINK-14651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-14651: - Description: Config option {{jobmanager.scheduler}} should be set to {{"ng"}} by default so that the new

[GitHub] [flink] flinkbot edited a comment on issue #10112: [FLINK-14640] Change Type of Field currentExecutions from ConcurrentHashMap to HashMap

flinkbot edited a comment on issue #10112: [FLINK-14640] Change Type of Field currentExecutions from ConcurrentHashMap to HashMap URL: https://github.com/apache/flink/pull/10112#issuecomment-550964937 ## CI report: * 13118777453ff58976b17b9aa1b7a4590ce86d5c : FAILURE [Build](htt

[GitHub] [flink] KurtYoung commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

KurtYoung commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r343535345 ## File path: flink-table/flink-table-planner-blink/src/main/scala/o

[jira] [Commented] (FLINK-14374) Enable RegionFailoverITCase to pass with scheduler NG

[ https://issues.apache.org/jira/browse/FLINK-14374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16969076#comment-16969076 ] Gary Yao commented on FLINK-14374: -- Currently it passes without {{FailingRestartStrateg

[GitHub] [flink] KurtYoung commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

KurtYoung commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r343533882 ## File path: flink-table/flink-table-planner-blink/src/main/scala/o

[GitHub] [flink] KurtYoung commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

KurtYoung commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r343518449 ## File path: flink-table/flink-table-planner-blink/src/main/scala/o

[GitHub] [flink] KurtYoung commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

KurtYoung commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r343536193 ## File path: flink-table/flink-table-planner-blink/src/main/scala/o

[GitHub] [flink] KurtYoung commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

KurtYoung commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r343525008 ## File path: flink-table/flink-table-planner-blink/src/main/scala/o

[GitHub] [flink] KurtYoung commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

KurtYoung commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r343536651 ## File path: flink-table/flink-table-planner-blink/src/main/scala/o

[GitHub] [flink] tillrohrmann commented on issue #10089: [FLINK-12342][yarn] Remove container requests in order to reduce excess containers

tillrohrmann commented on issue #10089: [FLINK-12342][yarn] Remove container requests in order to reduce excess containers URL: https://github.com/apache/flink/pull/10089#issuecomment-550994823 > 1. You are right. The the removal of the container requests and the upload of files is running

[GitHub] [flink] AHeise commented on a change in pull request #10009: [FLINK-14304] Avoid task starvation with mailbox

AHeise commented on a change in pull request #10009: [FLINK-14304] Avoid task starvation with mailbox URL: https://github.com/apache/flink/pull/10009#discussion_r343547453 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/MailboxOperatorT

[jira] [Updated] (FLINK-14582) Do not upload {uuid}-taskmanager-conf.yaml for each task manager container

[ https://issues.apache.org/jira/browse/FLINK-14582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14582: -- Priority: Major (was: Minor) > Do not upload {uuid}-taskmanager-conf.yaml for each task manag

[GitHub] [flink] JingsongLi commented on a change in pull request #10039: [FLINK-14262][table] Support referencing function with fully/partially qualified names in SQL

JingsongLi commented on a change in pull request #10039: [FLINK-14262][table] Support referencing function with fully/partially qualified names in SQL URL: https://github.com/apache/flink/pull/10039#discussion_r343548398 ## File path: flink-table/flink-table-planner-blink/src/main

[jira] [Closed] (FLINK-14582) Do not upload {uuid}-taskmanager-conf.yaml for each task manager container

[ https://issues.apache.org/jira/browse/FLINK-14582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-14582. - Resolution: Duplicate Closing this issue as a duplicate of FLINK-13184. Let's move the discussio

[jira] [Assigned] (FLINK-13184) Support launching task executors with multi-thread on YARN.

[ https://issues.apache.org/jira/browse/FLINK-13184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13184: - Assignee: (was: Xintong Song) > Support launching task executors with multi-thread

[GitHub] [flink] tillrohrmann commented on issue #9106: [FLINK-13184][yarn] Support launching task executors with multi-thread on YARN.

tillrohrmann commented on issue #9106: [FLINK-13184][yarn] Support launching task executors with multi-thread on YARN. URL: https://github.com/apache/flink/pull/9106#issuecomment-550996006 Closing this PR since it needs a major overhaul.

[GitHub] [flink] tillrohrmann closed pull request #9106: [FLINK-13184][yarn] Support launching task executors with multi-thread on YARN.

tillrohrmann closed pull request #9106: [FLINK-13184][yarn] Support launching task executors with multi-thread on YARN. URL: https://github.com/apache/flink/pull/9106 This is an automated message from the Apache Git Service.

[GitHub] [flink] docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r343548788 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/

[GitHub] [flink] docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r343549680 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/

[GitHub] [flink] KurtYoung commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

KurtYoung commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#discussion_r343549700 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apach

[jira] [Updated] (FLINK-13184) Starting a TaskExecutor blocks the YarnResourceManager's main thread

[ https://issues.apache.org/jira/browse/FLINK-13184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13184: -- Summary: Starting a TaskExecutor blocks the YarnResourceManager's main thread (was: Support l

[GitHub] [flink] KurtYoung commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

KurtYoung commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#discussion_r343550652 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apac

[GitHub] [flink] thorntree commented on issue #5430: [FLINK-8605] [rest] Enable job cancellation from the web UI

thorntree commented on issue #5430: [FLINK-8605] [rest] Enable job cancellation from the web UI URL: https://github.com/apache/flink/pull/5430#issuecomment-550997755 @GJL ok，thanks! This is an automated message from the Apac

[GitHub] [flink] dawidwys commented on a change in pull request #10039: [FLINK-14262][table] Support referencing function with fully/partially qualified names in SQL

dawidwys commented on a change in pull request #10039: [FLINK-14262][table] Support referencing function with fully/partially qualified names in SQL URL: https://github.com/apache/flink/pull/10039#discussion_r343550636 ## File path: flink-table/flink-table-planner-blink/src/main/j

[jira] [Updated] (FLINK-13184) Starting a TaskExecutor blocks the YarnResourceManager's main thread

[ https://issues.apache.org/jira/browse/FLINK-13184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13184: -- Fix Version/s: 1.9.2 1.8.3 > Starting a TaskExecutor blocks the YarnResourc

[jira] [Updated] (FLINK-13184) Starting a TaskExecutor blocks the YarnResourceManager's main thread

[ https://issues.apache.org/jira/browse/FLINK-13184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13184: -- Affects Version/s: 1.10.0 > Starting a TaskExecutor blocks the YarnResourceManager's main thre

[jira] [Updated] (FLINK-13184) Starting a TaskExecutor blocks the YarnResourceManager's main thread

[ https://issues.apache.org/jira/browse/FLINK-13184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13184: -- Description: Currently, YarnResourceManager starts all task executors in main thread. This co

[GitHub] [flink] GJL opened a new pull request #10114: [WIP][FLINK -14651][runtime] Enable DefaultScheduler

GJL opened a new pull request #10114: [WIP][FLINK -14651][runtime] Enable DefaultScheduler URL: https://github.com/apache/flink/pull/10114 WIP This is an automated message from the Apache Git Service. To respond to the messag

[jira] [Updated] (FLINK-13184) Starting a TaskExecutor blocks the YarnResourceManager's main thread

[ https://issues.apache.org/jira/browse/FLINK-13184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13184: -- Description: Currently, YarnResourceManager starts all task executors in main thread. This co

[jira] [Commented] (FLINK-13184) Starting a TaskExecutor blocks the YarnResourceManager's main thread

[ https://issues.apache.org/jira/browse/FLINK-13184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16969086#comment-16969086 ] Till Rohrmann commented on FLINK-13184: --- cc [~fly_in_gis] let's continue our discu

[GitHub] [flink] flinkbot edited a comment on issue #10009: [FLINK-14304] Avoid task starvation with mailbox

flinkbot edited a comment on issue #10009: [FLINK-14304] Avoid task starvation with mailbox URL: https://github.com/apache/flink/pull/10009#issuecomment-546724255 ## CI report: * 2b39236d76b1c56d240f2476c535568f0614c577 : CANCELED [Build](https://travis-ci.com/flink-ci/flink/bui

[GitHub] [flink] docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r343553792 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/

[GitHub] [flink] docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r343553591 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/

[GitHub] [flink] docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r343553894 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/

[GitHub] [flink] flinkbot commented on issue #10114: [WIP][FLINK -14651][runtime] Enable DefaultScheduler

flinkbot commented on issue #10114: [WIP][FLINK -14651][runtime] Enable DefaultScheduler URL: https://github.com/apache/flink/pull/10114#issuecomment-551000332 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull req

[GitHub] [flink] docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r343554982 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/

[GitHub] [flink] gyfora commented on a change in pull request #9533: [FLINK-13850] [Connectors / FileSystem] Refactor part file configuration into a single method

gyfora commented on a change in pull request #9533: [FLINK-13850] [Connectors / FileSystem] Refactor part file configuration into a single method URL: https://github.com/apache/flink/pull/9533#discussion_r343554863 ## File path: flink-streaming-java/src/main/java/org/apache/flink/s

[GitHub] [flink] docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

docete commented on a change in pull request #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#discussion_r343553591 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/

[GitHub] [flink] gyfora commented on a change in pull request #9533: [FLINK-13850] [Connectors / FileSystem] Refactor part file configuration into a single method

gyfora commented on a change in pull request #9533: [FLINK-13850] [Connectors / FileSystem] Refactor part file configuration into a single method URL: https://github.com/apache/flink/pull/9533#discussion_r343555422 ## File path: flink-streaming-java/src/main/java/org/apache/flink/s

[GitHub] [flink] flinkbot edited a comment on issue #10061: [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs on yarn.

flinkbot edited a comment on issue #10061: [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs on yarn. URL: https://github.com/apache/flink/pull/10061#issuecomment-548335375 ## CI report: * 6f081dffc4e0da

[GitHub] [flink] gyfora commented on a change in pull request #9533: [FLINK-13850] [Connectors / FileSystem] Refactor part file configuration into a single method

gyfora commented on a change in pull request #9533: [FLINK-13850] [Connectors / FileSystem] Refactor part file configuration into a single method URL: https://github.com/apache/flink/pull/9533#discussion_r343554580 ## File path: flink-streaming-java/src/main/java/org/apache/flink/s

[jira] [Updated] (FLINK-13634) StreamingFileSink - allow bulkwriter to compress data

[ https://issues.apache.org/jira/browse/FLINK-13634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] João Boto updated FLINK-13634: -- Description: I have developed a CompressFileWriter base on BulkWriter to compress data using hadoop co

[jira] [Updated] (FLINK-13634) StreamingFileSink - allow bulkwriter to compress data

[ https://issues.apache.org/jira/browse/FLINK-13634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] João Boto updated FLINK-13634: -- Description: I have developed a CompressFileWriter base on BulkWriter to compress datausing hadoop com

[jira] [Commented] (FLINK-13634) StreamingFileSink - allow bulkwriter to compress data

[ https://issues.apache.org/jira/browse/FLINK-13634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16969091#comment-16969091 ] João Boto commented on FLINK-13634: --- [~kkloudas], [~gyfora] could you check this? > S

[jira] [Commented] (FLINK-14646) Check non-null for key in KeyGroupStreamPartitioner

[ https://issues.apache.org/jira/browse/FLINK-14646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16969094#comment-16969094 ] Till Rohrmann commented on FLINK-14646: --- Sounds good to me. Do you wanna open a PR

[jira] [Assigned] (FLINK-14646) Check non-null for key in KeyGroupStreamPartitioner

[ https://issues.apache.org/jira/browse/FLINK-14646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-14646: - Assignee: Jiayi Liao > Check non-null for key in KeyGroupStreamPartitioner > --

[jira] [Updated] (FLINK-14646) Check non-null for key in KeyGroupStreamPartitioner

[ https://issues.apache.org/jira/browse/FLINK-14646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14646: -- Affects Version/s: (was: 1.9.0) 1.10.0 1.8.2

[jira] [Updated] (FLINK-14646) Check non-null for key in KeyGroupStreamPartitioner

[ https://issues.apache.org/jira/browse/FLINK-14646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14646: -- Fix Version/s: 1.9.2 1.8.3 1.10.0 > Check non-null for k

[jira] [Commented] (FLINK-14634) Metric Option of 'metrics.scope.delimiter' won't work probably.

[ https://issues.apache.org/jira/browse/FLINK-14634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16969092#comment-16969092 ] Chesnay Schepler commented on FLINK-14634: -- The delimiter used in the scope-for

[GitHub] [flink] KurtYoung commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

KurtYoung commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#discussion_r343556700 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apach

  1   2   3   4   5   6   7   >