[jira] [Commented] (FLINK-14613) Add validation check when applying UDF to tempral table key in Temporal Table Join condition

[ https://issues.apache.org/jira/browse/FLINK-14613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969194#comment-16969194 ] hailong wang commented on FLINK-14613: -- Hi [~jark], you are right. I have some misunderstanding

[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

[GitHub] [flink] flinkbot edited a comment on issue #10076: [FLINK-14465][runtime] Let `StandaloneJobClusterEntrypoint` use user code class loader

flinkbot edited a comment on issue #10076: [FLINK-14465][runtime] Let `StandaloneJobClusterEntrypoint` use user code class loader URL: https://github.com/apache/flink/pull/10076#issuecomment-549350838 ## CI report: * 20b4b8b96eb3e73db1e627b334fb7fb487aa3bb8 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

flinkbot edited a comment on issue #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#issuecomment-550174677 ## CI report: * a3db95a7340322421d1fa826dcac850116011687 : FAILURE

[jira] [Commented] (FLINK-14643) Deprecate metric `fullRestarts`

[ https://issues.apache.org/jira/browse/FLINK-14643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969259#comment-16969259 ] Chesnay Schepler commented on FLINK-14643: -- Sounds good, do you want to open a PR [~zhuzh]? >

[GitHub] [flink] flinkbot edited a comment on issue #9885: [FLINK-14344][checkpointing] A preparation for snapshotting master hook state asynchronously

flinkbot edited a comment on issue #9885: [FLINK-14344][checkpointing] A preparation for snapshotting master hook state asynchronously URL: https://github.com/apache/flink/pull/9885#issuecomment-541299624 ## CI report: * d0c426e6ff61dcad1de4c7d3e9a2a16416e77e54 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values

flinkbot edited a comment on issue #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values URL: https://github.com/apache/flink/pull/10079#issuecomment-549401980 ## CI report: * 5b7e9e832ed26f476d0149663b2f0dec9f1bc427 :

[GitHub] [flink] GJL commented on issue #10085: [FLINK-14373][tests] Fix ZooKeeperHighAvailabilityITCase to pass with NG scheduler

GJL commented on issue #10085: [FLINK-14373][tests] Fix ZooKeeperHighAvailabilityITCase to pass with NG scheduler URL: https://github.com/apache/flink/pull/10085#issuecomment-551110644 Merging. This is an automated message

[jira] [Updated] (FLINK-14494) Update documentation generator

[ https://issues.apache.org/jira/browse/FLINK-14494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14494: --- Labels: pull-request-available (was: ) > Update documentation generator >

[GitHub] [flink] dawidwys opened a new pull request #10117: [FLINK-14494][docs] Add ConfigOption type to the documentation generator

dawidwys opened a new pull request #10117: [FLINK-14494][docs] Add ConfigOption type to the documentation generator URL: https://github.com/apache/flink/pull/10117 ## What is the purpose of the change It adds generating type column to `ConfigOptionsDocGenerator` ## Verifying

[GitHub] [flink] dawidwys commented on issue #10117: [FLINK-14494][docs] Add ConfigOption type to the documentation generator

dawidwys commented on issue #10117: [FLINK-14494][docs] Add ConfigOption type to the documentation generator URL: https://github.com/apache/flink/pull/10117#issuecomment-551117235 I would appreciate if you had a look @zentol @kl0u

[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

[jira] [Commented] (FLINK-14642) Flink TupleSerializer and CaseClassSerializer shoud support copy NULL values

[ https://issues.apache.org/jira/browse/FLINK-14642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969369#comment-16969369 ] Victor Wong commented on FLINK-14642: - [~sewen], sure I will ping you once PR is ready:) > Flink

[jira] [Updated] (FLINK-14656) blink planner should also fetch catalog statistics for CatalogTableImpl

[ https://issues.apache.org/jira/browse/FLINK-14656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-14656: --- Description: currently, blink planner will convert {{CatalogTable}} to Calcite {{Table}}, fetch

[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

[GitHub] [flink] flinkbot edited a comment on issue #10115: [FLINK-14630] Re-enable logging for Yarn tests

flinkbot edited a comment on issue #10115: [FLINK-14630] Re-enable logging for Yarn tests URL: https://github.com/apache/flink/pull/10115#issuecomment-551055714 ## CI report: * 5b8fadf41840c5239b34d05b3c4c9f990a4230ce : UNKNOWN * 22c97864cd3eb0069da396b8f52237d9839875de :

[jira] [Updated] (FLINK-14656) blink planner should also fetch catalog statistics for permanent CatalogTableImpl

[ https://issues.apache.org/jira/browse/FLINK-14656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-14656: --- Summary: blink planner should also fetch catalog statistics for permanent CatalogTableImpl (was:

[GitHub] [flink] godfreyhe opened a new pull request #10119: [FLINK-14656] [table-planner-blink] blink planner should also fetch catalog statistics for permanent CatalogTableImpl

godfreyhe opened a new pull request #10119: [FLINK-14656] [table-planner-blink] blink planner should also fetch catalog statistics for permanent CatalogTableImpl URL: https://github.com/apache/flink/pull/10119 ## What is the purpose of the change *let blink planner also fetch

[jira] [Updated] (FLINK-14656) blink planner should also fetch catalog statistics for CatalogTableImpl

[ https://issues.apache.org/jira/browse/FLINK-14656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14656: --- Labels: pull-request-available (was: ) > blink planner should also fetch catalog

[GitHub] [flink] buptljy commented on issue #10120: [FLINK-14646] Check non-null for key in KeyGroupStreamPartitioner

buptljy commented on issue #10120: [FLINK-14646] Check non-null for key in KeyGroupStreamPartitioner URL: https://github.com/apache/flink/pull/10120#issuecomment-55117 cc @tillrohrmann This is an automated message from

[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 ] ASF GitHub Bot updated FLINK-14646: --- Labels: pull-request-available (was: ) > Check non-null for key in

[GitHub] [flink] flinkbot edited a comment on issue #10120: [FLINK-14646] Check non-null for key in KeyGroupStreamPartitioner

flinkbot edited a comment on issue #10120: [FLINK-14646] Check non-null for key in KeyGroupStreamPartitioner URL: https://github.com/apache/flink/pull/10120#issuecomment-55113 ## CI report: * a1ab1e437a28e69d77d58e1ba89ee4818ebfb85c : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #10119: [FLINK-14656] [table-planner-blink] blink planner should also fetch catalog statistics for permanent CatalogTableImpl

flinkbot edited a comment on issue #10119: [FLINK-14656] [table-planner-blink] blink planner should also fetch catalog statistics for permanent CatalogTableImpl URL: https://github.com/apache/flink/pull/10119#issuecomment-551177730 ## CI report: *

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

flinkbot edited a comment on issue #10114: [WIP][FLINK -14651][runtime] Enable DefaultScheduler URL: https://github.com/apache/flink/pull/10114#issuecomment-551014940 ## CI report: * c436371614d7db5dfc8c97e01a4594c3139715db : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10118: [FLINK-14657] Generalize and move config utils from flink-yarn to flink-core

flinkbot edited a comment on issue #10118: [FLINK-14657] Generalize and move config utils from flink-yarn to flink-core URL: https://github.com/apache/flink/pull/10118#issuecomment-551139397 ## CI report: * e778ea4b39b82aea97a12a29ea0d7ba4083dfedf : SUCCESS

[jira] [Updated] (FLINK-14656) blink planner should also fetch catalog statistics for CatalogTableImpl

[ https://issues.apache.org/jira/browse/FLINK-14656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-14656: --- Summary: blink planner should also fetch catalog statistics for CatalogTableImpl (was: blink

[jira] [Commented] (FLINK-14626) User jar packaged with hadoop dependencies may cause class conflit with hadoop jars on yarn

[ https://issues.apache.org/jira/browse/FLINK-14626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969388#comment-16969388 ] Victor Wong commented on FLINK-14626: - [~chesnay], thanks for your quick response. As an engineer

[GitHub] [flink] flinkbot edited a comment on issue #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

flinkbot edited a comment on issue #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#issuecomment-550174677 ## CI report: * a3db95a7340322421d1fa826dcac850116011687 : FAILURE

[GitHub] [flink] flinkbot commented on issue #10119: [FLINK-14656] [table-planner-blink] blink planner should also fetch catalog statistics for permanent CatalogTableImpl

flinkbot commented on issue #10119: [FLINK-14656] [table-planner-blink] blink planner should also fetch catalog statistics for permanent CatalogTableImpl URL: https://github.com/apache/flink/pull/10119#issuecomment-551167526 Thanks a lot for your contribution to the Apache Flink project.

[GitHub] [flink] flinkbot edited a comment on issue #9929: [BP-1.9][FLINK-12122] Add support for spreading slots out across all TaskExecutors

flinkbot edited a comment on issue #9929: [BP-1.9][FLINK-12122] Add support for spreading slots out across all TaskExecutors URL: https://github.com/apache/flink/pull/9929#issuecomment-543216984 ## CI report: * 54c386c5c9e0e45bf8d44a0acf6b6c778c36441c : CANCELED

[GitHub] [flink] GJL closed pull request #10085: [FLINK-14373][tests] Fix ZooKeeperHighAvailabilityITCase to pass with NG scheduler

GJL closed pull request #10085: [FLINK-14373][tests] Fix ZooKeeperHighAvailabilityITCase to pass with NG scheduler URL: https://github.com/apache/flink/pull/10085 This is an automated message from the Apache Git Service. To

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

GJL closed pull request #10082: [FLINK-14164][runtime] Add a counter ‘numberOfRestarts’ to show number of restarts URL: https://github.com/apache/flink/pull/10082 This is an automated message from the Apache Git Service. To

[GitHub] [flink] flinkbot commented on issue #10120: [FLINK-14646] Check non-null for key in KeyGroupStreamPartitioner

flinkbot commented on issue #10120: [FLINK-14646] Check non-null for key in KeyGroupStreamPartitioner URL: https://github.com/apache/flink/pull/10120#issuecomment-55113 ## CI report: * a1ab1e437a28e69d77d58e1ba89ee4818ebfb85c : UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on issue #10117: [FLINK-14494][docs] Add ConfigOption type to the documentation generator

flinkbot edited a comment on issue #10117: [FLINK-14494][docs] Add ConfigOption type to the documentation generator URL: https://github.com/apache/flink/pull/10117#issuecomment-551124860 ## CI report: * 6fb1d5a168ee34b529e33f332291fa3db6ec : FAILURE

[GitHub] [flink] flinkbot commented on issue #10119: [FLINK-14656] [table-planner-blink] blink planner should also fetch catalog statistics for permanent CatalogTableImpl

flinkbot commented on issue #10119: [FLINK-14656] [table-planner-blink] blink planner should also fetch catalog statistics for permanent CatalogTableImpl URL: https://github.com/apache/flink/pull/10119#issuecomment-551177730 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #10076: [FLINK-14465][runtime] Let `StandaloneJobClusterEntrypoint` use user code class loader

flinkbot edited a comment on issue #10076: [FLINK-14465][runtime] Let `StandaloneJobClusterEntrypoint` use user code class loader URL: https://github.com/apache/flink/pull/10076#issuecomment-549350838 ## CI report: * 20b4b8b96eb3e73db1e627b334fb7fb487aa3bb8 : SUCCESS

[jira] [Comment Edited] (FLINK-14626) User jar packaged with hadoop dependencies may cause class conflit with hadoop jars on yarn

[ https://issues.apache.org/jira/browse/FLINK-14626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969388#comment-16969388 ] Victor Wong edited comment on FLINK-14626 at 11/7/19 4:20 PM: -- [~chesnay],

[GitHub] [flink] flinkbot edited a comment on issue #10115: [FLINK-14630] Re-enable logging for Yarn tests

flinkbot edited a comment on issue #10115: [FLINK-14630] Re-enable logging for Yarn tests URL: https://github.com/apache/flink/pull/10115#issuecomment-551055714 ## CI report: * 5b8fadf41840c5239b34d05b3c4c9f990a4230ce : UNKNOWN * 22c97864cd3eb0069da396b8f52237d9839875de :

[GitHub] [flink] flinkbot edited a comment on issue #10118: [FLINK-14657] Generalize and move config utils from flink-yarn to flink-core

flinkbot edited a comment on issue #10118: [FLINK-14657] Generalize and move config utils from flink-yarn to flink-core URL: https://github.com/apache/flink/pull/10118#issuecomment-551139397 ## CI report: * e778ea4b39b82aea97a12a29ea0d7ba4083dfedf : PENDING

[GitHub] [flink] flinkbot commented on issue #10120: [FLINK-14646] Check non-null for key in KeyGroupStreamPartitioner

flinkbot commented on issue #10120: [FLINK-14646] Check non-null for key in KeyGroupStreamPartitioner URL: https://github.com/apache/flink/pull/10120#issuecomment-551172364 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[jira] [Comment Edited] (FLINK-14373) Enable ZooKeeperHighAvailabilityITCase to pass with scheduler NG

[ https://issues.apache.org/jira/browse/FLINK-14373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969428#comment-16969428 ] Gary Yao edited comment on FLINK-14373 at 11/7/19 5:51 PM: --- master:

[jira] [Updated] (FLINK-14656) blink planner should also fetch catalog statistics for CatalogTableImpl

[ https://issues.apache.org/jira/browse/FLINK-14656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-14656: --- Description: currently, blink planner will fetch the catalog statistics and convert to

[GitHub] [flink] sjwiesman commented on a change in pull request #10110: [FLINK-14301][doc] add documentation for functions categories and new function resolution orders

sjwiesman commented on a change in pull request #10110: [FLINK-14301][doc] add documentation for functions categories and new function resolution orders URL: https://github.com/apache/flink/pull/10110#discussion_r343757120 ## File path: docs/dev/table/functions/index.md ##

[GitHub] [flink] sjwiesman commented on a change in pull request #10110: [FLINK-14301][doc] add documentation for functions categories and new function resolution orders

sjwiesman commented on a change in pull request #10110: [FLINK-14301][doc] add documentation for functions categories and new function resolution orders URL: https://github.com/apache/flink/pull/10110#discussion_r343757527 ## File path: docs/dev/table/functions/index.md ##

[GitHub] [flink] sjwiesman commented on a change in pull request #10110: [FLINK-14301][doc] add documentation for functions categories and new function resolution orders

sjwiesman commented on a change in pull request #10110: [FLINK-14301][doc] add documentation for functions categories and new function resolution orders URL: https://github.com/apache/flink/pull/10110#discussion_r343757173 ## File path: docs/dev/table/functions/index.md ##

[GitHub] [flink] sjwiesman commented on a change in pull request #10110: [FLINK-14301][doc] add documentation for functions categories and new function resolution orders

sjwiesman commented on a change in pull request #10110: [FLINK-14301][doc] add documentation for functions categories and new function resolution orders URL: https://github.com/apache/flink/pull/10110#discussion_r343756991 ## File path: docs/dev/table/functions/index.md ##

[jira] [Updated] (FLINK-14656) blink planner should also fetch catalog statistics for permanent CatalogTableImpl

[ https://issues.apache.org/jira/browse/FLINK-14656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-14656: --- Description: currently, blink planner will fetch the catalog statistics and convert to

[GitHub] [flink] sjwiesman commented on a change in pull request #10110: [FLINK-14301][doc] add documentation for functions categories and new function resolution orders

sjwiesman commented on a change in pull request #10110: [FLINK-14301][doc] add documentation for functions categories and new function resolution orders URL: https://github.com/apache/flink/pull/10110#discussion_r343758484 ## File path: docs/dev/table/functions/index.md ##

[GitHub] [flink] sjwiesman commented on a change in pull request #10110: [FLINK-14301][doc] add documentation for functions categories and new function resolution orders

sjwiesman commented on a change in pull request #10110: [FLINK-14301][doc] add documentation for functions categories and new function resolution orders URL: https://github.com/apache/flink/pull/10110#discussion_r343759981 ## File path: docs/dev/table/functions/index.md ##

[GitHub] [flink] sjwiesman commented on a change in pull request #10110: [FLINK-14301][doc] add documentation for functions categories and new function resolution orders

sjwiesman commented on a change in pull request #10110: [FLINK-14301][doc] add documentation for functions categories and new function resolution orders URL: https://github.com/apache/flink/pull/10110#discussion_r343756009 ## File path: docs/dev/table/functions/index.md ##

[GitHub] [flink] sjwiesman commented on a change in pull request #10110: [FLINK-14301][doc] add documentation for functions categories and new function resolution orders

sjwiesman commented on a change in pull request #10110: [FLINK-14301][doc] add documentation for functions categories and new function resolution orders URL: https://github.com/apache/flink/pull/10110#discussion_r343724050 ## File path: docs/dev/table/functions/index.md ##

[jira] [Closed] (FLINK-14373) Enable ZooKeeperHighAvailabilityITCase to pass with scheduler NG

[ https://issues.apache.org/jira/browse/FLINK-14373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-14373. Resolution: Fixed 1.10: e933a5cbc263be5041bd3723cd2400c871739733 > Enable

[jira] [Closed] (FLINK-14164) Add a metric to show failover count regarding fine grained recovery

[ https://issues.apache.org/jira/browse/FLINK-14164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-14164. Resolution: Fixed master: 4f0d6c170937c57934faa23141777f2304072ee4

[jira] [Closed] (FLINK-12216) Respect the number of bytes from input parameters in HybridMemorySegment

[ https://issues.apache.org/jira/browse/FLINK-12216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-12216. > Respect the number of bytes from input parameters in HybridMemorySegment >

[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

[jira] [Resolved] (FLINK-12216) Respect the number of bytes from input parameters in HybridMemorySegment

[ https://issues.apache.org/jira/browse/FLINK-12216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-12216. -- Fix Version/s: 1.10.0 Resolution: Fixed Fixed via

[GitHub] [flink] flinkbot edited a comment on issue #10076: [FLINK-14465][runtime] Let `StandaloneJobClusterEntrypoint` use user code class loader

flinkbot edited a comment on issue #10076: [FLINK-14465][runtime] Let `StandaloneJobClusterEntrypoint` use user code class loader URL: https://github.com/apache/flink/pull/10076#issuecomment-549350838 ## CI report: * 20b4b8b96eb3e73db1e627b334fb7fb487aa3bb8 : SUCCESS

[jira] [Closed] (FLINK-14626) User jar packaged with hadoop dependencies may cause class conflit with hadoop jars on yarn

[ https://issues.apache.org/jira/browse/FLINK-14626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong closed FLINK-14626. --- Resolution: Invalid > User jar packaged with hadoop dependencies may cause class conflit with >

[GitHub] [flink] flinkbot edited a comment on issue #10111: [FLINK-13969] Resuming Externalized Checkpoint (rocks, incremental, scale down) end-to-end test fails on Travis

flinkbot edited a comment on issue #10111: [FLINK-13969] Resuming Externalized Checkpoint (rocks, incremental, scale down) end-to-end test fails on Travis URL: https://github.com/apache/flink/pull/10111#issuecomment-550658607 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #10115: [FLINK-14630] Re-enable logging for Yarn tests

flinkbot edited a comment on issue #10115: [FLINK-14630] Re-enable logging for Yarn tests URL: https://github.com/apache/flink/pull/10115#issuecomment-551055714 ## CI report: * 5b8fadf41840c5239b34d05b3c4c9f990a4230ce : UNKNOWN * 22c97864cd3eb0069da396b8f52237d9839875de :

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

flinkbot edited a comment on issue #10114: [WIP][FLINK -14651][runtime] Enable DefaultScheduler URL: https://github.com/apache/flink/pull/10114#issuecomment-551014940 ## CI report: * c436371614d7db5dfc8c97e01a4594c3139715db : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

flinkbot edited a comment on issue #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#issuecomment-549714188 ## CI report: * bdb7952a0a48b4e67f51a04db61cd96a1cbecbbc : FAILURE

[GitHub] [flink] buptljy opened a new pull request #10120: [FLINK-14646] Check non-null for key in KeyGroupStreamPartitioner

buptljy opened a new pull request #10120: [FLINK-14646] Check non-null for key in KeyGroupStreamPartitioner URL: https://github.com/apache/flink/pull/10120 ## What is the purpose of the change Add non-null check for key in KeyGroupStreamPartitioner because the NPE message

[jira] [Commented] (FLINK-14164) Add a metric to show failover count regarding fine grained recovery

[ https://issues.apache.org/jira/browse/FLINK-14164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969425#comment-16969425 ] Gary Yao commented on FLINK-14164: -- We decided to leave out the meter for now. See Github PR for

[jira] [Updated] (FLINK-14164) Add a metric to show failover count regarding fine grained recovery

[ https://issues.apache.org/jira/browse/FLINK-14164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-14164: - Description: Previously Flink uses restart all strategy to recover jobs from failures. And the metric

[GitHub] [flink] asfgit closed pull request #8194: [FLINK-12216][Runtime]Respect the number of bytes from input parameters in HybridMemorySegment

asfgit closed pull request #8194: [FLINK-12216][Runtime]Respect the number of bytes from input parameters in HybridMemorySegment URL: https://github.com/apache/flink/pull/8194 This is an automated message from the Apache

[GitHub] [flink] StephanEwen commented on a change in pull request #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator

StephanEwen commented on a change in pull request #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator URL: https://github.com/apache/flink/pull/9516#discussion_r343782961 ## File path:

[GitHub] [flink] StephanEwen commented on a change in pull request #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator

StephanEwen commented on a change in pull request #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator URL: https://github.com/apache/flink/pull/9516#discussion_r343782689 ## File path:

[GitHub] [flink] StephanEwen commented on a change in pull request #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator

StephanEwen commented on a change in pull request #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator URL: https://github.com/apache/flink/pull/9516#discussion_r343781924 ## File path:

[GitHub] [flink] StephanEwen commented on a change in pull request #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator

StephanEwen commented on a change in pull request #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator URL: https://github.com/apache/flink/pull/9516#discussion_r343780582 ## File path: flink-state-backends/flink-statebackend-heap-spillable/pom.xml ## @@

[GitHub] [flink] StephanEwen commented on a change in pull request #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator

StephanEwen commented on a change in pull request #9516: [FLINK-13815][State Backends] Implement the SpaceAllocator URL: https://github.com/apache/flink/pull/9516#discussion_r343780912 ## File path:

[GitHub] [flink] StephanEwen commented on issue #9992: [FLINK-14481][RunTime/Network]change Flink's port check to 0 to 65535

StephanEwen commented on issue #9992: [FLINK-14481][RunTime/Network]change Flink's port check to 0 to 65535 URL: https://github.com/apache/flink/pull/9992#issuecomment-551189918 Looks correct, thanks for fixing this. Merging this...

[GitHub] [flink] flinkbot edited a comment on issue #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

flinkbot edited a comment on issue #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#issuecomment-549714188 ## CI report: * bdb7952a0a48b4e67f51a04db61cd96a1cbecbbc : FAILURE

[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

[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:

[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:

[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:

[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:

[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: *

[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:

[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

[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

[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] [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=16969091#comment-16969091 ] João Boto commented on FLINK-13634: --- [~kkloudas], [~gyfora] could you check this? > StreamingFileSink

[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=16969094#comment-16969094 ] Till Rohrmann commented on FLINK-14646: --- Sounds good to me. Do you wanna open a PR for it

[jira] [Assigned] (FLINK-14639) Fix the document of Metircs that has an error for `User Scope`

[ https://issues.apache.org/jira/browse/FLINK-14639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-14639: Assignee: Chesnay Schepler > Fix the document of Metircs that has an error for

[jira] [Closed] (FLINK-14639) Fix the document of Metircs that has an error for `User Scope`

[ https://issues.apache.org/jira/browse/FLINK-14639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-14639. Fix Version/s: 1.9.2 1.8.3 1.10.0 Resolution:

[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: -- Issue Type: Bug (was: Improvement) > Starting a TaskExecutor blocks the

[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: -- Priority: Critical (was: Major) > Starting a TaskExecutor blocks the YarnResourceManager's

[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_r343565799 ## File path:

[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

[GitHub] [flink] pnowojski commented on a change in pull request #10084: [FLINK-14382][yarn] Incorrect handling of FLINK_PLUGINS_DIR on Yarn

pnowojski commented on a change in pull request #10084: [FLINK-14382][yarn] Incorrect handling of FLINK_PLUGINS_DIR on Yarn URL: https://github.com/apache/flink/pull/10084#discussion_r343565638 ## File path: flink-end-to-end-tests/run-pre-commit-tests.sh ## @@ -54,6 +54,7

[GitHub] [flink] pnowojski commented on a change in pull request #10084: [FLINK-14382][yarn] Incorrect handling of FLINK_PLUGINS_DIR on Yarn

pnowojski commented on a change in pull request #10084: [FLINK-14382][yarn] Incorrect handling of FLINK_PLUGINS_DIR on Yarn URL: https://github.com/apache/flink/pull/10084#discussion_r343561672 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #10106: [FLINK-11463][e2e] Design the e2e java framework so that at least the Kafka streaming tests can run on it

zentol commented on a change in pull request #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#discussion_r343572818 ## File path:

[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-551014940 ## CI report: * c436371614d7db5dfc8c97e01a4594c3139715db : UNKNOWN Bot commands The @flinkbot bot

[jira] [Closed] (FLINK-13702) BaseMapSerializerTest.testDuplicate fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-13702. Fix Version/s: 1.9.2 1.10.0 Resolution: Fixed Fixed in master:

[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_r343573724 ## File path:

[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_r343573552 ## File path:

[jira] [Closed] (FLINK-13740) TableAggregateITCase.testNonkeyedFlatAggregate failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-13740. Resolution: Fixed Fixed in master: 0b28e830d7366126a91ca9faa38cb19a8f66a9b6 1.9.2:

  1   2   3   4   5   6   7   >