[GitHub] [flink-shaded] zentol commented on a diff in pull request #119: Update Flink Shaded dependencies to the latest versions

2023-03-28 Thread via GitHub
zentol commented on code in PR #119: URL: https://github.com/apache/flink-shaded/pull/119#discussion_r1150270810 ## flink-shaded-netty-4/src/main/resources/META-INF/NOTICE: ## @@ -6,36 +6,37 @@ The Apache Software Foundation (http://www.apache.org/). This project bundles the

[GitHub] [flink] MartijnVisser merged pull request #22279: [FLINK-31612][Filesystems] Remove no longer necessary Hadoop relocation rules

2023-03-28 Thread via GitHub
MartijnVisser merged PR #22279: URL: https://github.com/apache/flink/pull/22279 -- 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] (FLINK-12449) [Bitwise Functions] Add BIT_AND, BIT_OR functions supported in Table API and SQL

2023-03-28 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12449 ] Ran Tao deleted comment on FLINK-12449: - was (Author: lemonjing): [~lzljs3620320] hi,Jingsong, can you assign this ticket to me? i'm glad to support it. > [Bitwise Functions] Add BIT_AND,

[GitHub] [flink-shaded] zentol commented on a diff in pull request #119: Update Flink Shaded dependencies to the latest versions

2023-03-28 Thread via GitHub
zentol commented on code in PR #119: URL: https://github.com/apache/flink-shaded/pull/119#discussion_r1150268693 ## flink-shaded-guava-30/pom.xml: ## @@ -35,7 +35,7 @@ under the License. jar -30.1.1-jre +31.1-jre Review Comment: > we should also

[GitHub] [flink-shaded] snuyanzin commented on pull request #119: Update Flink Shaded dependencies to the latest versions

2023-03-28 Thread via GitHub
snuyanzin commented on PR #119: URL: https://github.com/apache/flink-shaded/pull/119#issuecomment-1486478259 In general looks ok from my side (I have a comment about guava module and package name). A question about further steps: should every repo including connectors (at least

[GitHub] [flink] zentol commented on a diff in pull request #22271: [FLINK-28372][rpc] Migrate to Akka Artery

2023-03-28 Thread via GitHub
zentol commented on code in PR #22271: URL: https://github.com/apache/flink/pull/22271#discussion_r1150253727 ## flink-core/src/main/java/org/apache/flink/configuration/AkkaOptions.java: ## @@ -178,13 +170,12 @@ public static boolean

[GitHub] [flink] zentol commented on a diff in pull request #22271: [FLINK-28372][rpc] Migrate to Akka Artery

2023-03-28 Thread via GitHub
zentol commented on code in PR #22271: URL: https://github.com/apache/flink/pull/22271#discussion_r1150252967 ## flink-rpc/flink-rpc-akka/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaUtils.java: ## @@ -206,79 +203,30 @@ private static void addBaseRemoteAkkaConfig(

[GitHub] [flink] zentol commented on a diff in pull request #22271: [FLINK-28372][rpc] Migrate to Akka Artery

2023-03-28 Thread via GitHub
zentol commented on code in PR #22271: URL: https://github.com/apache/flink/pull/22271#discussion_r1150251774 ## flink-rpc/flink-rpc-akka/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaUtils.java: ## @@ -206,79 +203,30 @@ private static void addBaseRemoteAkkaConfig(

[GitHub] [flink] zentol commented on a diff in pull request #22169: [FLINK-31399] AdaptiveScheduler is able to handle changes in job resource requirements.

2023-03-28 Thread via GitHub
zentol commented on code in PR #22169: URL: https://github.com/apache/flink/pull/22169#discussion_r1150229502 ## flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerTest.java: ## @@ -951,6 +949,138 @@ void testConsistentMaxParallelism()

[GitHub] [flink] rkhachatryan commented on a diff in pull request #22169: [FLINK-31399] AdaptiveScheduler is able to handle changes in job resource requirements.

2023-03-28 Thread via GitHub
rkhachatryan commented on code in PR #22169: URL: https://github.com/apache/flink/pull/22169#discussion_r1150228308 ## flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerTest.java: ## @@ -951,6 +949,138 @@ void

[GitHub] [flink] zentol commented on a diff in pull request #22169: [FLINK-31399] AdaptiveScheduler is able to handle changes in job resource requirements.

2023-03-28 Thread via GitHub
zentol commented on code in PR #22169: URL: https://github.com/apache/flink/pull/22169#discussion_r1150221233 ## flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerTest.java: ## @@ -951,6 +949,138 @@ void testConsistentMaxParallelism()

[jira] [Commented] (FLINK-31553) Choose Catalog, non-url based

2023-03-28 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-31553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17705877#comment-17705877 ] João Boto commented on FLINK-31553: --- Hi [~matriv], I'm not an expert on those databases, but being

[jira] [Assigned] (FLINK-31631) Upgrade GCS connector to 2.2.11.

2023-03-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-31631: -- Assignee: Chris Nauroth > Upgrade GCS connector to 2.2.11. >

[jira] [Closed] (FLINK-31598) Cleanup usage of deprecated TableEnvironment#registerTable

2023-03-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-31598. --- Fix Version/s: 1.18.0 Resolution: Fixed Fixed in master: 2a3652d856347ddc333a476aacb0e750f6502a7b

[GitHub] [flink] wuchong merged pull request #22255: [FLINK-31598][table] Cleanup usage of deprecated TableEnvironment#registerTable

2023-03-28 Thread via GitHub
wuchong merged PR #22255: URL: https://github.com/apache/flink/pull/22255 -- 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] [Assigned] (FLINK-31634) FLIP-301: Hybrid Shuffle supports Remote Storage

2023-03-28 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan reassigned FLINK-31634: - Assignee: Yuxin Tan > FLIP-301: Hybrid Shuffle supports Remote Storage >

[GitHub] [flink] snuyanzin commented on pull request #21934: [FLINK-27998][table] Upgrade Calcite to 1.30.0

2023-03-28 Thread via GitHub
snuyanzin commented on PR #21934: URL: https://github.com/apache/flink/pull/21934#issuecomment-1486370469 @twalthr thanks a lot for the feedback I addressed all your comments, could you please make another review round? P.S. There is a strange behavior of GitHub: it shows one of

[jira] [Created] (FLINK-31647) Introduce remote storage tier reader

2023-03-28 Thread Yuxin Tan (Jira)
Yuxin Tan created FLINK-31647: - Summary: Introduce remote storage tier reader Key: FLINK-31647 URL: https://issues.apache.org/jira/browse/FLINK-31647 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-31646) Introduce remote storage tier

2023-03-28 Thread Yuxin Tan (Jira)
Yuxin Tan created FLINK-31646: - Summary: Introduce remote storage tier Key: FLINK-31646 URL: https://issues.apache.org/jira/browse/FLINK-31646 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-31644) Introduce disk tier

2023-03-28 Thread Yuxin Tan (Jira)
Yuxin Tan created FLINK-31644: - Summary: Introduce disk tier Key: FLINK-31644 URL: https://issues.apache.org/jira/browse/FLINK-31644 Project: Flink Issue Type: Sub-task Components:

[jira] [Created] (FLINK-31645) Introduce disk tier reader

2023-03-28 Thread Yuxin Tan (Jira)
Yuxin Tan created FLINK-31645: - Summary: Introduce disk tier reader Key: FLINK-31645 URL: https://issues.apache.org/jira/browse/FLINK-31645 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-31643) Introduce a temporary switch to enable the new shuffle implementation

2023-03-28 Thread Yuxin Tan (Jira)
Yuxin Tan created FLINK-31643: - Summary: Introduce a temporary switch to enable the new shuffle implementation Key: FLINK-31643 URL: https://issues.apache.org/jira/browse/FLINK-31643 Project: Flink

[jira] [Created] (FLINK-31642) Introduce memory tier reader

2023-03-28 Thread Yuxin Tan (Jira)
Yuxin Tan created FLINK-31642: - Summary: Introduce memory tier reader Key: FLINK-31642 URL: https://issues.apache.org/jira/browse/FLINK-31642 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-31641) Introduce memory tier

2023-03-28 Thread Yuxin Tan (Jira)
Yuxin Tan created FLINK-31641: - Summary: Introduce memory tier Key: FLINK-31641 URL: https://issues.apache.org/jira/browse/FLINK-31641 Project: Flink Issue Type: Sub-task Components:

[jira] [Created] (FLINK-31640) Introduce segment index tracker

2023-03-28 Thread Yuxin Tan (Jira)
Yuxin Tan created FLINK-31640: - Summary: Introduce segment index tracker Key: FLINK-31640 URL: https://issues.apache.org/jira/browse/FLINK-31640 Project: Flink Issue Type: Sub-task

[GitHub] [flink] lindong28 closed pull request #22275: [FLINK-31240][table] Reduce the overhead of conversion between DataStream and Table

2023-03-28 Thread via GitHub
lindong28 closed pull request #22275: [FLINK-31240][table] Reduce the overhead of conversion between DataStream and Table URL: https://github.com/apache/flink/pull/22275 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] DavidLiu001 commented on pull request #22241: [FLINK-31542][connectors] Fix FatalExceptionClassifier semantics of r…

2023-03-28 Thread via GitHub
DavidLiu001 commented on PR #22241: URL: https://github.com/apache/flink/pull/22241#issuecomment-1486346460 @vtkhanh, Can this PR be merged? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[jira] [Created] (FLINK-31639) Introduce tiered store memory manager

2023-03-28 Thread Yuxin Tan (Jira)
Yuxin Tan created FLINK-31639: - Summary: Introduce tiered store memory manager Key: FLINK-31639 URL: https://issues.apache.org/jira/browse/FLINK-31639 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-31638) Downstream supports reading buffers from tiered store

2023-03-28 Thread Yuxin Tan (Jira)
Yuxin Tan created FLINK-31638: - Summary: Downstream supports reading buffers from tiered store Key: FLINK-31638 URL: https://issues.apache.org/jira/browse/FLINK-31638 Project: Flink Issue Type:

[jira] [Created] (FLINK-31637) Introduce buffer accumulator tier

2023-03-28 Thread Yuxin Tan (Jira)
Yuxin Tan created FLINK-31637: - Summary: Introduce buffer accumulator tier Key: FLINK-31637 URL: https://issues.apache.org/jira/browse/FLINK-31637 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-31636) Upstream supports reading buffers from tiered store

2023-03-28 Thread Yuxin Tan (Jira)
Yuxin Tan created FLINK-31636: - Summary: Upstream supports reading buffers from tiered store Key: FLINK-31636 URL: https://issues.apache.org/jira/browse/FLINK-31636 Project: Flink Issue Type:

[jira] [Created] (FLINK-31635) Support writing records to the new tiered store architecture

2023-03-28 Thread Yuxin Tan (Jira)
Yuxin Tan created FLINK-31635: - Summary: Support writing records to the new tiered store architecture Key: FLINK-31635 URL: https://issues.apache.org/jira/browse/FLINK-31635 Project: Flink

[GitHub] [flink] flinkbot commented on pull request #22284: [FLINK-31547][jdbc-driver] Introduce FlinkResultSetMetaData for jdbc driver

2023-03-28 Thread via GitHub
flinkbot commented on PR #22284: URL: https://github.com/apache/flink/pull/22284#issuecomment-1486330492 ## CI report: * 9971b5d674340cb13601a9a36b89b182aec337ac UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-31618) Broken links in docs for Pulsar connector

2023-03-28 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31618: --- Affects Version/s: pulsar-4.0.0 (was: 1.17.0) > Broken links in docs for

[jira] [Closed] (FLINK-31618) Broken links in docs for Pulsar connector

2023-03-28 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-31618. -- Resolution: Fixed master via 33526f5e36a2d27eb7a80a1aeed130fa2914cc8d. > Broken links in docs for

[jira] [Updated] (FLINK-31618) Broken links in docs for Pulsar connector

2023-03-28 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31618: --- Fix Version/s: pulsar-4.0.0 > Broken links in docs for Pulsar connector >

[jira] [Comment Edited] (FLINK-31618) Broken links in docs for Pulsar connector

2023-03-28 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17705845#comment-17705845 ] Weijie Guo edited comment on FLINK-31618 at 3/28/23 7:05 AM: - master(4.0)

[jira] [Assigned] (FLINK-31618) Broken links in docs for Pulsar connector

2023-03-28 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-31618: -- Assignee: Yuxin Tan > Broken links in docs for Pulsar connector >

[GitHub] [flink-connector-pulsar] reswqa merged pull request #36: [FLINK-31618][docs] Fix the wrong links in producer option docs

2023-03-28 Thread via GitHub
reswqa merged PR #36: URL: https://github.com/apache/flink-connector-pulsar/pull/36 -- 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-connector-pulsar] boring-cyborg[bot] commented on pull request #36: [FLINK-31618][docs] Fix the wrong links in producer option docs

2023-03-28 Thread via GitHub
boring-cyborg[bot] commented on PR #36: URL: https://github.com/apache/flink-connector-pulsar/pull/36#issuecomment-1486323583 Awesome work, congrats on your first merged pull request! -- This is an automated message from the Apache Git Service. To respond to the message, please log

[jira] [Updated] (FLINK-31547) Introduce FlinkResultSetMetaData for jdbc driver

2023-03-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31547: --- Labels: pull-request-available (was: ) > Introduce FlinkResultSetMetaData for jdbc driver

[GitHub] [flink] FangYongs opened a new pull request, #22284: [FLINK-31547][jdbc-driver] Introduce FlinkResultSetMetaData for jdbc driver

2023-03-28 Thread via GitHub
FangYongs opened a new pull request, #22284: URL: https://github.com/apache/flink/pull/22284 ## What is the purpose of the change This PR aims to introduce `FlinkResultSetMetaData` for jdbc driver ## Brief change log - Added `ColumnInfo` for

[GitHub] [flink] jaumebecks commented on pull request #20343: [FLINK-25916][connector-kafka] Using upsert-kafka with a flush buffer…

2023-03-28 Thread via GitHub
jaumebecks commented on PR #20343: URL: https://github.com/apache/flink/pull/20343#issuecomment-1486296425 > > Shall we close this PR and move the conversation to [apache/flink-connector-kafka#5](https://github.com/apache/flink-connector-kafka/pull/5)? > > yes please. We're removing

[jira] [Commented] (FLINK-31550) Replace deprecated TableSchema with Schema in OperationConverterUtils

2023-03-28 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17705828#comment-17705828 ] Aitozi commented on FLINK-31550: Is this stale? {{OperationConverterUtils}} do not use {{TableSchema}}

<    1   2   3