wuchong commented on PR #19845:
URL: https://github.com/apache/flink/pull/19845#issuecomment-1144506307
Besides, there are many cases are failed, could you take a look?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
wuchong commented on code in PR #19845:
URL: https://github.com/apache/flink/pull/19845#discussion_r886303859
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/calls/ScalarOperatorGens.scala:
##
@@ -1763,6 +1763,11 @@ object ScalarOperatorG
[
https://issues.apache.org/jira/browse/FLINK-27862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song reassigned FLINK-27862:
Assignee: Guo Weijie
> FLIP-235: Hybrid Shuffle Mode
> -
>
>
Zhipeng Zhang created FLINK-27877:
-
Summary: Improve performance of several feature engineering
algorithms
Key: FLINK-27877
URL: https://issues.apache.org/jira/browse/FLINK-27877
Project: Flink
dusukang commented on PR #19741:
URL: https://github.com/apache/flink/pull/19741#issuecomment-1144456068
Thanks for your update. I also mentioned this in the previous issue.
I have debugged this case, it will not happen when we use
mysql-connector-java-5.x. in `com.mysql.jdbc.DatabaseMet
[
https://issues.apache.org/jira/browse/FLINK-27791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17545267#comment-17545267
]
Zhu Zhu commented on FLINK-27791:
-
The slot allocation timeout happened because the reso
[
https://issues.apache.org/jira/browse/FLINK-27791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-27791.
---
Resolution: Not A Bug
> SlotCountExceedingParallelismTest tests failed with
> NoResourceAvailableException
[
https://issues.apache.org/jira/browse/FLINK-27170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved FLINK-27170.
--
Resolution: Fixed
> Add Transformer and Estimator for OnlineLogisticRegression
> -
[
https://issues.apache.org/jira/browse/FLINK-27791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-27791:
Attachment: error.log
> SlotCountExceedingParallelismTest tests failed with
> NoResourceAvailableExceptio
fsk119 commented on PR #19741:
URL: https://github.com/apache/flink/pull/19741#issuecomment-1144402454
Hi, all. After digging in, I find the SQL
```
SELECT TABLE_SCHEMA AS TABLE_CAT, NULL AS TABLE_SCHEM, TABLE_NAME,
COLUMN_NAME, SEQ_IN_INDEX AS KEY_SEQ, 'PRIMARY' AS PK_NAME FROM
I
[
https://issues.apache.org/jira/browse/FLINK-27721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17545256#comment-17545256
]
Jark Wu commented on FLINK-27721:
-
Regarding the domain, I think we can try to buy the d
[
https://issues.apache.org/jira/browse/FLINK-27721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17545253#comment-17545253
]
Jark Wu commented on FLINK-27721:
-
Can we use the server which hosts https://flink-packa
[
https://issues.apache.org/jira/browse/FLINK-24932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17545252#comment-17545252
]
Sebastian Mattheis commented on FLINK-24932:
[~maver1ck] This is currently o
wuchong commented on code in PR #543:
URL: https://github.com/apache/flink-web/pull/543#discussion_r887522252
##
community.md:
##
@@ -144,6 +144,18 @@ If you send us an email with a code snippet, make sure
that:
3. you keep formatting when pasting code in order to keep the cod
[
https://issues.apache.org/jira/browse/FLINK-27841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17545250#comment-17545250
]
Feifan Wang commented on FLINK-27841:
-
Thanks [~martijnvisser] , I will read the tic
xintongsong commented on PR #19853:
URL: https://github.com/apache/flink/pull/19853#issuecomment-1144376645
73a33ab5f25dd5ac7e8adb1521c092a8aedcc736
--
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 t
xintongsong closed pull request #19853: [1.15][FLINK-27848][runtime] Fix the
problem that ZooKeeperLeaderElectionDr…
URL: https://github.com/apache/flink/pull/19853
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/FLINK-27848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-27848.
Resolution: Fixed
Fixed in:
- release-1.15: 73a33ab5f25dd5ac7e8adb1521c092a8aedcc736
> ZooKeeperL
flinkbot commented on PR #19866:
URL: https://github.com/apache/flink/pull/19866#issuecomment-1144364960
## CI report:
* 217c2b1f0381ade8b427aecb01a490a921c945a3 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27876:
---
Labels: pull-request-available (was: )
> Error side is chosen in BatchPhysicalHashJoinRule
xuyangzhong opened a new pull request, #19866:
URL: https://github.com/apache/flink/pull/19866
## What is the purpose of the change
If leftSize or rightSize is unknown or equal in Semi/Anti Join, the right
side of the join should be chosen as build side.
## Brief change log
xuyang created FLINK-27876:
--
Summary: Error side is chosen in BatchPhysicalHashJoinRule when
the join is Semi or Anti
Key: FLINK-27876
URL: https://issues.apache.org/jira/browse/FLINK-27876
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-27875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27875:
---
Labels: pull-request-available (was: )
> Introduce TableScan and TableRead as an abstractio
tsreaper opened a new pull request, #145:
URL: https://github.com/apache/flink-table-store/pull/145
In this step we introduce `TableScan` and `TableRead` They are an
abstraction layer above `FileStoreScan` and `FileStoreRead` to provide
`RowData` reading.
--
This is an automated message
tsreaper closed pull request #142: [FLINK-27814] Add an abstraction layer for
connectors to read and write row data instead of key-values
URL: https://github.com/apache/flink-table-store/pull/142
--
This is an automated message from the Apache Git Service.
To respond to the message, please lo
Caizhi Weng created FLINK-27875:
---
Summary: Introduce TableScan and TableRead as an abstraction layer
above FileStore for reading RowData
Key: FLINK-27875
URL: https://issues.apache.org/jira/browse/FLINK-27875
zhipeng93 merged PR #83:
URL: https://github.com/apache/flink-ml/pull/83
--
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
reswqa commented on PR #19853:
URL: https://github.com/apache/flink/pull/19853#issuecomment-1144354722
@xintongsong @zentol In the current master branch, the code that caused the
bug still exists, but after FLINK-25806, it is not called anywhere other than
tests. I will open a new pull requ
deadwind4 commented on code in PR #19802:
URL: https://github.com/apache/flink/pull/19802#discussion_r887445060
##
docs/content/docs/dev/table/sqlClient.md:
##
@@ -174,7 +174,7 @@ Mode "embedded" (default) submits Flink jobs from the local
machine.
[
https://issues.apache.org/jira/browse/FLINK-27856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-27856:
--
Fix Version/s: (was: kubernetes-operator-1.1.0)
> Adding pod template without spec crashes job man
[
https://issues.apache.org/jira/browse/FLINK-27856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-27856:
--
Affects Version/s: (was: kubernetes-operator-0.1.0)
(was: kubernetes-ope
[
https://issues.apache.org/jira/browse/FLINK-27856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-27856:
--
Component/s: Deployment / Kubernetes
> Adding pod template without spec crashes job manager
>
[
https://issues.apache.org/jira/browse/FLINK-27856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17545240#comment-17545240
]
Yang Wang commented on FLINK-27856:
---
We will have a NPE in the JobManager if the {{spe
[
https://issues.apache.org/jira/browse/FLINK-27856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-27856:
--
Component/s: (was: Kubernetes Operator)
> Adding pod template without spec crashes job manager
> -
fsk119 commented on PR #19847:
URL: https://github.com/apache/flink/pull/19847#issuecomment-1144345509
I open a ticket about the unstable tests. The failed test is not related to
the current modification.
@flinkbot run azure
--
This is an automated message from the Apache Git Serv
Shengkai Fang created FLINK-27874:
-
Summary: KeyedStateCheckpointingITCase Timeout
Key: FLINK-27874
URL: https://issues.apache.org/jira/browse/FLINK-27874
Project: Flink
Issue Type: Bug
HuangXingBo commented on code in PR #19802:
URL: https://github.com/apache/flink/pull/19802#discussion_r887437213
##
docs/content/docs/dev/table/sqlClient.md:
##
@@ -174,7 +174,7 @@ Mode "embedded" (default) submits Flink jobs from the local
machine.
[
https://issues.apache.org/jira/browse/FLINK-14412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin closed FLINK-14412.
Resolution: Won't Do
> Rename ML Pipeline to MLPipeline
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-27084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-27084:
-
Labels: test-stability (was: )
> Perround mode recreating operator fails
>
[
https://issues.apache.org/jira/browse/FLINK-27084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-27084:
-
Environment: *strong text*Flink 1.14.0, Flink ML 2.0.0 (was: Flink 1.14.0,
Flink ML 2.0.0)
> Perround
[
https://issues.apache.org/jira/browse/FLINK-24838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin closed FLINK-24838.
Resolution: Won't Do
> Add BaseAlgoImpl class to support link() and linkFrom() (FlinkML)
> ---
[
https://issues.apache.org/jira/browse/FLINK-27102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved FLINK-27102.
--
Resolution: Duplicate
Duplicate of https://issues.apache.org/jira/browse/FLINK-27294
> Add BinaryClas
weibozhao commented on code in PR #83:
URL: https://github.com/apache/flink-ml/pull/83#discussion_r887422996
##
flink-ml-lib/src/main/java/org/apache/flink/ml/classification/logisticregression/OnlineLogisticRegression.java:
##
@@ -0,0 +1,434 @@
+/*
+ * Licensed to the Apache Sof
[
https://issues.apache.org/jira/browse/FLINK-27294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned FLINK-27294:
Assignee: weibo zhao
> Add Transformer for BinaryClassificationEvaluator
> --
[
https://issues.apache.org/jira/browse/FLINK-27294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-27294:
-
Summary: Add Transformer for BinaryClassificationEvaluator (was: Add
Transformer for EvalBinaryClass)
[
https://issues.apache.org/jira/browse/FLINK-27798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned FLINK-27798:
Assignee: Yunfeng Zhou
> Migrate Flink ML to Flink 1.15.0
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-27742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved FLINK-27742.
--
Resolution: Fixed
> Fix compatibility issues between Flink ML Stages
> ---
[
https://issues.apache.org/jira/browse/FLINK-27798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved FLINK-27798.
--
Resolution: Fixed
> Migrate Flink ML to Flink 1.15.0
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-26801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-26801:
-
Labels: test-stability (was: )
> LogisticRegressionTest.testGetModelData» Runtime Failed to fetch next
[
https://issues.apache.org/jira/browse/FLINK-27742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned FLINK-27742:
Assignee: Yunfeng Zhou
> Fix compatibility issues between Flink ML Stages
> -
weibozhao commented on code in PR #83:
URL: https://github.com/apache/flink-ml/pull/83#discussion_r887419273
##
flink-ml-core/src/main/java/org/apache/flink/ml/common/datastream/DataStreamUtils.java:
##
@@ -182,4 +193,63 @@ public void snapshotState(StateSnapshotContext context)
luoyuxia commented on PR #18958:
URL: https://github.com/apache/flink/pull/18958#issuecomment-1144316154
@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.
paul8263 commented on code in PR #19772:
URL: https://github.com/apache/flink/pull/19772#discussion_r887407734
##
flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java:
##
@@ -110,10 +110,6 @@ public class CliFrontend {
private final Options customComma
[
https://issues.apache.org/jira/browse/FLINK-27872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Salva updated FLINK-27872:
--
Description:
Currently,
[KafkaBuilder|https://github.com/apache/flink/blob/master/flink-connectors/flink-conn
afedulov commented on PR #19286:
URL: https://github.com/apache/flink/pull/19286#issuecomment-1143994493
@AHeise I am not sure that the proposed alternative approach makes things
much easier. I personally find the implementation of the projection
specification as an array of arrays somewhat
Yaroslav Tkachenko created FLINK-27873:
--
Summary: Primary key is lost after calling addColumns
Key: FLINK-27873
URL: https://issues.apache.org/jira/browse/FLINK-27873
Project: Flink
Issu
[
https://issues.apache.org/jira/browse/FLINK-27842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge updated FLINK-27842:
Description:
Currently ndv, which stands for "number of distinct values", is used in
ColumnStats. First o
[
https://issues.apache.org/jira/browse/FLINK-27872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Salva updated FLINK-27872:
--
Description:
Currently,
[KafkaBuilder|https://github.com/apache/flink/blob/master/flink-connectors/flink-conn
[
https://issues.apache.org/jira/browse/FLINK-27872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Salva updated FLINK-27872:
--
Description:
Currently,
[KafkaBuilder|https://github.com/apache/flink/blob/master/flink-connectors/flink-conn
[
https://issues.apache.org/jira/browse/FLINK-27872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Salva updated FLINK-27872:
--
Description:
Currently,
[KafkaBuilder|https://github.com/apache/flink/blob/master/flink-connectors/flink-conn
[
https://issues.apache.org/jira/browse/FLINK-27872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Salva updated FLINK-27872:
--
Description:
Currently,
[KafkaBuilder|https://github.com/apache/flink/blob/master/flink-connectors/flink-conn
[
https://issues.apache.org/jira/browse/FLINK-27872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Salva updated FLINK-27872:
--
Description:
Currently,
[KafkaBuilder|https://github.com/apache/flink/blob/master/flink-connectors/flink-conn
[
https://issues.apache.org/jira/browse/FLINK-27872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Salva updated FLINK-27872:
--
Description:
Currently,
[KafkaBuilder|https://github.com/apache/flink/blob/master/flink-connectors/flink-conn
[
https://issues.apache.org/jira/browse/FLINK-27872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Salva updated FLINK-27872:
--
Description:
Currently,
[KafkaBuilder|https://github.com/apache/flink/blob/master/flink-connectors/flink-conn
[
https://issues.apache.org/jira/browse/FLINK-27872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Salva updated FLINK-27872:
--
Description:
Currently,
[KafkaBuilder|https://github.com/apache/flink/blob/master/flink-connectors/flink-conn
[
https://issues.apache.org/jira/browse/FLINK-27872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Salva updated FLINK-27872:
--
Description:
Currently,
[KafkaBuilder|https://github.com/apache/flink/blob/master/flink-connectors/flink-conn
[
https://issues.apache.org/jira/browse/FLINK-27872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Salva updated FLINK-27872:
--
Description:
Currently,
[KafkaBuilder|https://github.com/apache/flink/blob/master/flink-connectors/flink-conn
[
https://issues.apache.org/jira/browse/FLINK-27872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Salva updated FLINK-27872:
--
Description:
Currently,
[KafkaBuilder|[https://github.com/apache/flink/blob/master/flink-connectors/flink-con
[
https://issues.apache.org/jira/browse/FLINK-27872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Salva updated FLINK-27872:
--
Description:
[KafkaBuilder|[https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-kafka
[
https://issues.apache.org/jira/browse/FLINK-27872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Salva updated FLINK-27872:
--
Description:
The
[KafkaBuilder|[https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-
Salva created FLINK-27872:
-
Summary: Allow KafkaBuilder to set arbitrary subscribers
Key: FLINK-27872
URL: https://issues.apache.org/jira/browse/FLINK-27872
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-24960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17544992#comment-17544992
]
Niklas Semmler commented on FLINK-24960:
After a discussion with [~mapohl], a di
[
https://issues.apache.org/jira/browse/FLINK-27871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matyas Orhidi updated FLINK-27871:
--
Description:
The Operator does not detect when a configuration entry is removed from the
conf
[
https://issues.apache.org/jira/browse/FLINK-27871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matyas Orhidi updated FLINK-27871:
--
Description:
The Operator does not detect when a configuration entry is removed from the
conf
[
https://issues.apache.org/jira/browse/FLINK-27871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matyas Orhidi updated FLINK-27871:
--
Summary: Configuration change is undedected on config removal (was:
Dynamic configuration cha
Matyas Orhidi created FLINK-27871:
-
Summary: Dynamic configuration change is undedected on config
removal
Key: FLINK-27871
URL: https://issues.apache.org/jira/browse/FLINK-27871
Project: Flink
rxp90 commented on code in PR #19861:
URL: https://github.com/apache/flink/pull/19861#discussion_r886935086
##
docs/content/docs/ops/state/state_backends.md:
##
@@ -55,8 +55,7 @@ that store the values, triggers, etc.
The HashMapStateBackend is encouraged for:
- - Jobs with
Myasuka commented on code in PR #19789:
URL: https://github.com/apache/flink/pull/19789#discussion_r886914800
##
flink-runtime-web/web-dashboard/.eslintrc.js:
##
@@ -126,7 +126,9 @@ module.exports = {
{
files: ['*.html'],
extends: ['plugin:@angular-eslint/temp
Myasuka commented on code in PR #19861:
URL: https://github.com/apache/flink/pull/19861#discussion_r886891675
##
docs/content/docs/ops/state/state_backends.md:
##
@@ -55,8 +55,7 @@ that store the values, triggers, etc.
The HashMapStateBackend is encouraged for:
- - Jobs wi
[
https://issues.apache.org/jira/browse/FLINK-24932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17544937#comment-17544937
]
Yun Tang commented on FLINK-24932:
--
[~maver1ck] I think you can refer to
https://githu
[
https://issues.apache.org/jira/browse/FLINK-27841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17544932#comment-17544932
]
Yun Tang commented on FLINK-27841:
--
[~Feifan Wang] The cache miss should be related wit
[
https://issues.apache.org/jira/browse/FLINK-26993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Kalashnikov updated FLINK-26993:
--
Affects Version/s: 1.15.0
> CheckpointCoordinatorTest#testMinCheckpointPause
> ---
flinkbot commented on PR #19865:
URL: https://github.com/apache/flink/pull/19865#issuecomment-1143675821
## CI report:
* cdc7a3708a367fd4b67ddba9a725a306287d09a1 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Kalashnikov closed FLINK-27216.
-
Resolution: Duplicate
> CheckpointCoordinatorTest.testMinCheckpointPause failed on azure
[
https://issues.apache.org/jira/browse/FLINK-26993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17544930#comment-17544930
]
Anton Kalashnikov commented on FLINK-26993:
---
[~chesnay]. The release-1.15 is a
akalash opened a new pull request, #19865:
URL: https://github.com/apache/flink/pull/19865
## What is the purpose of the change
Backport to release-1.15 of https://github.com/apache/flink/pull/19356
## Does this pull request potentially affect one of the following parts:
[
https://issues.apache.org/jira/browse/FLINK-27579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17544908#comment-17544908
]
Liu commented on FLINK-27579:
-
[~wangyang0918] Can you review the code? Thanks.
> The param
afedulov commented on PR #19807:
URL: https://github.com/apache/flink/pull/19807#issuecomment-1143605803
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 comment.
To unsubscribe
Myracle commented on code in PR #19772:
URL: https://github.com/apache/flink/pull/19772#discussion_r886799160
##
flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java:
##
@@ -110,10 +110,6 @@ public class CliFrontend {
private final Options customComman
afedulov commented on PR #19808:
URL: https://github.com/apache/flink/pull/19808#issuecomment-1143604997
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 comment.
To unsubscribe
godfreyhe commented on code in PR #18408:
URL: https://github.com/apache/flink/pull/18408#discussion_r886754006
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecMatch.java:
##
@@ -0,0 +1,440 @@
+/*
+ * Licensed to t
JingGe commented on PR #19286:
URL: https://github.com/apache/flink/pull/19286#issuecomment-1143571784
@godfreyhe would you like to review this PR? Thanks!
--
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
flinkbot commented on PR #19864:
URL: https://github.com/apache/flink/pull/19864#issuecomment-1143570898
## CI report:
* 46bef9b31b255cf482eab85e14639613de4f6681 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo closed FLINK-27797.
Fix Version/s: 1.15.1
Resolution: Fixed
Merged into master via 586715f23ef49939ab74e4736c58
[
https://issues.apache.org/jira/browse/FLINK-27855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sushant resolved FLINK-27855.
-
Resolution: Fixed
> Job Manager fails to recover with S3 storage and HA enabled
> --
[
https://issues.apache.org/jira/browse/FLINK-27855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17544887#comment-17544887
]
Sushant commented on FLINK-27855:
-
Recovery files weren't deleted during creation/deleti
[
https://issues.apache.org/jira/browse/FLINK-27162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27162:
---
Labels: pull-request-available test-stability (was: test-stability)
> RescaleCheckpointManu
akalash opened a new pull request, #19864:
URL: https://github.com/apache/flink/pull/19864
## What is the purpose of the change
Checkpoint trigger always from one thread
## Brief change log
- *Trigger non-periodic checkpoint in 'timer' thread *
## Ver
HuangXingBo closed pull request #19834: [FLINK-27797][API/Python]
PythonTableUtils.getCollectionInputFormat c…
URL: https://github.com/apache/flink/pull/19834
--
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
[
https://issues.apache.org/jira/browse/FLINK-27786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17544886#comment-17544886
]
Alexander Preuss commented on FLINK-27786:
--
Following is a list of classes that
1 - 100 of 203 matches
Mail list logo
