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=17628684#comment-17628684
]
Gyula Fora commented on FLINK-29872:
Our goal is not to generate new clients if they are already
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
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=17628681#comment-17628681
]
zhenzhenhua commented on FLINK-26088:
-
We can use rest low client to support all Elasticsearch
[
https://issues.apache.org/jira/browse/FLINK-29796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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=17628667#comment-17628667
]
luoyuxia commented on FLINK-29877:
--
I'm not clear about your problem. Could you please expain a little
[
https://issues.apache.org/jira/browse/FLINK-29878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628662#comment-17628662
]
luoyuxia commented on FLINK-29878:
--
Introduce by FLINK-29478.
[~samrat007] Could you please have a
[
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
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
[
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
[
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
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() {
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() {
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
[
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
[
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=17628650#comment-17628650
]
penney commented on FLINK-29877:
-
And i found a strange question，If one of the three tables is empty,
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
[
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=17628648#comment-17628648
]
penney commented on FLINK-29877:
-
!image-2022-11-04-11-34-11-994.png!
> Failed to fetch next result
>
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
[
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=17628646#comment-17628646
]
luoyuxia commented on FLINK-29875:
--
I think it's expected. When use yarn to start cluster, we need to
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
[
https://issues.apache.org/jira/browse/FLINK-28985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628645#comment-17628645
]
waywtdcc commented on FLINK-28985:
--
hello? [~godfreyhe]
> support create table like view
>
[
https://issues.apache.org/jira/browse/FLINK-29877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628644#comment-17628644
]
Weijie Guo commented on FLINK-29877:
[~penney] Could you show a complete error stack?
> Failed to
[
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
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
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() {
[
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:
[
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:
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:
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
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
[
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-29832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628633#comment-17628633
]
Shammon commented on FLINK-29832:
-
Thanks [~TsReaper] When i tried to fixed this issue, i found the
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
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
[
https://issues.apache.org/jira/browse/FLINK-29873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628630#comment-17628630
]
luoyuxia commented on FLINK-29873:
--
I run the sql statements you post in the master branch, it won't
[
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=17628628#comment-17628628
]
Qingsheng Ren commented on FLINK-29831:
---
master: 8e66be89dfcb54b7256d51e9d89222ae6701061f
>
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:
[
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
[
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
[
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
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
[
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
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
[
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:
[
https://issues.apache.org/jira/browse/FLINK-29874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-29874:
---
Description:
The failure should be related to the flink shaded netty dependency.
{code:java}
[
https://issues.apache.org/jira/browse/FLINK-29857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuzelin updated FLINK-29857:
Component/s: Connectors / Hive
> Fix HiveServer2Endpoint crush when using Hive3 Beeline
>
[
https://issues.apache.org/jira/browse/FLINK-29461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628626#comment-17628626
]
Qingsheng Ren commented on FLINK-29461:
---
yuzelin commented on PR #21229:
URL: https://github.com/apache/flink/pull/21229#issuecomment-1302864599
@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.
zhuzhurk commented on code in PR #21197:
URL: https://github.com/apache/flink/pull/21197#discussion_r1013537283
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java:
##
@@ -603,6 +603,7 @@ public final void startScheduling() {
Leonard Xu created FLINK-29874:
--
Summary: Streaming File Sink end-to-end test failed on azure
Key: FLINK-29874
URL: https://issues.apache.org/jira/browse/FLINK-29874
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-29873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628625#comment-17628625
]
dalongliu commented on FLINK-29873:
---
CC [~godfreyhe]
> CannotPlanException raised after "CROSS JOIN
lindong28 commented on code in PR #166:
URL: https://github.com/apache/flink-ml/pull/166#discussion_r1013532619
##
flink-ml-core/src/main/java/org/apache/flink/ml/param/DoubleParam.java:
##
@@ -32,4 +34,12 @@ public DoubleParam(
public DoubleParam(String name, String
lindong28 commented on code in PR #166:
URL: https://github.com/apache/flink-ml/pull/166#discussion_r1013532619
##
flink-ml-core/src/main/java/org/apache/flink/ml/param/DoubleParam.java:
##
@@ -32,4 +34,12 @@ public DoubleParam(
public DoubleParam(String name, String
[
https://issues.apache.org/jira/browse/FLINK-29495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628623#comment-17628623
]
Yufan Sheng edited comment on FLINK-29495 at 11/4/22 1:42 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-29495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628623#comment-17628623
]
Yufan Sheng commented on FLINK-29495:
-
[~martijnvisser] The CI link you have provided is tests on
[
https://issues.apache.org/jira/browse/FLINK-29832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628619#comment-17628619
]
Caizhi Weng commented on FLINK-29832:
-
Hi [~zjureel].
Before diving into your implementation, I'd
[
https://issues.apache.org/jira/browse/FLINK-29860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628618#comment-17628618
]
Yufan Sheng commented on FLINK-29860:
-
I think we can just remove the extra document field for
[
https://issues.apache.org/jira/browse/FLINK-29672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
waywtdcc closed FLINK-29672.
Resolution: Later
> Support oracle catalog
> ---
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-29673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
waywtdcc closed FLINK-29673.
Resolution: Later
> Support sqlserver catalog
> -
>
> Key:
yunfengzhou-hub commented on code in PR #166:
URL: https://github.com/apache/flink-ml/pull/166#discussion_r1013518990
##
flink-ml-core/src/main/java/org/apache/flink/ml/param/DoubleParam.java:
##
@@ -32,4 +34,12 @@ public DoubleParam(
public DoubleParam(String name, String
tisonkun commented on PR #21204:
URL: https://github.com/apache/flink/pull/21204#issuecomment-1302841645
@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.
yunfengzhou-hub commented on code in PR #166:
URL: https://github.com/apache/flink-ml/pull/166#discussion_r1013518990
##
flink-ml-core/src/main/java/org/apache/flink/ml/param/DoubleParam.java:
##
@@ -32,4 +34,12 @@ public DoubleParam(
public DoubleParam(String name, String
[
https://issues.apache.org/jira/browse/FLINK-29872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628605#comment-17628605
]
Chesnay Schepler commented on FLINK-29872:
--
Can you expand on why you consider generating a
dannycranmer commented on code in PR #579:
URL: https://github.com/apache/flink-web/pull/579#discussion_r1013497201
##
_config.yml:
##
@@ -611,6 +623,12 @@ release_archive:
version_long: 2.0.0
release_date: 2020-04-02
+connectors:
+ - name: "Flink
Daeyeon Bae created FLINK-29873:
---
Summary: CannotPlanException raised after "CROSS JOIN UNNEST"
Key: FLINK-29873
URL: https://issues.apache.org/jira/browse/FLINK-29873
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-29855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628539#comment-17628539
]
Xinyi Yan commented on FLINK-29855:
---
In case someone is trying to repro it locally or is interested in
zentol commented on code in PR #579:
URL: https://github.com/apache/flink-web/pull/579#discussion_r1013415427
##
downloads.md:
##
@@ -107,6 +107,28 @@ Please have a look at the [Release Notes for Flink {{
flink_release.version_shor
{% endfor %}
+## Flink connectors
zentol commented on code in PR #579:
URL: https://github.com/apache/flink-web/pull/579#discussion_r1013415137
##
_config.yml:
##
@@ -611,6 +623,12 @@ release_archive:
version_long: 2.0.0
release_date: 2020-04-02
+connectors:
+ - name: "Flink
[
https://issues.apache.org/jira/browse/FLINK-29872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628537#comment-17628537
]
Gyula Fora commented on FLINK-29872:
You are right we could do many complicated things that might
[
https://issues.apache.org/jira/browse/FLINK-29872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628530#comment-17628530
]
Chesnay Schepler commented on FLINK-29872:
--
Then frankly you should use the client from the
[
https://issues.apache.org/jira/browse/FLINK-29872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628516#comment-17628516
]
Gyula Fora commented on FLINK-29872:
With components such as the Kubernetes Operator these
[
https://issues.apache.org/jira/browse/FLINK-29855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628515#comment-17628515
]
Xinyi Yan commented on FLINK-29855:
---
I added a new UDF that randomly returns either null or bytes, and
[
https://issues.apache.org/jira/browse/FLINK-29872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628511#comment-17628511
]
Chesnay Schepler commented on FLINK-29872:
--
That's not a compatibility direction that we
[
https://issues.apache.org/jira/browse/FLINK-29872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-29872:
-
Issue Type: Bug (was: New Feature)
> JobDetailsInfo Rest endpoint breaking change in
dannycranmer commented on code in PR #579:
URL: https://github.com/apache/flink-web/pull/579#discussion_r1013352153
##
downloads.md:
##
@@ -107,6 +107,28 @@ Please have a look at the [Release Notes for Flink {{
flink_release.version_shor
{% endfor %}
+## Flink connectors
ferenc-csaky commented on PR #21140:
URL: https://github.com/apache/flink/pull/21140#issuecomment-1302528490
Sorry for the delay, but finally I was able to spend some time on this and
verified that the token obtain logic works as expected:
```
2022-11-03 11:37:08,236 INFO
morhidi commented on PR #426:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/426#issuecomment-1302446806
+1 discussed offline already
--
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
[
https://issues.apache.org/jira/browse/FLINK-29855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628437#comment-17628437
]
Xinyi Yan commented on FLINK-29855:
---
hi [~luoyuxia], I think this is a critical bug, and it can cause
[
https://issues.apache.org/jira/browse/FLINK-29855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628431#comment-17628431
]
Xinyi Yan commented on FLINK-29855:
---
[~lsy], thanks for the reply. I don't think the datagen produces
gyfora commented on PR #426:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/426#issuecomment-1302422435
cc @morhidi
--
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-29851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29851:
---
Labels: pull-request-available (was: )
> Upgrade to Fabric8 6.x.x and JOSDK 4.x.x
>
1996fanrui commented on PR #21131:
URL: https://github.com/apache/flink/pull/21131#issuecomment-1302384607
@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
gyfora opened a new pull request, #426:
URL: https://github.com/apache/flink-kubernetes-operator/pull/426
## What is the purpose of the change
Upgrade to Fabric8 6.2.0 and JOSDK 4.1.0. This change is required to
leverage fixes in both fabric8 and the josdk. In addition I cleaned up
dannycranmer commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r1013142220
##
flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/util/DynamoDbSerializationUtil.java:
##
@@ -0,0 +1,196 @@
+/*
Gyula Fora created FLINK-29872:
--
Summary: JobDetailsInfo Rest endpoint breaking change in 1.16
Key: FLINK-29872
URL: https://issues.apache.org/jira/browse/FLINK-29872
Project: Flink
Issue Type:
1 - 100 of 275 matches
Mail list logo
