[GitHub] [flink] xintongsong commented on issue #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args

xintongsong commented on issue #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args URL: https://github.com/apache/flink/pull/11545#issuecomment-613833551 Thanks @azagrebin, comments addressed.

[GitHub] [flink] leonardBang commented on issue #11466: [FLINK-15400][connectors / elasticsearch] elasticsearch table sink support dynamic index.

leonardBang commented on issue #11466: [FLINK-15400][connectors / elasticsearch] elasticsearch table sink support dynamic index. URL: https://github.com/apache/flink/pull/11466#issuecomment-613833378 > Hi @leonardBang , what's the progress of this pr? waiting for review 藍, CC:

[GitHub] [flink] hequn8128 commented on a change in pull request #11724: [FLINK-16486][python][docs] Add documentation for vectorized Python UDF

hequn8128 commented on a change in pull request #11724: [FLINK-16486][python][docs] Add documentation for vectorized Python UDF URL: https://github.com/apache/flink/pull/11724#discussion_r408595195 ## File path: docs/dev/table/python/vectorized_python_udfs.md ## @@ -0,0

[GitHub] [flink] hequn8128 commented on a change in pull request #11724: [FLINK-16486][python][docs] Add documentation for vectorized Python UDF

hequn8128 commented on a change in pull request #11724: [FLINK-16486][python][docs] Add documentation for vectorized Python UDF URL: https://github.com/apache/flink/pull/11724#discussion_r408594055 ## File path: docs/dev/table/python/vectorized_python_udfs.md ## @@ -0,0

[GitHub] [flink] flinkbot edited a comment on issue #11711: [FLINK-17103][table-planner-blink] Supports dynamic options for Blink…

flinkbot edited a comment on issue #11711: [FLINK-17103][table-planner-blink] Supports dynamic options for Blink… URL: https://github.com/apache/flink/pull/11711#issuecomment-612758431 ## CI report: * 3ea01f3d73194e787d483bc463ddaa5b58a3dd9f Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11717: [FLINK-17093][python][table-planner][table-planner-blink] Fix Python UDF to make it work with inputs from composite field

flinkbot edited a comment on issue #11717: [FLINK-17093][python][table-planner][table-planner-blink] Fix Python UDF to make it work with inputs from composite field URL: https://github.com/apache/flink/pull/11717#issuecomment-612882448 ## CI report: *

[GitHub] [flink] dianfu commented on issue #11717: [FLINK-17093][python][table-planner][table-planner-blink] Fix Python UDF to make it work with inputs from composite field

dianfu commented on issue #11717: [FLINK-17093][python][table-planner][table-planner-blink] Fix Python UDF to make it work with inputs from composite field URL: https://github.com/apache/flink/pull/11717#issuecomment-613831240 The test failure of Azure is a known issue tracked in

[jira] [Commented] (FLINK-16572) CheckPubSubEmulatorTest is flaky on Azure

[ https://issues.apache.org/jira/browse/FLINK-16572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083816#comment-17083816 ] Dian Fu commented on FLINK-16572: - Another instance: 

[GitHub] [flink] flinkbot edited a comment on issue #11745: [FLINK-17133] [Table SQL/API] Support CsvParser Features for CSV form…

flinkbot edited a comment on issue #11745: [FLINK-17133] [Table SQL/API] Support CsvParser Features for CSV form… URL: https://github.com/apache/flink/pull/11745#issuecomment-613814332 ## CI report: * 4ce6d27ebc0bc4856c73ecb42724cc5650053b38 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11717: [FLINK-17093][python][table-planner][table-planner-blink] Fix Python UDF to make it work with inputs from composite field

flinkbot edited a comment on issue #11717: [FLINK-17093][python][table-planner][table-planner-blink] Fix Python UDF to make it work with inputs from composite field URL: https://github.com/apache/flink/pull/11717#issuecomment-612882448 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args

flinkbot edited a comment on issue #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args URL: https://github.com/apache/flink/pull/11545#issuecomment-604848813 ## CI report: * 46b64a4339ed27315eee1eb2d8d877c8dfaae993

[GitHub] [flink] danny0405 commented on a change in pull request #11711: [FLINK-17103][table-planner-blink] Supports dynamic options for Blink…

danny0405 commented on a change in pull request #11711: [FLINK-17103][table-planner-blink] Supports dynamic options for Blink… URL: https://github.com/apache/flink/pull/11711#discussion_r408587966 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #11711: [FLINK-17103][table-planner-blink] Supports dynamic options for Blink…

danny0405 commented on a change in pull request #11711: [FLINK-17103][table-planner-blink] Supports dynamic options for Blink… URL: https://github.com/apache/flink/pull/11711#discussion_r408586396 ## File path:

[jira] [Commented] (FLINK-16962) Convert DatadogReporter to plugin

[ https://issues.apache.org/jira/browse/FLINK-16962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083802#comment-17083802 ] molsion commented on FLINK-16962: - If no one can deal with the issue, can you assign it to me? >

[GitHub] [flink] flinkbot edited a comment on issue #11745: [FLINK-17133] [Table SQL/API] Support CsvParser Features for CSV form…

flinkbot edited a comment on issue #11745: [FLINK-17133] [Table SQL/API] Support CsvParser Features for CSV form… URL: https://github.com/apache/flink/pull/11745#issuecomment-613814332 ## CI report: * 4ce6d27ebc0bc4856c73ecb42724cc5650053b38 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11734: [FLINK-14713][rest]Show All Attempts For Vertex SubTask In Rest Api

flinkbot edited a comment on issue #11734: [FLINK-14713][rest]Show All Attempts For Vertex SubTask In Rest Api URL: https://github.com/apache/flink/pull/11734#issuecomment-613396242 ## CI report: * b619054eb53f92507c905b101598374a12be322c Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11742: [FLINK-16770][checkpoint] Avoid dispose checkpoint during async finalization of pendingcheckpoint

flinkbot edited a comment on issue #11742: [FLINK-16770][checkpoint] Avoid dispose checkpoint during async finalization of pendingcheckpoint URL: https://github.com/apache/flink/pull/11742#issuecomment-613607174 ## CI report: * 3f205fca8d3d3385eb80dd7f2d9bfd9e3d6ccc37 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Avoid caching buffers for blocked input channels before barrier alignment

flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Avoid caching buffers for blocked input channels before barrier alignment URL: https://github.com/apache/flink/pull/11351#issuecomment-596351676 ## CI report: * 715889a35cfcc3aaf1b17f39dadaa86f755cc75d UNKNOWN

[jira] [Commented] (FLINK-16967) Convert Slf4j reporter to plugin

[ https://issues.apache.org/jira/browse/FLINK-16967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083798#comment-17083798 ] molsion commented on FLINK-16967: - If no one work for this issue , i can work it. > Convert Slf4j

[GitHub] [flink] flinkbot commented on issue #11745: [FLINK-17133] [Table SQL/API] Support CsvParser Features for CSV form…

flinkbot commented on issue #11745: [FLINK-17133] [Table SQL/API] Support CsvParser Features for CSV form… URL: https://github.com/apache/flink/pull/11745#issuecomment-613814332 ## CI report: * 4ce6d27ebc0bc4856c73ecb42724cc5650053b38 UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on issue #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args

flinkbot edited a comment on issue #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args URL: https://github.com/apache/flink/pull/11545#issuecomment-604848813 ## CI report: * 7e5cae7e3825eb84d974708caa195e39dd9d8bfd

[GitHub] [flink] flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Avoid caching buffers for blocked input channels before barrier alignment

flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Avoid caching buffers for blocked input channels before barrier alignment URL: https://github.com/apache/flink/pull/11351#issuecomment-596351676 ## CI report: * 715889a35cfcc3aaf1b17f39dadaa86f755cc75d UNKNOWN

[GitHub] [flink] zhijiangW commented on a change in pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

zhijiangW commented on a change in pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint URL: https://github.com/apache/flink/pull/11687#discussion_r408575571 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11717: [FLINK-17093][python][table-planner][table-planner-blink] Fix Python UDF to make it work with inputs from composite field

flinkbot edited a comment on issue #11717: [FLINK-17093][python][table-planner][table-planner-blink] Fix Python UDF to make it work with inputs from composite field URL: https://github.com/apache/flink/pull/11717#issuecomment-612882448 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #11726: [FLINK-17128][table] Add isBounded to TableSinkFactory#Context

flinkbot edited a comment on issue #11726: [FLINK-17128][table] Add isBounded to TableSinkFactory#Context URL: https://github.com/apache/flink/pull/11726#issuecomment-613258923 ## CI report: * 7618afd25170b1e5fcf12ebab4443558c13a8a50 Travis:

[GitHub] [flink] zhijiangW commented on a change in pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

zhijiangW commented on a change in pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint URL: https://github.com/apache/flink/pull/11687#discussion_r408574292 ## File path:

[GitHub] [flink] flinkbot commented on issue #11745: [FLINK-17133] [Table SQL/API] Support CsvParser Features for CSV form…

flinkbot commented on issue #11745: [FLINK-17133] [Table SQL/API] Support CsvParser Features for CSV form… URL: https://github.com/apache/flink/pull/11745#issuecomment-613810067 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Avoid caching buffers for blocked input channels before barrier alignment

flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Avoid caching buffers for blocked input channels before barrier alignment URL: https://github.com/apache/flink/pull/11351#issuecomment-596351676 ## CI report: * 715889a35cfcc3aaf1b17f39dadaa86f755cc75d UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args

flinkbot edited a comment on issue #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args URL: https://github.com/apache/flink/pull/11545#issuecomment-604848813 ## CI report: * 7e5cae7e3825eb84d974708caa195e39dd9d8bfd

[GitHub] [flink] yuchuanchen opened a new pull request #11745: [FLINK-17133] [Table SQL/API] Support CsvParser Features for CSV form…

yuchuanchen opened a new pull request #11745: [FLINK-17133] [Table SQL/API] Support CsvParser Features for CSV form… URL: https://github.com/apache/flink/pull/11745 ## What is the purpose of the change Support [CsvParser

[jira] [Updated] (FLINK-17133) Support CsvParser Features for CSV format via SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-17133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17133: --- Labels: pull-request-available (was: ) > Support CsvParser Features for CSV format via SQL

[GitHub] [flink] yuchuanchen closed pull request #11744: [FLINK-17133][Table SQL/API] Support CsvParser Features for CSV format via SQL DDL

yuchuanchen closed pull request #11744: [FLINK-17133][Table SQL/API] Support CsvParser Features for CSV format via SQL DDL URL: https://github.com/apache/flink/pull/11744 This is an automated message from the Apache Git

[GitHub] [flink] zhijiangW commented on a change in pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

zhijiangW commented on a change in pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint URL: https://github.com/apache/flink/pull/11687#discussion_r408569446 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

zhijiangW commented on a change in pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint URL: https://github.com/apache/flink/pull/11687#discussion_r408569272 ## File path:

[jira] [Updated] (FLINK-17133) Support CsvParser Features for CSV format via SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-17133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Chen updated FLINK-17133: - Component/s: (was: Connectors / Kafka) > Support CsvParser Features for CSV format via SQL DDL >

[GitHub] [flink] wsry commented on a change in pull request #11351: [FLINK-16404][runtime] Avoid caching buffers for blocked input channels before barrier alignment

wsry commented on a change in pull request #11351: [FLINK-16404][runtime] Avoid caching buffers for blocked input channels before barrier alignment URL: https://github.com/apache/flink/pull/11351#discussion_r408568257 ## File path:

[GitHub] [flink] flinkbot commented on issue #11744: [FLINK-17133][Table SQL/API] Support CsvParser Features for CSV format via SQL DDL

flinkbot commented on issue #11744: [FLINK-17133][Table SQL/API] Support CsvParser Features for CSV format via SQL DDL URL: https://github.com/apache/flink/pull/11744#issuecomment-613803547 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] yuchuanchen opened a new pull request #11744: [Flink 17133][Table SQL/API] Support CsvParser Features for CSV format via SQL DDL

yuchuanchen opened a new pull request #11744: [Flink 17133][Table SQL/API] Support CsvParser Features for CSV format via SQL DDL URL: https://github.com/apache/flink/pull/11744 ## What is the purpose of the change Support [CsvParser

[GitHub] [flink] wangyang0918 edited a comment on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous

wangyang0918 edited a comment on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous URL: https://github.com/apache/flink/pull/11427#issuecomment-613795334 @azagrebin Thanks for the additional comments. First, i agree with you after these changes,

[GitHub] [flink] flinkbot edited a comment on issue #11742: [FLINK-16770][checkpoint] Avoid dispose checkpoint during async finalization of pendingcheckpoint

flinkbot edited a comment on issue #11742: [FLINK-16770][checkpoint] Avoid dispose checkpoint during async finalization of pendingcheckpoint URL: https://github.com/apache/flink/pull/11742#issuecomment-613607174 ## CI report: * 91051213112fc562af8f7e51c3b10fb650f3ea3b Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11734: [FLINK-14713][rest]Show All Attempts For Vertex SubTask In Rest Api

flinkbot edited a comment on issue #11734: [FLINK-14713][rest]Show All Attempts For Vertex SubTask In Rest Api URL: https://github.com/apache/flink/pull/11734#issuecomment-613396242 ## CI report: * b619054eb53f92507c905b101598374a12be322c Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11743: [FLINK-15827][runtime][coordination] Deprecate unused taskmanager.registration.* options

flinkbot edited a comment on issue #11743: [FLINK-15827][runtime][coordination] Deprecate unused taskmanager.registration.* options URL: https://github.com/apache/flink/pull/11743#issuecomment-613752677 ## CI report: * 36914420a6e26355a6012170fa033a8f3b93dbe8 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11717: [FLINK-17093][python][table-planner][table-planner-blink] Fix Python UDF to make it work with inputs from composite field

flinkbot edited a comment on issue #11717: [FLINK-17093][python][table-planner][table-planner-blink] Fix Python UDF to make it work with inputs from composite field URL: https://github.com/apache/flink/pull/11717#issuecomment-612882448 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args

flinkbot edited a comment on issue #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args URL: https://github.com/apache/flink/pull/11545#issuecomment-604848813 ## CI report: * 7e5cae7e3825eb84d974708caa195e39dd9d8bfd

[jira] [Commented] (FLINK-16921) "kubernetes session test" is unstable

[ https://issues.apache.org/jira/browse/FLINK-16921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083771#comment-17083771 ] Yang Wang commented on FLINK-16921: --- [~dian.fu] [~zjwang] Thanks for sharing more instances. I have

[GitHub] [flink] flinkbot edited a comment on issue #11742: [FLINK-16770][checkpoint] Avoid dispose checkpoint during async finalization of pendingcheckpoint

flinkbot edited a comment on issue #11742: [FLINK-16770][checkpoint] Avoid dispose checkpoint during async finalization of pendingcheckpoint URL: https://github.com/apache/flink/pull/11742#issuecomment-613607174 ## CI report: * 91051213112fc562af8f7e51c3b10fb650f3ea3b Travis:

[jira] [Closed] (FLINK-16748) Add Python UDTF doc

[ https://issues.apache.org/jira/browse/FLINK-16748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16748. --- Resolution: Resolved > Add Python UDTF doc > --- > > Key:

[GitHub] [flink] hequn8128 merged pull request #11531: [FLINK-16748][python][doc] Add Python UDTF doc

hequn8128 merged pull request #11531: [FLINK-16748][python][doc] Add Python UDTF doc URL: https://github.com/apache/flink/pull/11531 This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-16748) Add Python UDTF doc

[ https://issues.apache.org/jira/browse/FLINK-16748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083765#comment-17083765 ] Hequn Cheng commented on FLINK-16748: - Resolved in 1.11.0 via

[jira] [Assigned] (FLINK-16748) Add Python UDTF doc

[ https://issues.apache.org/jira/browse/FLINK-16748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-16748: --- Assignee: Huang Xingbo > Add Python UDTF doc > --- > >

[GitHub] [flink] hequn8128 commented on issue #11531: [FLINK-16748][python][doc] Add Python UDTF doc

hequn8128 commented on issue #11531: [FLINK-16748][python][doc] Add Python UDTF doc URL: https://github.com/apache/flink/pull/11531#issuecomment-613795774 @HuangXingBo Thanks a lot for the update. Merging... This is an

[GitHub] [flink] wangyang0918 commented on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous

wangyang0918 commented on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous URL: https://github.com/apache/flink/pull/11427#issuecomment-613795334 @azagrebin Thanks for the additional comments. First, i agree with you after these changes,

[jira] [Updated] (FLINK-13811) Support converting flink table to pandas dataframe

[ https://issues.apache.org/jira/browse/FLINK-13811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-13811: --- Description: Pandas dataframe is the de facto standard tableau data format of python community. It

[jira] [Created] (FLINK-17150) Introduce Canal format to support reading canal changelogs

Jark Wu created FLINK-17150: --- Summary: Introduce Canal format to support reading canal changelogs Key: FLINK-17150 URL: https://issues.apache.org/jira/browse/FLINK-17150 Project: Flink Issue Type:

[jira] [Created] (FLINK-17149) Introduce Debezium format to support reading debezium changelogs

Jark Wu created FLINK-17149: --- Summary: Introduce Debezium format to support reading debezium changelogs Key: FLINK-17149 URL: https://issues.apache.org/jira/browse/FLINK-17149 Project: Flink

[jira] [Created] (FLINK-17148) Support converting pandas dataframe to flink table

Dian Fu created FLINK-17148: --- Summary: Support converting pandas dataframe to flink table Key: FLINK-17148 URL: https://issues.apache.org/jira/browse/FLINK-17148 Project: Flink Issue Type:

[jira] [Commented] (FLINK-17138) LocalExecutorITCase.testParameterizedTypes failed on travis

[ https://issues.apache.org/jira/browse/FLINK-17138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083763#comment-17083763 ] Rui Li commented on FLINK-17138: Actually some test cases are intended to test LocalExecutor with Hive

[jira] [Updated] (FLINK-13811) Support converting flink table to pandas dataframe

[ https://issues.apache.org/jira/browse/FLINK-13811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-13811: Parent: FLINK-17146 Issue Type: Sub-task (was: New Feature) > Support converting flink table to

[jira] [Created] (FLINK-17147) Remove dynamic table options from table source table digest

Danny Chen created FLINK-17147: -- Summary: Remove dynamic table options from table source table digest Key: FLINK-17147 URL: https://issues.apache.org/jira/browse/FLINK-17147 Project: Flink

[jira] [Updated] (FLINK-15331) Create a table from a changelog

[ https://issues.apache.org/jira/browse/FLINK-15331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-15331: Fix Version/s: 1.11.0 > Create a table from a changelog > --- > >

[jira] [Commented] (FLINK-17137) Support mini batch for WindowOperator in blink planner

[ https://issues.apache.org/jira/browse/FLINK-17137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083760#comment-17083760 ] Benchao Li commented on FLINK-17137: OK, I'll attach a design documentation in a few days. >

[jira] [Created] (FLINK-17146) Support conversion between PyFlink Table and Pandas DataFrame

Dian Fu created FLINK-17146: --- Summary: Support conversion between PyFlink Table and Pandas DataFrame Key: FLINK-17146 URL: https://issues.apache.org/jira/browse/FLINK-17146 Project: Flink Issue

[jira] [Commented] (FLINK-16113) ExpressionReducer shouldn't escape the reduced string value

[ https://issues.apache.org/jira/browse/FLINK-16113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083759#comment-17083759 ] Benchao Li commented on FLINK-16113: [~jark] sure, I'd like to do it. > ExpressionReducer shouldn't

[jira] [Commented] (FLINK-17133) Support CsvParser Features for CSV format via SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-17133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083757#comment-17083757 ] Jark Wu commented on FLINK-17133: - I think it's reasonable to support them if they are needed for Flink

[jira] [Comment Edited] (FLINK-16113) ExpressionReducer shouldn't escape the reduced string value

[ https://issues.apache.org/jira/browse/FLINK-16113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083756#comment-17083756 ] Jark Wu edited comment on FLINK-16113 at 4/15/20, 3:12 AM: --- Sure. Would you

[jira] [Commented] (FLINK-16113) ExpressionReducer shouldn't escape the reduced string value

[ https://issues.apache.org/jira/browse/FLINK-16113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083756#comment-17083756 ] Jark Wu commented on FLINK-16113: - Sure. Would like like to open a pull request for 1.9 branch? There

[jira] [Comment Edited] (FLINK-17138) LocalExecutorITCase.testParameterizedTypes failed on travis

[ https://issues.apache.org/jira/browse/FLINK-17138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083754#comment-17083754 ] Jingsong Lee edited comment on FLINK-17138 at 4/15/20, 3:10 AM: CC:

[jira] [Commented] (FLINK-17138) LocalExecutorITCase.testParameterizedTypes failed on travis

[ https://issues.apache.org/jira/browse/FLINK-17138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083754#comment-17083754 ] Jingsong Lee commented on FLINK-17138: -- CC: [~lirui] Just like [~twalthr] said, maybe we should let

[jira] [Commented] (FLINK-17137) Support mini batch for WindowOperator in blink planner

[ https://issues.apache.org/jira/browse/FLINK-17137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083753#comment-17083753 ] Jark Wu commented on FLINK-17137: - We need a brief design documentation to explain how to support

[GitHub] [flink] flinkbot edited a comment on issue #11726: [FLINK-17128][table] Add isBounded to TableSinkFactory#Context

flinkbot edited a comment on issue #11726: [FLINK-17128][table] Add isBounded to TableSinkFactory#Context URL: https://github.com/apache/flink/pull/11726#issuecomment-613258923 ## CI report: * c1dc3facd8d02fd5bebc1919d12cce372b681a91 Travis:

[jira] [Commented] (FLINK-16100) Translate "Reading & Writing Hive Tables" page of "Hive Integration" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083751#comment-17083751 ] Jark Wu commented on FLINK-16100: - Assign this issue to you [~Minda Mei]. > Translate "Reading &

[jira] [Assigned] (FLINK-16100) Translate "Reading & Writing Hive Tables" page of "Hive Integration" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-16100: --- Assignee: Meiminda > Translate "Reading & Writing Hive Tables" page of "Hive Integration" into >

[GitHub] [flink] Myasuka commented on issue #11742: [FLINK-16770][checkpoint] Avoid dispose checkpoint during async finalization of pendingcheckpoint

Myasuka commented on issue #11742: [FLINK-16770][checkpoint] Avoid dispose checkpoint during async finalization of pendingcheckpoint URL: https://github.com/apache/flink/pull/11742#issuecomment-613789126 @ifndef-SleePy Already fix the broken tests by allowing pending checkpoint could

[jira] [Commented] (FLINK-17138) LocalExecutorITCase.testParameterizedTypes failed on travis

[ https://issues.apache.org/jira/browse/FLINK-17138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083750#comment-17083750 ] Jark Wu commented on FLINK-17138: - cc [~lzljs3620320]   > LocalExecutorITCase.testParameterizedTypes

[jira] [Closed] (FLINK-17139) The sub-plan reuse optimizer can't reuse sub-plan that from different sql node tree 

[ https://issues.apache.org/jira/browse/FLINK-17139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-17139. --- Resolution: Not A Problem Hi [~hackergin], [~wenlong.lwl] is correct. This is an expected behavior.

[jira] [Closed] (FLINK-17145) AggregateRemoveITCase.testAggregateRemove failed in travis

[ https://issues.apache.org/jira/browse/FLINK-17145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-17145. --- Resolution: Duplicate > AggregateRemoveITCase.testAggregateRemove failed in travis >

[jira] [Commented] (FLINK-17006) Various integration tests in table module fail with FileNotFoundException (in Rocksdb)

[ https://issues.apache.org/jira/browse/FLINK-17006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083748#comment-17083748 ] Jark Wu commented on FLINK-17006: - Another instance reported in FLINK-17140. The test case 

[jira] [Closed] (FLINK-17140) AsyncLookupJoinITCase.testAsyncJoinTemporalTableOnMultiFieldsWithUdf failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-17140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-17140. --- Fix Version/s: (was: 1.11.0) Resolution: Duplicate >

[jira] [Updated] (FLINK-17006) AggregateITCase.testDistinctGroupBy fails with FileNotFoundException (in Rocksdb)

[ https://issues.apache.org/jira/browse/FLINK-17006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-17006: Description: AggregateITCase.testDistinctGroupBy fails with FileNotFoundException (in Rocksdb) CI run:

[jira] [Updated] (FLINK-17006) Various integration tests in table module fail with FileNotFoundException (in Rocksdb)

[ https://issues.apache.org/jira/browse/FLINK-17006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-17006: Summary: Various integration tests in table module fail with FileNotFoundException (in Rocksdb) (was:

[jira] [Commented] (FLINK-17140) AsyncLookupJoinITCase.testAsyncJoinTemporalTableOnMultiFieldsWithUdf failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-17140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083747#comment-17083747 ] Jark Wu commented on FLINK-17140: - Probably caused by FLINK-16770. >

[GitHub] [flink] flinkbot edited a comment on issue #11726: [FLINK-17128][table] Add isBounded to TableSinkFactory#Context

flinkbot edited a comment on issue #11726: [FLINK-17128][table] Add isBounded to TableSinkFactory#Context URL: https://github.com/apache/flink/pull/11726#issuecomment-613258923 ## CI report: * c1dc3facd8d02fd5bebc1919d12cce372b681a91 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11734: [FLINK-14713][rest]Show All Attempts For Vertex SubTask In Rest Api

flinkbot edited a comment on issue #11734: [FLINK-14713][rest]Show All Attempts For Vertex SubTask In Rest Api URL: https://github.com/apache/flink/pull/11734#issuecomment-613396242 ## CI report: * 0eeb53aacb4950a211faf775388e3bdd38df4a13 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11531: [FLINK-16748][python][doc] Add Python UDTF doc

flinkbot edited a comment on issue #11531: [FLINK-16748][python][doc] Add Python UDTF doc URL: https://github.com/apache/flink/pull/11531#issuecomment-604443579 ## CI report: * e0206bfd6f024f6dc1b6b490fe4c1ed366f68ed0 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11717: [FLINK-17093][python][table-planner][table-planner-blink] Fix Python UDF to make it work with inputs from composite field

flinkbot edited a comment on issue #11717: [FLINK-17093][python][table-planner][table-planner-blink] Fix Python UDF to make it work with inputs from composite field URL: https://github.com/apache/flink/pull/11717#issuecomment-612882448 ## CI report: *

[GitHub] [flink] wuchong commented on a change in pull request #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks

wuchong commented on a change in pull request #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks URL: https://github.com/apache/flink/pull/11692#discussion_r408547579 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11717: [FLINK-17093][python][table-planner][table-planner-blink] Fix Python UDF to make it work with inputs from composite field

flinkbot edited a comment on issue #11717: [FLINK-17093][python][table-planner][table-planner-blink] Fix Python UDF to make it work with inputs from composite field URL: https://github.com/apache/flink/pull/11717#issuecomment-612882448 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #11734: [FLINK-14713][rest]Show All Attempts For Vertex SubTask In Rest Api

flinkbot edited a comment on issue #11734: [FLINK-14713][rest]Show All Attempts For Vertex SubTask In Rest Api URL: https://github.com/apache/flink/pull/11734#issuecomment-613396242 ## CI report: * 0eeb53aacb4950a211faf775388e3bdd38df4a13 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11531: [FLINK-16748][python][doc] Add Python UDTF doc

flinkbot edited a comment on issue #11531: [FLINK-16748][python][doc] Add Python UDTF doc URL: https://github.com/apache/flink/pull/11531#issuecomment-604443579 ## CI report: * e0206bfd6f024f6dc1b6b490fe4c1ed366f68ed0 Travis:

[GitHub] [flink] ifndef-SleePy commented on issue #11742: [FLINK-16770][checkpoint] Avoid dispose checkpoint during async finalization of pendingcheckpoint

ifndef-SleePy commented on issue #11742: [FLINK-16770][checkpoint] Avoid dispose checkpoint during async finalization of pendingcheckpoint URL: https://github.com/apache/flink/pull/11742#issuecomment-613778835 Hi @Myasuka , there are several unit testing cases failed. I think we should

[jira] [Commented] (FLINK-17141) Name of SQL Operator is too long

[ https://issues.apache.org/jira/browse/FLINK-17141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083740#comment-17083740 ] Jark Wu commented on FLINK-17141: - Is there a better way for this? For example, introduce a new

[jira] [Updated] (FLINK-17145) AggregateRemoveITCase.testAggregateRemove failed in travis

[ https://issues.apache.org/jira/browse/FLINK-17145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-17145: - Description: instance: [https://api.travis-ci.com/v3/job/319161311/log.txt] PR: 

[GitHub] [flink] dianfu commented on issue #11717: [FLINK-17093][python][table-planner][table-planner-blink] Fix Python UDF to make it work with inputs from composite field

dianfu commented on issue #11717: [FLINK-17093][python][table-planner][table-planner-blink] Fix Python UDF to make it work with inputs from composite field URL: https://github.com/apache/flink/pull/11717#issuecomment-613776556 @flinkbot run azure

[GitHub] [flink] dianfu commented on issue #11717: [FLINK-17093][python][table-planner][table-planner-blink] Fix Python UDF to make it work with inputs from composite field

dianfu commented on issue #11717: [FLINK-17093][python][table-planner][table-planner-blink] Fix Python UDF to make it work with inputs from composite field URL: https://github.com/apache/flink/pull/11717#issuecomment-613776518 @flinkbot run travis

[jira] [Updated] (FLINK-17141) Name of SQL Operator is too long

[ https://issues.apache.org/jira/browse/FLINK-17141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-17141: Component/s: API / DataStream > Name of SQL Operator is too long > > >

[jira] [Created] (FLINK-17145) AggregateRemoveITCase.testAggregateRemove failed in travis

Jingsong Lee created FLINK-17145: Summary: AggregateRemoveITCase.testAggregateRemove failed in travis Key: FLINK-17145 URL: https://issues.apache.org/jira/browse/FLINK-17145 Project: Flink

[GitHub] [flink] vthinkxie commented on issue #10228: [FLINK-14816] Add thread dump feature for taskmanager

vthinkxie commented on issue #10228: [FLINK-14816] Add thread dump feature for taskmanager URL: https://github.com/apache/flink/pull/10228#issuecomment-613775212 > Thanks a lot for creating this PR @lamber-ken and sorry that it took so long to get back to you. I've given your PR a round

[GitHub] [flink] HuangXingBo commented on issue #11531: [FLINK-16748][python][doc] Add Python UDTF doc

HuangXingBo commented on issue #11531: [FLINK-16748][python][doc] Add Python UDTF doc URL: https://github.com/apache/flink/pull/11531#issuecomment-613774850 Thanks a lot for @hequn8128 review, I have addressed the comments at the latest commit.

[GitHub] [flink] godfreyhe commented on issue #11671: [FLINK-17052] [client] Introduce PlanGenerator

godfreyhe commented on issue #11671: [FLINK-17052] [client] Introduce PlanGenerator URL: https://github.com/apache/flink/pull/11671#issuecomment-613774692 My private travis is green https://travis-ci.org/github/godfreyhe/flink/builds/674785749

[GitHub] [flink] godfreyhe commented on a change in pull request #11671: [FLINK-17052] [client] Introduce PlanGenerator

godfreyhe commented on a change in pull request #11671: [FLINK-17052] [client] Introduce PlanGenerator URL: https://github.com/apache/flink/pull/11671#discussion_r408539404 ## File path: flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/generator/TestUtils.java

  1   2   3   4   5   6   7   >