[
https://issues.apache.org/jira/browse/FLINK-30360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17649817#comment-17649817
]
Martijn Visser commented on FLINK-30360:
[~wjc920] I don't know HBase that well,
[
https://issues.apache.org/jira/browse/FLINK-28185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reopened FLINK-28185:
Re-opening so a backport to 1.16 can be added
> "Invalid negative offset" when using OffsetsI
MartijnVisser commented on PR #4:
URL:
https://github.com/apache/flink-connector-rabbitmq/pull/4#issuecomment-1359531946
@smulikHakipod Please follow
https://flink.apache.org/contributing/how-to-contribute.html next time,
specifically for your commit message layout.
--
This is an autom
boring-cyborg[bot] commented on PR #4:
URL:
https://github.com/apache/flink-connector-rabbitmq/pull/4#issuecomment-1359532519
Awesome work, congrats on your first merged pull request!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
MartijnVisser merged PR #4:
URL: https://github.com/apache/flink-connector-rabbitmq/pull/4
--
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-unsubs
[
https://issues.apache.org/jira/browse/FLINK-30417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-30417.
--
Fix Version/s: rabbitmq-3.0.1
Resolution: Fixed
Fixed in main: 967f713257bf7e933c04808c
MartijnVisser merged PR #21495:
URL: https://github.com/apache/flink/pull/21495
--
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
MartijnVisser commented on PR #21254:
URL: https://github.com/apache/flink/pull/21254#issuecomment-1359547294
> Is there a desire within the Flink team to ensure that PyFlink achieves
similar uptake and robustness as PySpark?
I think any open source community strives to improve their
GOODBOY008 commented on code in PR #21481:
URL: https://github.com/apache/flink/pull/21481#discussion_r1053433401
##
docs/content.zh/docs/connectors/table/jdbc.md:
##
@@ -672,12 +672,6 @@ Flink 支持连接到多个使用方言（dialect）的数据库，如 MySQL、O
DECIMAL(20, 0)
-
- B
[
https://issues.apache.org/jira/browse/FLINK-27640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17649828#comment-17649828
]
Martijn Visser commented on FLINK-27640:
[~luoyuxia] Do you know if this package
MartijnVisser commented on code in PR #21481:
URL: https://github.com/apache/flink/pull/21481#discussion_r1053436057
##
docs/content.zh/docs/connectors/table/jdbc.md:
##
@@ -672,12 +672,6 @@ Flink 支持连接到多个使用方言（dialect）的数据库，如 MySQL、O
DECIMAL(20, 0)
-
-
GOODBOY008 commented on code in PR #21481:
URL: https://github.com/apache/flink/pull/21481#discussion_r1053441739
##
docs/content.zh/docs/connectors/table/jdbc.md:
##
@@ -672,12 +672,6 @@ Flink 支持连接到多个使用方言（dialect）的数据库，如 MySQL、O
DECIMAL(20, 0)
-
- B
mxm opened a new pull request, #492:
URL: https://github.com/apache/flink-kubernetes-operator/pull/492
We were tracking the stabilization period from the job start time which can
greatly vary from the time the job goes into RUNNING state. This can result in
no stabilization period at all le
wanglijie95 commented on PR #2:
URL:
https://github.com/apache/flink-connector-jdbc/pull/2#issuecomment-1359578023
@MartijnVisser @eskabetxe Yes, I think it(expose ExecutionConfig or
isObjectReuseEnabled) is a blocker to the migration. The jdbc sink needs to
decide whether to buffer the co
mxm commented on PR #492:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/492#issuecomment-1359586067
Note: I need to tag the commit with the correct JIRA on merge.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHu
[
https://issues.apache.org/jira/browse/FLINK-30463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30463:
---
Labels: pull-request-available (was: )
> Stabilization period starts before job goes into R
reswqa commented on PR #50:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/50#issuecomment-1359591588
@MartijnVisser Thanks for the review, I have relocation the dependency of
`com.carrotsearch.hppc` and rebase this commit . It seems that first-time
contributors need a m
[
https://issues.apache.org/jira/browse/FLINK-30455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-30455:
---
Component/s: API / Core
> Avoid "cleaning" of java.lang.String in ClosureCleaner
> -
rmetzger commented on PR #21532:
URL: https://github.com/apache/flink/pull/21532#issuecomment-1359609287
Thanks a lot for opening a PR. It would be nice to have a Unit test for this
change in the `ClosureCleanerTest` which fails on Java 17 (because of the
reflective access), but succeeds af
eskabetxe opened a new pull request, #12:
URL: https://github.com/apache/flink-connector-jdbc/pull/12
All tests migrated to Junit5
--
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 com
[
https://issues.apache.org/jira/browse/FLINK-27940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27940:
---
Labels: pull-request-available starter (was: starter)
> [JUnit5 Migration] Module: flink-co
rmetzger commented on PR #21532:
URL: https://github.com/apache/flink/pull/21532#issuecomment-1359614383
The commit message doesn't adhere to Flink's commit message pattern.
It needs to be
`[FLINK-30455] Excluding java.lang.String and primitive types ...` (e.g.
Jira Id in brackets)
-
eskabetxe commented on code in PR #12:
URL:
https://github.com/apache/flink-connector-jdbc/pull/12#discussion_r1053484871
##
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/JdbcXaSinkMigrationTest.java:
##
@@ -77,7 +79,8 @@ public JdbcXaSinkMigrationTest(F
rmetzger commented on code in PR #21531:
URL: https://github.com/apache/flink/pull/21531#discussion_r1053490585
##
flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/FileSystemJobResultStore.java:
##
@@ -207,7 +207,7 @@ public Set getDirtyResultsInternal() thr
gunnarmorling commented on code in PR #21531:
URL: https://github.com/apache/flink/pull/21531#discussion_r1053500731
##
flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/FileSystemJobResultStore.java:
##
@@ -207,7 +207,7 @@ public Set getDirtyResultsInternal(
gyfora commented on code in PR #492:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/492#discussion_r1053501498
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/ScalingExecutor.java:
##
@@ -121,13 +122,22 @@ public boolean
[
https://issues.apache.org/jira/browse/FLINK-30456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Chang updated FLINK-30456:
--
Attachment: image-2022-12-20-08-21-02-597.png
> OLM Bundle Description Version Problems
>
[
https://issues.apache.org/jira/browse/FLINK-30456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17649882#comment-17649882
]
Ted Chang commented on FLINK-30456:
---
Hi Jim, could you also fix the LINKS showing n/a
gyfora commented on code in PR #491:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/491#discussion_r1053512772
##
tools/olm/docker-entry.sh:
##
@@ -102,6 +96,10 @@ generate_olm_bundle() {
yq ea -i ".spec.replaces = \"${PACKAGE_NAME}.v${PREVIOUS_BUNDLE_VERSION}
gyfora merged PR #490:
URL: https://github.com/apache/flink-kubernetes-operator/pull/490
--
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
[
https://issues.apache.org/jira/browse/FLINK-30437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-30437:
---
Fix Version/s: kubernetes-operator-1.3.1
> State incompatibility issue might cause state loss
>
[
https://issues.apache.org/jira/browse/FLINK-30437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17649890#comment-17649890
]
Gyula Fora commented on FLINK-30437:
merged to release-1.3 4e583a0faa0991c61b37ecd9b
[
https://issues.apache.org/jira/browse/FLINK-30408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-30408:
---
Fix Version/s: kubernetes-operator-1.3.1
> Add unit test for HA metadata check logic
> -
[
https://issues.apache.org/jira/browse/FLINK-30408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17649891#comment-17649891
]
Gyula Fora commented on FLINK-30408:
merged to release-1.3 4e583a0faa0991c61b37ecd9b
[
https://issues.apache.org/jira/browse/FLINK-30244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-30244.
--
Resolution: Abandoned
> When task using udf/udtf with jni, on k8s session the old TM will shut down
>
Gyula Fora created FLINK-30466:
--
Summary: Detect ineffective scaling operations
Key: FLINK-30466
URL: https://issues.apache.org/jira/browse/FLINK-30466
Project: Flink
Issue Type: New Feature
eskabetxe commented on code in PR #8:
URL:
https://github.com/apache/flink-connector-jdbc/pull/8#discussion_r1053513698
##
flink-connector-jdbc/pom.xml:
##
@@ -195,6 +203,14 @@ under the License.
test
+
+
hlteoh37 opened a new pull request, #21538:
URL: https://github.com/apache/flink/pull/21538
…eratorCoordinator
## What is the purpose of the change
* Improve the stability of the JobMaster when OperatorCoordinator throws an
Exception upon start(). Instead of restarting the entire J
[
https://issues.apache.org/jira/browse/FLINK-24386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-24386:
---
Labels: pull-request-available (was: )
> JobMaster should guard against exceptions from Ope
flinkbot commented on PR #21538:
URL: https://github.com/apache/flink/pull/21538#issuecomment-1359782359
## CI report:
* 0f68db2a53d68bb850f6cd0ac285075e144f38ab UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17649882#comment-17649882
]
Ted Chang edited comment on FLINK-30456 at 12/20/22 5:36 PM:
-
mbalassi commented on PR #21511:
URL: https://github.com/apache/flink/pull/21511#issuecomment-1359896458
Will merge this later today.
--
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
mas-chen opened a new pull request, #21539:
URL: https://github.com/apache/flink/pull/21539
…roup
## What is the purpose of the change
The addGroup returns new a metric group if the metric group is already
closed, so that implementations can recreate metrics.
##
[
https://issues.apache.org/jira/browse/FLINK-30409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30409:
---
Labels: pull-request-available (was: )
> Support reopening closed metric groups
> -
flinkbot commented on PR #21539:
URL: https://github.com/apache/flink/pull/21539#issuecomment-1359996492
## CI report:
* c8b29b3dac1540467927bb6ff50e43e50ec44df1 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Ge commented on code in PR #443:
URL: https://github.com/apache/flink-table-store/pull/443#discussion_r1053657989
##
docs/content/docs/features/table-types.md:
##
@@ -0,0 +1,142 @@
+---
+title: "Table Types"
+weight: 1
+type: docs
+aliases:
+- /features/table-types.html
+---
Ge commented on code in PR #443:
URL: https://github.com/apache/flink-table-store/pull/443#discussion_r1053671570
##
docs/content/docs/sql-api/writing-tables.md:
##
@@ -0,0 +1,79 @@
+---
+title: "Writing Tables"
+weight: 4
+type: docs
+aliases:
+- /sql-api/writing-tables.htm
mbalassi merged PR #21511:
URL: https://github.com/apache/flink/pull/21511
--
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.apac
jbusche commented on code in PR #491:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/491#discussion_r1053777424
##
tools/olm/docker-entry.sh:
##
@@ -102,6 +96,10 @@ generate_olm_bundle() {
yq ea -i ".spec.replaces = \"${PACKAGE_NAME}.v${PREVIOUS_BUNDLE_VERSION
jbusche commented on PR #491:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/491#issuecomment-1360368627
OK, let me test this one on my OpenShift cluster, will post results here
--
This is an automated message from the Apache Git Service.
To respond to the message, plea
Ge commented on code in PR #443:
URL: https://github.com/apache/flink-table-store/pull/443#discussion_r1053789276
##
docs/content/docs/features/table-types.md:
##
@@ -0,0 +1,142 @@
+---
+title: "Table Types"
+weight: 1
+type: docs
+aliases:
+- /features/table-types.html
+---
jbusche commented on PR #491:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/491#issuecomment-1360379235
It's looking good - it added the links as expected, and is matching on the
versions nicely.
Deployed well:
```
oc get pods
NAME
[
https://issues.apache.org/jira/browse/FLINK-30409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17650008#comment-17650008
]
Mason Chen commented on FLINK-30409:
[~xtsong] Thanks for assigning me the ticket. T
tedhtchang commented on code in PR #491:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/491#discussion_r1053794906
##
tools/olm/docker-entry.sh:
##
@@ -102,6 +96,10 @@ generate_olm_bundle() {
yq ea -i ".spec.replaces = \"${PACKAGE_NAME}.v${PREVIOUS_BUNDLE_VERS
morhidi commented on PR #487:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/487#issuecomment-1360392616
@gyfora how do you think we should fix this?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
morhidi commented on PR #491:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/491#issuecomment-1360393927
+1 LGTM
--
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 comme
tedhtchang commented on PR #491:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/491#issuecomment-1360404403
Tested on Kubernetes. LGTM
--
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
morhidi commented on code in PR #489:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/489#discussion_r1053822550
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/reconciler/deployment/ApplicationReconcilerUpgradeModeTest.java:
##
@@
vacaly commented on code in PR #192:
URL: https://github.com/apache/flink-ml/pull/192#discussion_r1053881373
##
flink-ml-lib/src/main/java/org/apache/flink/ml/recommendation/Swing.java:
##
@@ -0,0 +1,407 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * o
vacaly commented on code in PR #192:
URL: https://github.com/apache/flink-ml/pull/192#discussion_r1053881499
##
flink-ml-lib/src/main/java/org/apache/flink/ml/recommendation/Swing.java:
##
@@ -0,0 +1,407 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * o
vacaly commented on code in PR #192:
URL: https://github.com/apache/flink-ml/pull/192#discussion_r1053890313
##
flink-ml-lib/src/main/java/org/apache/flink/ml/recommendation/Swing.java:
##
@@ -0,0 +1,407 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * o
[
https://issues.apache.org/jira/browse/FLINK-30369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yunhong Zheng closed FLINK-30369.
-
Resolution: Not A Bug
> Fix FlinkFilterJoinRule push wrong filters to another side while join ty
Yunhong Zheng created FLINK-30467:
-
Summary: Improve the accuracy of estimating the row count of
LocalHashAgg to make more two-phase HashAgg operators effective
Key: FLINK-30467
URL: https://issues.apache.org/jir
vacaly commented on code in PR #192:
URL: https://github.com/apache/flink-ml/pull/192#discussion_r1053893147
##
flink-ml-lib/src/main/java/org/apache/flink/ml/recommendation/SwingModel.java:
##
@@ -0,0 +1,251 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
dianfu commented on PR #21254:
URL: https://github.com/apache/flink/pull/21254#issuecomment-1360669458
Sorry for late response. I have missed this PR. The PR LGTM and I guess it
should be caused by the bump of fastavro version which is introduced in
https://issues.apache.org/jira/browse/FLI
[
https://issues.apache.org/jira/browse/FLINK-27640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17650050#comment-17650050
]
luoyuxia commented on FLINK-27640:
--
I think it can safely be excluded since
org.pentah
dianfu closed pull request #21254: Update docker.md
URL: https://github.com/apache/flink/pull/21254
--
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: issu
lincoln-lil commented on code in PR #21219:
URL: https://github.com/apache/flink/pull/21219#discussion_r1053906856
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/EventTimeTemporalJoinRewriteRule.java:
##
@@ -0,0 +1,477 @@
+/*
+
wanglijie95 commented on PR #12:
URL:
https://github.com/apache/flink-connector-jdbc/pull/12#issuecomment-1360686642
@eskabetxe Please feel free to take it. I will assign it to you. And I can
help to review this pr :)
--
This is an automated message from the Apache Git Service.
To respon
[
https://issues.apache.org/jira/browse/FLINK-27940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang reassigned FLINK-27940:
--
Assignee: João Boto (was: Lijie Wang)
> [JUnit5 Migration] Module: flink-connector-jdbc
> --
xintongsong commented on code in PR #21447:
URL: https://github.com/apache/flink/pull/21447#discussion_r1053911284
##
flink-runtime/src/main/java/org/apache/flink/runtime/messages/ThreadInfoSample.java:
##
@@ -32,25 +36,33 @@
*/
public class ThreadInfoSample implements Serial
tweise commented on code in PR #489:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/489#discussion_r1053912124
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java:
##
@@ -116,9
vacaly commented on code in PR #192:
URL: https://github.com/apache/flink-ml/pull/192#discussion_r1053913128
##
flink-ml-lib/src/main/java/org/apache/flink/ml/recommendation/Swing.java:
##
@@ -0,0 +1,407 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * o
1996fanrui commented on code in PR #21447:
URL: https://github.com/apache/flink/pull/21447#discussion_r1053913594
##
flink-runtime/src/main/java/org/apache/flink/runtime/messages/ThreadInfoSample.java:
##
@@ -32,25 +36,33 @@
*/
public class ThreadInfoSample implements Seriali
xintongsong commented on code in PR #21347:
URL: https://github.com/apache/flink/pull/21347#discussion_r1053913714
##
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobClientHeartbeatHandler.java:
##
@@ -0,0 +1,66 @@
+/*
+ * Licensed to the Apache Software
fsk119 commented on PR #21187:
URL: https://github.com/apache/flink/pull/21187#issuecomment-1360718894
@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.
T
xintongsong commented on code in PR #21347:
URL: https://github.com/apache/flink/pull/21347#discussion_r1053915899
##
flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java:
##
@@ -1344,6 +1344,13 @@ public CompletableFuture>
listCompletedClusterDatas
chucheng92 commented on PR #21464:
URL: https://github.com/apache/flink/pull/21464#issuecomment-1360734949
@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-27640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17650050#comment-17650050
]
luoyuxia edited comment on FLINK-27640 at 12/21/22 2:41 AM:
tsreaper commented on code in PR #443:
URL: https://github.com/apache/flink-table-store/pull/443#discussion_r1053932615
##
docs/content/docs/features/table-types.md:
##
@@ -0,0 +1,142 @@
+---
+title: "Table Types"
+weight: 1
+type: docs
+aliases:
+- /features/table-types.html
+-
tsreaper commented on code in PR #443:
URL: https://github.com/apache/flink-table-store/pull/443#discussion_r1053934087
##
docs/content/docs/maintenance-actions/write-performance.md:
##
@@ -0,0 +1,118 @@
+---
+title: "Write Performance"
+weight: 1
+type: docs
+aliases:
+- /maint
tsreaper commented on code in PR #443:
URL: https://github.com/apache/flink-table-store/pull/443#discussion_r1053934427
##
docs/content/docs/sql-api/writing-tables.md:
##
@@ -0,0 +1,79 @@
+---
+title: "Writing Tables"
+weight: 4
+type: docs
+aliases:
+- /sql-api/writing-tables.h
[ https://issues.apache.org/jira/browse/FLINK-15325 ]
Zhu Zhu deleted comment on FLINK-15325:
-
was (Author: flink-jira-bot):
I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help
the community manage its development. I see
[ https://issues.apache.org/jira/browse/FLINK-15325 ]
Zhu Zhu deleted comment on FLINK-15325:
-
was (Author: flink-jira-bot):
This major issue is unassigned and itself and all of its Sub-Tasks have not
been updated for 30 days. So, it has been label
[ https://issues.apache.org/jira/browse/FLINK-15325 ]
Zhu Zhu deleted comment on FLINK-15325:
-
was (Author: flink-jira-bot):
This issue was labeled "stale-minor" 7 days ago and has not received any
updates so it is being deprioritized. If this tick
[ https://issues.apache.org/jira/browse/FLINK-15325 ]
Zhu Zhu deleted comment on FLINK-15325:
-
was (Author: flink-jira-bot):
This issue was labeled "stale-major" 7 ago and has not received any updates so
it is being deprioritized. If this ticket is
tsreaper commented on code in PR #443:
URL: https://github.com/apache/flink-table-store/pull/443#discussion_r1053934969
##
docs/content/docs/sql-api/writing-tables.md:
##
@@ -0,0 +1,79 @@
+---
+title: "Writing Tables"
+weight: 4
+type: docs
+aliases:
+- /sql-api/writing-tables.h
tsreaper commented on code in PR #443:
URL: https://github.com/apache/flink-table-store/pull/443#discussion_r1053935750
##
docs/content/docs/features/table-types.md:
##
@@ -0,0 +1,142 @@
+---
+title: "Table Types"
+weight: 1
+type: docs
+aliases:
+- /features/table-types.html
+-
zhipeng93 commented on code in PR #191:
URL: https://github.com/apache/flink-ml/pull/191#discussion_r1053903196
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/lsh/LSH.java:
##
@@ -0,0 +1,99 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or m
fsk119 merged PR #21433:
URL: https://github.com/apache/flink/pull/21433
--
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
Fanoid commented on code in PR #192:
URL: https://github.com/apache/flink-ml/pull/192#discussion_r1053957894
##
flink-ml-lib/src/main/java/org/apache/flink/ml/recommendation/Swing.java:
##
@@ -0,0 +1,407 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * o
Fanoid commented on code in PR #192:
URL: https://github.com/apache/flink-ml/pull/192#discussion_r1053958500
##
flink-ml-lib/src/main/java/org/apache/flink/ml/recommendation/Swing.java:
##
@@ -0,0 +1,407 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * o
Fanoid commented on code in PR #192:
URL: https://github.com/apache/flink-ml/pull/192#discussion_r1053958500
##
flink-ml-lib/src/main/java/org/apache/flink/ml/recommendation/Swing.java:
##
@@ -0,0 +1,407 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * o
xintongsong commented on code in PR #21496:
URL: https://github.com/apache/flink/pull/21496#discussion_r1053928976
##
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/active/ActiveResourceManager.java:
##
@@ -206,15 +220,29 @@ protected Optional
getWorkerNod
vacaly commented on code in PR #192:
URL: https://github.com/apache/flink-ml/pull/192#discussion_r1053974995
##
flink-ml-lib/src/main/java/org/apache/flink/ml/recommendation/SwingModelData.java:
##
@@ -0,0 +1,106 @@
+package org.apache.flink.ml.recommendation;
+
+import org.apac
gyfora commented on code in PR #489:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/489#discussion_r1053989089
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/reconciler/deployment/ApplicationReconcilerUpgradeModeTest.java:
##
@@ -
Rui Fan created FLINK-30468:
---
Summary: The SortOrder of BusyRatio should be descend by default
Key: FLINK-30468
URL: https://issues.apache.org/jira/browse/FLINK-30468
Project: Flink
Issue Type: Bug
1996fanrui opened a new pull request, #21540:
URL: https://github.com/apache/flink/pull/21540
## What is the purpose of the change
Currently, the sort order is ascend by default, it should be descend.
The most busy subtask should be displayed on top.
## Brief change log
[
https://issues.apache.org/jira/browse/FLINK-30468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30468:
---
Labels: pull-request-available (was: )
> The SortOrder of BusyRatio should be descend by de
1996fanrui commented on PR #21540:
URL: https://github.com/apache/flink/pull/21540#issuecomment-1360874693
After this PR:
1. The SortOrder of BusyRatio will be the desc by default.
https://user-images.githubusercontent.com/38427477/208828005-d902a419-a197-4e55-be00-0b086cf89436
101 - 200 of 225 matches
Mail list logo
