[jira] [Commented] (FLINK-22387) UpsertKafkaTableITCase hangs when setting up kafka

2021-04-28 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17335158#comment-17335158 ] Guowei Ma commented on FLINK-22387: ---

[GitHub] [flink] flinkbot edited a comment on pull request #15797: [FLINK-22484][table] Add built-in MAP_KEYS, MAP_VALUES, MAP_FROM_ARRA…

2021-04-28 Thread GitBox
flinkbot edited a comment on pull request #15797: URL: https://github.com/apache/flink/pull/15797#issuecomment-828531728 ## CI report: * 32b72459e66decd79269d3718f1ee40c3d765775 Azure:

[jira] [Comment Edited] (FLINK-22285) YARNHighAvailabilityITCase hangs

2021-04-28 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17335141#comment-17335141 ] Guowei Ma edited comment on FLINK-22285 at 4/29/21, 5:44 AM: -

[jira] [Commented] (FLINK-22499) JDBC sink table-api support "sink.parallelism" ?

2021-04-28 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17335142#comment-17335142 ] Shengkai Fang commented on FLINK-22499: --- This is the feature supported in FLINK-19942. You may cp

[jira] [Updated] (FLINK-22285) YARNHighAvailabilityITCase hangs

2021-04-28 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-22285: -- Affects Version/s: 1.11.3 > YARNHighAvailabilityITCase hangs > > >

[jira] [Commented] (FLINK-22285) YARNHighAvailabilityITCase hangs

2021-04-28 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17335141#comment-17335141 ] Guowei Ma commented on FLINK-22285: ---

[jira] [Created] (FLINK-22520) KafkaSourceLegacyITCase.testMultipleSourcesOnePartition hangs

2021-04-28 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-22520: - Summary: KafkaSourceLegacyITCase.testMultipleSourcesOnePartition hangs Key: FLINK-22520 URL: https://issues.apache.org/jira/browse/FLINK-22520 Project: Flink

[jira] [Commented] (FLINK-22503) getting error on select query in flink sql

2021-04-28 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17335137#comment-17335137 ] Shengkai Fang commented on FLINK-22503: --- Hi. This is the expected error. Please call `{{SET

[jira] [Closed] (FLINK-22503) getting error on select query in flink sql

2021-04-28 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-22503. - Resolution: Not A Bug > getting error on select query in flink sql >

[jira] [Updated] (FLINK-22503) getting error on select query in flink sql

2021-04-28 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-22503: -- Component/s: (was: Table SQL / API) Table SQL / Client > getting error

[GitHub] [flink] YikSanChan closed pull request #15404: [hotfix][docs] Remove redundant import

2021-04-28 Thread GitBox
YikSanChan closed pull request #15404: URL: https://github.com/apache/flink/pull/15404 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service,

[jira] [Closed] (FLINK-20086) Add documentation for the open method of UserDefinedFunction

2021-04-28 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-20086. --- Fix Version/s: (was: 1.11.4) (was: 1.13.0) 1.13.1

[jira] [Assigned] (FLINK-20086) Add documentation for the open method of UserDefinedFunction

2021-04-28 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-20086: --- Assignee: Yik San Chan > Add documentation for the open method of UserDefinedFunction >

[GitHub] [flink] dianfu closed pull request #15795: [FLINK-20086][docs] Override UserDefinedFunction open to load resources

2021-04-28 Thread GitBox
dianfu closed pull request #15795: URL: https://github.com/apache/flink/pull/15795 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please

[jira] [Comment Edited] (FLINK-17826) Add missing custom query support on new jdbc connector

2021-04-28 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17335131#comment-17335131 ] Leonard Xu edited comment on FLINK-17826 at 4/29/21, 4:02 AM: -- Hi,

[jira] [Commented] (FLINK-17826) Add missing custom query support on new jdbc connector

2021-04-28 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17335131#comment-17335131 ] Leonard Xu commented on FLINK-17826: Hi, [~f.pompermaier]  The concern about the custom query is

[jira] [Assigned] (FLINK-22519) Have python-archives also take tar.gz

2021-04-28 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-22519: --- Assignee: Yik San Chan > Have python-archives also take tar.gz >

[jira] [Updated] (FLINK-20951) IllegalArgumentException when reading Hive parquet table if condition not contain all partitioned fields

2021-04-28 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-20951: --- Fix Version/s: (was: 1.12.4) (was: 1.13.0) > IllegalArgumentException when

[GitHub] [flink] dianfu closed pull request #15783: [hotfix][python][docs] Fix python.archives docs

2021-04-28 Thread GitBox
dianfu closed pull request #15783: URL: https://github.com/apache/flink/pull/15783 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please

[jira] [Updated] (FLINK-22519) Have python-archives also take tar.gz

2021-04-28 Thread Yik San Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yik San Chan updated FLINK-22519: - Description:

[jira] [Commented] (FLINK-20951) IllegalArgumentException when reading Hive parquet table if condition not contain all partitioned fields

2021-04-28 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17335129#comment-17335129 ] Rui Li commented on FLINK-20951: Removing the fix version since this is not easy to reproduce. And

[jira] [Updated] (FLINK-22519) Have python-archives also take tar.gz

2021-04-28 Thread Yik San Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yik San Chan updated FLINK-22519: - Description:

[jira] [Updated] (FLINK-22519) Have python-archives also take tar.gz

2021-04-28 Thread Yik San Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yik San Chan updated FLINK-22519: - Description:

[jira] [Updated] (FLINK-22519) Have python-archives also take tar.gz

2021-04-28 Thread Yik San Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yik San Chan updated FLINK-22519: - Description:

[jira] [Created] (FLINK-22519) Have python-archives also take tar.gz

2021-04-28 Thread Yik San Chan (Jira)
Yik San Chan created FLINK-22519: Summary: Have python-archives also take tar.gz Key: FLINK-22519 URL: https://issues.apache.org/jira/browse/FLINK-22519 Project: Flink Issue Type: New

[jira] [Assigned] (FLINK-22518) Translate the page of "High Availability (HA)" into Chinese

2021-04-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-22518: --- Assignee: movesan Yang > Translate the page of "High Availability (HA)" into Chinese >

[jira] [Updated] (FLINK-22497) When using DefaultRollingPolicy in StreamingFileSink, the file will be finished delayed

2021-04-28 Thread ChangjiGuo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ChangjiGuo updated FLINK-22497: --- Environment: hadoop-2.8.4,Flink-1.11.2 (was: hadoop-2.8.4) > When using DefaultRollingPolicy in

[jira] [Commented] (FLINK-22499) JDBC sink table-api support "sink.parallelism" ?

2021-04-28 Thread ranqiqiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17335122#comment-17335122 ] ranqiqiang commented on FLINK-22499: thanks, but the version is "jdbc .. {{1.14-SNAPSHOT}}" If I

[jira] [Commented] (FLINK-22266) Harden JobMasterStopWithSavepointITCase

2021-04-28 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17335120#comment-17335120 ] Guowei Ma commented on FLINK-22266: ---

[jira] [Created] (FLINK-22518) Translate the page of "High Availability (HA)" into Chinese

2021-04-28 Thread movesan (Jira)
movesan created FLINK-22518: --- Summary: Translate the page of "High Availability (HA)" into Chinese Key: FLINK-22518 URL: https://issues.apache.org/jira/browse/FLINK-22518 Project: Flink Issue

[GitHub] [flink] wuchong closed pull request #15745: [FLINK-22304][table] Refactor some interfaces for TVF based window to…

2021-04-28 Thread GitBox
wuchong closed pull request #15745: URL: https://github.com/apache/flink/pull/15745 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service,

[GitHub] [flink-web] wuchong commented on pull request #436: Add Apache Flink release 1.13.0

2021-04-28 Thread GitBox
wuchong commented on pull request #436: URL: https://github.com/apache/flink-web/pull/436#issuecomment-828916305 LGTM. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For

[jira] [Commented] (FLINK-22518) Translate the page of "High Availability (HA)" into Chinese

2021-04-28 Thread movesan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17335114#comment-17335114 ] movesan commented on FLINK-22518: - Hi [~jark] . I am very interested in this job, Could you please

[jira] [Updated] (FLINK-16428) Fine-grained network buffer management for backpressure

2021-04-28 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-16428: Labels: (was: stale-critical) > Fine-grained network buffer management for backpressure >

[GitHub] [flink] PatrickRen commented on pull request #15767: [FLINK-22393][docs-zh] Translate the page of "Execution Mode (Batch/Streaming)" into Chinese

2021-04-28 Thread GitBox
PatrickRen commented on pull request #15767: URL: https://github.com/apache/flink/pull/15767#issuecomment-828900787 Thanks for the contribution @95chenjz ! But it looks like a new `.md` file is created for the Chinese documentation. I think the translation should be made in the file

[jira] [Created] (FLINK-22517) Fix pickle compatibility problem in different Python versions

2021-04-28 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-22517: Summary: Fix pickle compatibility problem in different Python versions Key: FLINK-22517 URL: https://issues.apache.org/jira/browse/FLINK-22517 Project: Flink

[GitHub] [flink] PatrickRen commented on a change in pull request #15763: [FLINK-22364][doc] Translate the page of "Data Sources" to Chinese.

2021-04-28 Thread GitBox
PatrickRen commented on a change in pull request #15763: URL: https://github.com/apache/flink/pull/15763#discussion_r620113572 ## File path: docs/content.zh/docs/dev/datastream/sources.md ## @@ -154,28 +161,32 @@ class MySplitEnumerator implements SplitEnumerator { } ```

[jira] [Comment Edited] (FLINK-20945) flink hive insert heap out of memory

2021-04-28 Thread George Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17335084#comment-17335084 ] George Song edited comment on FLINK-20945 at 4/29/21, 1:05 AM: ---

[jira] [Commented] (FLINK-20945) flink hive insert heap out of memory

2021-04-28 Thread George Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17335084#comment-17335084 ] George Song commented on FLINK-20945: - [~aswinram92] I think we need to move this ticket to

[GitHub] [flink] 95chenjz commented on pull request #15767: [FLINK-22393][docs-zh] Translate the page of "Execution Mode (Batch/Streaming)" into Chinese

2021-04-28 Thread GitBox
95chenjz commented on pull request #15767: URL: https://github.com/apache/flink/pull/15767#issuecomment-828877478 cc @wuchong @xccui @klion26 @PatrickRen @becketqin. Could you review my PR when you're free? No hurry, looking for your feedback. -- This is an automated message from the

[jira] [Closed] (FLINK-11681) Add an AbstractMetric to combine the metric definition and metric management.

2021-04-28 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin closed FLINK-11681. Resolution: Abandoned After some discussion, we have not reached consensus on whether this is

[jira] [Commented] (FLINK-20833) Expose pluggable interface for exception analysis and metrics reporting in Execution Graph

2021-04-28 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17335080#comment-17335080 ] Zhenqiu Huang commented on FLINK-20833: --- [~rmetzger] [~xintongsong] Would you please help to

[jira] [Commented] (FLINK-10806) Support multiple consuming offsets when discovering a new topic

2021-04-28 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17335079#comment-17335079 ] Jiangjie Qin commented on FLINK-10806: -- After FLIP-27, the DataStream source allows users to

[jira] [Assigned] (FLINK-16634) The PartitionDiscoverer in FlinkKafkaConsumer should not use the user provided client.id.

2021-04-28 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-16634: Assignee: Qingsheng Ren > The PartitionDiscoverer in FlinkKafkaConsumer should not use

[jira] [Closed] (FLINK-20108) SingleThreadFetcherManager may add splits to a shutting down SplitFetcher

2021-04-28 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin closed FLINK-20108. Fix Version/s: (was: 1.11.4) 1.11.3 Resolution: Fixed FLINK-18128

[jira] [Updated] (FLINK-22516) ResourceManager cannot establish leadership

2021-04-28 Thread Ricky Burnett (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ricky Burnett updated FLINK-22516: -- Affects Version/s: 1.9.3 > ResourceManager cannot establish leadership >

[jira] [Updated] (FLINK-22516) ResourceManager cannot establish leadership

2021-04-28 Thread Ricky Burnett (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ricky Burnett updated FLINK-22516: -- Environment: 1.9.3 Flink version, on kubernetes. > ResourceManager cannot establish

[GitHub] [flink] galenwarren commented on a change in pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

2021-04-28 Thread GitBox
galenwarren commented on a change in pull request #15599: URL: https://github.com/apache/flink/pull/15599#discussion_r622618082 ## File path: flink-filesystems/flink-gs-fs-hadoop/src/main/java/org/apache/flink/fs/gs/writer/GSRecoverableWriterCommitter.java ## @@ -0,0 +1,150

[GitHub] [flink] flinkbot edited a comment on pull request #15797: [FLINK-22484][table] Add built-in MAP_KEYS, MAP_VALUES, MAP_FROM_ARRA…

2021-04-28 Thread GitBox
flinkbot edited a comment on pull request #15797: URL: https://github.com/apache/flink/pull/15797#issuecomment-828531728 ## CI report: * 9208f004adafc3997d91921efe3e7d291eb8360f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15797: [FLINK-22484][table] Add built-in MAP_KEYS, MAP_VALUES, MAP_FROM_ARRA…

2021-04-28 Thread GitBox
flinkbot edited a comment on pull request #15797: URL: https://github.com/apache/flink/pull/15797#issuecomment-828531728 ## CI report: * 9208f004adafc3997d91921efe3e7d291eb8360f Azure:

[jira] [Updated] (FLINK-22516) ResourceManager cannot establish leadership

2021-04-28 Thread Ricky Burnett (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ricky Burnett updated FLINK-22516: -- Description: We are running Flink clusters with 2 Jobmanagers in HA mode.  After a Zookeeper

[jira] [Created] (FLINK-22516) ResourceManager cannot establish leadership

2021-04-28 Thread Ricky Burnett (Jira)
Ricky Burnett created FLINK-22516: - Summary: ResourceManager cannot establish leadership Key: FLINK-22516 URL: https://issues.apache.org/jira/browse/FLINK-22516 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #15797: [FLINK-22484][table] Add built-in MAP_KEYS, MAP_VALUES, MAP_FROM_ARRA…

2021-04-28 Thread GitBox
flinkbot edited a comment on pull request #15797: URL: https://github.com/apache/flink/pull/15797#issuecomment-828531728 ## CI report: * 9208f004adafc3997d91921efe3e7d291eb8360f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15798: [FLINK-22168][table] Fix several shortcomings that prevent schema expressions

2021-04-28 Thread GitBox
flinkbot edited a comment on pull request #15798: URL: https://github.com/apache/flink/pull/15798#issuecomment-828566333 ## CI report: * d02069bb5bff8be1d10a04cc981caa01fb3919ab Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15631: [FLINK-20103][tests] Add UnalignedCheckpointsStressITCase

2021-04-28 Thread GitBox
flinkbot edited a comment on pull request #15631: URL: https://github.com/apache/flink/pull/15631#issuecomment-820458718 ## CI report: * 8db656d8d783b61761d3de7727c0e8831c5e77cd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15479: [FLINK-19606][table-runtime-blink] Introduce StreamExecWindowJoin and window join it cases

2021-04-28 Thread GitBox
flinkbot edited a comment on pull request #15479: URL: https://github.com/apache/flink/pull/15479#issuecomment-812344008 ## CI report: * 1b562e2eec41f48d9ac9b4e7591240b6c8d99e61 Azure:

[jira] [Created] (FLINK-22515) Add Documentation for Flink Glue Schema Registry Integration

2021-04-28 Thread Linyu Yao (Jira)
Linyu Yao created FLINK-22515: - Summary: Add Documentation for Flink Glue Schema Registry Integration Key: FLINK-22515 URL: https://issues.apache.org/jira/browse/FLINK-22515 Project: Flink

[GitHub] [flink-web] XComp commented on a change in pull request #436: Add Apache Flink release 1.13.0

2021-04-28 Thread GitBox
XComp commented on a change in pull request #436: URL: https://github.com/apache/flink-web/pull/436#discussion_r622363151 ## File path: _posts/2021-04-22-release-1.13.0.md ## @@ -0,0 +1,483 @@ +--- +layout: post +title: "Apache Flink 1.13.0 Release Announcement" +date:

[jira] [Commented] (FLINK-22513) Failed to upload compile artifacts

2021-04-28 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334913#comment-17334913 ] Robert Metzger commented on FLINK-22513: Let's hope this is just some glitch in the

[GitHub] [flink] flinkbot edited a comment on pull request #15479: [FLINK-19606][table-runtime-blink] Introduce StreamExecWindowJoin and window join it cases

2021-04-28 Thread GitBox
flinkbot edited a comment on pull request #15479: URL: https://github.com/apache/flink/pull/15479#issuecomment-812344008 ## CI report: * 1b562e2eec41f48d9ac9b4e7591240b6c8d99e61 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15796: [FLINK-22511][python] Fix the bug of non-composite result type in Python TableAggregateFunction

2021-04-28 Thread GitBox
flinkbot edited a comment on pull request #15796: URL: https://github.com/apache/flink/pull/15796#issuecomment-828441475 ## CI report: * 4c3e94df03863bf43eac7b47be51764f2f4be659 Azure:

[jira] [Closed] (FLINK-11158) Do not show empty page for unknown jobs

2021-04-28 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-11158. --- Resolution: Fixed Actually, I think, this has been solved by now since the Web UI is presenting a

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

2021-04-28 Thread GitBox
flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN *

[GitHub] [flink] galenwarren commented on a change in pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

2021-04-28 Thread GitBox
galenwarren commented on a change in pull request #15599: URL: https://github.com/apache/flink/pull/15599#discussion_r622377812 ## File path: flink-filesystems/flink-gs-fs-hadoop/src/main/java/org/apache/flink/fs/gs/writer/GSRecoverableWriterCommitter.java ## @@ -0,0 +1,150

[GitHub] [flink] galenwarren commented on a change in pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

2021-04-28 Thread GitBox
galenwarren commented on a change in pull request #15599: URL: https://github.com/apache/flink/pull/15599#discussion_r622380775 ## File path: flink-filesystems/flink-gs-fs-hadoop/src/main/java/org/apache/flink/fs/gs/writer/GSRecoverableWriterState.java ## @@ -0,0 +1,158 @@

[GitHub] [flink] galenwarren commented on a change in pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

2021-04-28 Thread GitBox
galenwarren commented on a change in pull request #15599: URL: https://github.com/apache/flink/pull/15599#discussion_r622377812 ## File path: flink-filesystems/flink-gs-fs-hadoop/src/main/java/org/apache/flink/fs/gs/writer/GSRecoverableWriterCommitter.java ## @@ -0,0 +1,150

[GitHub] [flink] galenwarren commented on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

2021-04-28 Thread GitBox
galenwarren commented on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-828625909 @rmetzger Thanks for your help diagnosing the build issue -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] galenwarren commented on a change in pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

2021-04-28 Thread GitBox
galenwarren commented on a change in pull request #15599: URL: https://github.com/apache/flink/pull/15599#discussion_r622377812 ## File path: flink-filesystems/flink-gs-fs-hadoop/src/main/java/org/apache/flink/fs/gs/writer/GSRecoverableWriterCommitter.java ## @@ -0,0 +1,150

[GitHub] [flink] todd5167 commented on a change in pull request #15755: [FLINK-22318][table] Support RENAME column name for ALTER TABLE state…

2021-04-28 Thread GitBox
todd5167 commented on a change in pull request #15755: URL: https://github.com/apache/flink/pull/15755#discussion_r622333275 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/utils/OperationConverterUtils.java ## @@ -144,6

[GitHub] [flink] todd5167 commented on a change in pull request #15755: [FLINK-22318][table] Support RENAME column name for ALTER TABLE state…

2021-04-28 Thread GitBox
todd5167 commented on a change in pull request #15755: URL: https://github.com/apache/flink/pull/15755#discussion_r622333275 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/utils/OperationConverterUtils.java ## @@ -144,6

[GitHub] [flink] flinkbot edited a comment on pull request #15798: [FLINK-22168][table] Fix several shortcomings that prevent schema expressions

2021-04-28 Thread GitBox
flinkbot edited a comment on pull request #15798: URL: https://github.com/apache/flink/pull/15798#issuecomment-828566333 ## CI report: * d02069bb5bff8be1d10a04cc981caa01fb3919ab Azure:

[jira] [Created] (FLINK-22514) TypeExtractor - Improving log message

2021-04-28 Thread Avishay Balderman (Jira)
Avishay Balderman created FLINK-22514: - Summary: TypeExtractor - Improving log message Key: FLINK-22514 URL: https://issues.apache.org/jira/browse/FLINK-22514 Project: Flink Issue Type:

[jira] [Updated] (FLINK-22514) TypeExtractor - Improving log message

2021-04-28 Thread Avishay Balderman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Avishay Balderman updated FLINK-22514: -- Priority: Minor (was: Major) > TypeExtractor - Improving log message >

[GitHub] [flink] flinkbot commented on pull request #15798: [FLINK-22168][table] Fix several shortcomings that prevent schema expressions

2021-04-28 Thread GitBox
flinkbot commented on pull request #15798: URL: https://github.com/apache/flink/pull/15798#issuecomment-828566333 ## CI report: * d02069bb5bff8be1d10a04cc981caa01fb3919ab UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-22438) add numRecordsOut metric for Async IO

2021-04-28 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-22438: --- Fix Version/s: (was: 1.12.3) 1.12.4 > add numRecordsOut metric for

[jira] [Updated] (FLINK-22479) [Kinesis][Consumer] Potential lock-up under error condition

2021-04-28 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-22479: --- Fix Version/s: (was: 1.12.3) 1.12.4 > [Kinesis][Consumer] Potential

[jira] [Updated] (FLINK-22434) Dispatcher does not store suspended jobs in execution graph store

2021-04-28 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-22434: --- Fix Version/s: (was: 1.12.3) 1.12.4 > Dispatcher does not store

[GitHub] [flink-jira-bot] sjwiesman closed pull request #11: [hotfix] Make comment language friendly to contributors

2021-04-28 Thread GitBox
sjwiesman closed pull request #11: URL: https://github.com/apache/flink-jira-bot/pull/11 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service,

[GitHub] [flink] flinkbot edited a comment on pull request #15760: [FLINK-19606][table-runtime-blink] Introduce WindowJoinOperator and WindowJoinOperatorBuilder.

2021-04-28 Thread GitBox
flinkbot edited a comment on pull request #15760: URL: https://github.com/apache/flink/pull/15760#issuecomment-826500326 ## CI report: * e7a99f5f45e9acb529b903d7823735f3158756fc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15797: [FLINK-22484][table] Add built-in MAP_KEYS, MAP_VALUES, MAP_FROM_ARRA…

2021-04-28 Thread GitBox
flinkbot edited a comment on pull request #15797: URL: https://github.com/apache/flink/pull/15797#issuecomment-828531728 ## CI report: * 9208f004adafc3997d91921efe3e7d291eb8360f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15631: [FLINK-20103][tests] Add UnalignedCheckpointsStressITCase

2021-04-28 Thread GitBox
flinkbot edited a comment on pull request #15631: URL: https://github.com/apache/flink/pull/15631#issuecomment-820458718 ## CI report: * 64a6f1c0ccfa13b72911e110c52814d6cf41040a Azure:

[GitHub] [flink] flinkbot commented on pull request #15798: [FLINK-22168][table] Fix several shortcomings that prevent schema expressions

2021-04-28 Thread GitBox
flinkbot commented on pull request #15798: URL: https://github.com/apache/flink/pull/15798#issuecomment-828544554 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Created] (FLINK-22513) Failed to upload compile artifacts

2021-04-28 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-22513: Summary: Failed to upload compile artifacts Key: FLINK-22513 URL: https://issues.apache.org/jira/browse/FLINK-22513 Project: Flink Issue Type: Bug

[GitHub] [flink] twalthr opened a new pull request #15798: [FLINK-22168][table] Fix several shortcomings that prevent schema expressions

2021-04-28 Thread GitBox
twalthr opened a new pull request #15798: URL: https://github.com/apache/flink/pull/15798 ## What is the purpose of the change This fixes a couple of critical bugs in the stack that prevented Table API expressions to be used for schema declaration. Due to time constraints, this PR

[jira] [Commented] (FLINK-11103) Set a default uncaught exception handler

2021-04-28 Thread Ashwin Kolhatkar (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334781#comment-17334781 ] Ashwin Kolhatkar commented on FLINK-11103: -- Ok, I can do that. I'll create a class

[GitHub] [flink] flinkbot commented on pull request #15797: [FLINK-22484][table] Add built-in MAP_KEYS, MAP_VALUES, MAP_FROM_ARRA…

2021-04-28 Thread GitBox
flinkbot commented on pull request #15797: URL: https://github.com/apache/flink/pull/15797#issuecomment-828531728 ## CI report: * 9208f004adafc3997d91921efe3e7d291eb8360f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] dannycranmer merged pull request #15774: [FLINK-22479][Kinesis][Consumer] Potential lock-up under error condition (Flink 1.14)

2021-04-28 Thread GitBox
dannycranmer merged pull request #15774: URL: https://github.com/apache/flink/pull/15774 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service,

[GitHub] [flink] flinkbot edited a comment on pull request #15631: [FLINK-20103][tests] Add UnalignedCheckpointsStressITCase

2021-04-28 Thread GitBox
flinkbot edited a comment on pull request #15631: URL: https://github.com/apache/flink/pull/15631#issuecomment-820458718 ## CI report: * 64a6f1c0ccfa13b72911e110c52814d6cf41040a Azure:

[GitHub] [flink] flinkbot commented on pull request #15797: [FLINK-22484][table] Add built-in MAP_KEYS, MAP_VALUES, MAP_FROM_ARRA…

2021-04-28 Thread GitBox
flinkbot commented on pull request #15797: URL: https://github.com/apache/flink/pull/15797#issuecomment-828524777 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Comment Edited] (FLINK-22452) Support specifying custom transactional.id prefix in FlinkKafkaProducer

2021-04-28 Thread Marc Demierre (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334774#comment-17334774 ] Marc Demierre edited comment on FLINK-22452 at 4/28/21, 2:54 PM: - I just

[jira] [Updated] (FLINK-22484) Buit-in functions for collections

2021-04-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22484: --- Labels: pull-request-available (was: ) > Buit-in functions for collections >

[GitHub] [flink] snuyanzin opened a new pull request #15797: [FLINK-22484][table] Add built-in MAP_KEYS, MAP_VALUES, MAP_FROM_ARRA…

2021-04-28 Thread GitBox
snuyanzin opened a new pull request #15797: URL: https://github.com/apache/flink/pull/15797 ## What is the purpose of the change The PR implements three functions from the list mentioned in FLINK-22484 : `MAP_KEYS`, `MAP_VALUES`, `MAP_FROM_ARRAYS` ## Brief change

[jira] [Commented] (FLINK-22452) Support specifying custom transactional.id prefix in FlinkKafkaProducer

2021-04-28 Thread Marc Demierre (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334774#comment-17334774 ] Marc Demierre commented on FLINK-22452: --- I just hit this issue at my company today, due to the

[GitHub] [flink] flinkbot edited a comment on pull request #15712: [FLINK-22400][hive connect]fix NPE problem when convert flink object for Map

2021-04-28 Thread GitBox
flinkbot edited a comment on pull request #15712: URL: https://github.com/apache/flink/pull/15712#issuecomment-824189664 ## CI report: * 8256b986bcfce17787558b17bba6c2c6a9be24c2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15479: [FLINK-19606][table-runtime-blink] Introduce StreamExecWindowJoin and window join it cases

2021-04-28 Thread GitBox
flinkbot edited a comment on pull request #15479: URL: https://github.com/apache/flink/pull/15479#issuecomment-812344008 ## CI report: * 3764b47414eba44d4ea2f53b6973fe59f3356cfc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

2021-04-28 Thread GitBox
flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN *

[GitHub] [flink] pnowojski commented on pull request #15631: [FLINK-20103][tests] Add UnalignedCheckpointsStressITCase

2021-04-28 Thread GitBox
pnowojski commented on pull request #15631: URL: https://github.com/apache/flink/pull/15631#issuecomment-828499112 I have addressed the feedback. I have also included a couple of extra commits from @AHeise, so please pay special attention to those. -- This is an automated message from

[GitHub] [flink] pnowojski commented on a change in pull request #15631: [FLINK-20103][tests] Add UnalignedCheckpointsStressITCase

2021-04-28 Thread GitBox
pnowojski commented on a change in pull request #15631: URL: https://github.com/apache/flink/pull/15631#discussion_r67839 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointStressITCase.java ## @@ -0,0 +1,553 @@ +/* + * Licensed

[GitHub] [flink] pnowojski commented on a change in pull request #15631: [FLINK-20103][tests] Add UnalignedCheckpointsStressITCase

2021-04-28 Thread GitBox
pnowojski commented on a change in pull request #15631: URL: https://github.com/apache/flink/pull/15631#discussion_r63090 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointStressITCase.java ## @@ -0,0 +1,553 @@ +/* + * Licensed

[GitHub] [flink] pnowojski commented on a change in pull request #15631: [FLINK-20103][tests] Add UnalignedCheckpointsStressITCase

2021-04-28 Thread GitBox
pnowojski commented on a change in pull request #15631: URL: https://github.com/apache/flink/pull/15631#discussion_r60261 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointStressITCase.java ## @@ -0,0 +1,553 @@ +/* + * Licensed

  1   2   3   >