[jira] [Created] (FLINK-14381) Partition field names should be got from CatalogTable instead of source/sink

Jingsong Lee created FLINK-14381: Summary: Partition field names should be got from CatalogTable instead of source/sink Key: FLINK-14381 URL: https://issues.apache.org/jira/browse/FLINK-14381

[GitHub] [flink] wuchong commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese

wuchong commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese URL: https://github.com/apache/flink/pull/9805#discussion_r334219455 ## File path: docs/dev/stream/state/checkpointing.zh.md ## @@ -25,146

[GitHub] [flink] wuchong commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese

wuchong commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese URL: https://github.com/apache/flink/pull/9805#discussion_r334218905 ## File path: docs/dev/stream/state/checkpointing.zh.md ## @@ -173,30

[GitHub] [flink] wuchong commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese

wuchong commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese URL: https://github.com/apache/flink/pull/9805#discussion_r334219153 ## File path: docs/dev/stream/state/checkpointing.zh.md ## @@ -173,30

[GitHub] [flink] wuchong commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese

wuchong commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese URL: https://github.com/apache/flink/pull/9805#discussion_r334219278 ## File path: docs/dev/stream/state/checkpointing.zh.md ## @@ -173,30

[GitHub] [flink] wuchong commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese

wuchong commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese URL: https://github.com/apache/flink/pull/9805#discussion_r334219241 ## File path: docs/dev/stream/state/checkpointing.zh.md ## @@ -173,30

[GitHub] [flink] wuchong commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese

wuchong commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese URL: https://github.com/apache/flink/pull/9805#discussion_r334219200 ## File path: docs/dev/stream/state/checkpointing.zh.md ## @@ -173,30

[GitHub] [flink] wuchong commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese

wuchong commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese URL: https://github.com/apache/flink/pull/9805#discussion_r334218807 ## File path: docs/dev/stream/state/checkpointing.zh.md ## @@ -25,146

[GitHub] [flink] wuchong commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese

wuchong commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese URL: https://github.com/apache/flink/pull/9805#discussion_r334218926 ## File path: docs/dev/stream/state/checkpointing.zh.md ## @@ -173,30

[GitHub] [flink] wuchong commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese

wuchong commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese URL: https://github.com/apache/flink/pull/9805#discussion_r334218859 ## File path: docs/dev/stream/state/checkpointing.zh.md ## @@ -25,146

[GitHub] [flink] wuchong commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese

wuchong commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese URL: https://github.com/apache/flink/pull/9805#discussion_r334222457 ## File path: docs/dev/stream/state/checkpointing.zh.md ## @@ -25,146

[GitHub] [flink] wuchong commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese

wuchong commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese URL: https://github.com/apache/flink/pull/9805#discussion_r334218966 ## File path: docs/dev/stream/state/checkpointing.zh.md ## @@ -173,30

[GitHub] [flink] wuchong commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese

wuchong commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese URL: https://github.com/apache/flink/pull/9805#discussion_r334216793 ## File path: docs/dev/stream/state/checkpointing.zh.md ## @@ -25,146

[GitHub] [flink] wuchong commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese

wuchong commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese URL: https://github.com/apache/flink/pull/9805#discussion_r334218738 ## File path: docs/dev/stream/state/checkpointing.zh.md ## @@ -25,146

[GitHub] [flink] wuchong commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese

wuchong commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese URL: https://github.com/apache/flink/pull/9805#discussion_r334218610 ## File path: docs/dev/stream/state/checkpointing.zh.md ## @@ -25,146

[GitHub] [flink] wuchong commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese

wuchong commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese URL: https://github.com/apache/flink/pull/9805#discussion_r334216896 ## File path: docs/dev/stream/state/checkpointing.zh.md ## @@ -25,146

[GitHub] [flink] wuchong commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese

wuchong commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese URL: https://github.com/apache/flink/pull/9805#discussion_r334219286 ## File path: docs/dev/stream/state/checkpointing.zh.md ## @@ -173,30

[GitHub] [flink] wuchong commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese

wuchong commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese URL: https://github.com/apache/flink/pull/9805#discussion_r334216944 ## File path: docs/dev/stream/state/checkpointing.zh.md ## @@ -25,146

[jira] [Updated] (FLINK-14273) Improve exception message when signature validation of UDAF is failed

[ https://issues.apache.org/jira/browse/FLINK-14273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14273: Summary: Improve exception message when signature validation of UDAF is failed (was: when User-Defined

[GitHub] [flink] wuchong commented on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction

wuchong commented on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction URL: https://github.com/apache/flink/pull/9823#issuecomment-541288726 Hi @wangxlong , could you add a `UserDefinedFunctionValidationTest` in blink planner to verify this?

[GitHub] [flink] flinkbot edited a comment on issue #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect

flinkbot edited a comment on issue #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect URL: https://github.com/apache/flink/pull/9866#issuecomment-539968272 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #9760: [FLINK-13982][runtime] Implement memory calculation logics

flinkbot edited a comment on issue #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#issuecomment-534565595 ## CI report: * 6bc9773c54eed0b1646ec67413cb3855c1057d87 : FAILURE

[GitHub] [flink] lukess commented on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx

lukess commented on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx URL: https://github.com/apache/flink/pull/9848#issuecomment-541287581 [FLINK-14308](https://issues.apache.org/jira/browse/FLINK-14308)

[GitHub] [flink] flinkbot edited a comment on issue #9882: [FLINK-14380][Flink-Core] Type Extractor Setter

flinkbot edited a comment on issue #9882: [FLINK-14380][Flink-Core] Type Extractor Setter URL: https://github.com/apache/flink/pull/9882#issuecomment-541191860 ## CI report: * be39b56629b779f39b546e61315a2373d26e683c : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction

flinkbot edited a comment on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction URL: https://github.com/apache/flink/pull/9823#issuecomment-536781542 ## CI report: * 2b5531b068338321eb04cdf71714eae0d088ec0e : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9760: [FLINK-13982][runtime] Implement memory calculation logics

flinkbot edited a comment on issue #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#issuecomment-534565595 ## CI report: * 6bc9773c54eed0b1646ec67413cb3855c1057d87 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9882: [FLINK-14380][Flink-Core] Type Extractor Setter

flinkbot edited a comment on issue #9882: [FLINK-14380][Flink-Core] Type Extractor Setter URL: https://github.com/apache/flink/pull/9882#issuecomment-541191860 ## CI report: * be39b56629b779f39b546e61315a2373d26e683c : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect

flinkbot edited a comment on issue #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect URL: https://github.com/apache/flink/pull/9866#issuecomment-539968272 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #9860: [FLINK-14331][runtime] Reset vertices right after they transition to terminated states

flinkbot edited a comment on issue #9860: [FLINK-14331][runtime] Reset vertices right after they transition to terminated states URL: https://github.com/apache/flink/pull/9860#issuecomment-539900648 ## CI report: * 80c100513c089a9dd0930aa547383ae970c4e7f8 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9843: [FLINK-14296] [Table SQL] Use Optional for optional parameters in parser module

flinkbot edited a comment on issue #9843: [FLINK-14296] [Table SQL] Use Optional for optional parameters in parser module URL: https://github.com/apache/flink/pull/9843#issuecomment-538718823 ## CI report: * a9b3b6131bc282e47937d4eb4d9db4ab952ccd1a : CANCELED

[GitHub] [flink] flinkbot edited a comment on issue #9760: [FLINK-13982][runtime] Implement memory calculation logics

flinkbot edited a comment on issue #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#issuecomment-534565595 ## CI report: * 6bc9773c54eed0b1646ec67413cb3855c1057d87 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect

flinkbot edited a comment on issue #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect URL: https://github.com/apache/flink/pull/9866#issuecomment-539968272 ## CI report: *

[GitHub] [flink] ElliotVilhelm edited a comment on issue #9882: [FLINK-14380][Flink-Core] Type Extractor Setter

ElliotVilhelm edited a comment on issue #9882: [FLINK-14380][Flink-Core] Type Extractor Setter URL: https://github.com/apache/flink/pull/9882#issuecomment-541283935 > I don't think this pull request bound to FLINK-1430 though... @ElliotVilhelm Fixed, linked to JIRA is description 

[GitHub] [flink] ElliotVilhelm edited a comment on issue #9882: [FLINK-14380][Flink-Core] Type Extractor Setter

ElliotVilhelm edited a comment on issue #9882: [FLINK-14380][Flink-Core] Type Extractor Setter URL: https://github.com/apache/flink/pull/9882#issuecomment-541283935 > I don't think this pull request bound to FLINK-1430 though... @ElliotVilhelm Fixed, linked to JIRA in description 

[GitHub] [flink] ElliotVilhelm edited a comment on issue #9882: [FLINK-14380][Flink-Core] Type Extractor Setter

ElliotVilhelm edited a comment on issue #9882: [FLINK-14380][Flink-Core] Type Extractor Setter URL: https://github.com/apache/flink/pull/9882#issuecomment-541283935 > I don't think this pull request bound to FLINK-1430 though... @ElliotVilhelm Fixed, linked to JIRA is description 

[GitHub] [flink] ElliotVilhelm commented on issue #9882: [FLINK-14380][Flink-Core] Type Extractor Setter

ElliotVilhelm commented on issue #9882: [FLINK-14380][Flink-Core] Type Extractor Setter URL: https://github.com/apache/flink/pull/9882#issuecomment-541283935 > I don't think this pull request bound to FLINK-1430 though... @ElliotVilhelm  fixed.

[GitHub] [flink] flinkbot edited a comment on issue #9760: [FLINK-13982][runtime] Implement memory calculation logics

flinkbot edited a comment on issue #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#issuecomment-534565595 ## CI report: * 6bc9773c54eed0b1646ec67413cb3855c1057d87 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction

flinkbot edited a comment on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction URL: https://github.com/apache/flink/pull/9823#issuecomment-536781542 ## CI report: * 2b5531b068338321eb04cdf71714eae0d088ec0e : FAILURE

[GitHub] [flink] TisonKun commented on issue #9878: [FLINK-14149][coordination] Implement ZooKeeperLeaderElectionServiceNG

TisonKun commented on issue #9878: [FLINK-14149][coordination] Implement ZooKeeperLeaderElectionServiceNG URL: https://github.com/apache/flink/pull/9878#issuecomment-541282493 `LeaderStore` in this pull request is mainly for preview. If this patch is good to go, I'm ok to exclude

[GitHub] [flink] flinkbot edited a comment on issue #9883: [FLINK-13818][web]: Check whether web submission are enabled

flinkbot edited a comment on issue #9883: [FLINK-13818][web]: Check whether web submission are enabled URL: https://github.com/apache/flink/pull/9883#issuecomment-541277967 ## CI report: * d0647856d0adbe2fdb4ac79dae44e383dd3eb44d : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect

flinkbot edited a comment on issue #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect URL: https://github.com/apache/flink/pull/9866#issuecomment-539968272 ## CI report: *

[GitHub] [flink] ifndef-SleePy commented on issue #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering

ifndef-SleePy commented on issue #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering URL: https://github.com/apache/flink/pull/9853#issuecomment-541281220 @flinkbot attention @pnowojski This is an

[GitHub] [flink] flinkbot edited a comment on issue #9860: [FLINK-14331][runtime] Reset vertices right after they transition to terminated states

flinkbot edited a comment on issue #9860: [FLINK-14331][runtime] Reset vertices right after they transition to terminated states URL: https://github.com/apache/flink/pull/9860#issuecomment-539900648 ## CI report: * 80c100513c089a9dd0930aa547383ae970c4e7f8 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9843: [FLINK-14296] [Table SQL] Use Optional for optional parameters in parser module

flinkbot edited a comment on issue #9843: [FLINK-14296] [Table SQL] Use Optional for optional parameters in parser module URL: https://github.com/apache/flink/pull/9843#issuecomment-538718823 ## CI report: * a9b3b6131bc282e47937d4eb4d9db4ab952ccd1a : CANCELED

[GitHub] [flink] flinkbot edited a comment on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction

flinkbot edited a comment on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction URL: https://github.com/apache/flink/pull/9823#issuecomment-536781542 ## CI report: * 2b5531b068338321eb04cdf71714eae0d088ec0e : FAILURE

[GitHub] [flink] JingsongLi commented on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction

JingsongLi commented on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction URL: https://github.com/apache/flink/pull/9823#issuecomment-541280487 LGTM This is an automated message from

[GitHub] [flink] wangxlong commented on a change in pull request #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction

wangxlong commented on a change in pull request #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction URL: https://github.com/apache/flink/pull/9823#discussion_r334218530 ## File path:

[GitHub] [flink] jinglining removed a comment on issue #9859: [FLINK-11405][rest]rest api can more exceptions by query parameter

jinglining removed a comment on issue #9859: [FLINK-11405][rest]rest api can more exceptions by query parameter URL: https://github.com/apache/flink/pull/9859#issuecomment-540292931 > Please provide a description on what exactly you're trying to accomplish in the JIRA.

[GitHub] [flink] jinglining commented on issue #9859: [FLINK-11405][rest]rest api can more exceptions by query parameter

jinglining commented on issue #9859: [FLINK-11405][rest]rest api can more exceptions by query parameter URL: https://github.com/apache/flink/pull/9859#issuecomment-541280145 @zentol I have update the JIRA, could you open it?

[GitHub] [flink] zhuzhurk commented on a change in pull request #9860: [FLINK-14331][runtime] Reset vertices right after they transition to terminated states

zhuzhurk commented on a change in pull request #9860: [FLINK-14331][runtime] Reset vertices right after they transition to terminated states URL: https://github.com/apache/flink/pull/9860#discussion_r334218371 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9884: [FLINK-14266][table] Introduce RowCsvInputFormat to new CSV module

flinkbot edited a comment on issue #9884: [FLINK-14266][table] Introduce RowCsvInputFormat to new CSV module URL: https://github.com/apache/flink/pull/9884#issuecomment-541277981 ## CI report: * bbabed91379f6c9a9a9b10e8d4b4d0037a76af94 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9883: [FLINK-13818][web]: Check whether web submission are enabled

flinkbot edited a comment on issue #9883: [FLINK-13818][web]: Check whether web submission are enabled URL: https://github.com/apache/flink/pull/9883#issuecomment-541277967 ## CI report: * d0647856d0adbe2fdb4ac79dae44e383dd3eb44d : PENDING

[GitHub] [flink] wuchong commented on a change in pull request #9843: [FLINK-14296] [Table SQL] Use Optional for optional parameters in parser module

wuchong commented on a change in pull request #9843: [FLINK-14296] [Table SQL] Use Optional for optional parameters in parser module URL: https://github.com/apache/flink/pull/9843#discussion_r334218176 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #9843: [FLINK-14296] [Table SQL] Use Optional for optional parameters in parser module

wuchong commented on a change in pull request #9843: [FLINK-14296] [Table SQL] Use Optional for optional parameters in parser module URL: https://github.com/apache/flink/pull/9843#discussion_r334218311 ## File path:

[GitHub] [flink] zhuzhurk commented on issue #9860: [FLINK-14331][runtime] Reset vertices right after they transition to terminated states

zhuzhurk commented on issue #9860: [FLINK-14331][runtime] Reset vertices right after they transition to terminated states URL: https://github.com/apache/flink/pull/9860#issuecomment-541279533 @flinkbot run travis This is an

[GitHub] [flink] flinkbot edited a comment on issue #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect

flinkbot edited a comment on issue #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect URL: https://github.com/apache/flink/pull/9866#issuecomment-539968272 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #9843: [FLINK-14296] [Table SQL] Use Optional for optional parameters in parser module

flinkbot edited a comment on issue #9843: [FLINK-14296] [Table SQL] Use Optional for optional parameters in parser module URL: https://github.com/apache/flink/pull/9843#issuecomment-538718823 ## CI report: * a9b3b6131bc282e47937d4eb4d9db4ab952ccd1a : CANCELED

[GitHub] [flink] wangxlong commented on a change in pull request #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction

wangxlong commented on a change in pull request #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction URL: https://github.com/apache/flink/pull/9823#discussion_r334218093 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction

wuchong commented on a change in pull request #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction URL: https://github.com/apache/flink/pull/9823#discussion_r334217909 ## File path:

[jira] [Comment Edited] (FLINK-14360) Flink on yarn should support obtain delegation tokens of multi hdfs namespaces

[ https://issues.apache.org/jira/browse/FLINK-14360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16949883#comment-16949883 ] Shen Yinjie edited comment on FLINK-14360 at 10/12/19 3:09 AM: --- Thanks

[jira] [Commented] (FLINK-14360) Flink on yarn should support obtain delegation tokens of multi hdfs namespaces

[ https://issues.apache.org/jira/browse/FLINK-14360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16949883#comment-16949883 ] Shen Yinjie commented on FLINK-14360: - Thanks [~azagrebin] for comments! 1)Current "paths" only

[jira] [Comment Edited] (FLINK-14360) Flink on yarn should support obtain delegation tokens of multi hdfs namespaces

[ https://issues.apache.org/jira/browse/FLINK-14360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16949883#comment-16949883 ] Shen Yinjie edited comment on FLINK-14360 at 10/12/19 3:08 AM: --- Thanks

[GitHub] [flink] flinkbot commented on issue #9883: [FLINK-13818][web]: Check whether web submission are enabled

flinkbot commented on issue #9883: [FLINK-13818][web]: Check whether web submission are enabled URL: https://github.com/apache/flink/pull/9883#issuecomment-541277967 ## CI report: * d0647856d0adbe2fdb4ac79dae44e383dd3eb44d : UNKNOWN Bot commands The @flinkbot bot

[GitHub] [flink] flinkbot commented on issue #9884: [FLINK-14266][table] Introduce RowCsvInputFormat to new CSV module

flinkbot commented on issue #9884: [FLINK-14266][table] Introduce RowCsvInputFormat to new CSV module URL: https://github.com/apache/flink/pull/9884#issuecomment-541277981 ## CI report: * bbabed91379f6c9a9a9b10e8d4b4d0037a76af94 : UNKNOWN Bot commands The

[GitHub] [flink] wangxlong commented on a change in pull request #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction

wangxlong commented on a change in pull request #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction URL: https://github.com/apache/flink/pull/9823#discussion_r334217609 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9843: [FLINK-14296] [Table SQL] Use Optional for optional parameters in parser module

flinkbot edited a comment on issue #9843: [FLINK-14296] [Table SQL] Use Optional for optional parameters in parser module URL: https://github.com/apache/flink/pull/9843#issuecomment-538718823 ## CI report: * a9b3b6131bc282e47937d4eb4d9db4ab952ccd1a : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction

flinkbot edited a comment on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction URL: https://github.com/apache/flink/pull/9823#issuecomment-536781542 ## CI report: * 2b5531b068338321eb04cdf71714eae0d088ec0e : FAILURE

[jira] [Commented] (FLINK-14296) SqlNodes in the parser module should use an Optional for optional parameters

[ https://issues.apache.org/jira/browse/FLINK-14296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16949876#comment-16949876 ] Jiayi Liao commented on FLINK-14296: [~dwysakowicz] [~jark] Thanks for pointing this out. The PR can

[GitHub] [flink] TisonKun commented on issue #9882: [FLINK-1430][Flink-Core] Type Extractor Setter

TisonKun commented on issue #9882: [FLINK-1430][Flink-Core] Type Extractor Setter URL: https://github.com/apache/flink/pull/9882#issuecomment-541276637 I don't think this pull request bound to FLINK-1430 though... @ElliotVilhelm

[GitHub] [flink] buptljy commented on issue #9843: [FLINK-14296] [Table SQL] Use Optional for optional parameters in parser module

buptljy commented on issue #9843: [FLINK-14296] [Table SQL] Use Optional for optional parameters in parser module URL: https://github.com/apache/flink/pull/9843#issuecomment-541276324 > As per the [code style

[GitHub] [flink] buptljy commented on issue #9843: [FLINK-14296] [Table SQL] Use Optional for optional parameters in parser module

buptljy commented on issue #9843: [FLINK-14296] [Table SQL] Use Optional for optional parameters in parser module URL: https://github.com/apache/flink/pull/9843#issuecomment-541276393 @flinkbot run travis This is an

[GitHub] [flink] JingsongLi commented on a change in pull request #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction

JingsongLi commented on a change in pull request #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction URL: https://github.com/apache/flink/pull/9823#discussion_r334216910 ## File path:

[GitHub] [flink] flinkbot commented on issue #9884: [FLINK-14266][table] Introduce RowCsvInputFormat to new CSV module

flinkbot commented on issue #9884: [FLINK-14266][table] Introduce RowCsvInputFormat to new CSV module URL: https://github.com/apache/flink/pull/9884#issuecomment-541276093 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] [flink] flinkbot commented on issue #9883: [FLINK-13818][web]: Check whether web submission are enabled

flinkbot commented on issue #9883: [FLINK-13818][web]: Check whether web submission are enabled URL: https://github.com/apache/flink/pull/9883#issuecomment-541275967 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[GitHub] [flink] JingsongLi opened a new pull request #9884: [FLINK-14266][table] Introduce RowCsvInputFormat to new CSV module

JingsongLi opened a new pull request #9884: [FLINK-14266][table] Introduce RowCsvInputFormat to new CSV module URL: https://github.com/apache/flink/pull/9884 ## What is the purpose of the change Now, we have an old CSV, but that is not standard CSV support. we should support the

[jira] [Updated] (FLINK-14266) Introduce RowCsvInputFormat to new CSV module

[ https://issues.apache.org/jira/browse/FLINK-14266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14266: --- Labels: pull-request-available (was: ) > Introduce RowCsvInputFormat to new CSV module >

[jira] [Updated] (FLINK-13818) Check whether web submission are enabled

[ https://issues.apache.org/jira/browse/FLINK-13818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13818: --- Labels: pull-request-available (was: ) > Check whether web submission are enabled >

[GitHub] [flink] vthinkxie opened a new pull request #9883: [FLINK-13818][web]: Check whether web submission are enabled

vthinkxie opened a new pull request #9883: [FLINK-13818][web]: Check whether web submission are enabled URL: https://github.com/apache/flink/pull/9883 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server,

[GitHub] [flink] wuchong commented on a change in pull request #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction

wuchong commented on a change in pull request #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction URL: https://github.com/apache/flink/pull/9823#discussion_r334216716 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction

JingsongLi commented on a change in pull request #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction URL: https://github.com/apache/flink/pull/9823#discussion_r334216454 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction

flinkbot edited a comment on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction URL: https://github.com/apache/flink/pull/9823#issuecomment-536781542 ## CI report: * 2b5531b068338321eb04cdf71714eae0d088ec0e : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction

flinkbot edited a comment on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction URL: https://github.com/apache/flink/pull/9823#issuecomment-536781542 ## CI report: * 2b5531b068338321eb04cdf71714eae0d088ec0e : FAILURE

[GitHub] [flink] klion26 commented on a change in pull request #9882: [FLINK-1430][Flink-Core] Type Extractor Setter

klion26 commented on a change in pull request #9882: [FLINK-1430][Flink-Core] Type Extractor Setter URL: https://github.com/apache/flink/pull/9882#discussion_r334214888 ## File path: flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java ## @@

[GitHub] [flink] openinx commented on a change in pull request #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect

openinx commented on a change in pull request #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect URL: https://github.com/apache/flink/pull/9866#discussion_r334214024 ## File path:

[GitHub] [flink] TisonKun commented on issue #9852: [FLINK-14343][coordination] Remove uncompleted YARNHighAvailabilityService

TisonKun commented on issue #9852: [FLINK-14343][coordination] Remove uncompleted YARNHighAvailabilityService URL: https://github.com/apache/flink/pull/9852#issuecomment-541266449 Thanks for your review @tillrohrmann ! This

[GitHub] [flink] TisonKun commented on a change in pull request #9880: [FLINK-14347][test] Filter out expected exception string in YARN tests

TisonKun commented on a change in pull request #9880: [FLINK-14347][test] Filter out expected exception string in YARN tests URL: https://github.com/apache/flink/pull/9880#discussion_r334212438 ## File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java

[GitHub] [flink] flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#issuecomment-523769032 ## CI report: * 6107a00876759dcef075592c8bfa56764f66b6fa : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#issuecomment-523769032 ## CI report: * 6107a00876759dcef075592c8bfa56764f66b6fa : FAILURE

[GitHub] [flink] bremac commented on issue #9854: [FLINK-14230][task] Change the endInput call of the downstream operator to after the upstream operator closes

bremac commented on issue #9854: [FLINK-14230][task] Change the endInput call of the downstream operator to after the upstream operator closes URL: https://github.com/apache/flink/pull/9854#issuecomment-541249326 If this PR is reverting #9221, perhaps it should revert this line too?

[GitHub] [flink] flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#issuecomment-523769032 ## CI report: * 6107a00876759dcef075592c8bfa56764f66b6fa : FAILURE

[GitHub] [flink] carp84 commented on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

carp84 commented on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#issuecomment-541245502 bq. Some of the tests seem to be a bit convoluted with a lot of indirections which are not easy

[GitHub] [flink] carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r334193967 ## File path:

[GitHub] [flink] carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r334193401 ## File path:

[GitHub] [flink] carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r334190093 ## File path:

[GitHub] [flink] carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r334189729 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#issuecomment-523769032 ## CI report: * 6107a00876759dcef075592c8bfa56764f66b6fa : FAILURE

[GitHub] [flink] carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r334180670 ## File path:

[GitHub] [flink] carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r334180018 ## File path:

[GitHub] [flink] carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r334177724 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#issuecomment-523769032 ## CI report: * 6107a00876759dcef075592c8bfa56764f66b6fa : FAILURE

  1   2   3   4   5   >