SteNicholas commented on code in PR #584:
URL: https://github.com/apache/flink-table-store/pull/584#discussion_r1136549744
##
flink-table-store-flink/flink-table-store-flink-common/src/main/java/org/apache/flink/table/store/connector/FlinkConnectorOptions.java:
##
@@ -82,6
chucheng92 commented on PR #21904:
URL: https://github.com/apache/flink/pull/21904#issuecomment-1469368342
@leonardBang Hi, Xu, Can u help me to review it?
--
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
SteNicholas commented on code in PR #584:
URL: https://github.com/apache/flink-table-store/pull/584#discussion_r1136549744
##
flink-table-store-flink/flink-table-store-flink-common/src/main/java/org/apache/flink/table/store/connector/FlinkConnectorOptions.java:
##
@@ -82,6
SteNicholas commented on code in PR #584:
URL: https://github.com/apache/flink-table-store/pull/584#discussion_r1136549744
##
flink-table-store-flink/flink-table-store-flink-common/src/main/java/org/apache/flink/table/store/connector/FlinkConnectorOptions.java:
##
@@ -82,6
chucheng92 commented on PR #21442:
URL: https://github.com/apache/flink/pull/21442#issuecomment-1469359601
> hi. @MartijnVisser i have updated the pr. And i searched the source code
didn't find any other occurs using `org.apache.commons.collections`. PTAL.
thanks.
hi. @MartijnVisser
chucheng92 commented on PR #22091:
URL: https://github.com/apache/flink/pull/22091#issuecomment-1469355704
@PatrickRen hi, qingsheng. PTAL.
--
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
[
https://issues.apache.org/jira/browse/FLINK-31457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17700503#comment-17700503
]
Junrui Li commented on FLINK-31457:
---
[~a.pilipenko] I'm not sure what is the scenario where
[
https://issues.apache.org/jira/browse/FLINK-31368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17700500#comment-17700500
]
Jark Wu edited comment on FLINK-31368 at 3/15/23 4:26 AM:
--
[~luoyuxia], you are
[
https://issues.apache.org/jira/browse/FLINK-31368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17700500#comment-17700500
]
Jark Wu commented on FLINK-31368:
-
[~luoyuxia], you are right. I think we can create another issue for
lindong28 commented on code in PR #219:
URL: https://github.com/apache/flink-ml/pull/219#discussion_r1136518610
##
flink-ml-servable-lib/src/test/java/org/apache/flink/ml/classification/logisticregression/LogisticRegressionModelServableTest.java:
##
@@ -0,0 +1,153 @@
+/*
+ *
lindong28 commented on code in PR #219:
URL: https://github.com/apache/flink-ml/pull/219#discussion_r1136518610
##
flink-ml-servable-lib/src/test/java/org/apache/flink/ml/classification/logisticregression/LogisticRegressionModelServableTest.java:
##
@@ -0,0 +1,153 @@
+/*
+ *
lindong28 commented on code in PR #219:
URL: https://github.com/apache/flink-ml/pull/219#discussion_r1136518106
##
flink-ml-lib/src/test/java/org/apache/flink/ml/classification/LogisticRegressionTest.java:
##
@@ -253,6 +255,25 @@ public void testSaveLoadAndPredict() throws
[
https://issues.apache.org/jira/browse/FLINK-31380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17700499#comment-17700499
]
Ran Tao commented on FLINK-31380:
-
[~jark] Hi, Jark. I added a lot of test cases and did integration
[
https://issues.apache.org/jira/browse/FLINK-31380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17700498#comment-17700498
]
Ran Tao commented on FLINK-31380:
-
show catalogs;
+-+
| catalog name |
flinkbot commented on PR #22182:
URL: https://github.com/apache/flink/pull/22182#issuecomment-1469299098
## CI report:
* d1a3c2ef7490c7da79c7a1db446d983a6c0413fb UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #22181:
URL: https://github.com/apache/flink/pull/22181#issuecomment-1469299023
## CI report:
* 86c7796294d58dd44e189bf8ba4c3b105ea8725e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
chucheng92 commented on PR #22179:
URL: https://github.com/apache/flink/pull/22179#issuecomment-1469298702
@wuchong hi, jark. I added a lot of test cases and did integration testing
for a while. Can u help me to review this feature?
--
This is an automated message from the Apache Git
leonardBang commented on code in PR #22170:
URL: https://github.com/apache/flink/pull/22170#discussion_r1136511081
##
docs/data/sql_functions.yml:
##
@@ -499,7 +499,24 @@ temporal:
description: Gets current Unix timestamp in seconds. This function is not
deterministic
JunRuiLee commented on PR #22174:
URL: https://github.com/apache/flink/pull/22174#issuecomment-1469296655
@leonardBang Thanks for the quick code review. Sure, I've opened three pr:
release-1.16:https://github.com/apache/flink/pull/22174
release-1.17:
reswqa opened a new pull request, #22182:
URL: https://github.com/apache/flink/pull/22182
Backport FLINK-31420 to release-1.16.
--
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
JunRuiLee opened a new pull request, #22181:
URL: https://github.com/apache/flink/pull/22181
## What is the purpose of the change
Fix wrong key 'lookup.cache.caching-missing-key' in 'hbase.md'.
## Does this pull request potentially affect one of the following
flinkbot commented on PR #22180:
URL: https://github.com/apache/flink/pull/22180#issuecomment-1469281187
## CI report:
* c3cfa5253042e03aee0a7d07d1e91d52838a5bfa UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17700494#comment-17700494
]
Jingsong Lee edited comment on FLINK-31461 at 3/15/23 3:48 AM:
---
I think
[
https://issues.apache.org/jira/browse/FLINK-31461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17700494#comment-17700494
]
Jingsong Lee commented on FLINK-31461:
--
I think this is good
> Supports schema historical version
WencongLiu commented on PR #21645:
URL: https://github.com/apache/flink/pull/21645#issuecomment-1469274967
@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
reswqa opened a new pull request, #22180:
URL: https://github.com/apache/flink/pull/22180
Backport FLINK-31420 to release-1.17.
--
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
JingsongLi commented on code in PR #605:
URL: https://github.com/apache/flink-table-store/pull/605#discussion_r1136499298
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/AbstractFileStoreWrite.java:
##
@@ -232,50 +210,131 @@ public void
JingsongLi merged PR #606:
URL: https://github.com/apache/flink-table-store/pull/606
--
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:
flinkbot commented on PR #22179:
URL: https://github.com/apache/flink/pull/22179#issuecomment-1469265690
## CI report:
* fc06fe6b36ebdb7bf9b16842c3e6cc94cbeddfa2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
chucheng92 opened a new pull request, #22179:
URL: https://github.com/apache/flink/pull/22179
## What is the purpose of the change
Add filter support for show operations for
[FLIP-297](https://cwiki.apache.org/confluence/display/FLINK/FLIP-297%3A+Improve+Auxiliary+Sql+Statements)
jiangxin369 commented on code in PR #219:
URL: https://github.com/apache/flink-ml/pull/219#discussion_r1136491018
##
flink-ml-lib/src/test/java/org/apache/flink/ml/classification/LogisticRegressionTest.java:
##
@@ -253,6 +255,25 @@ public void testSaveLoadAndPredict() throws
wuchong closed pull request #22156: [FLINK-30129][table] Push projection
through ChangelogNormalize
URL: https://github.com/apache/flink/pull/22156
--
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
[
https://issues.apache.org/jira/browse/FLINK-30129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-30129.
---
Resolution: Fixed
Fixed in master:
[
https://issues.apache.org/jira/browse/FLINK-30181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17700474#comment-17700474
]
Yanfei Lei commented on FLINK-30181:
[
https://issues.apache.org/jira/browse/FLINK-30805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17700473#comment-17700473
]
Mason Chen commented on FLINK-30805:
[~echauchot] left a comment, I'm not sure this change makes
PatrickRen commented on code in PR #22146:
URL: https://github.com/apache/flink/pull/22146#discussion_r1136479162
##
docs/content.zh/release-notes/flink-1.17.md:
##
@@ -0,0 +1,203 @@
+---
+title: "Release Notes - Flink 1.17"
+---
+
+
+# Release notes - Flink 1.17
+
+These
wuchong commented on code in PR #22156:
URL: https://github.com/apache/flink/pull/22156#discussion_r1136478001
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/physical/stream/PushCalcPastChangelogNormalizeRule.java:
##
@@ -0,0 +1,333
zhuzhurk closed pull request #22167: [hotfix] [doc] Fix the configuration item
error of docs/content/docs/connectors/table/hbase.md
URL: https://github.com/apache/flink/pull/22167
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
jiangxin369 commented on code in PR #219:
URL: https://github.com/apache/flink-ml/pull/219#discussion_r1136472957
##
flink-ml-servable-lib/src/test/java/org/apache/flink/ml/classification/logisticregression/LogisticRegressionModelServableTest.java:
##
@@ -0,0 +1,153 @@
+/*
+ *
jiangxin369 commented on code in PR #219:
URL: https://github.com/apache/flink-ml/pull/219#discussion_r1136472041
##
flink-ml-servable-lib/src/test/java/org/apache/flink/ml/classification/logisticregression/LogisticRegressionModelServableTest.java:
##
@@ -0,0 +1,153 @@
+/*
+ *
godfreyhe commented on code in PR #22156:
URL: https://github.com/apache/flink/pull/22156#discussion_r1136471769
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/physical/stream/PushCalcPastChangelogNormalizeRule.java:
##
@@ -0,0 +1,333
Shammon created FLINK-31461:
---
Summary: Supports schema historical version expiring
Key: FLINK-31461
URL: https://issues.apache.org/jira/browse/FLINK-31461
Project: Flink
Issue Type: Improvement
yuzelin opened a new pull request, #606:
URL: https://github.com/apache/flink-table-store/pull/606
Delete misused `--detached` argument.
--
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
JingsongLi merged PR #590:
URL: https://github.com/apache/flink-table-store/pull/590
--
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-31430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31430:
---
Labels: pull-request-available (was: )
> Support migrating states between different
tsreaper opened a new pull request, #605:
URL: https://github.com/apache/flink-table-store/pull/605
Currently `Table` and `TableWrite` in Flink Table Store have a fixed schema.
However to consume schema changes, Flink Table Store CDC sinks should have the
ability to change its schema
[
https://issues.apache.org/jira/browse/FLINK-31453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin closed FLINK-31453.
Resolution: Fixed
> Update the test utils to call methods explicitly
>
[
https://issues.apache.org/jira/browse/FLINK-31453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17700460#comment-17700460
]
Dong Lin commented on FLINK-31453:
--
Merged to apache/flink-ml master branch
[
https://issues.apache.org/jira/browse/FLINK-31431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng closed FLINK-31431.
---
Resolution: Fixed
master: c155b9d7c0a6ef40327116cac88659c6be975919
> Support copying a
lindong28 merged PR #225:
URL: https://github.com/apache/flink-ml/pull/225
--
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:
lindong28 commented on PR #225:
URL: https://github.com/apache/flink-ml/pull/225#issuecomment-1469195403
Thanks for the PR. 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
[
https://issues.apache.org/jira/browse/FLINK-31453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned FLINK-31453:
Assignee: Jiang Xin
> Improve the test utils to call methods explicitly
>
[
https://issues.apache.org/jira/browse/FLINK-31453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-31453:
-
Summary: Update the test utils to call methods explicitly (was: Improve
the test utils to call methods
[
https://issues.apache.org/jira/browse/FLINK-31368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17700458#comment-17700458
]
luoyuxia commented on FLINK-31368:
--
[~jark] Also noticed `SqlToOperationConverter` has a similiar
tsreaper merged PR #600:
URL: https://github.com/apache/flink-table-store/pull/600
--
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:
zoltar9264 commented on PR #22168:
URL: https://github.com/apache/flink/pull/22168#issuecomment-1469191958
Thanks for your @pnowojski , I change the test as you commented and squash
the commits.
--
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/FLINK-31460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31460:
---
Labels: pull-request-available (was: )
> Fix hive catalog and connector jar name in the
zhuangchong opened a new pull request, #604:
URL: https://github.com/apache/flink-table-store/pull/604
Fix hive catalog and connector jar name in the create release script for
table store
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
zhuangchong created FLINK-31460:
---
Summary: Fix hive catalog and connector jar name in the create
release script for table store
Key: FLINK-31460
URL: https://issues.apache.org/jira/browse/FLINK-31460
[
https://issues.apache.org/jira/browse/FLINK-31453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31453:
---
Labels: pull-request-available (was: )
> Improve the test utils to call methods explicitly
jiangxin369 opened a new pull request, #225:
URL: https://github.com/apache/flink-ml/pull/225
## What is the purpose of the change
Refactor the `TestUtils.saveAndReload` method to call the static `load`
method of specific Stage explicitly.
## Brief change log
zhangjun0x01 commented on code in PR #584:
URL: https://github.com/apache/flink-table-store/pull/584#discussion_r1136446719
##
flink-table-store-flink/flink-table-store-flink-common/src/main/java/org/apache/flink/table/store/connector/FlinkConnectorOptions.java:
##
@@ -82,6
[
https://issues.apache.org/jira/browse/FLINK-31459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31459:
---
Labels: pull-request-available (was: )
> add UPDATE COLUMN POSITION for flink table store
zhangjun0x01 opened a new pull request, #603:
URL: https://github.com/apache/flink-table-store/pull/603
add UPDATE COLUMN POSITION for flink table store
--
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
Jun Zhang created FLINK-31459:
-
Summary: add UPDATE COLUMN POSITION for flink table store
Key: FLINK-31459
URL: https://issues.apache.org/jira/browse/FLINK-31459
Project: Flink
Issue Type:
lindong28 commented on code in PR #219:
URL: https://github.com/apache/flink-ml/pull/219#discussion_r1136431138
##
flink-ml-servable-lib/src/main/java/org/apache/flink/ml/classification/logisticregression/LogisticRegressionModelServable.java:
##
@@ -0,0 +1,148 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-29541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17700452#comment-17700452
]
Jark Wu commented on FLINK-29541:
-
Hi [~rskraba], I would suggest keeping this issue as is and creating
[
https://issues.apache.org/jira/browse/FLINK-31440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhuangchong closed FLINK-31440.
---
Resolution: Won't Do
> Split hive catalog to each module of each version
>
[
https://issues.apache.org/jira/browse/FLINK-31440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17700449#comment-17700449
]
zhuangchong commented on FLINK-31440:
-
In
zhuangchong closed pull request #601: [FLINK-31440] Split hive catalog to each
module of each version
URL: https://github.com/apache/flink-table-store/pull/601
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
zhuangchong commented on PR #601:
URL:
https://github.com/apache/flink-table-store/pull/601#issuecomment-1469111629
> Hi @zhuangchong Thanks for the contribution. In #569 , we found hive
catalog with hive-2.3.9 can be used for every hive metastore versions, so we
just keep one version for
[
https://issues.apache.org/jira/browse/FLINK-31438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31438.
Fix Version/s: table-store-0.4.0
Assignee: zhuangchong
Resolution: Fixed
master:
JingsongLi merged PR #599:
URL: https://github.com/apache/flink-table-store/pull/599
--
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:
RamanVerma commented on code in PR #22150:
URL: https://github.com/apache/flink/pull/22150#discussion_r1136426195
##
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java:
##
@@ -241,6 +246,8 @@ public void close() throws
JingsongLi commented on PR #601:
URL:
https://github.com/apache/flink-table-store/pull/601#issuecomment-1469088058
Hi @zhuangchong Thanks for the contribution.
In https://github.com/apache/flink-table-store/pull/569 , we found hive
catalog with hive-2.3.9 can be used for every hive
JingsongLi merged PR #602:
URL: https://github.com/apache/flink-table-store/pull/602
--
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:
RamanVerma commented on code in PR #22150:
URL: https://github.com/apache/flink/pull/22150#discussion_r1136403399
##
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java:
##
@@ -397,36 +409,57 @@ private void
rkhachatryan commented on code in PR #22169:
URL: https://github.com/apache/flink/pull/22169#discussion_r1136395017
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/WaitingForResources.java:
##
@@ -144,12 +135,17 @@ public Logger getLogger() {
}
rkhachatryan commented on code in PR #22169:
URL: https://github.com/apache/flink/pull/22169#discussion_r1136382696
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveScheduler.java:
##
@@ -216,11 +218,16 @@
private final
rkhachatryan commented on code in PR #22169:
URL: https://github.com/apache/flink/pull/22169#discussion_r1136373675
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Executing.java:
##
@@ -123,9 +123,18 @@ private void
dongjoon-hyun commented on PR #19844:
URL: https://github.com/apache/flink/pull/19844#issuecomment-1469026424
Thank you, @pgaref and @liujiawinds .
--
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-31428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17700406#comment-17700406
]
Yufan Sheng commented on FLINK-31428:
-
Add a `AutoCloseable` do make sense to me. BTW, I don't think
flinkbot commented on PR #22178:
URL: https://github.com/apache/flink/pull/22178#issuecomment-1468822240
## CI report:
* dfd76d47460ee60ac544397fe7e65e6017437028 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30950:
---
Labels: pull-request-available (was: )
> Remove flink-connector-aws-base from Flink main
hlteoh37 opened a new pull request, #22178:
URL: https://github.com/apache/flink/pull/22178
…it has been migrated to flink-connector-aws
## What is the purpose of the change
Remove flink-connector-aws-base from main Flink repository since it has been
externalized to
[
https://issues.apache.org/jira/browse/FLINK-30949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh closed FLINK-30949.
---
Resolution: Not A Problem
> Sync flink-connector-aws-base from Flink main to
[
https://issues.apache.org/jira/browse/FLINK-30949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17700370#comment-17700370
]
Hong Liang Teoh commented on FLINK-30949:
-
Did a diff between
[
https://issues.apache.org/jira/browse/FLINK-31428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17700359#comment-17700359
]
Alpha Diallo commented on FLINK-31428:
--
Ok I see. Yes, the reason we added the factory is in case
[
https://issues.apache.org/jira/browse/FLINK-31458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aleksandr Pilipenko closed FLINK-31458.
---
Resolution: Duplicate
> Support waiting for required resources in DefaultScheduler
Aleksandr Pilipenko created FLINK-31458:
---
Summary: Support waiting for required resources in
DefaultScheduler during job restart
Key: FLINK-31458
URL: https://issues.apache.org/jira/browse/FLINK-31458
Aleksandr Pilipenko created FLINK-31457:
---
Summary: Support waiting for required resources in
DefaultScheduler during job restart
Key: FLINK-31457
URL: https://issues.apache.org/jira/browse/FLINK-31457
kevincherian closed pull request #22177: Kc/issue 32
URL: https://github.com/apache/flink/pull/22177
--
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:
kevincherian opened a new pull request, #22177:
URL: https://github.com/apache/flink/pull/22177
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring
[
https://issues.apache.org/jira/browse/FLINK-31428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17700323#comment-17700323
]
Yufan Sheng commented on FLINK-31428:
-
It's better to extend the {{ConsumerInterceptor}} and
[
https://issues.apache.org/jira/browse/FLINK-31428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17700319#comment-17700319
]
Yufan Sheng edited comment on FLINK-31428 at 3/14/23 5:36 PM:
--
I don't
[
https://issues.apache.org/jira/browse/FLINK-31428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17700319#comment-17700319
]
Yufan Sheng commented on FLINK-31428:
-
I don't think it's ok to expose the deserialized/serialized
gaoyunhaii commented on PR #21736:
URL: https://github.com/apache/flink/pull/21736#issuecomment-1468528005
Hi @XComp sorry for the long delay due to being bound recently, I have
merged the previous commits except for the last change that reads latest
published version from the file. I'll
[
https://issues.apache.org/jira/browse/FLINK-28758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-28758:
--
Assignee: Mark Cho
> FlinkKafkaConsumer fails to stop with savepoint
>
[
https://issues.apache.org/jira/browse/FLINK-31319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ran Tao updated FLINK-31319:
Affects Version/s: 1.17.0
1.16.2
> Inconsistent condition judgement about kafka
[
https://issues.apache.org/jira/browse/FLINK-31452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ran Tao updated FLINK-31452:
Description:
Currently TableEnv support return sorted views and tables.
{code:java}
@Override
public
1 - 100 of 304 matches
Mail list logo
