[jira] [Comment Edited] (FLINK-28334) PushProjectIntoTableSourceScanRule should cover the case when table source SupportsReadingMetadata and not SupportsProjectionPushDown

2022-07-06 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563593#comment-17563593 ] godfrey he edited comment on FLINK-28334 at 7/7/22 6:55 AM:

[GitHub] [flink-table-store] LadyForest commented on a diff in pull request #182: [FLINK-27708] Add background compaction task for append-only table when ingesting

2022-07-06 Thread GitBox
LadyForest commented on code in PR #182: URL: https://github.com/apache/flink-table-store/pull/182#discussion_r915516473 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/AppendOnlyFileStoreWrite.java: ## @@ -82,9 +100,48 @@ public Callable crea

[GitHub] [flink-table-store] LadyForest commented on a diff in pull request #182: [FLINK-27708] Add background compaction task for append-only table when ingesting

2022-07-06 Thread GitBox
LadyForest commented on code in PR #182: URL: https://github.com/apache/flink-table-store/pull/182#discussion_r915513633 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/data/AppendOnlyCompactManager.java: ## @@ -0,0 +1,128 @@ +/* + * Licensed to the Apa

[jira] [Created] (FLINK-28436) test_multi_sessionjob.sh is failing intermittently

2022-07-06 Thread Matyas Orhidi (Jira)
Matyas Orhidi created FLINK-28436: - Summary: test_multi_sessionjob.sh is failing intermittently Key: FLINK-28436 URL: https://issues.apache.org/jira/browse/FLINK-28436 Project: Flink Issue Ty

[GitHub] [flink] swuferhong commented on a diff in pull request #20009: [FLINK-27991][table-planner] ORC format supports reporting statistics

2022-07-06 Thread GitBox
swuferhong commented on code in PR #20009: URL: https://github.com/apache/flink/pull/20009#discussion_r915507045 ## flink-formats/flink-orc/src/main/java/org/apache/flink/orc/OrcFileFormatFactory.java: ## @@ -167,5 +188,179 @@ public ChangelogMode getChangelogMode() { p

[jira] [Closed] (FLINK-28334) PushProjectIntoTableSourceScanRule should cover the case when table source SupportsReadingMetadata and not SupportsProjectionPushDown

2022-07-06 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-28334. -- Resolution: Fixed Fix in master: fb9843af5ffeb6d7561876704d463dea1fcdc153 > PushProjectIntoTableSourc

[GitHub] [flink] godfreyhe closed pull request #20118: [FLINK-28334][table-planner] Fix PushProjectIntoTableSourceScanRule: covers the case when table source SupportsReadingMetadata and not SupportsPr

2022-07-06 Thread GitBox
godfreyhe closed pull request #20118: [FLINK-28334][table-planner] Fix PushProjectIntoTableSourceScanRule: covers the case when table source SupportsReadingMetadata and not SupportsProjectionPushDown URL: https://github.com/apache/flink/pull/20118 -- This is an automated message from the Apa

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #202: [FLINK-28110] Support projection pushdown for Hive readers

2022-07-06 Thread GitBox
JingsongLi commented on code in PR #202: URL: https://github.com/apache/flink-table-store/pull/202#discussion_r915498253 ## flink-table-store-hive/flink-table-store-hive-connector/src/main/java/org/apache/flink/table/store/mapred/TableStoreRecordReader.java: ## @@ -36,24 +41,44

[jira] [Resolved] (FLINK-28176) test_es_sink_dynamic failed in jdk11

2022-07-06 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo resolved FLINK-28176. -- Resolution: Fixed Merged into master via fa67c3b7072fb8d80d05e10b1703cff5700fcb39 > test_es_s

[jira] [Assigned] (FLINK-28416) Add the new LookupFunction interface for lookup table source

2022-07-06 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-28416: - Assignee: Qingsheng Ren > Add the new LookupFunction interface for lookup table source

[jira] [Assigned] (FLINK-28417) Add interface and default implementation for cache in lookup table

2022-07-06 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-28417: - Assignee: Qingsheng Ren > Add interface and default implementation for cache in lookup

[GitHub] [flink] HuangXingBo closed pull request #20191: [FLINK-28176][python] Refactor the test in test_connectors.py

2022-07-06 Thread GitBox
HuangXingBo closed pull request #20191: [FLINK-28176][python] Refactor the test in test_connectors.py URL: https://github.com/apache/flink/pull/20191 -- 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

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #182: [FLINK-27708] Add background compaction task for append-only table when ingesting

2022-07-06 Thread GitBox
JingsongLi commented on code in PR #182: URL: https://github.com/apache/flink-table-store/pull/182#discussion_r915444076 ## docs/layouts/shortcodes/generated/core_configuration.html: ## @@ -36,13 +36,25 @@ compaction.max-size-amplification-percent 200

[jira] [Comment Edited] (FLINK-28435) Flink version 1.15.0 consumption Kafka has backpressure.

2022-07-06 Thread HunterHunter (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563586#comment-17563586 ] HunterHunter edited comment on FLINK-28435 at 7/7/22 6:06 AM:

[jira] [Commented] (FLINK-28435) Flink version 1.15.0 consumption Kafka has backpressure.

2022-07-06 Thread HunterHunter (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563586#comment-17563586 ] HunterHunter commented on FLINK-28435: -- [~jark]  > Flink version 1.15.0 consumpti

[jira] [Created] (FLINK-28435) Flink version 1.15.0 consumption Kafka has backpressure.

2022-07-06 Thread HunterHunter (Jira)
HunterHunter created FLINK-28435: Summary: Flink version 1.15.0 consumption Kafka has backpressure. Key: FLINK-28435 URL: https://issues.apache.org/jira/browse/FLINK-28435 Project: Flink Iss

[GitHub] [flink] luoyuxia commented on pull request #19069: [FLINK-24862][Connectors / Hive][backport]Fix user-defined hive udaf/udtf cannot be used normally in hive dialect for flink1.14

2022-07-06 Thread GitBox
luoyuxia commented on PR #19069: URL: https://github.com/apache/flink/pull/19069#issuecomment-1177119760 @hehuiyuan I think @beyond1920 can help merge when she is free. Just be patient. -- This is an automated message from the Apache Git Service. To respond to the message, please log on t

[GitHub] [flink] lpn666 closed pull request #20192: [sql-jdbc]

2022-07-06 Thread GitBox
lpn666 closed pull request #20192: [sql-jdbc] URL: https://github.com/apache/flink/pull/20192 -- 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. To unsubscribe, e-mail: issues-uns

[GitHub] [flink] lpn666 commented on pull request #20192: [sql-jdbc]

2022-07-06 Thread GitBox
lpn666 commented on PR #20192: URL: https://github.com/apache/flink/pull/20192#issuecomment-1177110023 > ## What is the purpose of the change > When I using the sql-jdbc to transform a big table from mysql to other database, the flink program load the entire table into memory. The source

[jira] [Commented] (FLINK-28431) CompletedCheckPoints stored on ZooKeeper is not up-to-date, when JobManager is restarted it fails to recover the job due to "checkpoint FileNotFound exception"

2022-07-06 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563584#comment-17563584 ] Yun Tang commented on FLINK-28431: -- [~aresyhzhang] Could you check the original JM logs

[GitHub] [flink] lpn666 opened a new pull request, #20192: [sql-jdbc]

2022-07-06 Thread GitBox
lpn666 opened a new pull request, #20192: URL: https://github.com/apache/flink/pull/20192 ## What is the purpose of the change When I using the sql-jdbc to transform a big table from mysql to other database, the flink program load the entire table into memory. The source

[GitHub] [flink] liuzhuang2017 commented on pull request #20061: [hotfix][flink-rpc] Fix the RemoteRpcInvocation class typo.

2022-07-06 Thread GitBox
liuzhuang2017 commented on PR #20061: URL: https://github.com/apache/flink/pull/20061#issuecomment-1177101540 @flinkbot run azure -- 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 comm

[jira] [Closed] (FLINK-28312) Introduce REST APIs for log URL retrieval

2022-07-06 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo closed FLINK-28312. -- Resolution: Fixed > Introduce REST APIs for log URL retrieval > --

[jira] [Commented] (FLINK-28312) Introduce REST APIs for log URL retrieval

2022-07-06 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563582#comment-17563582 ] Yangze Guo commented on FLINK-28312: master a99fc3ffbf95910dd8fad6833852ca5eed3f1896

[GitHub] [flink] KarmaGYZ closed pull request #20179: [FLINK-28312][rest] Introduce REST APIs for log URL retrieval

2022-07-06 Thread GitBox
KarmaGYZ closed pull request #20179: [FLINK-28312][rest] Introduce REST APIs for log URL retrieval URL: https://github.com/apache/flink/pull/20179 -- 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

[GitHub] [flink] 1996fanrui commented on pull request #20137: Just for CI

2022-07-06 Thread GitBox
1996fanrui commented on PR #20137: URL: https://github.com/apache/flink/pull/20137#issuecomment-1177084314 @flinkbot run azure -- 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

[GitHub] [flink] 1996fanrui commented on pull request #19781: Just for test : output buffer aligned to uc

2022-07-06 Thread GitBox
1996fanrui commented on PR #19781: URL: https://github.com/apache/flink/pull/19781#issuecomment-1177082931 @flinkbot run azure -- 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

[jira] [Commented] (FLINK-28297) Incorrect metric group order for namespaced operator metrics

2022-07-06 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563577#comment-17563577 ] Gyula Fora commented on FLINK-28297: On a second thought we might simply want to get

[jira] [Updated] (FLINK-28110) Table Store Hive Reader supports projection pushdown

2022-07-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28110: --- Labels: pull-request-available (was: ) > Table Store Hive Reader supports projection pushdo

[GitHub] [flink-table-store] tsreaper opened a new pull request, #202: [FLINK-28110] Support projection pushdown for Hive readers

2022-07-06 Thread GitBox
tsreaper opened a new pull request, #202: URL: https://github.com/apache/flink-table-store/pull/202 As Hive 2 only provides selected column names and requires the source not to change the schema, we implement projection pushdown by only reading selected columns from files and set the other

[GitHub] [flink] sunshineJK commented on a diff in pull request #20127: [FLINK-26270] Flink SQL write data to kafka by CSV format , whether d…

2022-07-06 Thread GitBox
sunshineJK commented on code in PR #20127: URL: https://github.com/apache/flink/pull/20127#discussion_r915458758 ## flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFormatOptions.java: ## @@ -87,5 +87,11 @@ public class CsvFormatOptions {

[GitHub] [flink] sunshineJK commented on a diff in pull request #20127: [FLINK-26270] Flink SQL write data to kafka by CSV format , whether d…

2022-07-06 Thread GitBox
sunshineJK commented on code in PR #20127: URL: https://github.com/apache/flink/pull/20127#discussion_r915458318 ## flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFormatOptions.java: ## @@ -87,5 +87,11 @@ public class CsvFormatOptions {

[jira] [Closed] (FLINK-28393) Support AvroInputFormat in PyFlink

2022-07-06 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-28393. --- Assignee: Juntao Hu Resolution: Fixed Merged to master via bbd5a813e9c6a17b0c3bb31ee27d92d00448c956 >

[jira] [Updated] (FLINK-28393) Support AvroInputFormat in PyFlink

2022-07-06 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-28393: Affects Version/s: (was: shaded-7.0) > Support AvroInputFormat in PyFlink > --

[GitHub] [flink] dianfu closed pull request #20163: [FLINK-28393][python][format] Support AvroInputFormat

2022-07-06 Thread GitBox
dianfu closed pull request #20163: [FLINK-28393][python][format] Support AvroInputFormat URL: https://github.com/apache/flink/pull/20163 -- 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

[GitHub] [flink] godfreyhe commented on a diff in pull request #20118: [FLINK-28334][table-planner] Fix PushProjectIntoTableSourceScanRule: covers the case when table source SupportsReadingMetadata an

2022-07-06 Thread GitBox
godfreyhe commented on code in PR #20118: URL: https://github.com/apache/flink/pull/20118#discussion_r915444008 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PushProjectIntoTableSourceScanRule.java: ## @@ -337,11 +339,71 @@ pr

[jira] [Commented] (FLINK-27759) Rethink how to get the git commit id for docker image in Flink Kubernetes operator

2022-07-06 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563565#comment-17563565 ] Yang Wang commented on FLINK-27759: --- This is still not fixed. But it is not a high-pri

[jira] [Assigned] (FLINK-28110) Table Store Hive Reader supports projection pushdown

2022-07-06 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-28110: Assignee: Caizhi Weng > Table Store Hive Reader supports projection pushdown > --

[jira] [Assigned] (FLINK-28289) Introduce Spark2 Reader for table store

2022-07-06 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-28289: Assignee: Nicholas Jiang > Introduce Spark2 Reader for table store >

[jira] [Closed] (FLINK-28040) Introduce Trino reader for table store

2022-07-06 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-28040. Resolution: Won't Fix > Introduce Trino reader for table store > -

[GitHub] [flink] reswqa commented on a diff in pull request #19960: [FLINK-27907][runtime] implement disk read and write logic for hybrid shuffle

2022-07-06 Thread GitBox
reswqa commented on code in PR #19960: URL: https://github.com/apache/flink/pull/19960#discussion_r915441265 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsSubpartitionFileReader.java: ## @@ -0,0 +1,416 @@ +/* + * Licensed to the Apache Sof

[GitHub] [flink] HuangZhenQiu commented on a diff in pull request #20001: [FLINK-27659][table] Planner support to use jar which is registered by 'CREATE FUNTION USING JAR' syntax

2022-07-06 Thread GitBox
HuangZhenQiu commented on code in PR #20001: URL: https://github.com/apache/flink/pull/20001#discussion_r915435030 ## flink-table/flink-sql-client/src/main/java/org/apache/flink/util/ClientMutableURLClassLoader.java: ## @@ -0,0 +1,115 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] HuangZhenQiu commented on pull request #20176: [FLINK-27660][table] add table api for registering function with resource

2022-07-06 Thread GitBox
HuangZhenQiu commented on PR #20176: URL: https://github.com/apache/flink/pull/20176#issuecomment-1177020994 @lsyldliu Sure. I will rebase later. -- 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 t

[jira] [Updated] (FLINK-28291) Add kerberos delegation token renewer feature instead of logged from keytab individually

2022-07-06 Thread jiulong.zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jiulong.zhu updated FLINK-28291: Labels: (was: patch) > Add kerberos delegation token renewer feature instead of logged from keyt

[jira] [Updated] (FLINK-28291) Add kerberos delegation token renewer feature instead of logged from keytab individually

2022-07-06 Thread jiulong.zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jiulong.zhu updated FLINK-28291: Labels: PatchAvailable patch-available (was: ) > Add kerberos delegation token renewer feature in

[jira] [Commented] (FLINK-28433) Allow connection to mysql through mariadb driver

2022-07-06 Thread bo zhao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563557#comment-17563557 ] bo zhao commented on FLINK-28433: - Hi guys,  I'm working on this now. Thanks > Allow c

[GitHub] [flink] lsyldliu commented on pull request #20176: [FLINK-27660][table] add table api for registering function with resource

2022-07-06 Thread GitBox
lsyldliu commented on PR #20176: URL: https://github.com/apache/flink/pull/20176#issuecomment-1177006660 @HuangZhenQiu After https://github.com/apache/flink/pull/20001 merge, you can rebase master, and I will review -- This is an automated message from the Apache Git Service. To respond t

[GitHub] [flink] hehuiyuan commented on pull request #19069: [FLINK-24862][Connectors / Hive][backport]Fix user-defined hive udaf/udtf cannot be used normally in hive dialect for flink1.14

2022-07-06 Thread GitBox
hehuiyuan commented on PR #19069: URL: https://github.com/apache/flink/pull/19069#issuecomment-1177000574 Hi @luoyuxia , who can merge? -- 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 specifi

[GitHub] [flink] hehuiyuan commented on pull request #19069: [FLINK-24862][Connectors / Hive][backport]Fix user-defined hive udaf/udtf cannot be used normally in hive dialect for flink1.14

2022-07-06 Thread GitBox
hehuiyuan commented on PR #19069: URL: https://github.com/apache/flink/pull/19069#issuecomment-1176999775 Hi @beyond1920 , who will merge? -- 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 spec

[GitHub] [flink] JesseAtSZ commented on pull request #20091: [FLINK-27570][runtime] Fix initialize base locations for checkpoint

2022-07-06 Thread GitBox
JesseAtSZ commented on PR #20091: URL: https://github.com/apache/flink/pull/20091#issuecomment-1176999771 @flinkbot run azure -- 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.

[jira] [Commented] (FLINK-26848) JDBC don't flush data when disable flush-max-rows and flush-interval

2022-07-06 Thread hehuiyuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563552#comment-17563552 ] hehuiyuan commented on FLINK-26848: --- Hi [~jark]  , have time to look at this issues?

[GitHub] [flink] xintongsong commented on a diff in pull request #19960: [FLINK-27907][runtime] implement disk read and write logic for hybrid shuffle

2022-07-06 Thread GitBox
xintongsong commented on code in PR #19960: URL: https://github.com/apache/flink/pull/19960#discussion_r915383242 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/SubpartitionFileReader.java: ## @@ -0,0 +1,43 @@ +/* + * Licensed to the Apache S

[GitHub] [flink] flinkbot commented on pull request #20191: [FLINK-28176][python] Refactor the test in test_connectors.py

2022-07-06 Thread GitBox
flinkbot commented on PR #20191: URL: https://github.com/apache/flink/pull/20191#issuecomment-1176985873 ## CI report: * 08c0ada2f1fe1af11deb8c54dac06e80579b5c1d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-28010) Use deleteRange to optimize the clear operation of RocksDBMapState.

2022-07-06 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563546#comment-17563546 ] Yun Tang commented on FLINK-28010: -- [~Ming Li] Since we do not have a special separator

[jira] [Updated] (FLINK-28176) test_es_sink_dynamic failed in jdk11

2022-07-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28176: --- Labels: pull-request-available test-stability (was: test-stability) > test_es_sink_dynamic

[GitHub] [flink] HuangXingBo opened a new pull request, #20191: [FLINK-28176][python] Refactor the test in test_connectors.py

2022-07-06 Thread GitBox
HuangXingBo opened a new pull request, #20191: URL: https://github.com/apache/flink/pull/20191 ## What is the purpose of the change *This pull request will refactor the test in `test_connectors.py`* ## Brief change log - *Refactor the test in test_connectors.py*

[jira] [Updated] (FLINK-28431) CompletedCheckPoints stored on ZooKeeper is not up-to-date, when JobManager is restarted it fails to recover the job due to "checkpoint FileNotFound exception"

2022-07-06 Thread aresyhzhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] aresyhzhang updated FLINK-28431: Attachment: error.log > CompletedCheckPoints stored on ZooKeeper is not up-to-date, when JobManage

[GitHub] [flink] sunshineJK commented on a diff in pull request #20127: [FLINK-26270] Flink SQL write data to kafka by CSV format , whether d…

2022-07-06 Thread GitBox
sunshineJK commented on code in PR #20127: URL: https://github.com/apache/flink/pull/20127#discussion_r915399942 ## docs/content.zh/docs/connectors/table/formats/csv.md: ## @@ -3,7 +3,7 @@ title: CSV weight: 2 type: docs aliases: - - /zh/dev/table/connectors/formats/csv.html

[jira] [Updated] (FLINK-28431) CompletedCheckPoints stored on ZooKeeper is not up-to-date, when JobManager is restarted it fails to recover the job due to "checkpoint FileNotFound exception"

2022-07-06 Thread aresyhzhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] aresyhzhang updated FLINK-28431: Attachment: (was: error.log) > CompletedCheckPoints stored on ZooKeeper is not up-to-date, whe

[jira] [Commented] (FLINK-28431) CompletedCheckPoints stored on ZooKeeper is not up-to-date, when JobManager is restarted it fails to recover the job due to "checkpoint FileNotFound exception"

2022-07-06 Thread aresyhzhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563540#comment-17563540 ] aresyhzhang commented on FLINK-28431: - Not tried with latest flink 1.15, but flink 1

[GitHub] [flink] zoltar9264 commented on pull request #20093: [FLINK-28172][changelog] Scatter dstl files into separate directories…

2022-07-06 Thread GitBox
zoltar9264 commented on PR #20093: URL: https://github.com/apache/flink/pull/20093#issuecomment-1176966940 @flinkbot run azure -- 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

[jira] [Assigned] (FLINK-28429) Reduce pyflink tests time

2022-07-06 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo reassigned FLINK-28429: Assignee: Huang Xingbo > Reduce pyflink tests time > - > >

[jira] [Assigned] (FLINK-28426) PyFlink provides M1 wheel package

2022-07-06 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo reassigned FLINK-28426: Assignee: Huang Xingbo > PyFlink provides M1 wheel package >

[jira] [Commented] (FLINK-28434) Extend "NestedProjectionUtil" to unify support for projection pushdown for physical fields or metadata only

2022-07-06 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563534#comment-17563534 ] lincoln lee commented on FLINK-28434: - cc [~fsk119] would you like to look at this i

[GitHub] [flink] lincoln-lil commented on a diff in pull request #20118: [FLINK-28334][table-planner] Fix PushProjectIntoTableSourceScanRule: covers the case when table source SupportsReadingMetadata

2022-07-06 Thread GitBox
lincoln-lil commented on code in PR #20118: URL: https://github.com/apache/flink/pull/20118#discussion_r915383719 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PushProjectIntoTableSourceScanRule.java: ## @@ -337,11 +339,69 @@

[jira] [Created] (FLINK-28434) Extend "NestedProjectionUtil" to unify support for projection pushdown for physical fields or metadata only

2022-07-06 Thread lincoln lee (Jira)
lincoln lee created FLINK-28434: --- Summary: Extend "NestedProjectionUtil" to unify support for projection pushdown for physical fields or metadata only Key: FLINK-28434 URL: https://issues.apache.org/jira/browse/FLIN

[jira] [Updated] (FLINK-28430) HiveFunctionWrapper should use UserClassLoader to load class

2022-07-06 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28430: - Description: Now, HiveFunctionWrapper will use current thread's ClassLoader to load the Hive UDFs class

[jira] [Updated] (FLINK-28430) HiveFunctionWrapper should use UserClassLoader to load class

2022-07-06 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28430: - Description: Now, HiveFunctionWrapper will use current thread's ClassLoader to load the Hive UDFs class

[jira] [Commented] (FLINK-27767) Introduce Endpoint API and utils

2022-07-06 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563531#comment-17563531 ] Shengkai Fang commented on FLINK-27767: --- Closed in master: eb395309e046418128363a5

[jira] [Closed] (FLINK-27767) Introduce Endpoint API and utils

2022-07-06 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-27767. - Resolution: Implemented > Introduce Endpoint API and utils > >

[GitHub] [flink] flinkbot commented on pull request #20190: [FLINK-28426][python] Supports m1 wheel package in PyFlink

2022-07-06 Thread GitBox
flinkbot commented on PR #20190: URL: https://github.com/apache/flink/pull/20190#issuecomment-1176955030 ## CI report: * 4d0a083fb3bde009a06ffd5623f038ebd1985f9b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] HuangXingBo commented on pull request #20190: [FLINK-28426][python] Supports m1 wheel package in PyFlink

2022-07-06 Thread GitBox
HuangXingBo commented on PR #20190: URL: https://github.com/apache/flink/pull/20190#issuecomment-1176952374 https://dev.azure.com/hxbks2ks/FLINK-TEST/_build/results?buildId=1895&view=results Manual Test in my private Azure -- This is an automated message from the Apache Git Service. To r

[GitHub] [flink] fsk119 merged pull request #19849: [FLINK-27767][sql-gateway] Introduce Endpoint API and utils

2022-07-06 Thread GitBox
fsk119 merged PR #19849: URL: https://github.com/apache/flink/pull/19849 -- 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. To unsubscribe, e-mail: issues-unsubscr...@flink.apache

[jira] [Updated] (FLINK-28426) PyFlink provides M1 wheel package

2022-07-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28426: --- Labels: pull-request-available (was: ) > PyFlink provides M1 wheel package > --

[GitHub] [flink] HuangXingBo opened a new pull request, #20190: [FLINK-28426][python] Supports m1 wheel package in PyFlink

2022-07-06 Thread GitBox
HuangXingBo opened a new pull request, #20190: URL: https://github.com/apache/flink/pull/20190 ## What is the purpose of the change *This pull request will support m1 wheel package in PyFlink* ## Brief change log - *Supports m1 wheel package in PyFlink* ## Ve

[GitHub] [flink-docker] xintongsong merged pull request #122: Update key for 1.15.1 to full fingerprint for official-images

2022-07-06 Thread GitBox
xintongsong merged PR #122: URL: https://github.com/apache/flink-docker/pull/122 -- 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. To unsubscribe, e-mail: issues-unsubscr...@flin

[GitHub] [flink-docker] xintongsong merged pull request #123: Update key for 1.15.1 to use full fingerprint

2022-07-06 Thread GitBox
xintongsong merged PR #123: URL: https://github.com/apache/flink-docker/pull/123 -- 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. To unsubscribe, e-mail: issues-unsubscr...@flin

[GitHub] [flink] luoyuxia commented on pull request #20071: [FLINK-28247][hive] fix "no any field presented in group by" exception when over window contains grouping function in Hive dialect

2022-07-06 Thread GitBox
luoyuxia commented on PR #20071: URL: https://github.com/apache/flink/pull/20071#issuecomment-1176948801 @lirui-apache The CI is passed now~ -- 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 sp

[jira] [Commented] (FLINK-28414) Using flink to query the hive table, an exception occurred, SQL validation failed. Failed to get table schema from deserializer

2022-07-06 Thread xcrossed (Jira)
xtOutputFormat' > LOCATION > 's3://.com/user/hive/warehouse/xxx/events' > TBLPROPERTIES ( > 'transient_lastDdlTime'='1623066811') > Time taken: 0.087 seconds, Fetched: 41 row(s) >   > flink table code >   > val hive = new HiveCatalo

[jira] [Created] (FLINK-28433) Allow connection to mysql through mariadb driver

2022-07-06 Thread PengLei (Jira)
PengLei created FLINK-28433: --- Summary: Allow connection to mysql through mariadb driver Key: FLINK-28433 URL: https://issues.apache.org/jira/browse/FLINK-28433 Project: Flink Issue Type: Improvemen

[jira] [Updated] (FLINK-28413) Support ParquetColumnarRowInputFormat in PyFlink

2022-07-06 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-28413: Affects Version/s: (was: 1.15.1) > Support ParquetColumnarRowInputFormat in PyFlink >

[jira] [Assigned] (FLINK-28413) Support ParquetColumnarRowInputFormat in PyFlink

2022-07-06 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-28413: --- Assignee: Juntao Hu > Support ParquetColumnarRowInputFormat in PyFlink > --

[jira] [Commented] (FLINK-28364) Python Job support for Kubernetes Operator

2022-07-06 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563521#comment-17563521 ] Dian Fu commented on FLINK-28364: - [~gyfora] [~thw] +1 to start with a simple example.

[jira] [Closed] (FLINK-28369) Support PARSE_URL bulit-in function in Table API

2022-07-06 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-28369. --- Resolution: Fixed Merged to master via a5b088da231be0d844ef2bc74c148e3bafffb2e1 > Support PARSE_URL bulit-i

[GitHub] [flink] flinkbot commented on pull request #20189: [FLINK-28388][docs][tests] Fix documentation build

2022-07-06 Thread GitBox
flinkbot commented on PR #20189: URL: https://github.com/apache/flink/pull/20189#issuecomment-1176923788 ## CI report: * eb3a95316259e4c79775c8b813ab2eae498950f6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] dianfu merged pull request #20146: [FLINK-28369][table][python] Support PARSE_URL in Table API

2022-07-06 Thread GitBox
dianfu merged PR #20146: URL: https://github.com/apache/flink/pull/20146 -- 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. To unsubscribe, e-mail: issues-unsubscr...@flink.apache

[GitHub] [flink] swuferhong commented on pull request #20007: [FLINK-27989][table-planner] Csv format supports reporting statistics

2022-07-06 Thread GitBox
swuferhong commented on PR #20007: URL: https://github.com/apache/flink/pull/20007#issuecomment-1176921874 @flinkbot run azure -- 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

[jira] [Updated] (FLINK-28388) Python doc build breaking nightly docs

2022-07-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28388: --- Labels: pull-request-available (was: ) > Python doc build breaking nightly docs > -

[GitHub] [flink] dianfu opened a new pull request, #20189: [FLINK-28388][docs][tests] Fix documentation build

2022-07-06 Thread GitBox
dianfu opened a new pull request, #20189: URL: https://github.com/apache/flink/pull/20189 ## What is the purpose of the change *This pull request fixes documentation build* This change is a trivial rework without any test coverage. ## Does this pull request potentiall

[jira] [Commented] (FLINK-28388) Python doc build breaking nightly docs

2022-07-06 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563515#comment-17563515 ] Dian Fu commented on FLINK-28388: - [~mbalassi] Thanks for suggestions. Will try it. > P

[jira] [Updated] (FLINK-28287) Should TaskManagerRunner need a ShutdownHook

2022-07-06 Thread JieFang.He (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JieFang.He updated FLINK-28287: --- Affects Version/s: 1.14.0 > Should TaskManagerRunner need a ShutdownHook > -

[jira] [Updated] (FLINK-28287) Should TaskManagerRunner need a ShutdownHook

2022-07-06 Thread JieFang.He (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JieFang.He updated FLINK-28287: --- Affects Version/s: 1.15.1 1.14.5 (was: 1.14.0) > S

[jira] [Updated] (FLINK-25450) JobMasterTest.testJobFailureWhenTaskExecutorHeartbeatTimeout is unstable on azure

2022-07-06 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25450: --- Labels: stale-major test-stability (was: test-stability) I am the [Flink Jira Bot|https://g

[jira] [Updated] (FLINK-22255) AdaptiveScheduler improvements/bugs

2022-07-06 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22255: --- Labels: pull-request-available stale-major (was: pull-request-available) I am the [Flink Ji

[jira] [Updated] (FLINK-25456) FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint

2022-07-06 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25456: --- Labels: auto-deprioritized-critical stale-major test-stability (was: auto-deprioritized-cri

[jira] [Updated] (FLINK-25939) PyFlink YARN per-job on Docker test fails on AZP because it could not acquire all required slots

2022-07-06 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25939: --- Labels: auto-deprioritized-critical stale-major test-stability (was: auto-deprioritized-cri

[jira] [Updated] (FLINK-24345) Translate "File Systems" page of "Internals" into Chinese

2022-07-06 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-24345: --- Labels: pull-request-available stale-major (was: pull-request-available) I am the [Flink Ji

[jira] [Updated] (FLINK-25624) KafkaSinkITCase.testRecoveryWithExactlyOnceGuarantee blocked on azure pipeline

2022-07-06 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25624: --- Labels: stale-major test-stability (was: test-stability) I am the [Flink Jira Bot|https://g

[jira] [Updated] (FLINK-25217) FLIP-190: Support Version Upgrades for Table API & SQL Programs

2022-07-06 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25217: --- Labels: pull-request-available stale-major (was: pull-request-available) I am the [Flink Ji

[jira] [Updated] (FLINK-25585) JobManagerHAProcessFailureRecoveryITCase.testDispatcherProcessFailure failed on the azure

2022-07-06 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25585: --- Labels: auto-deprioritized-critical stale-major test-stability (was: auto-deprioritized-cri

  1   2   3   4   5   >