[GitHub] [flink] flinkbot commented on pull request #19430: [BK-1.15][FLINK-26931][Connector/pulsar] Make the producer name and consumer name unique in Pulsar

2022-04-11 Thread GitBox
flinkbot commented on PR #19430: URL: https://github.com/apache/flink/pull/19430#issuecomment-1096192959 ## CI report: * 7fe3b4d67587ab503212ec4a79ad30272900c829 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink-web] infoverload commented on a diff in pull request #526: Announcement blogpost for the 1.15 release

2022-04-11 Thread GitBox
infoverload commented on code in PR #526: URL: https://github.com/apache/flink-web/pull/526#discussion_r848042270 ## _posts/2022-04-11-1.15-announcement.md: ## @@ -0,0 +1,375 @@ +--- +layout: post +title: "Announcing the Release of Apache Flink 1.15" +subtitle: "" +date: 2022-0

[GitHub] [flink-web] infoverload commented on a diff in pull request #526: Announcement blogpost for the 1.15 release

2022-04-11 Thread GitBox
infoverload commented on code in PR #526: URL: https://github.com/apache/flink-web/pull/526#discussion_r848042065 ## _posts/2022-04-11-1.15-announcement.md: ## @@ -0,0 +1,375 @@ +--- +layout: post +title: "Announcing the Release of Apache Flink 1.15" +subtitle: "" +date: 2022-0

[jira] [Closed] (FLINK-27172) Support bulk based format provided by Flink

2022-04-11 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-27172. Fix Version/s: table-store-0.2.0 Resolution: Fixed master: e1e65d73b71122a23142c48ce7f792e3

[jira] [Updated] (FLINK-27191) Support multi kerberos-enabled Hive clusters

2022-04-11 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27191: - Description: Currently, to access kerberos-enabled Hive cluster, users are expected to add key/secret in

[GitHub] [flink-table-store] JingsongLi merged pull request #89: [FLINK-27172] Support bulk based format provided by Flink

2022-04-11 Thread GitBox
JingsongLi merged PR #89: URL: https://github.com/apache/flink-table-store/pull/89 -- 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...@fl

[GitHub] [flink-web] infoverload commented on a diff in pull request #526: Announcement blogpost for the 1.15 release

2022-04-11 Thread GitBox
infoverload commented on code in PR #526: URL: https://github.com/apache/flink-web/pull/526#discussion_r848040776 ## _posts/2022-04-11-1.15-announcement.md: ## @@ -0,0 +1,375 @@ +--- +layout: post +title: "Announcing the Release of Apache Flink 1.15" +subtitle: "" +date: 2022-0

[GitHub] [flink] syhily opened a new pull request, #19430: [BK-1.15][FLINK-26931][Connector/pulsar] Make the producer name and consumer name unique in Pulsar

2022-04-11 Thread GitBox
syhily opened a new pull request, #19430: URL: https://github.com/apache/flink/pull/19430 This is a backport PR for #19285. -- 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-27190) Revisit error handling in main reconcile() loop

2022-04-11 Thread Matyas Orhidi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matyas Orhidi updated FLINK-27190: -- Description: The are some improvements introduced around error handling: * [https://github.co

[jira] [Updated] (FLINK-27190) Revisit error handling in main reconcile() loop

2022-04-11 Thread Matyas Orhidi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matyas Orhidi updated FLINK-27190: -- Description: The are some improvements introduced around error handling: * [https://github.co

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #165: [FLINK-26140] Support rollback strategies

2022-04-11 Thread GitBox
gyfora commented on code in PR #165: URL: https://github.com/apache/flink-kubernetes-operator/pull/165#discussion_r848038451 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/ApplicationReconciler.java: ## @@ -111,12 +114,34 @

[jira] [Commented] (FLINK-27190) Revisit error handling in main reconcile() loop

2022-04-11 Thread Matyas Orhidi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520943#comment-17520943 ] Matyas Orhidi commented on FLINK-27190: --- Nothing major [~gyfora]: * The main reas

[GitHub] [flink-web] infoverload commented on a diff in pull request #526: Announcement blogpost for the 1.15 release

2022-04-11 Thread GitBox
infoverload commented on code in PR #526: URL: https://github.com/apache/flink-web/pull/526#discussion_r848035205 ## _posts/2022-04-11-1.15-announcement.md: ## @@ -0,0 +1,375 @@ +--- +layout: post +title: "Announcing the Release of Apache Flink 1.15" +subtitle: "" +date: 2022-0

[GitHub] [flink-web] infoverload commented on a diff in pull request #526: Announcement blogpost for the 1.15 release

2022-04-11 Thread GitBox
infoverload commented on code in PR #526: URL: https://github.com/apache/flink-web/pull/526#discussion_r848034858 ## _posts/2022-04-11-1.15-announcement.md: ## @@ -0,0 +1,375 @@ +--- +layout: post +title: "Announcing the Release of Apache Flink 1.15" +subtitle: "" +date: 2022-0

[jira] [Commented] (FLINK-26761) Fix the cast exception thrown by PreValidateReWriter when insert into/overwrite a partitioned table.

2022-04-11 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520941#comment-17520941 ] zoucao commented on FLINK-26761: Sure, [~godfreyhe], plz assign it to me. > Fix the cas

[jira] [Updated] (FLINK-27195) KafkaSourceReader offsetsToCommit should be mutable

2022-04-11 Thread Mason Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mason Chen updated FLINK-27195: --- Description: In the KafkaSourceReader, offsetsToCommit should be mutable. Currently, the condition t

[GitHub] [flink] luoyuxia commented on pull request #19329: [FLINK-22318][table] Support RENAME column name for ALTER TABLE statement

2022-04-11 Thread GitBox
luoyuxia commented on PR #19329: URL: https://github.com/apache/flink/pull/19329#issuecomment-1096175728 @lsyldliu Thanks for updating. LGTM 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 t

[jira] [Updated] (FLINK-27191) Support multi kerberos-enabled Hive clusters

2022-04-11 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27191: - Description: Currently, to accesse kerberos-enabled Hive cluster, users are expected to add key/secret i

[jira] [Created] (FLINK-27195) KafkaSourceReader offsetsToCommit should be mutable

2022-04-11 Thread Mason Chen (Jira)
Mason Chen created FLINK-27195: -- Summary: KafkaSourceReader offsetsToCommit should be mutable Key: FLINK-27195 URL: https://issues.apache.org/jira/browse/FLINK-27195 Project: Flink Issue Type: B

[GitHub] [flink-kubernetes-operator] Aitozi commented on a diff in pull request #165: [FLINK-26140] Support rollback strategies

2022-04-11 Thread GitBox
Aitozi commented on code in PR #165: URL: https://github.com/apache/flink-kubernetes-operator/pull/165#discussion_r848028572 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/ApplicationReconciler.java: ## @@ -111,12 +114,34 @

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #165: [FLINK-26140] Support rollback strategies

2022-04-11 Thread GitBox
gyfora commented on code in PR #165: URL: https://github.com/apache/flink-kubernetes-operator/pull/165#discussion_r848024085 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/ApplicationReconciler.java: ## @@ -111,12 +114,34 @

[GitHub] [flink-kubernetes-operator] Aitozi commented on a diff in pull request #165: [FLINK-26140] Support rollback strategies

2022-04-11 Thread GitBox
Aitozi commented on code in PR #165: URL: https://github.com/apache/flink-kubernetes-operator/pull/165#discussion_r848017896 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/ApplicationReconciler.java: ## @@ -111,12 +114,34 @

[GitHub] [flink] lsyldliu commented on pull request #19329: [FLINK-22318][table] Support RENAME column name for ALTER TABLE statement

2022-04-11 Thread GitBox
lsyldliu commented on PR #19329: URL: https://github.com/apache/flink/pull/19329#issuecomment-1096149139 @luoyuxia Thanks for your second round review, I have fixed the comment. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #165: [FLINK-26140] Support rollback strategies

2022-04-11 Thread GitBox
gyfora commented on code in PR #165: URL: https://github.com/apache/flink-kubernetes-operator/pull/165#discussion_r848015530 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/deployment/SessionObserver.java: ## @@ -50,4 +52,9 @@ public voi

[jira] [Updated] (FLINK-27194) Whether to consider adding the configuration of ignore when data deserialization failed for avro fromat.

2022-04-11 Thread hehuiyuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-27194: -- Summary: Whether to consider adding the configuration of ignore when data deserialization failed for a

[jira] [Updated] (FLINK-27194) Whether to consider adding the configuration of ignore when data deserialization failed for avro format.

2022-04-11 Thread hehuiyuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-27194: -- Summary: Whether to consider adding the configuration of ignore when data deserialization failed for a

[jira] [Created] (FLINK-27194) Whether to consider adding the configuration of ignore when data deserialization failed.

2022-04-11 Thread hehuiyuan (Jira)
hehuiyuan created FLINK-27194: - Summary: Whether to consider adding the configuration of ignore when data deserialization failed. Key: FLINK-27194 URL: https://issues.apache.org/jira/browse/FLINK-27194 Pr

[jira] [Commented] (FLINK-27191) Support multi kerberos-enabled Hive clusters

2022-04-11 Thread Yuan Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520931#comment-17520931 ] Yuan Zhu commented on FLINK-27191: -- Hi, [~luoyuxia]. Do you have any idea to deal with

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #165: [FLINK-26140] Support rollback strategies

2022-04-11 Thread GitBox
gyfora commented on code in PR #165: URL: https://github.com/apache/flink-kubernetes-operator/pull/165#discussion_r848012796 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/ReconciliationUtils.java: ## @@ -62,40 +64,42 @@ public static

[GitHub] [flink] lsyldliu commented on a diff in pull request #19329: [FLINK-22318][table] Support RENAME column name for ALTER TABLE statement

2022-04-11 Thread GitBox
lsyldliu commented on code in PR #19329: URL: https://github.com/apache/flink/pull/19329#discussion_r848011475 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/operations/SqlToOperationConverterTest.java: ## @@ -1269,6 +1271,112 @@ public void test

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #165: [FLINK-26140] Support rollback strategies

2022-04-11 Thread GitBox
gyfora commented on code in PR #165: URL: https://github.com/apache/flink-kubernetes-operator/pull/165#discussion_r848012465 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/ApplicationReconciler.java: ## @@ -111,12 +114,34 @

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #165: [FLINK-26140] Support rollback strategies

2022-04-11 Thread GitBox
gyfora commented on code in PR #165: URL: https://github.com/apache/flink-kubernetes-operator/pull/165#discussion_r848012019 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/ApplicationReconciler.java: ## @@ -111,12 +114,34 @

[GitHub] [flink] lsyldliu commented on a diff in pull request #19329: [FLINK-22318][table] Support RENAME column name for ALTER TABLE statement

2022-04-11 Thread GitBox
lsyldliu commented on code in PR #19329: URL: https://github.com/apache/flink/pull/19329#discussion_r848011475 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/operations/SqlToOperationConverterTest.java: ## @@ -1269,6 +1271,112 @@ public void test

[GitHub] [flink] lsyldliu commented on a diff in pull request #19329: [FLINK-22318][table] Support RENAME column name for ALTER TABLE statement

2022-04-11 Thread GitBox
lsyldliu commented on code in PR #19329: URL: https://github.com/apache/flink/pull/19329#discussion_r848011475 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/operations/SqlToOperationConverterTest.java: ## @@ -1269,6 +1271,112 @@ public void test

[jira] [Updated] (FLINK-27193) Kyro Serialisation and Deserialisation returns a different object

2022-04-11 Thread Akshay Hazari (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Akshay Hazari updated FLINK-27193: -- Description: We have a unit test to check if Kyro serialisation and deserialisation results i

[GitHub] [flink-web] infoverload commented on a diff in pull request #526: Announcement blogpost for the 1.15 release

2022-04-11 Thread GitBox
infoverload commented on code in PR #526: URL: https://github.com/apache/flink-web/pull/526#discussion_r848006711 ## _posts/2022-04-11-1.15-announcement.md: ## @@ -0,0 +1,375 @@ +--- +layout: post +title: "Announcing the Release of Apache Flink 1.15" +subtitle: "" +date: 2022-0

[GitHub] [flink] lsyldliu commented on a diff in pull request #19329: [FLINK-22318][table] Support RENAME column name for ALTER TABLE statement

2022-04-11 Thread GitBox
lsyldliu commented on code in PR #19329: URL: https://github.com/apache/flink/pull/19329#discussion_r848005643 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/OperationConverterUtils.java: ## @@ -144,6 +147,150 @@ public static Operation con

[GitHub] [flink-kubernetes-operator] Aitozi commented on a diff in pull request #165: [FLINK-26140] Support rollback strategies

2022-04-11 Thread GitBox
Aitozi commented on code in PR #165: URL: https://github.com/apache/flink-kubernetes-operator/pull/165#discussion_r847992477 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/deployment/ApplicationObserver.java: ## @@ -144,4 +148,22 @@ pri

[GitHub] [flink-web] infoverload commented on a diff in pull request #526: Announcement blogpost for the 1.15 release

2022-04-11 Thread GitBox
infoverload commented on code in PR #526: URL: https://github.com/apache/flink-web/pull/526#discussion_r848005265 ## _posts/2022-04-11-1.15-announcement.md: ## @@ -0,0 +1,375 @@ +--- +layout: post +title: "Announcing the Release of Apache Flink 1.15" +subtitle: "" +date: 2022-0

[jira] [Updated] (FLINK-27193) Kyro Serialisation and Deserialisation returns a different object

2022-04-11 Thread Akshay Hazari (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Akshay Hazari updated FLINK-27193: -- Description: We have a unit test to check if Kyro serialisation and deserialisation results i

[jira] [Updated] (FLINK-27193) Kyro Serialisation and Deserialisation returns a different object

2022-04-11 Thread Akshay Hazari (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Akshay Hazari updated FLINK-27193: -- Priority: Minor (was: Not a Priority) > Kyro Serialisation and Deserialisation returns a diff

[jira] [Updated] (FLINK-27193) Kyro Serialisation and Deserialisation returns a different object

2022-04-11 Thread Akshay Hazari (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Akshay Hazari updated FLINK-27193: -- Description: We have a unit test to check if Kyro serialisation and deserialisation results i

[jira] [Created] (FLINK-27193) Kyro Serialisation and Deserialisation returns a different object

2022-04-11 Thread Akshay Hazari (Jira)
Akshay Hazari created FLINK-27193: - Summary: Kyro Serialisation and Deserialisation returns a different object Key: FLINK-27193 URL: https://issues.apache.org/jira/browse/FLINK-27193 Project: Flink

[jira] [Commented] (FLINK-27190) Revisit error handling in main reconcile() loop

2022-04-11 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520915#comment-17520915 ] Gyula Fora commented on FLINK-27190: What improvements do you suggest? > Revisit er

[GitHub] [flink] liuzhuang2017 commented on a diff in pull request #19413: [FLINK-16078] [docs-zh] Translate "Tuning Checkpoints and Large State…

2022-04-11 Thread GitBox
liuzhuang2017 commented on code in PR #19413: URL: https://github.com/apache/flink/pull/19413#discussion_r847981768 ## docs/content.zh/docs/ops/state/large_state_tuning.md: ## @@ -166,149 +125,101 @@ public class MyOptionsFactory implements ConfigurableRocksDBOptionsFactory {

[jira] [Commented] (FLINK-27165) Benchmark test SerializationFrameworkMiniBenchmarks#serializerHeavyString became unstable

2022-04-11 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520914#comment-17520914 ] Anton Kalashnikov commented on FLINK-27165: --- I can try to take a look. But I d

[GitHub] [flink] masteryhx commented on a diff in pull request #19142: [FLINK-23252][changelog] Support recovery from checkpoint after disab…

2022-04-11 Thread GitBox
masteryhx commented on code in PR #19142: URL: https://github.com/apache/flink/pull/19142#discussion_r847968836 ## flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/metadata/MetadataV2V3SerializerBase.java: ## @@ -391,7 +394,7 @@ static void serializeKeyedStateHand

[jira] [Updated] (FLINK-27192) Parquet File Read From Local

2022-04-11 Thread Karthik (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Karthik updated FLINK-27192: Issue Type: Technical Debt (was: Bug) > Parquet File Read From Local > > >

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #87: [FLINK-27123] Introduce filter predicate for 'LIKE'

2022-04-11 Thread GitBox
JingsongLi commented on code in PR #87: URL: https://github.com/apache/flink-table-store/pull/87#discussion_r847944688 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/StartsWith.java: ## @@ -0,0 +1,62 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #87: [FLINK-27123] Introduce filter predicate for 'LIKE'

2022-04-11 Thread GitBox
JingsongLi commented on code in PR #87: URL: https://github.com/apache/flink-table-store/pull/87#discussion_r847942602 ## flink-table-store-core/src/test/java/org/apache/flink/table/store/file/predicate/PredicateTest.java: ## @@ -325,11 +345,29 @@ public void testUnsupportedExpr

[jira] [Updated] (FLINK-26761) Fix the cast exception thrown by PreValidateReWriter when insert into/overwrite a partitioned table.

2022-04-11 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-26761: --- Fix Version/s: 1.16.0 > Fix the cast exception thrown by PreValidateReWriter when insert > into/ove

[jira] [Commented] (FLINK-26761) Fix the cast exception thrown by PreValidateReWriter when insert into/overwrite a partitioned table.

2022-04-11 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520902#comment-17520902 ] godfrey he commented on FLINK-26761: [~zoucao] you are right, it's a bug. would you

[jira] [Updated] (FLINK-27192) Parquet File Read From Local

2022-04-11 Thread Karthik (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Karthik updated FLINK-27192: Component/s: Table SQL / API Table SQL / Client Fix Version/s: 1.13.6

[jira] [Updated] (FLINK-27189) Support to always add quotes for string data in CSV format

2022-04-11 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-27189: Summary: Support to always add quotes for string data in CSV format (was: Ability for table api to always

[jira] [Updated] (FLINK-27189) Ability for table api to always add quotes to generated csv

2022-04-11 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-27189: Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile) (was: API / Python) > A

[jira] [Created] (FLINK-27192) Hi,

2022-04-11 Thread Karthik (Jira)
Karthik created FLINK-27192: --- Summary: Hi, Key: FLINK-27192 URL: https://issues.apache.org/jira/browse/FLINK-27192 Project: Flink Issue Type: Bug Reporter: Karthik -- This message

[jira] [Commented] (FLINK-27138) flink1.14.0-sql-job submit failed:Flink doesn't support individual window table-valued function TUMBLE

2022-04-11 Thread yanbiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520899#comment-17520899 ] yanbiao commented on FLINK-27138: - [~martijnvisser] got it,thanks for your help:) > fli

[jira] [Assigned] (FLINK-26829) ClassCastException will be thrown when the second operand of divide is a function call

2022-04-11 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-26829: -- Assignee: luoyuxia > ClassCastException will be thrown when the second operand of divide is

[jira] [Commented] (FLINK-25242) UDF with primitive int argument does not accept int values even after a not null filter

2022-04-11 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520898#comment-17520898 ] godfrey he commented on FLINK-25242: good catch~ > UDF with primitive int argument

[GitHub] [flink-ml] weibozhao commented on a diff in pull request #83: [FLINK-27170] Add Transformer and Estimator of Ftrl

2022-04-11 Thread GitBox
weibozhao commented on code in PR #83: URL: https://github.com/apache/flink-ml/pull/83#discussion_r847916030 ## flink-ml-lib/src/main/java/org/apache/flink/ml/classification/logisticregression/LinearModelData.java: ## @@ -37,60 +38,68 @@ import java.io.OutputStream; /** - *

[GitHub] [flink-ml] weibozhao commented on a diff in pull request #83: [FLINK-27170] Add Transformer and Estimator of Ftrl

2022-04-11 Thread GitBox
weibozhao commented on code in PR #83: URL: https://github.com/apache/flink-ml/pull/83#discussion_r847915850 ## flink-ml-lib/src/main/java/org/apache/flink/ml/classification/logisticregression/LinearModelData.java: ## @@ -37,60 +38,68 @@ import java.io.OutputStream; /** - *

[jira] [Resolved] (FLINK-26757) change the default value of state.backend.rocksdb.restore-overlap-fraction-threshold

2022-04-11 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-26757. -- Resolution: Fixed merged in master: 4034d3cd6d13e88e2e5ca101510bf333e94a53fa > change the default val

[GitHub] [flink] Myasuka merged pull request #19324: [FLINK-26757][state] Change the default value of state.backend.rocksdb.restore-overlap-fraction-threshold to 0

2022-04-11 Thread GitBox
Myasuka merged PR #19324: URL: https://github.com/apache/flink/pull/19324 -- 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.apach

[GitHub] [flink] Myasuka commented on a diff in pull request #19413: [FLINK-16078] [docs-zh] Translate "Tuning Checkpoints and Large State…

2022-04-11 Thread GitBox
Myasuka commented on code in PR #19413: URL: https://github.com/apache/flink/pull/19413#discussion_r847908442 ## docs/content.zh/docs/ops/state/large_state_tuning.md: ## @@ -166,149 +125,101 @@ public class MyOptionsFactory implements ConfigurableRocksDBOptionsFactory { } ```

[GitHub] [flink] zoltar9264 commented on a diff in pull request #19252: [FLINK-25867][docs] translate ChangelogBackend documentation to chinese

2022-04-11 Thread GitBox
zoltar9264 commented on code in PR #19252: URL: https://github.com/apache/flink/pull/19252#discussion_r847906550 ## docs/content.zh/docs/ops/state/state_backends.md: ## @@ -38,6 +38,8 @@ under the License. 在启动 CheckPoint 机制时,状态会随着 CheckPoint 而持久化,以防止数据丢失、保障恢复时的一致性。 状态内部的存储格式、状

[GitHub] [flink] zoltar9264 commented on pull request #19252: [FLINK-25867][docs] translate ChangelogBackend documentation to chinese

2022-04-11 Thread GitBox
zoltar9264 commented on PR #19252: URL: https://github.com/apache/flink/pull/19252#issuecomment-1095911460 Thank for your review again @masteryhx , I hive fixed problems you mentioned. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] zoltar9264 commented on a diff in pull request #19252: [FLINK-25867][docs] translate ChangelogBackend documentation to chinese

2022-04-11 Thread GitBox
zoltar9264 commented on code in PR #19252: URL: https://github.com/apache/flink/pull/19252#discussion_r847905580 ## docs/content.zh/docs/ops/state/state_backends.md: ## @@ -306,77 +329,75 @@ public class MyOptionsFactory implements ConfigurableRocksDBOptionsFactory { {{< top

[GitHub] [flink] luoyuxia commented on pull request #19400: [FLINK-25142][Connectors / Hive]Fix user-defined hive udtf initialize exception in hive dialect

2022-04-11 Thread GitBox
luoyuxia commented on PR #19400: URL: https://github.com/apache/flink/pull/19400#issuecomment-1095903340 Thanks @Tartarus0zm for contribution. It's a continue work of #17990. LGTM. @beyond1920 @wuchong Could you please help review & merge? -- This is an automated message from the

[jira] [Updated] (FLINK-27191) Support multi kerberos-enabled Hive clusters

2022-04-11 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27191: - Component/s: Connectors / Hive > Support multi kerberos-enabled Hive clusters > ---

[jira] [Created] (FLINK-27191) Support multi kerberos-enabled Hive clusters

2022-04-11 Thread luoyuxia (Jira)
luoyuxia created FLINK-27191: Summary: Support multi kerberos-enabled Hive clusters Key: FLINK-27191 URL: https://issues.apache.org/jira/browse/FLINK-27191 Project: Flink Issue Type: Improvement

[GitHub] [flink] luoyuxia commented on pull request #19423: [FLINK-27175][hive] Support to call Hive UDAF when the UDAF accepts one parameter with array type

2022-04-11 Thread GitBox
luoyuxia commented on PR #19423: URL: https://github.com/apache/flink/pull/19423#issuecomment-1095873524 @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] flinkbot commented on pull request #19429: [hotfix][docs] Fix the "capacity-planning" page of "Tuning Checkpoint…

2022-04-11 Thread GitBox
flinkbot commented on PR #19429: URL: https://github.com/apache/flink/pull/19429#issuecomment-1095867338 ## CI report: * 9e092e3dfca1ea6effdf2edd26acdf9c590d5ac6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] wenlong88 commented on pull request #19179: [FLINK-26756][table-planner] Fix the deserialization error for match recognize

2022-04-11 Thread GitBox
wenlong88 commented on PR #19179: URL: https://github.com/apache/flink/pull/19179#issuecomment-1095863004 LGTM -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscrib

[GitHub] [flink] liuzhuang2017 opened a new pull request, #19429: [hotfix][docs] Fix the "capacity-planning" page of "Tuning Checkpoint…

2022-04-11 Thread GitBox
liuzhuang2017 opened a new pull request, #19429: URL: https://github.com/apache/flink/pull/19429 Fix the "capacity-planning" page of "Tuning Checkpoints and Large State" ## What is the purpose of the change Fix the "capacity-planning" page of "Tuning Checkpoints and Larg

[GitHub] [flink-table-store] LadyForest commented on a diff in pull request #87: [FLINK-27123] Introduce filter predicate for 'LIKE'

2022-04-11 Thread GitBox
LadyForest commented on code in PR #87: URL: https://github.com/apache/flink-table-store/pull/87#discussion_r847890543 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/PredicateConverter.java: ## @@ -95,9 +102,46 @@ public Predicate visit(CallE

[GitHub] [flink] zoltar9264 commented on a diff in pull request #19252: [FLINK-25867][docs] translate ChangelogBackend documentation to chinese

2022-04-11 Thread GitBox
zoltar9264 commented on code in PR #19252: URL: https://github.com/apache/flink/pull/19252#discussion_r847887144 ## docs/content.zh/docs/ops/state/state_backends.md: ## @@ -306,77 +329,75 @@ public class MyOptionsFactory implements ConfigurableRocksDBOptionsFactory { {{< top

[GitHub] [flink] zoltar9264 commented on a diff in pull request #19252: [FLINK-25867][docs] translate ChangelogBackend documentation to chinese

2022-04-11 Thread GitBox
zoltar9264 commented on code in PR #19252: URL: https://github.com/apache/flink/pull/19252#discussion_r847885936 ## docs/content.zh/docs/ops/state/state_backends.md: ## @@ -38,6 +38,8 @@ under the License. 在启动 CheckPoint 机制时,状态会随着 CheckPoint 而持久化,以防止数据丢失、保障恢复时的一致性。 状态内部的存储格式、状

[GitHub] [flink] masteryhx commented on a diff in pull request #19252: [FLINK-25867][docs] translate ChangelogBackend documentation to chinese

2022-04-11 Thread GitBox
masteryhx commented on code in PR #19252: URL: https://github.com/apache/flink/pull/19252#discussion_r847882156 ## docs/content.zh/docs/ops/state/state_backends.md: ## @@ -306,77 +329,75 @@ public class MyOptionsFactory implements ConfigurableRocksDBOptionsFactory { {{< top

[GitHub] [flink] masteryhx commented on a diff in pull request #19252: [FLINK-25867][docs] translate ChangelogBackend documentation to chinese

2022-04-11 Thread GitBox
masteryhx commented on code in PR #19252: URL: https://github.com/apache/flink/pull/19252#discussion_r847877301 ## docs/content.zh/docs/ops/state/state_backends.md: ## @@ -38,6 +38,8 @@ under the License. 在启动 CheckPoint 机制时,状态会随着 CheckPoint 而持久化,以防止数据丢失、保障恢复时的一致性。 状态内部的存储格式、状态

[jira] [Commented] (FLINK-27018) timestamp missing end zero when outputing to kafka

2022-04-11 Thread Yao Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520882#comment-17520882 ] Yao Zhang commented on FLINK-27018: --- Hi [~fpaul] and [~jeff-zou] , I reproduced this

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #87: [FLINK-27123] Introduce filter predicate for 'LIKE'

2022-04-11 Thread GitBox
JingsongLi commented on code in PR #87: URL: https://github.com/apache/flink-table-store/pull/87#discussion_r847865264 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/PredicateConverter.java: ## @@ -95,9 +102,46 @@ public Predicate visit(CallE

[GitHub] [flink] beyond1920 closed pull request #19109: [FLINK-26681][hive] Support sql statement end with ";" for Hive dialect query

2022-04-11 Thread GitBox
beyond1920 closed pull request #19109: [FLINK-26681][hive] Support sql statement end with ";" for Hive dialect query URL: https://github.com/apache/flink/pull/19109 -- 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-ml] yunfengzhou-hub commented on a diff in pull request #83: [FLINK-27170] Add Transformer and Estimator of Ftrl

2022-04-11 Thread GitBox
yunfengzhou-hub commented on code in PR #83: URL: https://github.com/apache/flink-ml/pull/83#discussion_r847844186 ## flink-ml-lib/src/main/java/org/apache/flink/ml/classification/ftrl/Ftrl.java: ## @@ -0,0 +1,395 @@ +/* Review Comment: Jira tickets for algorithms that are s

[jira] [Commented] (FLINK-27187) The attemptsPerUpload metric may be lower than it actually is

2022-04-11 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520859#comment-17520859 ] Feifan Wang commented on FLINK-27187: - I think it's ok. Should I open a new ticket d

[jira] [Commented] (FLINK-27187) The attemptsPerUpload metric may be lower than it actually is

2022-04-11 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520845#comment-17520845 ] Roman Khachatryan commented on FLINK-27187: --- How about "totalAttemptsPerUpload

[jira] [Commented] (FLINK-27187) The attemptsPerUpload metric may be lower than it actually is

2022-04-11 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520836#comment-17520836 ] Feifan Wang commented on FLINK-27187: - [~roman] , how would you like to name the met

[jira] [Commented] (FLINK-27187) The attemptsPerUpload metric may be lower than it actually is

2022-04-11 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520833#comment-17520833 ] Roman Khachatryan commented on FLINK-27187: --- The number of the successfull att

[jira] [Commented] (FLINK-27132) CheckpointResourcesCleanupRunner might discard shared state of the initial checkpoint

2022-04-11 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520830#comment-17520830 ] Roman Khachatryan commented on FLINK-27132: --- Sorry, I mean the 5th item. And

[jira] [Updated] (FLINK-26070) Update dependency numpy to >=1.21.0,<1.22

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

[jira] [Updated] (FLINK-25962) Flink generated Avro schemas can't be parsed using Python

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

[jira] [Updated] (FLINK-21383) Docker image does not play well together with ConfigMap based flink-conf.yamls

2022-04-11 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21383: --- Labels: auto-deprioritized-major usability (was: stale-major usability) Priority: Mino

[jira] [Updated] (FLINK-27132) CheckpointResourcesCleanupRunner might discard shared state of the initial checkpoint

2022-04-11 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-27132: -- Description: When considering the following case: # A job starts from a checkpoint in

[jira] [Updated] (FLINK-27132) CheckpointResourcesCleanupRunner might discard shared state of the initial checkpoint

2022-04-11 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-27132: -- Description: When considering the following case: # A job starts from a checkpoint in

[jira] [Updated] (FLINK-27132) CheckpointResourcesCleanupRunner might discard shared state of the initial checkpoint

2022-04-11 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-27132: -- Description: When considering the following case: # A job starts from a checkpoint in

[jira] [Commented] (FLINK-26811) Document CRD upgrade process

2022-04-11 Thread Ted Chang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520813#comment-17520813 ] Ted Chang commented on FLINK-26811: --- [~wangyang0918] good reference. I will add that.

[jira] [Commented] (FLINK-27101) Periodically break the chain of incremental checkpoint

2022-04-11 Thread Steven Zhen Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520811#comment-17520811 ] Steven Zhen Wu commented on FLINK-27101: [~yunta] a pluggable checkpoint trigger

[jira] [Created] (FLINK-27190) Revisit error handling in main reconcile() loop

2022-04-11 Thread Matyas Orhidi (Jira)
Matyas Orhidi created FLINK-27190: - Summary: Revisit error handling in main reconcile() loop Key: FLINK-27190 URL: https://issues.apache.org/jira/browse/FLINK-27190 Project: Flink Issue Type:

[GitHub] [flink] flinkbot commented on pull request #19428: [FLINK-25694] [file-system] Ugrade Presto

2022-04-11 Thread GitBox
flinkbot commented on PR #19428: URL: https://github.com/apache/flink/pull/19428#issuecomment-1095522423 ## CI report: * 8cb988ee3e60ba740733ece9b96bde1c86d5bef4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-25694) GSON/Alluxio Vulnerability

2022-04-11 Thread David Perkins (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520798#comment-17520798 ] David Perkins commented on FLINK-25694: --- A new version was finally released. Creat

[jira] [Updated] (FLINK-25694) GSON/Alluxio Vulnerability

2022-04-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25694: --- Labels: pull-request-available (was: ) > GSON/Alluxio Vulnerability > -

  1   2   3   4   >