[GitHub] [flink] luoyuxia commented on pull request #19338: [FLINK-27006][Table SQL / API] Support CharSingleValueAggFunction

2022-05-06 Thread GitBox
luoyuxia commented on PR #19338: URL: https://github.com/apache/flink/pull/19338#issuecomment-1119411162 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

[jira] [Updated] (FLINK-27412) Allow flinkVersion v1_13 in flink-kubernetes-operator

2022-05-06 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-27412: --- Priority: Critical (was: Major) > Allow flinkVersion v1_13 in flink-kubernetes-operator >

[jira] [Updated] (FLINK-27498) Add E2E tests to cover Flink 1.15

2022-05-06 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-27498: --- Priority: Blocker (was: Critical) > Add E2E tests to cover Flink 1.15 >

[jira] [Updated] (FLINK-27499) Bump base Flink version to 1.15.0

2022-05-06 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-27499: --- Priority: Blocker (was: Critical) > Bump base Flink version to 1.15.0 >

[jira] [Commented] (FLINK-27499) Bump base Flink version to 1.15.0

2022-05-06 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17532724#comment-17532724 ] Gyula Fora commented on FLINK-27499: I think those tickets are somewhat unrelated to this, but we

[GitHub] [flink] ChengkaiYang2022 commented on pull request #19498: [FLINK-26588][docs]Translate the new CAST documentation to Chinese

2022-05-06 Thread GitBox
ChengkaiYang2022 commented on PR #19498: URL: https://github.com/apache/flink/pull/19498#issuecomment-1119409572 https://user-images.githubusercontent.com/8577744/167102086-9015292e-d597-4440-be93-16075ce6c596.png;>

[GitHub] [flink] ChengkaiYang2022 commented on pull request #19498: [FLINK-26588][docs]Translate the new CAST documentation to Chinese

2022-05-06 Thread GitBox
ChengkaiYang2022 commented on PR #19498: URL: https://github.com/apache/flink/pull/19498#issuecomment-1119408110 Hi,@fsk119 ,thanks for your review and comments. I took all the suggestions and push a new

[jira] [Updated] (FLINK-27530) FLIP-227: Support overdraft buffer

2022-05-06 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-27530: --- Summary: FLIP-227: Support overdraft buffer (was: Support overdraft buffer) > FLIP-227:

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #184: [FLINK-27262] Enrich validator for FlinkSessionJob

2022-05-06 Thread GitBox
gyfora commented on code in PR #184: URL: https://github.com/apache/flink-kubernetes-operator/pull/184#discussion_r866630569 ## helm/flink-kubernetes-operator/templates/webhook.yaml: ## @@ -83,7 +83,7 @@ metadata: cert-manager.io/inject-ca-from: {{ .Release.Namespace

[GitHub] [flink-table-store] LadyForest opened a new pull request, #109: [FLINK-27528] Introduce a new configuration option key 'compact.rescale-bucket' for FileStore

2022-05-06 Thread GitBox
LadyForest opened a new pull request, #109: URL: https://github.com/apache/flink-table-store/pull/109 This config key controls the behavior for `ALTER TABLE ... COMPACT`. When `compact.rescale-bucket` is false, it indicates the compaction will rewrite data according to the bucket

[jira] [Updated] (FLINK-27528) Introduce a new configuration option key 'compact.rescale-bucket' for FileStore

2022-05-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27528: --- Labels: pull-request-available (was: ) > Introduce a new configuration option key

[GitHub] [flink] flinkbot commented on pull request #19655: [FLINK-27527] Create a file-based upsert sink for testing internal components

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

[jira] [Created] (FLINK-27531) Add explict doc on data consistency problem of RocksDB's map state iterator

2022-05-06 Thread Yun Tang (Jira)
Yun Tang created FLINK-27531: Summary: Add explict doc on data consistency problem of RocksDB's map state iterator Key: FLINK-27531 URL: https://issues.apache.org/jira/browse/FLINK-27531 Project: Flink

[GitHub] [flink-ml] lindong28 commented on a diff in pull request #87: [FLINK-27096] Add a script to visualize benchmark results

2022-05-06 Thread GitBox
lindong28 commented on code in PR #87: URL: https://github.com/apache/flink-ml/pull/87#discussion_r866599491 ## flink-ml-benchmark/src/main/java/org/apache/flink/ml/benchmark/Benchmark.java: ## @@ -31,34 +31,33 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory;

[jira] [Updated] (FLINK-27527) Create a file-based Upsert sink for testing internal components

2022-05-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27527: --- Labels: pull-request-available (was: ) > Create a file-based Upsert sink for testing

[GitHub] [flink] alpreu opened a new pull request, #19655: [FLINK-27527] Create a file-based upsert sink for testing internal components

2022-05-06 Thread GitBox
alpreu opened a new pull request, #19655: URL: https://github.com/apache/flink/pull/19655 ## What is the purpose of the change This pull request introduces a new file-bases upsert sink for testing internal components. ## Brief change log - Created a file-based

[jira] [Updated] (FLINK-27522) Ignore max buffers per channel when allocate buffer

2022-05-06 Thread fanrui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] fanrui updated FLINK-27522: --- Parent: FLINK-27530 Issue Type: Sub-task (was: Improvement) > Ignore max buffers per channel when

[jira] [Updated] (FLINK-26762) Add the overdraft buffer in BufferPool to reduce unaligned checkpoint being blocked

2022-05-06 Thread fanrui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] fanrui updated FLINK-26762: --- Parent: FLINK-27530 Issue Type: Sub-task (was: Improvement) > Add the overdraft buffer in

[jira] [Created] (FLINK-27530) Support overdraft buffer

2022-05-06 Thread fanrui (Jira)
fanrui created FLINK-27530: -- Summary: Support overdraft buffer Key: FLINK-27530 URL: https://issues.apache.org/jira/browse/FLINK-27530 Project: Flink Issue Type: Improvement Components:

[jira] [Commented] (FLINK-27529) HybridSourceSplitEnumerator sourceIndex using error Integer check

2022-05-06 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17532709#comment-17532709 ] Ran Tao commented on FLINK-27529: - [~thw] Hi, Thomas. If you have time, pls have a look about this

[GitHub] [flink] ChengkaiYang2022 commented on a diff in pull request #19498: [FLINK-26588][docs]Translate the new CAST documentation to Chinese

2022-05-06 Thread GitBox
ChengkaiYang2022 commented on code in PR #19498: URL: https://github.com/apache/flink/pull/19498#discussion_r866611046 ## docs/content.zh/docs/dev/table/types.md: ## @@ -1487,6 +1481,93 @@ Not supported. {{< /tab >}} {{< /tabs >}} + + +cast 方法 Review Comment: OK, maybe

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #195: [FLINK-27468] Recover missing deployments and other cancel/upgrade improvements for 1.15

2022-05-06 Thread GitBox
gyfora commented on PR #195: URL: https://github.com/apache/flink-kubernetes-operator/pull/195#issuecomment-1119384598 @wangyang0918 let me know if you have any questions, it's not a trivial change but there are a lot of big improvements here I believe  -- This is an automated message

[GitHub] [flink] flinkbot commented on pull request #19654: [FLINK-27529][connector/common] Replace HybridSourceSplitEnumerator readerSourceIndex to safely int check

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

[jira] [Updated] (FLINK-27529) HybridSourceSplitEnumerator sourceIndex using error Integer check

2022-05-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27529: --- Labels: pull-request-available (was: ) > HybridSourceSplitEnumerator sourceIndex using

[GitHub] [flink] chucheng92 opened a new pull request, #19654: [FLINK-27529][connector/common] Replace HybridSourceSplitEnumerator readerSourceIndex to safely int check

2022-05-06 Thread GitBox
chucheng92 opened a new pull request, #19654: URL: https://github.com/apache/flink/pull/19654 ## What is the purpose of the change Currently HybridSourceSplitEnumerator check readerSourceIndex using Integer type but == operator. In some case, it will cause severe error(Integer ==

[GitHub] [flink-kubernetes-operator] wangyang0918 commented on pull request #195: [FLINK-27468] Recover missing deployments and other cancel/upgrade improvements for 1.15

2022-05-06 Thread GitBox
wangyang0918 commented on PR #195: URL: https://github.com/apache/flink-kubernetes-operator/pull/195#issuecomment-1119380750 I am getting to this PR and try to give it a pass very soon. -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[jira] [Updated] (FLINK-27529) HybridSourceSplitEnumerator sourceIndex using error Integer check

2022-05-06 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ran Tao updated FLINK-27529: Description: Currently HybridSourceSplitEnumerator check readerSourceIndex using Integer type but ==

[jira] [Updated] (FLINK-27529) HybridSourceSplitEnumerator sourceIndex using error Integer check

2022-05-06 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ran Tao updated FLINK-27529: Description: Currently HybridSourceSplitEnumerator check readerSourceIndex using Integer type but ==

[jira] [Updated] (FLINK-27529) HybridSourceSplitEnumerator sourceIndex using error Integer check

2022-05-06 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ran Tao updated FLINK-27529: Description: Currently HybridSourceSplitEnumerator check readerSourceIndex using Integer type but ==

[jira] [Created] (FLINK-27529) HybridSourceSplitEnumerator sourceIndex use error Integer check

2022-05-06 Thread Ran Tao (Jira)
Ran Tao created FLINK-27529: --- Summary: HybridSourceSplitEnumerator sourceIndex use error Integer check Key: FLINK-27529 URL: https://issues.apache.org/jira/browse/FLINK-27529 Project: Flink Issue

[jira] [Updated] (FLINK-27529) HybridSourceSplitEnumerator sourceIndex using error Integer check

2022-05-06 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ran Tao updated FLINK-27529: Summary: HybridSourceSplitEnumerator sourceIndex using error Integer check (was:

[GitHub] [flink] afedulov commented on a diff in pull request #19629: [FLINK-27480][kafka] Explain possible metrics InstanceAlreadyExistsException in docs

2022-05-06 Thread GitBox
afedulov commented on code in PR #19629: URL: https://github.com/apache/flink/pull/19629#discussion_r866590211 ## docs/content/docs/connectors/datastream/kafka.md: ## @@ -307,6 +307,13 @@ For metrics of Kafka consumer, you can refer to

[jira] [Comment Edited] (FLINK-27457) CassandraOutputFormats should support flush

2022-05-06 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17532701#comment-17532701 ] Etienne Chauchot edited comment on FLINK-27457 at 5/6/22 8:11 AM: --

[GitHub] [flink] Myracle commented on pull request #19651: [FLINK-26909][Client/Job Submission] Support AdaptiveBatch when parallelism is -1 from Cli

2022-05-06 Thread GitBox
Myracle commented on PR #19651: URL: https://github.com/apache/flink/pull/19651#issuecomment-1119364061 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

[jira] [Updated] (FLINK-27516) The config execution.attached doesn't take effect when not set by Cli param

2022-05-06 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-27516: Summary: The config execution.attached doesn't take effect when not set by Cli param (was: The config

[jira] [Commented] (FLINK-27457) CassandraOutputFormats should support flush

2022-05-06 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17532701#comment-17532701 ] Etienne Chauchot commented on FLINK-27457: -- [~chesnay] can you assign me this ticket as I

[jira] [Updated] (FLINK-27528) Introduce a new configuration option key 'compact.rescale-bucket' for FileStore

2022-05-06 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-27528: -- Summary: Introduce a new configuration option key 'compact.rescale-bucket' for FileStore (was:

[jira] [Updated] (FLINK-27516) The config execution.attached doesn't take effect wen not set by Cli param

2022-05-06 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-27516: Summary: The config execution.attached doesn't take effect wen not set by Cli param (was: The config

[GitHub] [flink] echauchot commented on pull request #19586: [FLINK-26824] [FLINK-27457] Upgrade Flink's supported Cassandra versions to match all Apache Cassandra supported versions and support flush

2022-05-06 Thread GitBox
echauchot commented on PR #19586: URL: https://github.com/apache/flink/pull/19586#issuecomment-1119360748 @zentol I added the flush mechanism to all Cassandra output formats and the related tests (vastly inspired from `CassandraSinkBaseTest`) in the 3 last commits (different ticket).

[GitHub] [flink-ml] lindong28 merged pull request #90: [FLINK-27093] Add Transformer and Estimator for LinearRegression

2022-05-06 Thread GitBox
lindong28 merged PR #90: URL: https://github.com/apache/flink-ml/pull/90 -- 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-ml] lindong28 commented on pull request #90: [FLINK-27093] Add Transformer and Estimator for LinearRegression

2022-05-06 Thread GitBox
lindong28 commented on PR #90: URL: https://github.com/apache/flink-ml/pull/90#issuecomment-1119358841 Thanks for the update. 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

[GitHub] [flink] fsk119 commented on a diff in pull request #19498: [FLINK-26588][docs]Translate the new CAST documentation to Chinese

2022-05-06 Thread GitBox
fsk119 commented on code in PR #19498: URL: https://github.com/apache/flink/pull/19498#discussion_r866558853 ## docs/content.zh/docs/dev/table/types.md: ## @@ -1487,6 +1481,93 @@ Not supported. {{< /tab >}} {{< /tabs >}} + + +cast 方法 +--- + +Flink Table API 和 Flink SQL

[jira] [Resolved] (FLINK-26052) Update chinese documentation regarding FLIP-203

2022-05-06 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-26052. -- Fix Version/s: 1.16.0 1.15.1 Resolution: Fixed merged in master:

[GitHub] [flink] Myasuka merged pull request #19616: [FLINK-26052][docs-zh] Document savepoint format

2022-05-06 Thread GitBox
Myasuka merged PR #19616: URL: https://github.com/apache/flink/pull/19616 -- 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] fsk119 commented on a diff in pull request #19498: [FLINK-26588][docs]Translate the new CAST documentation to Chinese

2022-05-06 Thread GitBox
fsk119 commented on code in PR #19498: URL: https://github.com/apache/flink/pull/19498#discussion_r866547558 ## docs/content.zh/docs/dev/table/types.md: ## @@ -1487,6 +1481,93 @@ Not supported. {{< /tab >}} {{< /tabs >}} + + +cast 方法 +--- + +Flink Table API 和 Flink SQL

[jira] [Updated] (FLINK-27526) Support scaling bucket number for FileStore

2022-05-06 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-27526: -- Description: Currently, TableStore does not support changing the number of the bucket (denoted by

[jira] [Created] (FLINK-27528) Introduce a new configuration option key 'compact-rescale'

2022-05-06 Thread Jane Chan (Jira)
Jane Chan created FLINK-27528: - Summary: Introduce a new configuration option key 'compact-rescale' Key: FLINK-27528 URL: https://issues.apache.org/jira/browse/FLINK-27528 Project: Flink Issue

[jira] [Updated] (FLINK-27526) Support scaling bucket number for FileStore

2022-05-06 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-27526: -- Description: Currently, TableStore does not support changing the number of the bucket (denoted by

[GitHub] [flink] flinkbot commented on pull request #19653: [FLINK-27523] Runtime supports producing and consuming cached intermediate results

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

[jira] [Updated] (FLINK-27526) Support scaling bucket number for FileStore

2022-05-06 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-27526: -- Description: Currently, TableStore does not support changing the number of the bucket (denoted by

[jira] [Updated] (FLINK-27526) Support scaling bucket number for FileStore

2022-05-06 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-27526: -- Description: Currently, TableStore does not support changing the number of the bucket (denoted by

[jira] [Updated] (FLINK-27523) Runtime supports producing and consuming cached intermediate result

2022-05-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27523: --- Labels: pull-request-available (was: ) > Runtime supports producing and consuming cached

[GitHub] [flink] hililiwei opened a new pull request, #17613: [FLINK-24536][Table SQL/Planner] flink sql support bang equal '!='

2022-05-06 Thread GitBox
hililiwei opened a new pull request, #17613: URL: https://github.com/apache/flink/pull/17613 ## What is the purpose of the change flink sql support bang equal '!=' https://issues.apache.org/jira/browse/FLINK-24536 ## Brief change log flink sql support bang

[GitHub] [flink] Sxnan opened a new pull request, #19653: [FLINK-27523] Runtime supports producing and consuming cached intermediate results

2022-05-06 Thread GitBox
Sxnan opened a new pull request, #19653: URL: https://github.com/apache/flink/pull/19653 ## What is the purpose of the change Runtime support producing and consuming cached intermediate results. ## Brief change log - Allow ShuffleMaster to promote partition

[jira] [Created] (FLINK-27527) Create a file-based Upsert sink for testing internal components

2022-05-06 Thread Alexander Preuss (Jira)
Alexander Preuss created FLINK-27527: Summary: Create a file-based Upsert sink for testing internal components Key: FLINK-27527 URL: https://issues.apache.org/jira/browse/FLINK-27527 Project:

[GitHub] [flink] hililiwei closed pull request #17613: [FLINK-24536][Table SQL/Planner] flink sql support bang equal '!='

2022-05-06 Thread GitBox
hililiwei closed pull request #17613: [FLINK-24536][Table SQL/Planner] flink sql support bang equal '!=' URL: https://github.com/apache/flink/pull/17613 -- 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

[jira] [Assigned] (FLINK-27526) Support scaling bucket number for FileStore

2022-05-06 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-27526: Assignee: Jane Chan > Support scaling bucket number for FileStore >

[GitHub] [flink-web] dawidwys commented on pull request #516: Tidying up snapshots

2022-05-06 Thread GitBox
dawidwys commented on PR #516: URL: https://github.com/apache/flink-web/pull/516#issuecomment-1119321986 Merged in 93bd43090eae792e9b2ff205d03b7af740f84c8d -- 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

[jira] [Created] (FLINK-27526) Support scaling bucket number for FileStore

2022-05-06 Thread Jane Chan (Jira)
Jane Chan created FLINK-27526: - Summary: Support scaling bucket number for FileStore Key: FLINK-27526 URL: https://issues.apache.org/jira/browse/FLINK-27526 Project: Flink Issue Type: New

[GitHub] [flink-web] dawidwys closed pull request #516: Tidying up snapshots

2022-05-06 Thread GitBox
dawidwys closed pull request #516: Tidying up snapshots URL: https://github.com/apache/flink-web/pull/516 -- 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,

[GitHub] [flink-web] dawidwys commented on pull request #516: Tidying up snapshots

2022-05-06 Thread GitBox
dawidwys commented on PR #516: URL: https://github.com/apache/flink-web/pull/516#issuecomment-1119321632 Thanks for the review @infoverload, 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 go

[jira] [Closed] (FLINK-27477) Drop flink-yarn test-jar

2022-05-06 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-27477. Assignee: Chesnay Schepler Resolution: Fixed master:

[GitHub] [flink] zentol merged pull request #19626: [FLINK-27477][yarn][tests] Drop flink-yarn test-jar

2022-05-06 Thread GitBox
zentol merged PR #19626: URL: https://github.com/apache/flink/pull/19626 -- 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-27500) Validation error handling inside controller blocks reconciliation

2022-05-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27500: --- Labels: pull-request-available (was: ) > Validation error handling inside controller

[GitHub] [flink-kubernetes-operator] gyfora opened a new pull request, #196: [FLINK-27500] Validation errors should not block reconciliation

2022-05-06 Thread GitBox
gyfora opened a new pull request, #196: URL: https://github.com/apache/flink-kubernetes-operator/pull/196 This PR solves the issue detailed in https://issues.apache.org/jira/browse/FLINK-27500 by reconciling using the previous (valid) spec if validation fails for some reason. This

[jira] [Commented] (FLINK-27275) Support partial insert in flink-connector-jdbc

2022-05-06 Thread Fangliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17532669#comment-17532669 ] Fangliang Liu commented on FLINK-27275: --- In addition, the `reduceBuffer` in

[jira] [Commented] (FLINK-27483) Support adding custom HTTP header for HTTP based Jar fetch

2022-05-06 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17532671#comment-17532671 ] Yang Wang commented on FLINK-27483: --- [~aitozi] Do I miss something? I am afraid the operator

[jira] [Updated] (FLINK-27525) Add a demo for using kafka sink via Flink SQL

2022-05-06 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27525: - Component/s: Connectors / Kafka Documentation > Add a demo for using kafka sink via

[jira] [Created] (FLINK-27525) Add a demo for using kafka sink via Flink SQL

2022-05-06 Thread luoyuxia (Jira)
luoyuxia created FLINK-27525: Summary: Add a demo for using kafka sink via Flink SQL Key: FLINK-27525 URL: https://issues.apache.org/jira/browse/FLINK-27525 Project: Flink Issue Type:

[jira] [Comment Edited] (FLINK-27275) Support partial insert in flink-connector-jdbc

2022-05-06 Thread Fangliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17528025#comment-17528025 ] Fangliang Liu edited comment on FLINK-27275 at 5/6/22 6:46 AM: --- Now the

[GitHub] [flink-web] openinx commented on a diff in pull request #531: Add Table Store 0.1.0 release

2022-05-06 Thread GitBox
openinx commented on code in PR #531: URL: https://github.com/apache/flink-web/pull/531#discussion_r866533145 ## _posts/2022-05-01-release-table-store-0.1.0.md: ## @@ -0,0 +1,93 @@ +--- +layout: post +title: "Apache Flink Table Store 0.1.0 Release Announcement" +subtitle:

[GitHub] [flink-web] openinx commented on a diff in pull request #531: Add Table Store 0.1.0 release

2022-05-06 Thread GitBox
openinx commented on code in PR #531: URL: https://github.com/apache/flink-web/pull/531#discussion_r866532269 ## _posts/2022-05-01-release-table-store-0.1.0.md: ## @@ -0,0 +1,93 @@ +--- +layout: post +title: "Apache Flink Table Store 0.1.0 Release Announcement" +subtitle:

[jira] [Comment Edited] (FLINK-25795) Support Pulsar sink connector in Python DataStream API.

2022-05-06 Thread LuNng Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17532582#comment-17532582 ] LuNng Wang edited comment on FLINK-25795 at 5/6/22 6:43 AM: [~syhily] Yes ,

[GitHub] [flink-web] openinx commented on a diff in pull request #531: Add Table Store 0.1.0 release

2022-05-06 Thread GitBox
openinx commented on code in PR #531: URL: https://github.com/apache/flink-web/pull/531#discussion_r866531464 ## _posts/2022-05-01-release-table-store-0.1.0.md: ## @@ -0,0 +1,93 @@ +--- +layout: post +title: "Apache Flink Table Store 0.1.0 Release Announcement" +subtitle:

[jira] [Created] (FLINK-27524) Introduce cache API to DataStream

2022-05-06 Thread Xuannan Su (Jira)
Xuannan Su created FLINK-27524: -- Summary: Introduce cache API to DataStream Key: FLINK-27524 URL: https://issues.apache.org/jira/browse/FLINK-27524 Project: Flink Issue Type: Sub-task

[GitHub] [flink] JingGe commented on pull request #19624: [FLINK-27476][test] build import option only focuses on maven main class files

2022-05-06 Thread GitBox
JingGe commented on PR #19624: URL: https://github.com/apache/flink/pull/19624#issuecomment-1119306059 Thanks for your feedback @zentol, I addressed your comments, please take a look. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Created] (FLINK-27523) Runtime supports producing and consuming cached intermediate result

2022-05-06 Thread Xuannan Su (Jira)
Xuannan Su created FLINK-27523: -- Summary: Runtime supports producing and consuming cached intermediate result Key: FLINK-27523 URL: https://issues.apache.org/jira/browse/FLINK-27523 Project: Flink

[GitHub] [flink-web] openinx commented on a diff in pull request #531: Add Table Store 0.1.0 release

2022-05-06 Thread GitBox
openinx commented on code in PR #531: URL: https://github.com/apache/flink-web/pull/531#discussion_r866528803 ## _config.yml: ## @@ -198,6 +198,24 @@ flink_kubernetes_operator_releases: asc_url:

[GitHub] [flink-web] openinx commented on a diff in pull request #531: Add Table Store 0.1.0 release

2022-05-06 Thread GitBox
openinx commented on code in PR #531: URL: https://github.com/apache/flink-web/pull/531#discussion_r866527890 ## _config.yml: ## @@ -198,6 +198,24 @@ flink_kubernetes_operator_releases: asc_url:

[jira] [Created] (FLINK-27522) Ignore max buffers per channel when allocate buffer

2022-05-06 Thread fanrui (Jira)
fanrui created FLINK-27522: -- Summary: Ignore max buffers per channel when allocate buffer Key: FLINK-27522 URL: https://issues.apache.org/jira/browse/FLINK-27522 Project: Flink Issue Type:

[GitHub] [flink] Aitozi commented on pull request #18762: [FlINK-26112][k8s]Port getRestEndpoint method to the specific service type subclass

2022-05-06 Thread GitBox
Aitozi commented on PR #18762: URL: https://github.com/apache/flink/pull/18762#issuecomment-1119302541 @wangyang0918 Can we move forward this PR, since 1.15 has been released -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink-web] openinx commented on a diff in pull request #531: Add Table Store 0.1.0 release

2022-05-06 Thread GitBox
openinx commented on code in PR #531: URL: https://github.com/apache/flink-web/pull/531#discussion_r866527445 ## _config.yml: ## @@ -198,6 +198,24 @@ flink_kubernetes_operator_releases: asc_url:

[jira] [Created] (FLINK-27521) FLIP-205: Support Cache in DataStream for Batch Processing

2022-05-06 Thread Xuannan Su (Jira)
Xuannan Su created FLINK-27521: -- Summary: FLIP-205: Support Cache in DataStream for Batch Processing Key: FLINK-27521 URL: https://issues.apache.org/jira/browse/FLINK-27521 Project: Flink Issue

[GitHub] [flink] flinkbot commented on pull request #19652: [hotfix][docs] Fix the inaccessible huawei cloud link.

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

[GitHub] [flink] Aitozi commented on pull request #19630: [FLINK-27461] Add option to set userAgent for kubeclient

2022-05-06 Thread GitBox
Aitozi commented on PR #19630: URL: https://github.com/apache/flink/pull/19630#issuecomment-1119300896 @wangyang0918 Thanks for your suggestion, I have pushed the fix, please take a look again. -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] liuzhuang2017 opened a new pull request, #19652: [hotfix][docs] Fix the inaccessible huawei cloud link.

2022-05-06 Thread GitBox
liuzhuang2017 opened a new pull request, #19652: URL: https://github.com/apache/flink/pull/19652 ## What is the purpose of the change - Fix the inaccessible huawei cloud link. ## Brief change log - Change the inaccessible

[GitHub] [flink] HuangZhenQiu commented on a diff in pull request #14678: [FLINK-20833][runtime] Add pluggable failure listener in job manager

2022-05-06 Thread GitBox
HuangZhenQiu commented on code in PR #14678: URL: https://github.com/apache/flink/pull/14678#discussion_r866516090 ## docs/deployment/advanced/platform.md: ## @@ -0,0 +1,50 @@ +--- +title: "Customizable Features for Platform Users" +nav-title: platform +nav-parent_id: advanced

[GitHub] [flink] HuangZhenQiu commented on a diff in pull request #14678: [FLINK-20833][runtime] Add pluggable failure listener in job manager

2022-05-06 Thread GitBox
HuangZhenQiu commented on code in PR #14678: URL: https://github.com/apache/flink/pull/14678#discussion_r866515939 ## flink-runtime/src/main/java/org/apache/flink/runtime/failurelistener/FailureListenerUtils.java: ## @@ -0,0 +1,55 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] HuangZhenQiu commented on a diff in pull request #14678: [FLINK-20833][runtime] Add pluggable failure listener in job manager

2022-05-06 Thread GitBox
HuangZhenQiu commented on code in PR #14678: URL: https://github.com/apache/flink/pull/14678#discussion_r866515602 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java: ## @@ -333,10 +340,15 @@ public void onUnknownDeploymentsOf( }

[GitHub] [flink] HuangZhenQiu commented on a diff in pull request #14678: [FLINK-20833][runtime] Add pluggable failure listener in job manager

2022-05-06 Thread GitBox
HuangZhenQiu commented on code in PR #14678: URL: https://github.com/apache/flink/pull/14678#discussion_r866515482 ## flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterSchedulerTest.java: ## @@ -103,7 +105,8 @@ public SchedulerNG createInstance(

[GitHub] [flink] HuangZhenQiu commented on a diff in pull request #14678: [FLINK-20833][runtime] Add pluggable failure listener in job manager

2022-05-06 Thread GitBox
HuangZhenQiu commented on code in PR #14678: URL: https://github.com/apache/flink/pull/14678#discussion_r866515154 ## flink-tests/src/test/java/org/apache/flink/test/plugin/jar/failurelistener/TestFailureListener.java: ## @@ -0,0 +1,33 @@ +/* + * Licensed to the Apache Software

[jira] [Updated] (FLINK-27091) Add Estimator and Transformer for SVM

2022-05-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27091: --- Labels: pull-request-available (was: ) > Add Estimator and Transformer for SVM >

[GitHub] [flink-ml] zhipeng93 opened a new pull request, #93: [FLINK-27091] Add Transformer and Estimator of LinearSVC

2022-05-06 Thread GitBox
zhipeng93 opened a new pull request, #93: URL: https://github.com/apache/flink-ml/pull/93 ## What is the purpose of the change - Add Transformer and Estimator of LinearSVC in FlinkML. ## Brief change log - Added Transformer and Estimator of LinearSVC. - Added unit test for

[jira] [Commented] (FLINK-27495) Observer should update last savepoint information directly from cluster too

2022-05-06 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17532655#comment-17532655 ] Gyula Fora commented on FLINK-27495: I mean fetching using the rest api > Observer should update

<    1   2   3