[jira] [Updated] (FLINK-28958) flink dataStream to table grows beyond 64 KB

2022-08-14 Thread zck (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zck updated FLINK-28958: Affects Version/s: 1.14.4 (was: 1.14.5) > flink dataStream to table grows beyond 64

[jira] [Updated] (FLINK-28963) Add API compatibility test for sql gateway rest endpoint

2022-08-14 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wencong Liu updated FLINK-28963: Description: Under the package {_}flink-runtime-web{_}, RestAPIStabilityTest performs

[jira] [Created] (FLINK-28963) Add API compatibility test for Sql Gateway Rest Endpoint

2022-08-14 Thread Wencong Liu (Jira)
Wencong Liu created FLINK-28963: --- Summary: Add API compatibility test for Sql Gateway Rest Endpoint Key: FLINK-28963 URL: https://issues.apache.org/jira/browse/FLINK-28963 Project: Flink Issue

[jira] [Updated] (FLINK-28963) Add API compatibility test for sql gateway rest endpoint

2022-08-14 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wencong Liu updated FLINK-28963: Summary: Add API compatibility test for sql gateway rest endpoint (was: Add API compatibility

[GitHub] [flink] godfreyhe commented on a diff in pull request #20513: [FLINK-28858][docs] Add document to describe join hints for batch sql

2022-08-14 Thread GitBox
godfreyhe commented on code in PR #20513: URL: https://github.com/apache/flink/pull/20513#discussion_r945418738 ## docs/content/docs/dev/table/sql/queries/hints.md: ## @@ -84,4 +84,222 @@ insert into kafka_table1 /*+ OPTIONS('sink.partitioner'='round-robin') */ select ```

[GitHub] [flink] lindong28 commented on a diff in pull request #20454: [FLINK-28639][Runtime/Checkpointing] Preserve consistency of events from subtask to OC

2022-08-14 Thread GitBox
lindong28 commented on code in PR #20454: URL: https://github.com/apache/flink/pull/20454#discussion_r945428399 ## flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/SubtaskGatewayImpl.java: ## @@ -86,6 +91,24 @@ class SubtaskGatewayImpl implements

[jira] [Created] (FLINK-28962) Constant memory usage increase

2022-08-14 Thread zhangdong7 (Jira)
zhangdong7 created FLINK-28962: -- Summary: Constant memory usage increase Key: FLINK-28962 URL: https://issues.apache.org/jira/browse/FLINK-28962 Project: Flink Issue Type: Bug

[jira] (FLINK-28530) Improvement of extraction of conditions that can be pushed into join inputs

2022-08-14 Thread Alexander Trushev (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28530 ] Alexander Trushev deleted comment on FLINK-28530: --- was (Author: trushev): Please assign this ticket to me > Improvement of extraction of conditions that can be pushed into join inputs

[jira] [Closed] (FLINK-28567) Introduce predicate inference from one side of join to the other

2022-08-14 Thread Alexander Trushev (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Trushev closed FLINK-28567. - Resolution: Duplicate > Introduce predicate inference from one side of join to the

[GitHub] [flink] trushev closed pull request #20261: [FLINK-28530][table-planner] Improvement of extraction of conditions that can be pushed into join inputs

2022-08-14 Thread GitBox
trushev closed pull request #20261: [FLINK-28530][table-planner] Improvement of extraction of conditions that can be pushed into join inputs URL: https://github.com/apache/flink/pull/20261 -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] trushev commented on pull request #20281: [FLINK-28567][table-planner] Introduce predicate inference from one side of join to the other

2022-08-14 Thread GitBox
trushev commented on PR #20281: URL: https://github.com/apache/flink/pull/20281#issuecomment-1214618817 Implemented https://github.com/apache/flink/pull/20432 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] trushev closed pull request #20281: [FLINK-28567][table-planner] Introduce predicate inference from one side of join to the other

2022-08-14 Thread GitBox
trushev closed pull request #20281: [FLINK-28567][table-planner] Introduce predicate inference from one side of join to the other URL: https://github.com/apache/flink/pull/20281 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Closed] (FLINK-28908) Coder for LIST type is incorrectly chosen is PyFlink

2022-08-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-28908. --- Assignee: Juntao Hu Resolution: Fixed Fixed in: - master via de8ff096a5344d85eb9be497902b99dd4b24e2a9

[GitHub] [flink] dianfu closed pull request #20539: [FLINK-28908][python] Coder for LIST type is incorrectly chosen

2022-08-14 Thread GitBox
dianfu closed pull request #20539: [FLINK-28908][python] Coder for LIST type is incorrectly chosen URL: https://github.com/apache/flink/pull/20539 -- 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] flinkbot commented on pull request #20573: [FLINK-28913][hive] Fix fail to open HiveCatalog when it's for hive3

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

[jira] [Commented] (FLINK-28567) Introduce predicate inference from one side of join to the other

2022-08-14 Thread Alexander Trushev (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17579524#comment-17579524 ] Alexander Trushev commented on FLINK-28567: --- It looks like [~godfreyhe] have implemented the

[jira] [Comment Edited] (FLINK-28567) Introduce predicate inference from one side of join to the other

2022-08-14 Thread Alexander Trushev (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17579524#comment-17579524 ] Alexander Trushev edited comment on FLINK-28567 at 8/15/22 4:31 AM:

[jira] [Updated] (FLINK-28913) Fix fail to open HiveCatalog when it's for hive3

2022-08-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28913: --- Labels: pull-request-available (was: ) > Fix fail to open HiveCatalog when it's for hive3

[GitHub] [flink] flinkbot commented on pull request #20572: [FLINK-28956][hive] Fix non-multi insert statement fall into multi insert logic in Hive dialect

2022-08-14 Thread GitBox
flinkbot commented on PR #20572: URL: https://github.com/apache/flink/pull/20572#issuecomment-1214607482 ## CI report: * 9eec182bddec3be9c28f13adf0ddce7ce197edea UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] luoyuxia opened a new pull request, #20573: [FLINK-28913][hive] Fix fail to open HiveCatalog when it's for hive3

2022-08-14 Thread GitBox
luoyuxia opened a new pull request, #20573: URL: https://github.com/apache/flink/pull/20573 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them

[jira] [Updated] (FLINK-28913) Fix fail to open HiveCatalog when it's for hive3

2022-08-14 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28913: - Summary: Fix fail to open HiveCatalog when it's for hive3 (was: Fix fail to open HiveCatalog in hive3)

[jira] [Updated] (FLINK-28913) Fix fail to open HiveCatalog in hive3

2022-08-14 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28913: - Summary: Fix fail to open HiveCatalog in hive3 (was: Fix fail to open HiveCatalog when it's for hive3)

[jira] [Created] (FLINK-28961) Add the doc how to support third party connector in Python DataStream API

2022-08-14 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-28961: Summary: Add the doc how to support third party connector in Python DataStream API Key: FLINK-28961 URL: https://issues.apache.org/jira/browse/FLINK-28961 Project:

[jira] [Updated] (FLINK-28956) FIx non-multi insert statement fall into multi insert logic in Hive dialect

2022-08-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28956: --- Labels: pull-request-available (was: ) > FIx non-multi insert statement fall into multi

[GitHub] [flink] luoyuxia opened a new pull request, #20572: [FLINK-28956][hive] Fix non-multi insert statement fall into multi insert logic in Hive dialect

2022-08-14 Thread GitBox
luoyuxia opened a new pull request, #20572: URL: https://github.com/apache/flink/pull/20572 ## What is the purpose of the change To fix non-multi insert statement fall into multi insert logic in Hive dialect ## Brief change log - Make the check for multi dest

[GitHub] [flink] godfreyhe commented on a diff in pull request #20506: [FLINK-28493][docs] Add document to describe "ANALYZE TABLE" syntax

2022-08-14 Thread GitBox
godfreyhe commented on code in PR #20506: URL: https://github.com/apache/flink/pull/20506#discussion_r945409287 ## docs/content/docs/dev/table/sql/analyze.md: ## @@ -0,0 +1,364 @@ +--- +title: "ANALYZE TABLE Statements" +weight: 8 +type: docs +aliases: + -

[jira] [Commented] (FLINK-28958) flink dataStream to table grows beyond 64 KB

2022-08-14 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17579523#comment-17579523 ] Jingsong Lee commented on FLINK-28958: -- The generated code in StructuredObjectConverter is not

[GitHub] [flink] flinkbot commented on pull request #20571: [FLINK-27015][hive] Fix exception for casting timestamp to decimal in Hive dialect

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

[jira] [Updated] (FLINK-28927) Can not clean up the uploaded shared files when the checkpoint times out

2022-08-14 Thread ChangjiGuo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ChangjiGuo updated FLINK-28927: --- Description: If a checkpoint times out, the task will cancel the AsyncCheckpointRunnable thread

[GitHub] [flink] luoyuxia closed pull request #19298: [FLINK-27015][hive] Fix exception for casting timestamp to decimal in Hive dialect

2022-08-14 Thread GitBox
luoyuxia closed pull request #19298: [FLINK-27015][hive] Fix exception for casting timestamp to decimal in Hive dialect URL: https://github.com/apache/flink/pull/19298 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Updated] (FLINK-28960) Flink-Pulsar java.lang.NoClassDefFoundError: javax/xml/bind/annotation/XmlElement

2022-08-14 Thread Yufan Sheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yufan Sheng updated FLINK-28960: Summary: Flink-Pulsar java.lang.NoClassDefFoundError: javax/xml/bind/annotation/XmlElement (was:

[jira] [Updated] (FLINK-27015) Fix exception for casting timestam to decimal in Hive dialect

2022-08-14 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27015: - Fix Version/s: 1.16.0 > Fix exception for casting timestam to decimal in Hive dialect >

[jira] [Updated] (FLINK-27015) Fix exception for casting timestam to decimal in Hive dialect

2022-08-14 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27015: - Component/s: Connectors / Hive > Fix exception for casting timestam to decimal in Hive dialect >

[jira] [Updated] (FLINK-27015) Fix exception for casting timestam to decimal in Hive dialect

2022-08-14 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27015: - Affects Version/s: 1.16.0 > Fix exception for casting timestam to decimal in Hive dialect >

[GitHub] [flink] liuyongvs commented on pull request #20544: [FLINK-28893][table] Add built-in conv function.

2022-08-14 Thread GitBox
liuyongvs commented on PR #20544: URL: https://github.com/apache/flink/pull/20544#issuecomment-1214588228 hi @twalthr @wuchong do you have time to review it? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Updated] (FLINK-27015) Fix exception for casting timestam to decimal in Hive dialect

2022-08-14 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27015: - Priority: Critical (was: Major) > Fix exception for casting timestam to decimal in Hive dialect >

[GitHub] [flink] liming30 commented on a diff in pull request #20405: [FLINK-28010][state] Use deleteRange to optimize the clear method of RocksDBMapState.

2022-08-14 Thread GitBox
liming30 commented on code in PR #20405: URL: https://github.com/apache/flink/pull/20405#discussion_r945411319 ## flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/EmbeddedRocksDBStateBackendTest.java: ## @@ -637,11 +642,75

[jira] [Updated] (FLINK-27015) Fix exception for casting timestam to decimal in Hive dialect

2022-08-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27015: --- Labels: pull-request-available (was: ) > Fix exception for casting timestam to decimal in

[GitHub] [flink] luoyuxia opened a new pull request, #20571: [FLINK-27015][hive] Fix exception for casting timestamp to decimal in Hive dialect

2022-08-14 Thread GitBox
luoyuxia opened a new pull request, #20571: URL: https://github.com/apache/flink/pull/20571 ## What is the purpose of the change To fix the exception for casting timestamp to decimal in Hive dialect ## Brief change log - Add a custome udf `flink_hive_to_decimal `

[jira] [Commented] (FLINK-28927) Can not clean up the uploaded shared files when the checkpoint times out

2022-08-14 Thread ChangjiGuo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17579515#comment-17579515 ] ChangjiGuo commented on FLINK-28927: [~yunta] Thanks for your replay. In my first solution, I caught

[jira] [Updated] (FLINK-28960) java.lang.NoClassDefFoundError: javax/xml/bind/annotation/XmlElement

2022-08-14 Thread Yufan Sheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yufan Sheng updated FLINK-28960: Description: {code:java} Unknown HK2 failure detected: MultiException stack 1 of 2

[jira] [Updated] (FLINK-28960) java.lang.NoClassDefFoundError: javax/xml/bind/annotation/XmlElement

2022-08-14 Thread Yufan Sheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yufan Sheng updated FLINK-28960: Description: Unknown HK2 failure detected: MultiException stack 1 of 2

[jira] [Created] (FLINK-28960) java.lang.NoClassDefFoundError: javax/xml/bind/annotation/XmlElement

2022-08-14 Thread Yufan Sheng (Jira)
Yufan Sheng created FLINK-28960: --- Summary: java.lang.NoClassDefFoundError: javax/xml/bind/annotation/XmlElement Key: FLINK-28960 URL: https://issues.apache.org/jira/browse/FLINK-28960 Project: Flink

[jira] [Created] (FLINK-28959) 504 gateway timeout when consume large number of topics using TopicPatten

2022-08-14 Thread Yufan Sheng (Jira)
Yufan Sheng created FLINK-28959: --- Summary: 504 gateway timeout when consume large number of topics using TopicPatten Key: FLINK-28959 URL: https://issues.apache.org/jira/browse/FLINK-28959 Project:

[jira] [Comment Edited] (FLINK-28878) PipelinedRegionSchedulingITCase.testRecoverFromPartitionException failed with AssertionError

2022-08-14 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17579512#comment-17579512 ] Zhu Zhu edited comment on FLINK-28878 at 8/15/22 3:44 AM: -- Fixed via master:

[jira] [Updated] (FLINK-28878) PipelinedRegionSchedulingITCase.testRecoverFromPartitionException failed with AssertionError

2022-08-14 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-28878: Fix Version/s: 1.15.2 > PipelinedRegionSchedulingITCase.testRecoverFromPartitionException failed with >

[jira] [Closed] (FLINK-28878) PipelinedRegionSchedulingITCase.testRecoverFromPartitionException failed with AssertionError

2022-08-14 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28878. --- Resolution: Fixed Fixed via 5f8f387cba774a2c3900ea38e8a3dad017cf1790 >

[jira] [Updated] (FLINK-28878) PipelinedRegionSchedulingITCase.testRecoverFromPartitionException failed with AssertionError

2022-08-14 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-28878: Component/s: Tests (was: Runtime / Coordination) >

[jira] [Updated] (FLINK-28878) PipelinedRegionSchedulingITCase.testRecoverFromPartitionException failed with AssertionError

2022-08-14 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-28878: Affects Version/s: 1.14.5 > PipelinedRegionSchedulingITCase.testRecoverFromPartitionException failed with

[jira] [Updated] (FLINK-28878) PipelinedRegionSchedulingITCase.testRecoverFromPartitionException failed with AssertionError

2022-08-14 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-28878: Affects Version/s: 1.15.1 > PipelinedRegionSchedulingITCase.testRecoverFromPartitionException failed with

[jira] [Updated] (FLINK-28920) Release Testing: Verify Python DataStream Window

2022-08-14 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-28920: - Description: * Build flink source code and compile source code {code:bash} $ cd

[jira] [Updated] (FLINK-28920) Release Testing: Verify Python DataStream Window

2022-08-14 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-28920: - Description: * Build flink source code and compile source code {code:bash} $ cd

[GitHub] [flink] zhuzhurk closed pull request #20559: [FLINK-28878][tests] Increase slot request timeout of PipelinedRegionSchedulingITCase

2022-08-14 Thread GitBox
zhuzhurk closed pull request #20559: [FLINK-28878][tests] Increase slot request timeout of PipelinedRegionSchedulingITCase URL: https://github.com/apache/flink/pull/20559 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] zhuzhurk commented on pull request #20559: [FLINK-28878][tests] Increase slot request timeout of PipelinedRegionSchedulingITCase

2022-08-14 Thread GitBox
zhuzhurk commented on PR #20559: URL: https://github.com/apache/flink/pull/20559#issuecomment-1214580796 Thanks for reviewing! @HuangXingBo Merging. -- 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

[jira] [Created] (FLINK-28958) flink dataStream to table grows beyond 64 KB

2022-08-14 Thread zck (Jira)
zck created FLINK-28958: --- Summary: flink dataStream to table grows beyond 64 KB Key: FLINK-28958 URL: https://issues.apache.org/jira/browse/FLINK-28958 Project: Flink Issue Type: Bug

[jira] [Comment Edited] (FLINK-28930) Add "What is Flink Table Store?" link to flink website

2022-08-14 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17578759#comment-17578759 ] Jingsong Lee edited comment on FLINK-28930 at 8/15/22 3:33 AM: --- asf-site:

[jira] [Updated] (FLINK-28918) Release Testing: Verify FLIP-206 in Python DataStream API

2022-08-14 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-28918: - Description: * Build flink source code and compile source code {code:bash} $ cd

[GitHub] [flink-web] JingsongLi merged pull request #564: [FLINK-28930] Add roadmap of Flink Table Store to Apache Flink Roadmap

2022-08-14 Thread GitBox
JingsongLi merged PR #564: URL: https://github.com/apache/flink-web/pull/564 -- 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] [Resolved] (FLINK-26938) HybridSource recovery from savepoint fails When flink parallelism is greater than the number of Kafka partitions

2022-08-14 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang resolved FLINK-26938. Fix Version/s: 1.16.0 Resolution: Fixed > HybridSource recovery from savepoint

[jira] [Created] (FLINK-28957) Optimize Python API doc

2022-08-14 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-28957: Summary: Optimize Python API doc Key: FLINK-28957 URL: https://issues.apache.org/jira/browse/FLINK-28957 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-28944) Optimize the Python Execution Mode Documentation

2022-08-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-28944. --- Resolution: Fixed Merged to master via a62c5a35aa29014780bb5598facd0fbdf2db4426 > Optimize the Python

[jira] [Commented] (FLINK-28956) FIx non-multi insert statement fall into multi insert logic in Hive dialect

2022-08-14 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17579501#comment-17579501 ] luoyuxia commented on FLINK-28956: -- To fix it, we need a more strict check. > FIx non-multi insert

[GitHub] [flink] dianfu closed pull request #20561: [FLINK-28944][python][docs] Optimize the Python Execution Mode Documentation

2022-08-14 Thread GitBox
dianfu closed pull request #20561: [FLINK-28944][python][docs] Optimize the Python Execution Mode Documentation URL: https://github.com/apache/flink/pull/20561 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] wuchong commented on pull request #20469: [FLINK-28773][hive] Fix Hive sink not write a success file after finish writing in batch mode

2022-08-14 Thread GitBox
wuchong commented on PR #20469: URL: https://github.com/apache/flink/pull/20469#issuecomment-1214566213 Hi @Tartarus0zm , do you have time to update the PR? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Updated] (FLINK-28956) FIx non-multi insert statement fall into multi insert logic in Hive dialect

2022-08-14 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28956: - Description: In [FLINK-27387|https://issues.apache.org/jira/browse/FLINK-27387], we support multi

[jira] [Closed] (FLINK-28208) The method createBatchSink in class HiveTableSink should setParallelism for map operator

2022-08-14 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-28208. --- Fix Version/s: 1.16.0 Assignee: Liu Resolution: Fixed Fixed in master:

[GitHub] [flink] wuchong merged pull request #20471: [FLINK-28208][Connectors/Hive] Set parallelism for map operator in class HiveTableSink's method createBatchSink

2022-08-14 Thread GitBox
wuchong merged PR #20471: URL: https://github.com/apache/flink/pull/20471 -- 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] [Commented] (FLINK-28953) Release Testing: Verify FLIP-91 SQL Gateway

2022-08-14 Thread Jun He (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17579499#comment-17579499 ] Jun He commented on FLINK-28953: Hi, I have implemented an add jar syntax in our company's flink

[jira] [Commented] (FLINK-28926) Release Testing: Verify flip-235 hybrid shuffle mode

2022-08-14 Thread Yu Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17579497#comment-17579497 ] Yu Chen commented on FLINK-28926: - Hi, I would like to take this release testing, please assign this

[jira] [Created] (FLINK-28956) FIx non-multi insert statement fall into multi insert logic in Hive dialect

2022-08-14 Thread luoyuxia (Jira)
luoyuxia created FLINK-28956: Summary: FIx non-multi insert statement fall into multi insert logic in Hive dialect Key: FLINK-28956 URL: https://issues.apache.org/jira/browse/FLINK-28956 Project: Flink

[GitHub] [flink] flinkbot commented on pull request #20570: [hotfix][docs] Fix typos in java doc

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

[jira] [Updated] (FLINK-28953) Release Testing: Verify FLIP-91 SQL Gateway

2022-08-14 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-28953: - Labels: release-testing (was: ) > Release Testing: Verify FLIP-91 SQL Gateway >

[jira] [Updated] (FLINK-28953) Release Testing: Verify FLIP-91 SQL Gateway

2022-08-14 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-28953: - Priority: Blocker (was: Major) > Release Testing: Verify FLIP-91 SQL Gateway >

[jira] [Updated] (FLINK-28954) Release Testing: Verify FLIP-223 HiveServer2 Endpoint

2022-08-14 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-28954: - Labels: release-testing (was: ) > Release Testing: Verify FLIP-223 HiveServer2 Endpoint >

[jira] [Updated] (FLINK-28954) Release Testing: Verify FLIP-223 HiveServer2 Endpoint

2022-08-14 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-28954: - Priority: Blocker (was: Major) > Release Testing: Verify FLIP-223 HiveServer2 Endpoint >

[GitHub] [flink] zhongqishang opened a new pull request, #20570: [hotfix][docs] Fix typos in java doc

2022-08-14 Thread GitBox
zhongqishang opened a new pull request, #20570: URL: https://github.com/apache/flink/pull/20570 ## What is the purpose of the change Fix typos in java doc ## Brief change log Fix the wrong java doc. ## Verifying this change This change is a trivial rework /

[jira] [Commented] (FLINK-28440) EventTimeWindowCheckpointingITCase.testSlidingTimeWindow failed with restore

2022-08-14 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17579492#comment-17579492 ] Huang Xingbo commented on FLINK-28440: --

[jira] [Updated] (FLINK-27301) KafkaSourceE2ECase#restartFromSavepoint is failed on Azure

2022-08-14 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-27301: - Priority: Critical (was: Major) > KafkaSourceE2ECase#restartFromSavepoint is failed on Azure >

[jira] [Commented] (FLINK-27301) KafkaSourceE2ECase#restartFromSavepoint is failed on Azure

2022-08-14 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17579490#comment-17579490 ] Huang Xingbo commented on FLINK-27301: --

[jira] [Commented] (FLINK-28955) YARNHighAvailabilityITCase compile failed in hadoop3

2022-08-14 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17579486#comment-17579486 ] Huang Xingbo commented on FLINK-28955: -- [~chesnay] Could you help take a look? >

[jira] [Created] (FLINK-28955) YARNHighAvailabilityITCase compile failed in hadoop3

2022-08-14 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-28955: Summary: YARNHighAvailabilityITCase compile failed in hadoop3 Key: FLINK-28955 URL: https://issues.apache.org/jira/browse/FLINK-28955 Project: Flink Issue

[jira] [Updated] (FLINK-28954) Release Testing: Verify FLIP-223 HiveServer2 Endpoint

2022-08-14 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-28954: -- Summary: Release Testing: Verify FLIP-223 HiveServer2 Endpoint (was: Release Testing: Verify

[jira] [Commented] (FLINK-28945) Several task IO metrics not displayed on web ui

2022-08-14 Thread Junhan Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17579484#comment-17579484 ] Junhan Yang commented on FLINK-28945: - >From the web UI's perspective, the metrics displayed in the

[jira] [Updated] (FLINK-28945) Several task IO metrics not displayed on web ui

2022-08-14 Thread Junhan Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junhan Yang updated FLINK-28945: Attachment: image-2022-08-15-10-22-59-964.png > Several task IO metrics not displayed on web ui >

[jira] [Created] (FLINK-28954) Release Testing: Verify HiveServer2 Endpoint

2022-08-14 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-28954: - Summary: Release Testing: Verify HiveServer2 Endpoint Key: FLINK-28954 URL: https://issues.apache.org/jira/browse/FLINK-28954 Project: Flink Issue Type:

[jira] [Created] (FLINK-28953) Release Testing: Verify FLIP-91 SQL Gateway

2022-08-14 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-28953: - Summary: Release Testing: Verify FLIP-91 SQL Gateway Key: FLINK-28953 URL: https://issues.apache.org/jira/browse/FLINK-28953 Project: Flink Issue Type:

[GitHub] [flink] flinkbot commented on pull request #20569: [hotfix][hive] fix unstable test in HiveDialectQueryITCase#testBoolComparison

2022-08-14 Thread GitBox
flinkbot commented on PR #20569: URL: https://github.com/apache/flink/pull/20569#issuecomment-1214535048 ## CI report: * 4373f3c05abd1b0b238286d4cbe47d1c8a4c1a1e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-28915) Flink Native k8s mode jar localtion support s3 schema

2022-08-14 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17579478#comment-17579478 ] Yang Wang commented on FLINK-28915: --- Just like what we have done in the flink-kubernetes-operator, I

[GitHub] [flink] yunfengzhou-hub commented on pull request #20454: [FLINK-28639][Runtime/Checkpointing] Preserve consistency of events from subtask to OC

2022-08-14 Thread GitBox
yunfengzhou-hub commented on PR #20454: URL: https://github.com/apache/flink/pull/20454#issuecomment-1214533392 @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] luoyuxia opened a new pull request, #20569: [hotfix][hive] fix unstable test in HiveDialectQueryITCase#testBoolComparison

2022-08-14 Thread GitBox
luoyuxia opened a new pull request, #20569: URL: https://github.com/apache/flink/pull/20569 ## What is the purpose of the change fi x the unstable test in HiveDialectQueryITCase#testBoolComparison ## Brief change log Wait the insert statement finish. ##

[jira] [Reopened] (FLINK-28795) Unstable test for HiveDialectQueryITCase#testInsertDirectory

2022-08-14 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo reopened FLINK-28795: -- > Unstable test for HiveDialectQueryITCase#testInsertDirectory >

[jira] [Commented] (FLINK-28795) Unstable test for HiveDialectQueryITCase#testInsertDirectory

2022-08-14 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17579475#comment-17579475 ] Huang Xingbo commented on FLINK-28795: --

[jira] [Updated] (FLINK-28952) Release Testing: Veify Hive dialect

2022-08-14 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-28952: - Affects Version/s: 1.16.0 > Release Testing: Veify Hive dialect >

[jira] [Updated] (FLINK-28952) Release Testing: Veify Hive dialect

2022-08-14 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-28952: - Labels: release-testing (was: ) > Release Testing: Veify Hive dialect >

[jira] [Updated] (FLINK-28952) Release Testing: Veify Hive dialect

2022-08-14 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-28952: - Priority: Blocker (was: Major) > Release Testing: Veify Hive dialect >

[jira] [Updated] (FLINK-28952) Release Testing: Veify Hive dialect

2022-08-14 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28952: - Fix Version/s: 1.16.0 > Release Testing: Veify Hive dialect > > >

[jira] [Updated] (FLINK-28952) Release Testing: Veify Hive dialect

2022-08-14 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28952: - Component/s: Connectors / Hive Table SQL / API > Release Testing: Veify Hive dialect

[jira] [Created] (FLINK-28952) Release Testing: Veify Hive dialect

2022-08-14 Thread luoyuxia (Jira)
luoyuxia created FLINK-28952: Summary: Release Testing: Veify Hive dialect Key: FLINK-28952 URL: https://issues.apache.org/jira/browse/FLINK-28952 Project: Flink Issue Type: Sub-task

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #142: [FLINK-28943] Add Transformer and Estimator for MaxAbsScaler

2022-08-14 Thread GitBox
yunfengzhou-hub commented on code in PR #142: URL: https://github.com/apache/flink-ml/pull/142#discussion_r945371997 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/maxabsscaler/MaxAbsScaler.java: ## @@ -0,0 +1,201 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [flink-ml] yunfengzhou-hub commented on pull request #140: [FLINK-28894] Add Transformer for Interaction

2022-08-14 Thread GitBox
yunfengzhou-hub commented on PR #140: URL: https://github.com/apache/flink-ml/pull/140#issuecomment-1214497136 Thanks for updating the PR. The correctness and the APIs LGTM. @zhipeng93 could you please take a look at this PR? -- This is an automated message from the Apache Git Service.

  1   2   >