PatrickRen merged PR #20831:
URL: https://github.com/apache/flink/pull/20831
--
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.ap
PatrickRen commented on PR #20831:
URL: https://github.com/apache/flink/pull/20831#issuecomment-1303046885
A successful run:
https://renqs.visualstudio.com/Apache%20Flink/_build/results?buildId=417&view=results
--
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-29881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628723#comment-17628723
]
yuzelin edited comment on FLINK-29881 at 11/4/22 6:53 AM:
--
Hi,
tsreaper merged PR #349:
URL: https://github.com/apache/flink-table-store/pull/349
--
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
yangjf2019 commented on code in PR #425:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/425#discussion_r1013676491
##
docs/content/docs/custom-resource/reference.md:
##
@@ -67,7 +67,7 @@ This page serves as a full reference for FlinkDeployment
custom resource de
[
https://issues.apache.org/jira/browse/FLINK-29881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628723#comment-17628723
]
yuzelin commented on FLINK-29881:
-
Hi,
Maybe it is a little misleading, let me explai
[
https://issues.apache.org/jira/browse/FLINK-29881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yiwei93 updated FLINK-29881:
Attachment: image-2022-11-04-14-47-00-762.png
> when Fetch results in sql gateway, the result using open a
reswqa commented on code in PR #21137:
URL: https://github.com/apache/flink/pull/21137#discussion_r1013672492
##
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterServiceLeadershipRunnerTest.java:
##
@@ -93,48 +87,47 @@ public class JobMasterServiceLeadersh
gyfora commented on code in PR #425:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/425#discussion_r1013668485
##
docs/content/docs/custom-resource/reference.md:
##
@@ -67,7 +67,7 @@ This page serves as a full reference for FlinkDeployment
custom resource defini
[
https://issues.apache.org/jira/browse/FLINK-29876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29876:
---
Labels: pull-request-available (was: )
> Explicitly throw exception from Table Store sink w
tsreaper opened a new pull request, #352:
URL: https://github.com/apache/flink-table-store/pull/352
Currently table store sink does not support unaligned checkpoint or at least
once checkpoint mode, but no exception is explicitly thrown. We should throw
exception so that users can change th
reswqa commented on PR #21137:
URL: https://github.com/apache/flink/pull/21137#issuecomment-1303034139
Thanks everyone for your comments and discussion, which is very meaningful
to me. Based on the above discussion, I think @xintongsong's suggestion looks
good to me, +1 for this plan.
We
[
https://issues.apache.org/jira/browse/FLINK-29877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628715#comment-17628715
]
Leonard Xu commented on FLINK-29877:
I don't see a reasonable opinion that we should
[
https://issues.apache.org/jira/browse/FLINK-29877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-29877:
---
Priority: Major (was: Blocker)
> Failed to fetch next result
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-29881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628708#comment-17628708
]
yuanfenghu commented on FLINK-29881:
The executestatment operation is asynchronous,
[
https://issues.apache.org/jira/browse/FLINK-29876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng reassigned FLINK-29876:
---
Assignee: Caizhi Weng
> Explicitly throw exception from Table Store sink when unaligned che
[
https://issues.apache.org/jira/browse/FLINK-29874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-29874:
---
Component/s: BuildSystem / Shaded
> Streaming File Sink end-to-end test failed on azure due to
> Cl
[
https://issues.apache.org/jira/browse/FLINK-29874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628707#comment-17628707
]
Leonard Xu commented on FLINK-29874:
https://dev.azure.com/apache-flink/apache-flink
[
https://issues.apache.org/jira/browse/FLINK-29874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628706#comment-17628706
]
Leonard Xu commented on FLINK-29874:
https://dev.azure.com/apache-flink/apache-flink
[
https://issues.apache.org/jira/browse/FLINK-29874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-29874:
---
Priority: Critical (was: Major)
> Streaming File Sink end-to-end test failed on azure due to
> Cla
[
https://issues.apache.org/jira/browse/FLINK-29874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628705#comment-17628705
]
Leonard Xu commented on FLINK-29874:
https://dev.azure.com/apache-flink/apache-flink
[
https://issues.apache.org/jira/browse/FLINK-29836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628703#comment-17628703
]
Leonard Xu commented on FLINK-29836:
https://dev.azure.com/apache-flink/apache-flink
[
https://issues.apache.org/jira/browse/FLINK-29877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628702#comment-17628702
]
penney commented on FLINK-29877:
-
It's TableA union all TableB union all TableC.The dat
[
https://issues.apache.org/jira/browse/FLINK-29877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
penney updated FLINK-29877:
Attachment: image-2022-11-04-14-22-36-466.png
> Failed to fetch next result
> ---
[
https://issues.apache.org/jira/browse/FLINK-25587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628699#comment-17628699
]
Leonard Xu commented on FLINK-25587:
##[error]Exit code 137 returned from process: f
yiwei93 created FLINK-29881:
---
Summary: when Fetch results in sql gateway, the result using open
api is different from using restful api
Key: FLINK-29881
URL: https://issues.apache.org/jira/browse/FLINK-29881
[
https://issues.apache.org/jira/browse/FLINK-29610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628690#comment-17628690
]
Jiale Tan edited comment on FLINK-29610 at 11/4/22 6:16 AM:
[
https://issues.apache.org/jira/browse/FLINK-29405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628695#comment-17628695
]
Leonard Xu commented on FLINK-29405:
https://dev.azure.com/apache-flink/apache-flink
[
https://issues.apache.org/jira/browse/FLINK-29879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29879:
-
Description:
Similar to streaming mode, we introuce the following four operators:
BatchFileWriter -> Ba
[
https://issues.apache.org/jira/browse/FLINK-29610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiale Tan updated FLINK-29610:
--
Description:
In {{{}SavepointHandlers{}}}, both
{{[StopWithSavepointHandler|https://github.com/apache
leletan closed pull request #21191: [FLINK-29610] [flink-runtime]: Use rest
time out instead of RpcUtils.INF_TIMEOUT Infinite timeout in SavepointHandlers
and CheckpointHandlers
URL: https://github.com/apache/flink/pull/21191
--
This is an automated message from the Apache Git Service.
To re
reswqa commented on code in PR #21137:
URL: https://github.com/apache/flink/pull/21137#discussion_r1013656229
##
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterServiceLeadershipRunnerTest.java:
##
@@ -93,48 +87,47 @@ public class JobMasterServiceLeadersh
flinkbot commented on PR #21239:
URL: https://github.com/apache/flink/pull/21239#issuecomment-1303022931
## CI report:
* 1eb77f4640aec4ba4e70fe632e88c8055bcfb837 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiale Tan updated FLINK-29610:
--
Summary: Infinite timeout is used in SavepointHandlers and
CheckpointTriggerHandler calls to RestfulGa
[
https://issues.apache.org/jira/browse/FLINK-29879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29879:
-
Description:
Similar to streaming mode, we introuce the following four operators:
BatchFileWriter -> Ba
[
https://issues.apache.org/jira/browse/FLINK-29610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628690#comment-17628690
]
Jiale Tan commented on FLINK-29610:
---
[~gaoyunhaii] thanks for the info!
I created a P
luoyuxia created FLINK-29880:
Summary: Hive sink supports merge files in batch mode
Key: FLINK-29880
URL: https://issues.apache.org/jira/browse/FLINK-29880
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-29879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29879:
-
Summary: Introduce operators for files merging in batch mode (was:
Introduce operators for files mergin
[
https://issues.apache.org/jira/browse/FLINK-29879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29879:
-
Description: Similar to straming
> Introduce operators for files merging
>
luoyuxia created FLINK-29879:
Summary: Introduce operators for files merging
Key: FLINK-29879
URL: https://issues.apache.org/jira/browse/FLINK-29879
Project: Flink
Issue Type: Sub-task
leletan opened a new pull request, #21239:
URL: https://github.com/apache/flink/pull/21239
## What is the purpose of the change
This pull request makes SavepointHandlers and CheckpointHandlers call to
RestfulGateway using `ASK_TIMEOUT_DURATION`, instead of `RpcUtils.INF_TIMEOU
reswqa commented on code in PR #21137:
URL: https://github.com/apache/flink/pull/21137#discussion_r1013644830
##
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMasterServiceLeadershipRunner.java:
##
@@ -151,10 +155,12 @@ public CompletableFuture closeAsync() {
[
https://issues.apache.org/jira/browse/FLINK-29872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628684#comment-17628684
]
Gyula Fora commented on FLINK-29872:
Our goal is not to generate new clients if they
xintongsong commented on PR #21137:
URL: https://github.com/apache/flink/pull/21137#issuecomment-1303003420
This is indeed a fascinating discussion.
I see the point that there are some calls in `cloaseAsync` that may or may
not run under the lock. I also agree that it would be nice th
JerryYue-M commented on PR #21197:
URL: https://github.com/apache/flink/pull/21197#issuecomment-1302998406
@zhuzhurk all the questions you mentioned had resolved, add ut to check
all the operator coordinators had registered metrics after scheduling, please
review it again
thanks a lot
[
https://issues.apache.org/jira/browse/FLINK-26088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628681#comment-17628681
]
zhenzhenhua commented on FLINK-26088:
-
We can use rest low client to support all Ela
[
https://issues.apache.org/jira/browse/FLINK-29796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628677#comment-17628677
]
Dian Fu commented on FLINK-29796:
-
cc [~hxb]
> pyflink protobuf requirement out of date
[
https://issues.apache.org/jira/browse/FLINK-29877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628667#comment-17628667
]
luoyuxia commented on FLINK-29877:
--
I'm not clear about your problem. Could you please
[
https://issues.apache.org/jira/browse/FLINK-29878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628662#comment-17628662
]
luoyuxia commented on FLINK-29878:
--
Introduce by FLINK-29478.
[~samrat007] Could you p
[
https://issues.apache.org/jira/browse/FLINK-29878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29878:
-
Description:
When I try to use flink-sql-connector-hive-3.1.3, it will throw the following
exception:
{
luoyuxia created FLINK-29878:
Summary: Fail to use flink-sql-connector-hive-3.1.3
Key: FLINK-29878
URL: https://issues.apache.org/jira/browse/FLINK-29878
Project: Flink
Issue Type: Bug
reswqa commented on code in PR #21137:
URL: https://github.com/apache/flink/pull/21137#discussion_r1013588761
##
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterServiceLeadershipRunnerTest.java:
##
@@ -46,45 +49,36 @@
import org.apache.flink.util.FlinkEx
reswqa commented on code in PR #21137:
URL: https://github.com/apache/flink/pull/21137#discussion_r1013588761
##
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterServiceLeadershipRunnerTest.java:
##
@@ -46,45 +49,36 @@
import org.apache.flink.util.FlinkEx
[
https://issues.apache.org/jira/browse/FLINK-29848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng closed FLINK-29848.
---
Resolution: Fixed
master: 18c01207839a6b2eade3a010538a4aa1610a2eb6
> Port BinaryRowDataUtil to Flin
[
https://issues.apache.org/jira/browse/FLINK-29848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng reassigned FLINK-29848:
---
Assignee: Jane Chan
> Port BinaryRowDataUtil to Flink Table Store
> ---
reswqa commented on code in PR #21185:
URL: https://github.com/apache/flink/pull/21185#discussion_r1013586123
##
flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/history/HistoryServerStaticFileServerHandlerTest.java:
##
@@ -30,12 +31,33 @@
import java.nio.f
zhuzhurk commented on code in PR #21197:
URL: https://github.com/apache/flink/pull/21197#discussion_r1013586043
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java:
##
@@ -603,6 +603,7 @@ public final void startScheduling() {
exe
LadyForest commented on code in PR #350:
URL: https://github.com/apache/flink-table-store/pull/350#discussion_r1013585500
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/utils/SnapshotManager.java:
##
@@ -109,7 +139,7 @@ public Long findLatest() throws
zhuzhurk commented on code in PR #21197:
URL: https://github.com/apache/flink/pull/21197#discussion_r1013581586
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java:
##
@@ -603,6 +603,7 @@ public final void startScheduling() {
exe
jiangxin369 commented on code in PR #166:
URL: https://github.com/apache/flink-ml/pull/166#discussion_r1013581529
##
flink-ml-core/src/main/java/org/apache/flink/ml/param/DoubleParam.java:
##
@@ -32,4 +34,12 @@ public DoubleParam(
public DoubleParam(String name, String desc
[
https://issues.apache.org/jira/browse/FLINK-29801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-29801:
Component/s: Runtime / Metrics
(was: Runtime / Coordination)
> OperatorCoordinator ne
[
https://issues.apache.org/jira/browse/FLINK-29801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-29801:
---
Assignee: yuemeng
> OperatorCoordinator need open the way to operate metricGroup interface
> --
[
https://issues.apache.org/jira/browse/FLINK-29877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628650#comment-17628650
]
penney commented on FLINK-29877:
-
And i found a strange question，If one of the three ta
dangshazi commented on code in PR #21185:
URL: https://github.com/apache/flink/pull/21185#discussion_r1013573867
##
flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/history/HistoryServerStaticFileServerHandlerTest.java:
##
@@ -30,12 +31,33 @@
import java.ni
[
https://issues.apache.org/jira/browse/FLINK-29877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
penney updated FLINK-29877:
Attachment: image-2022-11-04-11-34-11-994.png
> Failed to fetch next result
> ---
[
https://issues.apache.org/jira/browse/FLINK-29877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628648#comment-17628648
]
penney commented on FLINK-29877:
-
!image-2022-11-04-11-34-11-994.png!
> Failed to fetc
dangshazi commented on code in PR #21185:
URL: https://github.com/apache/flink/pull/21185#discussion_r1013573354
##
flink-core/src/main/java/org/apache/flink/configuration/HistoryServerOptions.java:
##
@@ -143,5 +143,16 @@ public class HistoryServerOptions {
dangshazi commented on code in PR #21185:
URL: https://github.com/apache/flink/pull/21185#discussion_r1013573243
##
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServerStaticFileServerHandler.java:
##
@@ -266,6 +324,18 @@ private void respond
[
https://issues.apache.org/jira/browse/FLINK-29877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
penney updated FLINK-29877:
Attachment: image-2022-11-04-11-33-48-535.png
> Failed to fetch next result
> ---
[
https://issues.apache.org/jira/browse/FLINK-29748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi closed FLINK-29748.
--
Resolution: Won't Fix
> Expose the optimize phase in the connector context
> -
[
https://issues.apache.org/jira/browse/FLINK-29875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628646#comment-17628646
]
luoyuxia commented on FLINK-29875:
--
I think it's expected. When use yarn to start clust
LadyForest commented on PR #345:
URL:
https://github.com/apache/flink-table-store/pull/345#issuecomment-1302911100
Actually, `default` is a keyword in SQL, and one should escape it when
referring it.
E.g.
```sql
SELECT * FROM table_store.`default`.my_table
```
--
This is an
[
https://issues.apache.org/jira/browse/FLINK-28985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628645#comment-17628645
]
waywtdcc commented on FLINK-28985:
--
hello? [~godfreyhe]
> support create table like v
[
https://issues.apache.org/jira/browse/FLINK-29877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628644#comment-17628644
]
Weijie Guo commented on FLINK-29877:
[~penney] Could you show a complete error stack
[
https://issues.apache.org/jira/browse/FLINK-28812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28812:
---
Labels: pull-request-available (was: )
> Add read.compacted to read compacted snapshot only
zjureel opened a new pull request, #351:
URL: https://github.com/apache/flink-table-store/pull/351
Support to read compacted snapshot only
--
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 spec
JerryYue-M commented on code in PR #21197:
URL: https://github.com/apache/flink/pull/21197#discussion_r1013564167
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java:
##
@@ -603,6 +603,7 @@ public final void startScheduling() {
e
[
https://issues.apache.org/jira/browse/FLINK-29877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
penney updated FLINK-29877:
Attachment: image-2022-11-04-11-13-48-282.png
Description:
runTimeConfiguration.set(TaskManagerOption
[
https://issues.apache.org/jira/browse/FLINK-29848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29848:
---
Labels: pull-request-available (was: )
> Port BinaryRowDataUtil to Flink Table Store
>
tsreaper merged PR #348:
URL: https://github.com/apache/flink-table-store/pull/348
--
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
penney created FLINK-29877:
---
Summary: Failed to fetch next result
Key: FLINK-29877
URL: https://issues.apache.org/jira/browse/FLINK-29877
Project: Flink
Issue Type: Bug
Components: Table
zjureel commented on PR #345:
URL:
https://github.com/apache/flink-table-store/pull/345#issuecomment-1302893696
Hi @tsreaper I have updated this issue, what do you think of it? THX
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
Caizhi Weng created FLINK-29876:
---
Summary: Explicitly throw exception from Table Store sink when
unaligned checkpoint is enabled
Key: FLINK-29876
URL: https://issues.apache.org/jira/browse/FLINK-29876
P
[
https://issues.apache.org/jira/browse/FLINK-29832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shammon updated FLINK-29832:
Summary: Improve switch to default database in docs (was: Refactor default
database name in flink table s
[
https://issues.apache.org/jira/browse/FLINK-29832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shammon updated FLINK-29832:
Description: `FlinkCatalogFactory` creates a default database named
`default` in table store. The `default
[
https://issues.apache.org/jira/browse/FLINK-29832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628633#comment-17628633
]
Shammon commented on FLINK-29832:
-
Thanks [~TsReaper] When i tried to fixed this issue,
leonardBang commented on PR #21227:
URL: https://github.com/apache/flink/pull/21227#issuecomment-1302878796
Hi, @zentol @MartijnVisser I would be wait to today afternoon if you can
have a quick hotfix when you start work, otherwise I plan to revert this commit
as it leads to all PR CI faile
Shengkai Fang created FLINK-29875:
-
Summary: Can not find JobConf when using Hive Connector
Key: FLINK-29875
URL: https://issues.apache.org/jira/browse/FLINK-29875
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-29873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628630#comment-17628630
]
luoyuxia commented on FLINK-29873:
--
I run the sql statements you post in the master bra
[
https://issues.apache.org/jira/browse/FLINK-29831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren closed FLINK-29831.
-
Fix Version/s: 1.17.0
Resolution: Fixed
> Multiple Hive tests are failing
> -
[
https://issues.apache.org/jira/browse/FLINK-29831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-29831:
-
Assignee: luoyuxia
> Multiple Hive tests are failing
> ---
[
https://issues.apache.org/jira/browse/FLINK-29831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628628#comment-17628628
]
Qingsheng Ren commented on FLINK-29831:
---
master: 8e66be89dfcb54b7256d51e9d89222ae6
PatrickRen merged PR #21218:
URL: https://github.com/apache/flink/pull/21218
--
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.ap
[
https://issues.apache.org/jira/browse/FLINK-29857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuzelin updated FLINK-29857:
Description: Hive3 add a new 'TGetInfoType' value 'CLI_ODBC_KEYWORDS', but
'HiveServer2Endpoint' doesn't h
[
https://issues.apache.org/jira/browse/FLINK-29857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuzelin updated FLINK-29857:
Description: Hive3 add a new 'TGetInfoType' value 'CLI_ODBC_KEYWORDS', but
'HiveServer2Endpoint' doesn't h
[
https://issues.apache.org/jira/browse/FLINK-29857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuzelin updated FLINK-29857:
Description: Hive3 add a new 'TGetInfoType' value 'CLI_ODBC_KEYWORDS', but
'HiveServer2Endpoint' doesn't h
Aitozi commented on PR #21174:
URL: https://github.com/apache/flink/pull/21174#issuecomment-1302869573
The CI failure seems unrelated
> Caused by: org.apache.kafka.common.errors.TopicExistsException: Topic
'partition_failure_recovery_EventTime' already exists.
--
This is an automa
[
https://issues.apache.org/jira/browse/FLINK-29857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuzelin updated FLINK-29857:
Summary: Fix failure to connect to 'HiveServer2Endpoint' when using hive3
beeline (was: Fix HiveServer2En
leonardBang commented on PR #21227:
URL: https://github.com/apache/flink/pull/21227#issuecomment-1302869160
The CI failed，I created an issue, Could you take a look it FLINK-29874?
@zentol
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
[
https://issues.apache.org/jira/browse/FLINK-29874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-29874:
---
Summary: Streaming File Sink end-to-end test failed on azure due to
ClassNotFoundException (was: St
1 - 100 of 306 matches
Mail list logo
