fsk119 merged PR #21134:
URL: https://github.com/apache/flink/pull/21134
--
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.apache
flinkbot commented on PR #21136:
URL: https://github.com/apache/flink/pull/21136#issuecomment-1288505413
## CI report:
* 0cc2200f45faddcddeaf90eaa4aceb31b9bcab2f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
gyfora commented on code in PR #409:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/409#discussion_r1002929772
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkResourceExceptionUtils.java:
##
@@ -0,0 +1,118 @@
+/*
+ * Lic
fredia opened a new pull request, #21136:
URL: https://github.com/apache/flink/pull/21136
## What is the purpose of the change
Improve logging in SharedStateRegistry
and make the conditional logic more clear.
This PR is copied from https://github.com/apache/flink/pull/207
[
https://issues.apache.org/jira/browse/FLINK-29733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang updated FLINK-29733:
-
Labels: pull-request-available test-stability (was: pull-request-available)
> Error Flink conne
[
https://issues.apache.org/jira/browse/FLINK-29733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang updated FLINK-29733:
-
Component/s: Connectors / Hive
> Error Flink connector hive Test failing
> -
[
https://issues.apache.org/jira/browse/FLINK-29733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang updated FLINK-29733:
-
Affects Version/s: 1.17.0
> Error Flink connector hive Test failing
> --
rgsriram commented on code in PR #408:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/408#discussion_r1002928530
##
examples/flink-python-example/Dockerfile:
##
@@ -36,7 +36,7 @@ apt-get clean && \
rm -rf /var/lib/apt/lists/*
# install PyFlink
-RUN pip3 insta
gyfora commented on code in PR #409:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/409#discussion_r1002927900
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/spec/AbstractFlinkSpec.java:
##
@@ -57,6 +57,9 @@ public abstract cl
jiangjiguang commented on PR #20830:
URL: https://github.com/apache/flink/pull/20830#issuecomment-1288495452
@luoyuxia packer is made by this.packer =
Packer.LITTLE_ENDIAN.newBytePacker(bitWidth); so it impossible to run the
abstract parent class BytePacker'method
> Error Flink connector hive Test failing
>
Samrat002 opened a new pull request, #21135:
URL: https://github.com/apache/flink/pull/21135
## What is the purpose of the change
This is a quick fix missed due to FLINK-29478.
*(For example: This pull request makes task deployment go through the blob
server, rather than th
Shengkai Fang created FLINK-29734:
-
Summary: Support authentication in the Flink SQL Gateway
Key: FLINK-29734
URL: https://issues.apache.org/jira/browse/FLINK-29734
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-29733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Samrat Deb updated FLINK-29733:
---
Summary: Error Flink connector hive Test failing (was: Error Flink
connector hive )
> Error Flink
Samrat Deb created FLINK-29733:
--
Summary: Error Flink connector hive
Key: FLINK-29733
URL: https://issues.apache.org/jira/browse/FLINK-29733
Project: Flink
Issue Type: Bug
Reporter:
jiangjiguang commented on PR #20830:
URL: https://github.com/apache/flink/pull/20830#issuecomment-1288481471
--
This is an automated message from the Apache Git Service.
To
jiangjiguang commented on PR #20830:
URL: https://github.com/apache/flink/pull/20830#issuecomment-1288480519
--
This is an automated message from the Apache Git Service.
To
jiangjiguang commented on code in PR #20830:
URL: https://github.com/apache/flink/pull/20830#discussion_r1002916628
##
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/vector/reader/RunLengthDecoder.java:
##
@@ -265,8 +265,16 @@ void readNextGroup() {
[
https://issues.apache.org/jira/browse/FLINK-29478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622976#comment-17622976
]
Samrat Deb commented on FLINK-29478:
Looking into it [~hxb] !
> Flink sql Connecto
[
https://issues.apache.org/jira/browse/FLINK-29405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622973#comment-17622973
]
Xingbo Huang commented on FLINK-29405:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622971#comment-17622971
]
Xingbo Huang commented on FLINK-24119:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-29405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622969#comment-17622969
]
Xingbo Huang commented on FLINK-29405:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-29478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622967#comment-17622967
]
Xingbo Huang commented on FLINK-29478:
--
[https://dev.azure.com/apache-flink/apache-
[
https://issues.apache.org/jira/browse/FLINK-29387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622965#comment-17622965
]
Xingbo Huang commented on FLINK-29387:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622964#comment-17622964
]
Xingbo Huang commented on FLINK-24119:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-29684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-29684:
Fix Version/s: 1.17.0
> [UI] Upgrade runtime web Angular framework and associated deps to v14
> --
[
https://issues.apache.org/jira/browse/FLINK-29729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622955#comment-17622955
]
Zhiping Wu edited comment on FLINK-29729 at 10/24/22 5:28 AM:
[
https://issues.apache.org/jira/browse/FLINK-29729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622955#comment-17622955
]
Zhiping Wu edited comment on FLINK-29729 at 10/24/22 5:26 AM:
[
https://issues.apache.org/jira/browse/FLINK-29729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622955#comment-17622955
]
Zhiping Wu edited comment on FLINK-29729 at 10/24/22 5:25 AM:
[
https://issues.apache.org/jira/browse/FLINK-29729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622955#comment-17622955
]
Zhiping Wu commented on FLINK-29729:
Hi [~lsy], thanks for looking at this case.
>F
[
https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622950#comment-17622950
]
Benchao Li commented on FLINK-29692:
Regarding "early-fire with window" versus "unbo
[
https://issues.apache.org/jira/browse/FLINK-29728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622948#comment-17622948
]
Weijie Guo commented on FLINK-29728:
[~angelok] Thanks for reporting this, the code
fredia commented on code in PR #20965:
URL: https://github.com/apache/flink/pull/20965#discussion_r1002873597
##
flink-state-backends/flink-statebackend-common/src/main/java/org/apache/flink/state/common/ChangelogMaterializationMetricGroup.java:
##
@@ -51,14 +57,17 @@ public Cha
luoyuxia commented on code in PR #20830:
URL: https://github.com/apache/flink/pull/20830#discussion_r1002872635
##
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/vector/reader/RunLengthDecoder.java:
##
@@ -265,8 +265,16 @@ void readNextGroup() {
[
https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622940#comment-17622940
]
Jing Zhang edited comment on FLINK-29692 at 10/24/22 4:21 AM:
[
https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622940#comment-17622940
]
Jing Zhang commented on FLINK-29692:
Sorry for late response.
I'm still wondering w
SteNicholas commented on PR #327:
URL:
https://github.com/apache/flink-table-store/pull/327#issuecomment-1288397838
@JingsongLi, could you add this way that creates table in the `Create Table`
document?
--
This is an automated message from the Apache Git Service.
To respond to the messag
zoltar9264 commented on code in PR #20965:
URL: https://github.com/apache/flink/pull/20965#discussion_r1002868608
##
flink-state-backends/flink-statebackend-common/src/main/java/org/apache/flink/state/common/ChangelogMaterializationMetricGroup.java:
##
@@ -51,14 +57,17 @@ public
luoyuxia commented on code in PR #21128:
URL: https://github.com/apache/flink/pull/21128#discussion_r1002865693
##
flink-connectors/flink-connector-hive/pom.xml:
##
@@ -39,6 +39,11 @@ under the License.
0.9.8
10.10.2.0
1.8.2
+
flinkbot commented on PR #21134:
URL: https://github.com/apache/flink/pull/21134#issuecomment-1288372336
## CI report:
* e637df006f28bfd7c27b570561b43c0a7c0f015f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
LadyForest opened a new pull request, #21134:
URL: https://github.com/apache/flink/pull/21134
## What is the purpose of the change
This pull request fixes the issue that when dropping a catalog in use, the
following SHOW CURRENT CATALOG still displays the dropped catalog by preventing
[
https://issues.apache.org/jira/browse/FLINK-29677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-29677:
--
Summary: Prevent dropping the current catalog (was: DROP CATALOG statement
does not reset current cat
[
https://issues.apache.org/jira/browse/FLINK-29677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-29677:
--
Affects Version/s: 1.16.0
> DROP CATALOG statement does not reset current catalog
> -
flinkbot commented on PR #21133:
URL: https://github.com/apache/flink/pull/21133#issuecomment-1288356742
## CI report:
* c6c7fe02c0c3b17bd3dd8231c25cbe279b600a5a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29732:
---
Labels: pull-request-available (was: )
> Support configuring session with SQL statement
> -
yuzelin opened a new pull request, #21133:
URL: https://github.com/apache/flink/pull/21133
…h sql statement.
## What is the purpose of the change
Implement `SqlGatewayService#configureSession` described in
[FLIP-91](https://cwiki.apache.org/confluence/display/FLINK/FLIP-91%
[
https://issues.apache.org/jira/browse/FLINK-29732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuzelin updated FLINK-29732:
Description: Implement SqlGatewayService#configureSession described in
[FLIP-91|https://cwiki.apache.org/c
yuzelin created FLINK-29732:
---
Summary: Support configuring session with SQL statement
Key: FLINK-29732
URL: https://issues.apache.org/jira/browse/FLINK-29732
Project: Flink
Issue Type: Sub-task
JingsongLi commented on code in PR #326:
URL: https://github.com/apache/flink-table-store/pull/326#discussion_r1002844838
##
flink-table-store-benchmark/flink-table-store-micro-benchmarks/src/main/java/org/apache/flink/table/store/benchmark/file/mergetree/MergeTreeWriterBenchmark.java:
[
https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622923#comment-17622923
]
yuzelin edited comment on FLINK-29646 at 10/24/22 2:47 AM:
---
Th
JingsongLi commented on code in PR #328:
URL: https://github.com/apache/flink-table-store/pull/328#discussion_r1002843817
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/compact/CompactStrategy.java:
##
@@ -37,4 +37,7 @@ public interface Compa
[
https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622923#comment-17622923
]
yuzelin commented on FLINK-29646:
-
Thanks for your suggestion. As [~fsk119] said, recent
fredia commented on code in PR #20965:
URL: https://github.com/apache/flink/pull/20965#discussion_r1002841563
##
flink-state-backends/flink-statebackend-common/src/main/java/org/apache/flink/state/common/ChangelogMaterializationMetricGroup.java:
##
@@ -51,14 +57,17 @@ public Cha
[
https://issues.apache.org/jira/browse/FLINK-29729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622913#comment-17622913
]
dalongliu commented on FLINK-29729:
---
Do we can configure the aws credential info at th
[
https://issues.apache.org/jira/browse/FLINK-28256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-28256.
Resolution: Fixed
master:
9cf4f76b736000a2ccd31a937551c0bca1c2e557
2d0562329615727cb0406cb9afd18cc
[
https://issues.apache.org/jira/browse/FLINK-28796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-28796:
--
Parent: FLINK-29073
Issue Type: Sub-task (was: Improvement)
> Add Statement Completem
[
https://issues.apache.org/jira/browse/FLINK-28914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622908#comment-17622908
]
Shengkai Fang commented on FLINK-28914:
---
Yes. Thanks for the mention. I think it s
JingsongLi closed pull request #305: [FLINK-28256] Move the write and
prepareCommit logic of AbstractTableWrite to FileStoreWrite
URL: https://github.com/apache/flink-table-store/pull/305
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
JingsongLi commented on PR #305:
URL:
https://github.com/apache/flink-table-store/pull/305#issuecomment-1288308960
Merged in 9cf4f76b736000a2ccd31a937551c0bca1c2e557
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
[
https://issues.apache.org/jira/browse/FLINK-29188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang closed FLINK-29188.
-
Fix Version/s: 1.16.0
(was: 1.17.0)
Resolution: Fixed
> The option
[
https://issues.apache.org/jira/browse/FLINK-29731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-29731:
--
Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
(was: Table
[
https://issues.apache.org/jira/browse/FLINK-29731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622906#comment-17622906
]
Shengkai Fang commented on FLINK-29731:
---
Is it same to the confluent avro format[1
fsk119 commented on PR #17830:
URL: https://github.com/apache/flink/pull/17830#issuecomment-1288285590
Sorry for the late response. I will take a look this week.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/FLINK-29731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Krish Narukulla updated FLINK-29731:
Description: Flink needs to integrate with Confluent for protobuf format,
to able to lever
[
https://issues.apache.org/jira/browse/FLINK-29708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622894#comment-17622894
]
Daren Wong commented on FLINK-29708:
Hi Gyula, thanks for the feedback, have updated
[
https://issues.apache.org/jira/browse/FLINK-29708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daren Wong updated FLINK-29708:
---
Description:
h1. Problem Statement:
FlinkDeployment and FlinkSessionJob CRD has a CommonStatus erro
[
https://issues.apache.org/jira/browse/FLINK-29708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29708:
---
Labels: pull-request-available (was: )
> Enrich Flink Kubernetes Operator CRD error field
>
darenwkt opened a new pull request, #409:
URL: https://github.com/apache/flink-kubernetes-operator/pull/409
## What is the purpose of the change
This PR aims to:
- Store exception metadata in JSON format under existing CR Error field.
Metadata includes: exception type, mess
qingwei91 commented on PR #20140:
URL: https://github.com/apache/flink/pull/20140#issuecomment-1288189339
@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.
qingwei91 commented on PR #20140:
URL: https://github.com/apache/flink/pull/20140#issuecomment-1288133847
@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.
1996fanrui commented on PR #21131:
URL: https://github.com/apache/flink/pull/21131#issuecomment-1288125009
Hi @pnowojski , please help take a look this PR in your free time.
This PR can simplify the `ChannelStateWriteRequestDispatcherImpl`, and it is
useful for FLINK-29730.
Af
[
https://issues.apache.org/jira/browse/FLINK-29729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622806#comment-17622806
]
dalongliu commented on FLINK-29729:
---
Thanks for opening this ticket, I will take a loo
Krishnaiah Narukulla created FLINK-29731:
Summary: Protobuf-confluent format
Key: FLINK-29731
URL: https://issues.apache.org/jira/browse/FLINK-29731
Project: Flink
Issue Type: New Fea
RocMarshal commented on PR #20990:
URL: https://github.com/apache/flink/pull/20990#issuecomment-1288099447
@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
[
https://issues.apache.org/jira/browse/FLINK-22402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia resolved FLINK-22402.
--
Resolution: Invalid
Close it since we have hive dialect test in sql-clinet
> Add hive dialect test in
qingwei91 commented on code in PR #20140:
URL: https://github.com/apache/flink/pull/20140#discussion_r1002679105
##
flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableSourceITCase.java:
##
@@ -264,6 +264,146 @@ void testLimi
1996fanrui commented on PR #21131:
URL: https://github.com/apache/flink/pull/21131#issuecomment-1288068334
@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
qingwei91 commented on code in PR #20140:
URL: https://github.com/apache/flink/pull/20140#discussion_r1002677936
##
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcFilterPushdownPreparedStatementVisitor.java:
##
@@ -0,0 +1,178 @@
+/*
flinkbot commented on PR #21132:
URL: https://github.com/apache/flink/pull/21132#issuecomment-1288064935
## CI report:
* 5bb906442bd4ec76b04600149131412e70386ae7 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29134:
---
Labels: pull-request-available (was: )
> fetch metrics may cause oom(ThreadPool task pile u
TanYuxin-tyx opened a new pull request, #21132:
URL: https://github.com/apache/flink/pull/21132
## What is the purpose of the change
In https://issues.apache.org/jira/projects/FLINK/issues/FLINK-29134, the OOM
issue is caused by adding too many useless updating metric task
zoltar9264 commented on PR #20965:
URL: https://github.com/apache/flink/pull/20965#issuecomment-1288046005
@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
libenchao commented on code in PR #20140:
URL: https://github.com/apache/flink/pull/20140#discussion_r1002654132
##
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcFilterPushdownPreparedStatementVisitor.java:
##
@@ -0,0 +1,178 @@
+/*
87 matches
Mail list logo
