Weijie Guo created FLINK-31764:
--
Summary: Get rid of numberOfRequestedOverdraftMemorySegments in
LocalBufferPool
Key: FLINK-31764
URL: https://issues.apache.org/jira/browse/FLINK-31764
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-31301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17710396#comment-17710396
]
Aitozi commented on FLINK-31301:
[~lincoln.86xy] , I opened PR for this, could you help review it,
[
https://issues.apache.org/jira/browse/FLINK-31763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31763:
---
Description:
As we discussed in FLINK-31610, new buffers can be requested only when
Weijie Guo created FLINK-31763:
--
Summary: Ensure that the total number of requested buffers does
not exceed poolSize + maxOverdraftBuffersPerGate
Key: FLINK-31763
URL:
xintongsong commented on code in PR #22330:
URL: https://github.com/apache/flink/pull/22330#discussion_r1162243590
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/upstream/common/TierStorage.java:
##
@@ -0,0 +1,44 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-31760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17710379#comment-17710379
]
Ran Tao commented on FLINK-31760:
-
[~morezaei00] Hi, Mohsen, I think it's a bug, coalesce need return
[
https://issues.apache.org/jira/browse/FLINK-28171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17710375#comment-17710375
]
Sergio Sainz edited comment on FLINK-28171 at 4/11/23 2:42 AM:
---
Hello
[
https://issues.apache.org/jira/browse/FLINK-28171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17710375#comment-17710375
]
Sergio Sainz commented on FLINK-28171:
--
Hello [~wangyang0918] ! also experiencing this issue with
[
https://issues.apache.org/jira/browse/FLINK-31762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liam updated FLINK-31762:
-
Summary: Subscribe to multiple Kafka topics may cause partition assignment
skew (was: Subscribe multiple Kafka
Liam created FLINK-31762:
Summary: Subscribe multiple Kafka topics may cause partition
assignment skew
Key: FLINK-31762
URL: https://issues.apache.org/jira/browse/FLINK-31762
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-27463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liam closed FLINK-27463.
Resolution: Won't Do
> The JDBC connector should support option for ‘upsert’ or ‘insert’
>
flinkbot commented on PR #22374:
URL: https://github.com/apache/flink/pull/22374#issuecomment-1502413566
## CI report:
* 1f37f1de408883d6e75632851034a056c8d1083c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31761:
---
Labels: pull-request-available (was: )
> Fix Some Typo And Improve lambda expressions.
>
slfan1989 opened a new pull request, #22374:
URL: https://github.com/apache/flink/pull/22374
## What is the purpose of the change
When reading the code, I found 2 typo errors and improved the lambada
expression.
This PR will improve this part of the content.
##
Shilun Fan created FLINK-31761:
--
Summary: Fix Some Typo And Improve lambda expressions.
Key: FLINK-31761
URL: https://issues.apache.org/jira/browse/FLINK-31761
Project: Flink
Issue Type:
Mohsen Rezaei created FLINK-31760:
-
Summary: COALESCE() with NULL arguments throws error
Key: FLINK-31760
URL: https://issues.apache.org/jira/browse/FLINK-31760
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31759:
---
Description:
# FLINK-30291 introduce a new shortcode({{{}sql_connector_download_table{}}})
for
[
https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31759:
---
Component/s: (was: Connectors / Kafka)
> Update some external connectors to use
[
https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31759:
---
Component/s: Connectors / Kafka
> Update some external connectors to use
[
https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31759:
---
Description:
# FLINK-30291 introduce a new shortcode({{{}sql_connector_download_table{}}})
for
reswqa commented on PR #17:
URL:
https://github.com/apache/flink-connector-opensearch/pull/17#issuecomment-1502153037
cc @dannycranmer. I realized we have synced the docs to flink 1.17 branch in
https://github.com/apache/flink/pull/22365, to fix this, do we need to push a
v1.0.0-docs
boring-cyborg[bot] commented on PR #17:
URL:
https://github.com/apache/flink-connector-opensearch/pull/17#issuecomment-1502150744
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
reswqa opened a new pull request, #17:
URL: https://github.com/apache/flink-connector-opensearch/pull/17
I compiled the flink documentation locally and found the problem shown in
the figure below:
reswqa opened a new pull request, #7:
URL: https://github.com/apache/flink-connector-gcp-pubsub/pull/7
This should also backports to v3.0 branch.
--
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
boring-cyborg[bot] commented on PR #7:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/7#issuecomment-1502116737
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This
[
https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31759:
---
Component/s: Connectors / Google Cloud PubSub
> Update some external connectors to use
[
https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31759:
---
Description:
# FLINK-30291 introduce a new shortcode({{{}sql_connector_download_table{}}})
for
[
https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31759:
---
Component/s: Connectors / HBase
> Update some external connectors to use
[
https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31759:
---
Description:
# FLINK-30291 introduce a new shortcode({{{}sql_connector_download_table{}}})
for
boring-cyborg[bot] commented on PR #8:
URL:
https://github.com/apache/flink-connector-hbase/pull/8#issuecomment-1502107159
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is an
reswqa opened a new pull request, #8:
URL: https://github.com/apache/flink-connector-hbase/pull/8
This should also backports to v3.0 branch.
--
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
boring-cyborg[bot] commented on PR #9:
URL:
https://github.com/apache/flink-connector-rabbitmq/pull/9#issuecomment-1502092259
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is
[
https://issues.apache.org/jira/browse/FLINK-31746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17710240#comment-17710240
]
Weijie Guo commented on FLINK-31746:
Details about the failed task should be found in the
[
https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31759:
---
Description:
# FLINK-30291 introduce a new shortcode({{{}sql_connector_download_table{}}})
for
[
https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31759:
---
Component/s: Connectors/ RabbitMQ
> Update some external connectors to use
[
https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31759:
---
Description:
# FLINK-30291 introduce a new shortcode({{{}sql_connector_download_table{}}})
for
[
https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31759:
---
Labels: pull-request-available (was: )
> Update some external connectors to use
boring-cyborg[bot] commented on PR #38:
URL:
https://github.com/apache/flink-connector-jdbc/pull/38#issuecomment-1502053994
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is
[
https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31759:
---
Description:
# FLINK-30291 introduce a new shortcode({{{}sql_connector_download_table{}}})
for
[
https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31759:
---
Summary: Update some external connectors to use
sql_connector_download_table and connector_artifact
[
https://issues.apache.org/jira/browse/FLINK-31746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17710214#comment-17710214
]
Haoze Wu commented on FLINK-31746:
--
[~martijnvisser] I reproduced the similar issue in Flink-1.17.0. It
[
https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31759:
---
Component/s: Connectors / JDBC
> Update some external connectors to use
[
https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31759:
---
Description:
FLINK-30291 introduce a new shortcode(sql_connector_download_table) for
externalized
[
https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31759:
---
Description:
FLINK-30291 introduce a new shortcode(\{{sql_connector_download_table}}) for
[
https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31759:
---
Description: FLINK-30291 introduce a new
> Update some external connectors to use modified
[
https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31759:
---
Summary: Update some external connectors to use
sql_connector_download_table shortcode (was:
[
https://issues.apache.org/jira/browse/FLINK-31759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31759:
---
Component/s: Connectors / ElasticSearch
> Update some external connectors to use modified
Weijie Guo created FLINK-31759:
--
Summary: Update some external connectors to use modified
sql_connector_download_table shortcode
Key: FLINK-31759
URL: https://issues.apache.org/jira/browse/FLINK-31759
flinkbot commented on PR #22373:
URL: https://github.com/apache/flink/pull/22373#issuecomment-1501938278
## CI report:
* a92df67bc3b466b4fb84552aa3f55c1f25d70893 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31758:
---
Labels: pull-request-available (was: )
> Some external connectors sql client jar has a
reswqa opened a new pull request, #22373:
URL: https://github.com/apache/flink/pull/22373
## What is the purpose of the change
*After [FLINK-30378](https://issues.apache.org/jira/browse/FLINK-30378), we
can load sql connector data from external connector's own data file. However,
we
[
https://issues.apache.org/jira/browse/FLINK-31758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31758:
---
Component/s: Connectors / Common
> Some external connectors sql client jar has a wrong download url
[
https://issues.apache.org/jira/browse/FLINK-31758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31758:
---
Affects Version/s: 1.17.0
> Some external connectors sql client jar has a wrong download url in
[
https://issues.apache.org/jira/browse/FLINK-31758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31758:
---
Description: After FLINK-30378, we can load sql connector data from
external connector's own data
Weijie Guo created FLINK-31758:
--
Summary: Some external connectors sql client jar has a wrong
download url in document
Key: FLINK-31758
URL: https://issues.apache.org/jira/browse/FLINK-31758
Project:
clownxc commented on PR #22353:
URL: https://github.com/apache/flink/pull/22353#issuecomment-1501898847
Could you please take a look when you have time? thanks a lot ! @luoyuxia
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
nikolasten commented on PR #16:
URL:
https://github.com/apache/flink-connector-pulsar/pull/16#issuecomment-1501806550
Repo is this `https://repository.apache.org/content/repositories/snapshots`.
Tried using `4.0-snapshot` but i get this when upgrading from 1.16.0 version
[
https://issues.apache.org/jira/browse/FLINK-31165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706652#comment-17706652
]
lincoln lee edited comment on FLINK-31165 at 4/10/23 1:06 PM:
--
fixed in
lincoln-lil merged PR #22372:
URL: https://github.com/apache/flink/pull/22372
--
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-30264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xin Hao closed FLINK-30264.
---
Resolution: Fixed
> Set session job status to FAILED if already have retried max attempts
>
BoYiZhang commented on code in PR #22204:
URL: https://github.com/apache/flink/pull/22204#discussion_r1161678153
##
docs/content/docs/dev/table/sql/create.md:
##
@@ -316,7 +316,7 @@ CREATE TABLE MyTable (
`user_id` BIGINT,
`price` DOUBLE,
`quantity` DOUBLE,
- `cost`
[
https://issues.apache.org/jira/browse/FLINK-31713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-31713.
--
Fix Version/s: kubernetes-operator-1.5.0
Resolution: Fixed
8d7758c in main
> k8s
mbalassi merged PR #562:
URL: https://github.com/apache/flink-kubernetes-operator/pull/562
--
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:
jiangxin369 commented on PR #231:
URL: https://github.com/apache/flink-ml/pull/231#issuecomment-1501661163
@zhipeng93 Could you help review this PR?
--
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
jiangxin369 commented on PR #229:
URL: https://github.com/apache/flink-ml/pull/229#issuecomment-1501660711
@zhipeng93 Thanks for the review, I've updated the PR.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
jiangxin369 commented on code in PR #229:
URL: https://github.com/apache/flink-ml/pull/229#discussion_r1161619708
##
flink-ml-iteration/src/main/java/org/apache/flink/iteration/operator/OperatorUtils.java:
##
@@ -104,6 +107,33 @@ public static StreamConfig
[
https://issues.apache.org/jira/browse/FLINK-29672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17710104#comment-17710104
]
RocMarshal commented on FLINK-29672:
It looks like a duplicated Jira as
[
https://issues.apache.org/jira/browse/FLINK-31702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-31702.
---
Resolution: Fixed
> Integrate Opensearch connector docs into Flink docs v1.17/master
>
[
https://issues.apache.org/jira/browse/FLINK-31702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17710101#comment-17710101
]
Danny Cranmer commented on FLINK-31702:
---
Merged to master
dannycranmer merged PR #22366:
URL: https://github.com/apache/flink/pull/22366
--
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:
dannycranmer merged PR #22365:
URL: https://github.com/apache/flink/pull/22365
--
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-29334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17710097#comment-17710097
]
Wencong Liu commented on FLINK-29334:
-
[~mapohl] CI on GitHub has passed :), please take a look.
nikolasten commented on PR #16:
URL:
https://github.com/apache/flink-connector-pulsar/pull/16#issuecomment-1501605205
Is there a way to use latest snapshot version instead of waiting for a
release of this? In which repo is snapshot version published?
We are having production issues due
TanYuxin-tyx commented on PR #22330:
URL: https://github.com/apache/flink/pull/22330#issuecomment-1501547675
@xintongsong Thanks for reviewing the PR. I have updated the code according
to the comments.
Could you please review it again when having free time?
--
This is an
flinkbot commented on PR #22372:
URL: https://github.com/apache/flink/pull/22372#issuecomment-1501543466
## CI report:
* 3ef17fe2df8ba9fa4ffc92b7a37430c523f6b094 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
TanYuxin-tyx commented on PR #22330:
URL: https://github.com/apache/flink/pull/22330#issuecomment-1501539681
@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
LadyForest opened a new pull request, #22372:
URL: https://github.com/apache/flink/pull/22372
## What is the purpose of the change
This PR is cherry-picked from commit eeb446c0ed07c38175efdadf7e2e21702ff02b70
## Brief change log
Improve the error message in
TanYuxin-tyx commented on PR #22330:
URL: https://github.com/apache/flink/pull/22330#issuecomment-1501526262
@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
LadyForest commented on PR #22300:
URL: https://github.com/apache/flink/pull/22300#issuecomment-1501523853
> @LadyForest could you also backport this to 1.17 branch?
Sure. I'll do it right now.
--
This is an automated message from the Apache Git Service.
To respond to the message,
kingsathurthi commented on PR #552:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/552#issuecomment-1501508714
Sure will follow the contribution specifications. Where do I find your mail
id
--
This is an automated message from the Apache Git Service.
To respond to the
TanYuxin-tyx commented on code in PR #22330:
URL: https://github.com/apache/flink/pull/22330#discussion_r1161504837
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/tieredstore/upstream/common/StorageTier.java:
##
@@ -0,0 +1,59 @@
+/*
+ * Licensed to
TanYuxin-tyx commented on code in PR #22330:
URL: https://github.com/apache/flink/pull/22330#discussion_r1161500134
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/tieredstore/upstream/common/StorageTier.java:
##
@@ -0,0 +1,59 @@
+/*
+ * Licensed to
TanYuxin-tyx commented on code in PR #22330:
URL: https://github.com/apache/flink/pull/22330#discussion_r1161502932
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/tieredstore/upstream/common/StorageTier.java:
##
@@ -0,0 +1,59 @@
+/*
+ * Licensed to
TanYuxin-tyx commented on code in PR #22330:
URL: https://github.com/apache/flink/pull/22330#discussion_r1161502777
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/tieredstore/upstream/TieredStoreMode.java:
##
@@ -0,0 +1,44 @@
+/*
+ * Licensed to
TanYuxin-tyx commented on code in PR #22330:
URL: https://github.com/apache/flink/pull/22330#discussion_r1161502620
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/tieredstore/upstream/TieredStoreProducerImpl.java:
##
@@ -0,0 +1,82 @@
+/*
+ *
TanYuxin-tyx commented on code in PR #22330:
URL: https://github.com/apache/flink/pull/22330#discussion_r1161502026
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/tieredstore/upstream/TieredStoreResultPartition.java:
##
@@ -0,0 +1,282 @@
+/*
+ *
TanYuxin-tyx commented on code in PR #22330:
URL: https://github.com/apache/flink/pull/22330#discussion_r1161501622
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/tieredstore/upstream/TieredStoreConfiguration.java:
##
@@ -0,0 +1,52 @@
+/*
+ *
TanYuxin-tyx commented on code in PR #22330:
URL: https://github.com/apache/flink/pull/22330#discussion_r1161500942
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/tieredstore/upstream/common/MemorySegmentAndChannel.java:
##
@@ -0,0 +1,57 @@
+/*
+ *
TanYuxin-tyx commented on code in PR #22330:
URL: https://github.com/apache/flink/pull/22330#discussion_r1161500038
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/tieredstore/upstream/common/StorageTier.java:
##
@@ -0,0 +1,59 @@
+/*
+ * Licensed to
TanYuxin-tyx commented on code in PR #22330:
URL: https://github.com/apache/flink/pull/22330#discussion_r1161499623
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/tieredstore/upstream/common/StorageTier.java:
##
@@ -0,0 +1,59 @@
+/*
+ * Licensed to
TanYuxin-tyx commented on code in PR #22330:
URL: https://github.com/apache/flink/pull/22330#discussion_r1161498735
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/tieredstore/upstream/TieredStoreMode.java:
##
@@ -0,0 +1,44 @@
+/*
+ * Licensed to
TanYuxin-tyx commented on code in PR #22330:
URL: https://github.com/apache/flink/pull/22330#discussion_r1161498489
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/tieredstore/upstream/TieredStoreMode.java:
##
@@ -0,0 +1,44 @@
+/*
+ * Licensed to
TanYuxin-tyx commented on code in PR #22330:
URL: https://github.com/apache/flink/pull/22330#discussion_r1161498297
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/tieredstore/upstream/TieredStoreMode.java:
##
@@ -0,0 +1,44 @@
+/*
+ * Licensed to
TanYuxin-tyx commented on code in PR #22330:
URL: https://github.com/apache/flink/pull/22330#discussion_r1161498092
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/tieredstore/upstream/TieredStoreMode.java:
##
@@ -0,0 +1,44 @@
+/*
+ * Licensed to
TanYuxin-tyx commented on code in PR #22330:
URL: https://github.com/apache/flink/pull/22330#discussion_r1161497423
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/tieredstore/upstream/TieredStoreMode.java:
##
@@ -0,0 +1,44 @@
+/*
+ * Licensed to
yangjf2019 commented on PR #552:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/552#issuecomment-1501485976
> @yangjf2019 shall we connect and discuss, Please share your slack id or
find mine @satz
Or we can discuss it by email.
--
This is an automated message from
yangjf2019 commented on PR #552:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/552#issuecomment-1501482806
And, please refer to the [contribution specification
](https://flink.apache.org/how-to-contribute/overview/), please open a work
order on jira and associate the work
kingsathurthi commented on PR #552:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/552#issuecomment-1501478206
@yangjf2019 shall we connect and discuss, Please share your slack id or find
mine @satz
--
This is an automated message from the Apache Git Service.
To respond
yangjf2019 commented on PR #552:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/552#issuecomment-1501469247
There are still more compatibility-related issues:
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
[
https://issues.apache.org/jira/browse/FLINK-26265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-26265:
-
Fix Version/s: ml-2.1.0
(was: ml-2.2.0)
> Support Java algorithm in Python ML
1 - 100 of 101 matches
Mail list logo
