Aitozi commented on PR #19938:
URL: https://github.com/apache/flink/pull/19938#issuecomment-1153076854
cc @xintongsong
--
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
[
https://issues.apache.org/jira/browse/FLINK-28011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-28011:
-
Component/s: Connectors / Hive
> Optimize getAllPartitions in HiveSource
>
[
https://issues.apache.org/jira/browse/FLINK-28011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-28011:
-
Fix Version/s: 1.16.0
> Optimize getAllPartitions in HiveSource
>
[
https://issues.apache.org/jira/browse/FLINK-20760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-20760.
---
Fix Version/s: 1.16.0
Resolution: Fixed
Fixed in flink-web: 29dbb9e8aa5b67d645e8f412fb831acb4d3030dd
luoyuxia created FLINK-28011:
Summary: Optimize getAllPartitions in HiveSource
Key: FLINK-28011
URL: https://issues.apache.org/jira/browse/FLINK-28011
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-20760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-20760:
---
Assignee: zhuyufeng
> Broken doc link in Apache Flink Code Style and Quality Guide
>
wuchong merged PR #549:
URL: https://github.com/apache/flink-web/pull/549
--
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:
[
https://issues.apache.org/jira/browse/FLINK-27651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-27651.
---
Assignee: dalongliu
Resolution: Fixed
Fixed in master: c1b32be0faa29ecf0b7b358404aba534cba59903
>
wuchong merged PR #19742:
URL: https://github.com/apache/flink/pull/19742
--
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:
flinkbot commented on PR #19938:
URL: https://github.com/apache/flink/pull/19938#issuecomment-1153068629
## CI report:
* 242b236162ecb30f17e358a6df130308e507dbf6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27737:
---
Labels: pull-request-available (was: )
> Remove legacy support for unfenced executor in
Aitozi opened a new pull request, #19938:
URL: https://github.com/apache/flink/pull/19938
## What is the purpose of the change
This PR is mean to clean up all the un-fenced executor support in the
rpcEndpoint.
## Brief change log
- Make the FencedRpcEndpoint's
[
https://issues.apache.org/jira/browse/FLINK-27940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553204#comment-17553204
]
Lijie Wang commented on FLINK-27940:
thanks, [~jingge] :)
> [JUnit5 Migration] Module:
[
https://issues.apache.org/jira/browse/FLINK-27960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27960:
---
Labels: pull-request-available (was: )
> Make the apt-get updating optional
>
Aitozi opened a new pull request, #266:
URL: https://github.com/apache/flink-kubernetes-operator/pull/266
when developing, we could use to speed up
```
docker build --build-arg FAST=true . -t
/flink-kubernetes-operator:latest
```
--
This is an automated message from the
luoyuxia commented on PR #19876:
URL: https://github.com/apache/flink/pull/19876#issuecomment-1153038068
@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.
luoyuxia commented on PR #19929:
URL: https://github.com/apache/flink/pull/19929#issuecomment-1153037611
@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.
luoyuxia commented on code in PR #19931:
URL: https://github.com/apache/flink/pull/19931#discussion_r894604477
##
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/copy/HiveParserBaseSemanticAnalyzer.java:
##
@@ -387,7 +387,9 @@
[
https://issues.apache.org/jira/browse/FLINK-27940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553179#comment-17553179
]
Jing Ge commented on FLINK-27940:
-
[~wanglijie95] just assigned this task to you. Thanks for your
[
https://issues.apache.org/jira/browse/FLINK-27940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge reassigned FLINK-27940:
---
Assignee: Lijie Wang
> [JUnit5 Migration] Module: flink-connector-jdbc
>
rkhachatryan commented on code in PR #19907:
URL: https://github.com/apache/flink/pull/19907#discussion_r895055680
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskLocalStateStore.java:
##
@@ -76,7 +74,7 @@ public interface TaskLocalStateStore {
/**
gaborgsomogyi commented on PR #19825:
URL: https://github.com/apache/flink/pull/19825#issuecomment-1152982014
@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
brachipa commented on PR #16598:
URL: https://github.com/apache/flink/pull/16598#issuecomment-1152977558
Hi. Kind reminder, what the status of this? Can it br merged?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
gaborgsomogyi commented on PR #19825:
URL: https://github.com/apache/flink/pull/19825#issuecomment-1152972312
@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
gaborgsomogyi commented on PR #19933:
URL: https://github.com/apache/flink/pull/19933#issuecomment-1152972241
@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
[
https://issues.apache.org/jira/browse/FLINK-27965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553119#comment-17553119
]
Jane Chan commented on FLINK-27965:
---
Another case
Add "explain plan for" under TableSinkJsonPlanTest
[
https://issues.apache.org/jira/browse/FLINK-27965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-27965:
--
Summary: EXPLAIN PLAN FOR does not work for insert clause with static
partition (was: Query schema
[
https://issues.apache.org/jira/browse/FLINK-27940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553116#comment-17553116
]
Lijie Wang commented on FLINK-27940:
Hi [~alexanderpreuss], if you don't mind, I'd like to take on
knaufk commented on code in PR #550:
URL: https://github.com/apache/flink-web/pull/550#discussion_r895028059
##
_posts/2022-06-10-release-1.14.5.md:
##
@@ -0,0 +1,188 @@
+---
+layout: post
+title: "Apache Flink 1.14.5 Release Announcement"
+date: 2022-06-10T08:00:00.000Z
[
https://issues.apache.org/jira/browse/FLINK-28007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zichen Liu updated FLINK-28007:
---
Labels: pull-request-available (was: )
> Tests for AWS Connectors Using SDK v2 to use Synchronous
flinkbot commented on PR #19937:
URL: https://github.com/apache/flink/pull/19937#issuecomment-1152898039
## CI report:
* 26dcc153af6bb17290cfbb35825fdd1c53af1f5d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
CrynetLogistics opened a new pull request, #19937:
URL: https://github.com/apache/flink/pull/19937
…sink tests to using synchronous http clients
## What is the purpose of the change
The unit & integration tests for the aws connectors in the Flink repository
create
LadyForest commented on code in PR #137:
URL: https://github.com/apache/flink-table-store/pull/137#discussion_r895008431
##
flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/FileSystemCatalogITCase.java:
##
@@ -0,0 +1,111 @@
+/*
+ * Licensed to
luoyuxia commented on PR #19931:
URL: https://github.com/apache/flink/pull/19931#issuecomment-1152896647
@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.
luoyuxia commented on PR #19876:
URL: https://github.com/apache/flink/pull/19876#issuecomment-1152896621
@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.
LadyForest commented on code in PR #137:
URL: https://github.com/apache/flink-table-store/pull/137#discussion_r895007236
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/catalog/FileSystemCatalog.java:
##
@@ -0,0 +1,298 @@
+/*
+ * Licensed to the Apache
lsyldliu commented on PR #17654:
URL: https://github.com/apache/flink/pull/17654#issuecomment-1152893981
@meetjunsu Can you help update this pr by rebase the master branch?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
[
https://issues.apache.org/jira/browse/FLINK-18967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-18967:
--
Parent: FLINK-27593
Issue Type: Sub-task (was: Improvement)
> Upgrade ORC to 1.5.10 version
[
https://issues.apache.org/jira/browse/FLINK-22370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-22370:
--
Parent: FLINK-27593
Issue Type: Sub-task (was: Bug)
>
[
https://issues.apache.org/jira/browse/FLINK-25565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-25565:
--
Parent: FLINK-27593
Issue Type: Sub-task (was: New Feature)
> Write and Read Parquet INT64
[
https://issues.apache.org/jira/browse/FLINK-25113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-25113:
--
Parent: FLINK-27593
Issue Type: Sub-task (was: Technical Debt)
> Cleanup from Parquet and
Mrzyxing commented on code in PR #548:
URL: https://github.com/apache/flink-web/pull/548#discussion_r895002907
##
contributing/docs-style.zh.md:
##
@@ -151,257 +102,220 @@ under the License.
-->
```
-Below are the front matter variables most commonly used along the Flink
Mrzyxing commented on code in PR #548:
URL: https://github.com/apache/flink-web/pull/548#discussion_r895002853
##
contributing/docs-style.zh.md:
##
@@ -1,131 +1,82 @@
---
-title: "Documentation Style Guide"
+title: "文档样式指南"
---
-This guide provides an overview of the
Mrzyxing commented on code in PR #548:
URL: https://github.com/apache/flink-web/pull/548#discussion_r895002820
##
contributing/docs-style.zh.md:
##
@@ -1,131 +1,82 @@
---
-title: "Documentation Style Guide"
+title: "文档样式指南"
---
-This guide provides an overview of the
Mrzyxing commented on code in PR #548:
URL: https://github.com/apache/flink-web/pull/548#discussion_r895002779
##
contributing/docs-style.zh.md:
##
@@ -1,131 +1,82 @@
---
-title: "Documentation Style Guide"
+title: "文档样式指南"
---
-This guide provides an overview of the
Mrzyxing commented on code in PR #548:
URL: https://github.com/apache/flink-web/pull/548#discussion_r895002739
##
contributing/docs-style.zh.md:
##
@@ -1,131 +1,82 @@
---
-title: "Documentation Style Guide"
+title: "文档样式指南"
---
-This guide provides an overview of the
Mrzyxing commented on code in PR #548:
URL: https://github.com/apache/flink-web/pull/548#discussion_r895002683
##
contributing/docs-style.zh.md:
##
@@ -1,131 +1,82 @@
---
-title: "Documentation Style Guide"
+title: "文档样式指南"
---
-This guide provides an overview of the
lsyldliu commented on PR #19860:
URL: https://github.com/apache/flink/pull/19860#issuecomment-1152888610
@zhuzhurk According to the offline discuss, I have updated this PR, can you
help take a look again? This is the pre PR of
ming li created FLINK-28010:
---
Summary: Use deleteRange to optimize the clear operation of
RocksDBMapState.
Key: FLINK-28010
URL: https://issues.apache.org/jira/browse/FLINK-28010
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-28009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xingyuan cheng updated FLINK-28009:
---
Description:
Optimizing split data logic for large data volumes using parallel streams
[
https://issues.apache.org/jira/browse/FLINK-27658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-27658:
--
Component/s: Runtime / Task
> FlinkUserCodeClassLoader expose addURL method to allow to register jar
[
https://issues.apache.org/jira/browse/FLINK-27658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-27658:
--
Summary: FlinkUserCodeClassLoader expose addURL method to allow to register
jar dynamically (was:
xingyuan cheng created FLINK-28009:
--
Summary: Optimize data split
Key: FLINK-28009
URL: https://issues.apache.org/jira/browse/FLINK-28009
Project: Flink
Issue Type: Improvement
complone opened a new pull request, #151:
URL: https://github.com/apache/flink-table-store/pull/151
Optimizing split data logic for large data volumes using parallel streams
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
gaborgsomogyi commented on PR #19933:
URL: https://github.com/apache/flink/pull/19933#issuecomment-1152884488
@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
gaborgsomogyi commented on PR #19825:
URL: https://github.com/apache/flink/pull/19825#issuecomment-1152884459
@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
gaborgsomogyi commented on PR #19825:
URL: https://github.com/apache/flink/pull/19825#issuecomment-1152884441
FLINK-27792 issue occurs in the jenkins jobs permanently.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
gaborgsomogyi commented on PR #19933:
URL: https://github.com/apache/flink/pull/19933#issuecomment-1152884422
FLINK-27792 issue occurs in the jenkins jobs permanently.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
[
https://issues.apache.org/jira/browse/FLINK-27792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi updated FLINK-27792:
--
Priority: Blocker (was: Major)
> InterruptedException thrown by ChannelStateWriterImpl
>
[
https://issues.apache.org/jira/browse/FLINK-27792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553053#comment-17553053
]
Gabor Somogyi commented on FLINK-27792:
---
It would be good to be solved because it blocks other PRs
Myasuka commented on code in PR #548:
URL: https://github.com/apache/flink-web/pull/548#discussion_r894990979
##
contributing/docs-style.zh.md:
##
@@ -1,131 +1,82 @@
---
-title: "Documentation Style Guide"
+title: "文档样式指南"
---
-This guide provides an overview of the
luoyuxia commented on PR #19929:
URL: https://github.com/apache/flink/pull/19929#issuecomment-1152875620
@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.
lsyldliu commented on code in PR #19742:
URL: https://github.com/apache/flink/pull/19742#discussion_r894986764
##
flink-table/flink-sql-parser/src/test/java/org/apache/flink/sql/parser/FlinkSqlParserImplTest.java:
##
@@ -1324,15 +1324,26 @@ void testCreateFunction() {
1996fanrui commented on code in PR #19864:
URL: https://github.com/apache/flink/pull/19864#discussion_r894984520
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java:
##
@@ -74,11 +74,14 @@
import java.util.Set;
import
LadyForest commented on code in PR #137:
URL: https://github.com/apache/flink-table-store/pull/137#discussion_r894982385
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/catalog/TableStoreCatalog.java:
##
@@ -0,0 +1,224 @@
+/*
+ * Licensed to the Apache
LadyForest commented on code in PR #137:
URL: https://github.com/apache/flink-table-store/pull/137#discussion_r894982385
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/catalog/TableStoreCatalog.java:
##
@@ -0,0 +1,224 @@
+/*
+ * Licensed to the Apache
66 matches
Mail list logo