[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

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

[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=17563584#comment-17563584 ] Yun Tang commented on FLINK-28431: -- [~aresyhzhang] Could you check the original JM logs to see whether

[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

[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=17563582#comment-17563582 ] Yangze Guo commented on FLINK-28312: master a99fc3ffbf95910dd8fad6833852ca5eed3f1896 > Introduce

[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

[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

[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

[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=17563577#comment-17563577 ] Gyula Fora commented on FLINK-28297: On a second thought we might simply want to get the resourcens

[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

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

[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=17563565#comment-17563565 ] Yang Wang commented on FLINK-27759: --- This is still not fixed. But it is not a high-priority ticket. We

[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

[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

[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

[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

[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=17563557#comment-17563557 ] bo zhao commented on FLINK-28433: - Hi guys,  I'm working on this now. Thanks > Allow connection to

[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

[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

[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

[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

[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=17563552#comment-17563552 ] hehuiyuan commented on FLINK-26848: --- Hi [~jark]  , have time to look at this issues? > JDBC don't

[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

[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=17563546#comment-17563546 ] Yun Tang commented on FLINK-28010: -- [~Ming Li] Since we do not have a special separator between the

[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

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

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

[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=17563540#comment-17563540 ] aresyhzhang commented on FLINK-28431: - Not tried with latest flink 1.15, but flink 1.14.2 will also

[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

[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=17563534#comment-17563534 ] lincoln lee commented on FLINK-28434: - cc [~fsk119] would you like to look at this issue when you

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

[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

[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

[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=17563531#comment-17563531 ] Shengkai Fang commented on FLINK-27767: --- Closed in master:

[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=results Manual Test in my private Azure -- This is an automated message from the Apache Git Service. To

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

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

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

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

[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

[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)
> Time taken: 0.087 seconds, Fetched: 41 row(s) >   > flink table code >   > val hive = new HiveCatalog(name, defaultDatabase, hiveConfDir) > tableEnv.registerCatalog(name, hive) > // > set the HiveCatalog as the current catalog of the session > tableEnv.useCatalog(nam

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

[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=17563521#comment-17563521 ] Dian Fu commented on FLINK-28364: - [~gyfora] [~thw] +1 to start with a simple example. > Python Job

[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

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

[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

[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

[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=17563515#comment-17563515 ] Dian Fu commented on FLINK-28388: - [~mbalassi] Thanks for suggestions. Will try it. > Python doc build

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

[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

[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

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

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

[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

[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

[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

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

[jira] [Updated] (FLINK-24528) Flink HBase Asyc Lookup throw NPE if rowkey is null

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

[jira] [Updated] (FLINK-26970) Fix comment style error

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

[jira] [Updated] (FLINK-25480) Create dashboard/monitoring to see resource usage per E2E test

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

[jira] [Updated] (FLINK-25736) Chinese Translation - Update documentation for Kinesis Table Api

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

[jira] [Updated] (FLINK-25695) TemporalJoin cause state leak in some cases

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

[jira] [Updated] (FLINK-21234) testKafkaSourceSinkWithKeyAndPartialValue[legacy = false, format = csv] hang

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

[jira] [Updated] (FLINK-25651) Flink1.14.2 DataStream Connectors Kafka Deserializer example method uses the wrong parameter

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

[jira] [Updated] (FLINK-25737) Chinese Translation - Add documentation for Firehose Async Sink

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

[jira] [Updated] (FLINK-21420) Add path templating to the DataStream API

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

[jira] [Updated] (FLINK-24577) Support cast from BINARY/VARBINARY/BYTES to of RAW()

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

[jira] [Updated] (FLINK-21573) Support expression reuse in codegen

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

[jira] [Updated] (FLINK-25938) SynchronousCheckpointITCase.taskDispatcherThreadPoolAllowsForSynchronousCheckpoints fails on AZP

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

[jira] [Updated] (FLINK-21283) Support sql extension for flink sql

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

[jira] [Updated] (FLINK-20995) WebSubmissionJobClient should implement CoordinationRequestGateway and throws proper exceptions

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

[jira] [Updated] (FLINK-22178) Support ignore-first-line option in new csv format

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

[jira] [Updated] (FLINK-21665) Create catalog statement should support [IF NOT EXIST] and [COMMENT]

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

  1   2   3   4   5   >