[
https://issues.apache.org/jira/browse/FLINK-3967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-3967.
-
Assignee: (was: Mans Singh)
Resolution: Won't Fix
> Provide RethinkDB Sink for Flink
>
JunRuiLee opened a new pull request, #22029:
URL: https://github.com/apache/flink/pull/22029
## What is the purpose of the change
Add an allowed errors in logs for speculative execution:
`ERROR org.apache.flink.runtime.io.disk.iomanager.IOManager [] - The
[
https://issues.apache.org/jira/browse/FLINK-31216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-31216.
--
Resolution: Duplicate
> Update kryo to current
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-31223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-31223:
---
Fix Version/s: (was: 1.17.0)
> sql-client.sh fails to start with ssl enabled
>
[
https://issues.apache.org/jira/browse/FLINK-31232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31232.
Fix Version/s: table-store-0.4.0
Assignee: Nicholas Jiang
Resolution: Fixed
JingsongLi merged PR #560:
URL: https://github.com/apache/flink-table-store/pull/560
--
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:
GOODBOY008 commented on PR #8:
URL:
https://github.com/apache/flink-connector-jdbc/pull/8#issuecomment-1445838508
@leonardBang Please cc, If you are available.
--
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-31211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17693827#comment-17693827
]
leo.zhi commented on FLINK-31211:
-
Thanks Martijn, it helps me a lot.
> Flink chk files not delete
[
https://issues.apache.org/jira/browse/FLINK-31211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
leo.zhi updated FLINK-31211:
Description:
Checkpoint chk files can be deleted automic when the version of flink 1.13, but
we upgert
tamirsagi commented on PR #536:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/536#issuecomment-1445836400
@gyfora Would you please review?
--
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-31077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-31077.
---
Resolution: Fixed
master:
eb17ec3f05d4bd512bc70ee79296d0b884894eaf
release-1.17:
slfan1989 commented on PR #22019:
URL: https://github.com/apache/flink/pull/22019#issuecomment-1445809156
@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
slfan1989 commented on PR #22019:
URL: https://github.com/apache/flink/pull/22019#issuecomment-1445804528
@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
[
https://issues.apache.org/jira/browse/FLINK-31234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weihua Hu updated FLINK-31234:
--
Description:
Flink on Kubernetes does not support redirecting stdout/stderr to files. This
is to
SteNicholas commented on code in PR #554:
URL: https://github.com/apache/flink-table-store/pull/554#discussion_r1118344187
##
docs/layouts/shortcodes/generated/core_configuration.html:
##
@@ -218,6 +218,12 @@
Enum
Specify the scanning behavior of the
Weihua Hu created FLINK-31234:
-
Summary: Add an option to redirect stdout/stderr for flink on
kubernetes
Key: FLINK-31234
URL: https://issues.apache.org/jira/browse/FLINK-31234
Project: Flink
zhuzhurk closed pull request #21943: [FLINK-31077][runtime] Mark pending
checkpoint onCompletionPromise complete only after the completed checkpoint is
added to the store.
URL: https://github.com/apache/flink/pull/21943
--
This is an automated message from the Apache Git Service.
To respond
[
https://issues.apache.org/jira/browse/FLINK-30396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-30396:
Fix Version/s: 1.17.0
> sql hint 'LOOKUP' which is defined in outer query block may take effect
[
https://issues.apache.org/jira/browse/FLINK-30396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee closed FLINK-30396.
---
Resolution: Fixed
> sql hint 'LOOKUP' which is defined in outer query block may take effect in
>
[
https://issues.apache.org/jira/browse/FLINK-30396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17693587#comment-17693587
]
lincoln lee edited comment on FLINK-30396 at 2/27/23 6:47 AM:
--
fixed in
lincoln-lil closed pull request #22025: [bp-1.17][FLINK-30396][table-planner]
Fix incorrect hint propagation into sub-query of lookup join hint
URL: https://github.com/apache/flink/pull/22025
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
lsyldliu commented on PR #22024:
URL: https://github.com/apache/flink/pull/22024#issuecomment-1445784931
@godfreyhe Thanks for reviewing, I've addressed your comments. Regarding
removing the config from `GeneratedClass`, I think we can complete it in
another PR.
--
This is an automated
[
https://issues.apache.org/jira/browse/FLINK-31139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei reassigned FLINK-31139:
--
Assignee: Feifan Wang
> not upload empty state changelog file
>
[
https://issues.apache.org/jira/browse/FLINK-31214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17693806#comment-17693806
]
Samrat Deb commented on FLINK-31214:
I would like to work in this issue.
can you please assign
[
https://issues.apache.org/jira/browse/FLINK-31223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17693802#comment-17693802
]
macdoor615 commented on FLINK-31223:
[~fsk119] you are right. it is not a big problem in embedded
[
https://issues.apache.org/jira/browse/FLINK-31233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weihua Hu updated FLINK-31233:
--
Description:
When running Flink on Kubernetes, the stdout logs is not redirected to files so
it will
SteNicholas opened a new pull request, #560:
URL: https://github.com/apache/flink-table-store/pull/560
Parquet format should support MULTISET type for Table Store. Meanwhile, the
FileStats couldn't support the MULTISET type because the null count of
ColumnStatistics for ARRAY, MAP and
[
https://issues.apache.org/jira/browse/FLINK-31232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31232:
---
Labels: pull-request-available (was: )
> Parquet format supports MULTISET type for Table
zhipeng93 merged PR #212:
URL: https://github.com/apache/flink-ml/pull/212
--
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:
Weihua Hu created FLINK-31233:
-
Summary: no error should be logged when retrieving the task
manager's stdout if it does not exist
Key: FLINK-31233
URL: https://issues.apache.org/jira/browse/FLINK-31233
zhipeng93 commented on PR #212:
URL: https://github.com/apache/flink-ml/pull/212#issuecomment-1445758405
> @zhipeng93 Thanks for the review. The change made in this PR should be
able to improve all existing data generators via `RowGenerator`. Can you check
if there is anything missing?
Nicholas Jiang created FLINK-31232:
--
Summary: Parquet format supports MULTISET type for Table Store
Key: FLINK-31232
URL: https://issues.apache.org/jira/browse/FLINK-31232
Project: Flink
dianfu commented on PR #20756:
URL: https://github.com/apache/flink/pull/20756#issuecomment-1445749286
Closed this PR as this should have already been supported.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
dianfu closed pull request #20756: [FLINK-27929][python] Drop support for
python36
URL: https://github.com/apache/flink/pull/20756
--
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
lindong28 commented on PR #212:
URL: https://github.com/apache/flink-ml/pull/212#issuecomment-1445747413
@zhipeng93 Thanks for the review. The change made in this PR should be able
to improve all existing data generators via `RowGenerator`. Can you check if
there is anything missing?
--
[
https://issues.apache.org/jira/browse/FLINK-29825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29825:
---
Labels: pull-request-available (was: )
> Improve benchmark stability
>
fredia opened a new pull request, #66:
URL: https://github.com/apache/flink-benchmarks/pull/66
Replace median-based regression detect algorithm with max/min-based.
Detailed design is in
https://docs.google.com/document/d/1Bvzvq79Ll5yxd1UtC0YzczgFbZPAgPcN3cI0MjVkIag/edit
--
This is an
JingsongLi commented on code in PR #546:
URL: https://github.com/apache/flink-table-store/pull/546#discussion_r1118300656
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/table/system/SnapshotsTable.java:
##
@@ -71,7 +71,10 @@ public class SnapshotsTable
pgaref commented on PR #21923:
URL: https://github.com/apache/flink/pull/21923#issuecomment-1445719083
> Hi @pgaref , thanks a lot for the refactor, it's very useful for
maintainability. I have left some comments, please help take a look in your
free time, thanks~
>
> Thanks
[
https://issues.apache.org/jira/browse/FLINK-31221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-31221:
---
Assignee: Shilun Fan
> Fix Typo in YarnConfigOptions
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-31231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17693785#comment-17693785
]
CHEN Zhongpu commented on FLINK-31231:
--
It seems that this issue only occurs in Mac/Linux, because
[
https://issues.apache.org/jira/browse/FLINK-30277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang updated FLINK-30277:
-
Issue Type: New Feature (was: Improvement)
> Allow PYTHONPATH of Python Worker configurable
>
[
https://issues.apache.org/jira/browse/FLINK-30277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang updated FLINK-30277:
-
Affects Version/s: 1.18.0
(was: 1.16.0)
> Allow PYTHONPATH of Python
[
https://issues.apache.org/jira/browse/FLINK-31092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17693779#comment-17693779
]
luoyuxia edited comment on FLINK-31092 at 2/27/23 4:29 AM:
---
Try to analyze the
[
https://issues.apache.org/jira/browse/FLINK-31092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17693779#comment-17693779
]
luoyuxia commented on FLINK-31092:
--
Try to analyze the heap dump, I found most of object will be
CHEN Zhongpu created FLINK-31231:
Summary: flink-playgrounds has permission errors in mounted files
Key: FLINK-31231
URL: https://issues.apache.org/jira/browse/FLINK-31231
Project: Flink
godfreyhe commented on code in PR #22024:
URL: https://github.com/apache/flink/pull/22024#discussion_r1118269139
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/utils/SorMergeJoinOperatorUtil.java:
##
@@ -48,6 +49,17 @@ public static
liuyongvs commented on code in PR #19623:
URL: https://github.com/apache/flink/pull/19623#discussion_r1118251199
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayDistinctFunction.java:
##
@@ -0,0 +1,64 @@
+/*
+ * Licensed to
1996fanrui commented on PR #22020:
URL: https://github.com/apache/flink/pull/22020#issuecomment-1445656410
Hi @slfan1989 , thanks for your contribution, please run `mvn
spotless:apply` to fix the checkstyle.
liuyongvs commented on code in PR #19623:
URL: https://github.com/apache/flink/pull/19623#discussion_r1118251199
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayDistinctFunction.java:
##
@@ -0,0 +1,64 @@
+/*
+ * Licensed to
JingsongLi merged PR #556:
URL: https://github.com/apache/flink-table-store/pull/556
--
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:
JingsongLi commented on PR #557:
URL:
https://github.com/apache/flink-table-store/pull/557#issuecomment-1445638952
>
File is immutable, should never be modified.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
JingsongLi commented on PR #558:
URL:
https://github.com/apache/flink-table-store/pull/558#issuecomment-1445638482
@SteNicholas Thanks for the review, comments addressed.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
JingsongLi commented on code in PR #558:
URL: https://github.com/apache/flink-table-store/pull/558#discussion_r1118245870
##
flink-table-store-flink/flink-table-store-flink-common/src/main/java/org/apache/flink/table/store/connector/sink/TableStoreSink.java:
##
@@ -88,6 +90,10
zhangjun0x01 commented on code in PR #547:
URL: https://github.com/apache/flink-table-store/pull/547#discussion_r1118244978
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/CoreOptions.java:
##
@@ -474,6 +474,20 @@ public class CoreOptions implements
JingsongLi commented on code in PR #558:
URL: https://github.com/apache/flink-table-store/pull/558#discussion_r1118243404
##
docs/content/docs/features/table-types.md:
##
@@ -102,6 +102,9 @@ Current supported aggregate functions and data types are:
* `listagg`: supports STRING
slfan1989 commented on PR #22020:
URL: https://github.com/apache/flink/pull/22020#issuecomment-1445629495
@1996fanrui Can you help review this pr? Thank you very much!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
slfan1989 commented on PR #22019:
URL: https://github.com/apache/flink/pull/22019#issuecomment-1445628767
@1996fanrui Can you help review this pr? Thank you very much!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
liuyongvs commented on code in PR #21993:
URL: https://github.com/apache/flink/pull/21993#discussion_r1118239596
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/SpecificInputTypeStrategies.java:
##
@@ -71,7 +71,11 @@ public
liuyongvs commented on code in PR #21993:
URL: https://github.com/apache/flink/pull/21993#discussion_r1118238858
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ArrayElementArgumentTypeStrategy.java:
##
@@ -31,24 +31,28 @@
[
https://issues.apache.org/jira/browse/FLINK-30277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang closed FLINK-30277.
Fix Version/s: 1.18.0
Resolution: Fixed
Merged into master via
HuangXingBo closed pull request #21770: [FLINK-30277][python]Allow PYTHONPATH
of Python Worker configurable
URL: https://github.com/apache/flink/pull/21770
--
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
[
https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17693756#comment-17693756
]
Rui Fan commented on FLINK-29816:
-
Thanks [~RocMarshal] for your contribution, and [~Weijie Guo]
[
https://issues.apache.org/jira/browse/FLINK-30664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17693755#comment-17693755
]
luoyuxia commented on FLINK-30664:
--
What do you mean by saying "hive and hive-metastore combination
[
https://issues.apache.org/jira/browse/FLINK-30634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia resolved FLINK-30634.
--
Resolution: Duplicate
> HiveTableSourceITCase.setupSourceDatabaseAndData fails with
>
1996fanrui merged PR #21999:
URL: https://github.com/apache/flink/pull/21999
--
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-31192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17693754#comment-17693754
]
xzw0223 commented on FLINK-31192:
-
[~Weijie Guo] It's taken care of. Can you take a look at it? Thank
[
https://issues.apache.org/jira/browse/FLINK-31223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17693751#comment-17693751
]
Shengkai Fang edited comment on FLINK-31223 at 2/27/23 2:08 AM:
Hello.
[
https://issues.apache.org/jira/browse/FLINK-31223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17693751#comment-17693751
]
Shengkai Fang commented on FLINK-31223:
---
Hello. In the embedded mode, we always assume the started
zhipeng93 commented on PR #217:
URL: https://github.com/apache/flink-ml/pull/217#issuecomment-1445562764
@gaoyunhaii Can you help to 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
zhipeng93 commented on PR #216:
URL: https://github.com/apache/flink-ml/pull/216#issuecomment-1445562636
@gaoyunhaii Can you help to 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
RocMarshal commented on PR #21999:
URL: https://github.com/apache/flink/pull/21999#issuecomment-1445562489
> @RocMarshal Would you mind creating the `backport` pull request of
`release-1.17` and `release-1.16` after all reviewers approved.
@reswqa Yes. I'm glad to ~
--
This is
zhipeng93 commented on PR #215:
URL: https://github.com/apache/flink-ml/pull/215#issuecomment-1445562467
@gaoyunhaii Can you help to 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
zhipeng93 commented on PR #206:
URL: https://github.com/apache/flink-ml/pull/206#issuecomment-1445562174
@gaoyunhaii Can you help to 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
zhipeng93 commented on PR #212:
URL: https://github.com/apache/flink-ml/pull/212#issuecomment-1445559813
Thanks for the update. There are many other data generators in the benchmark
settings, do you think we should apply same optimization here?
--
This is an automated message from the
zhipeng93 commented on code in PR #212:
URL: https://github.com/apache/flink-ml/pull/212#discussion_r1118206725
##
flink-ml-benchmark/src/main/java/org/apache/flink/ml/benchmark/datagenerator/common/DenseVectorArrayGenerator.java:
##
@@ -42,7 +42,7 @@ protected RowGenerator[]
Fanoid commented on PR #214:
URL: https://github.com/apache/flink-ml/pull/214#issuecomment-1445556809
> Update `ModelServable#setModelData` to use the signature `default T
setModelData(InputStream... modelDataInputs) throws IOException`.
Hi, I just found we have made this change. I
lincoln-lil commented on PR #21545:
URL: https://github.com/apache/flink/pull/21545#issuecomment-1445551956
@Mulavar I've created one https://github.com/apache/flink/pull/22025,
please help to check if you have time
--
This is an automated message from the Apache Git Service.
To respond
lindong28 commented on code in PR #212:
URL: https://github.com/apache/flink-ml/pull/212#discussion_r1118201388
##
flink-ml-benchmark/src/main/java/org/apache/flink/ml/benchmark/datagenerator/common/DenseVectorArrayGenerator.java:
##
@@ -42,7 +42,7 @@ protected RowGenerator[]
flinkbot commented on PR #22028:
URL: https://github.com/apache/flink/pull/22028#issuecomment-1445547559
## CI report:
* 08c662fee24f32931227f95dc333471e4676e5f1 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
lindong28 commented on code in PR #212:
URL: https://github.com/apache/flink-ml/pull/212#discussion_r1118201388
##
flink-ml-benchmark/src/main/java/org/apache/flink/ml/benchmark/datagenerator/common/DenseVectorArrayGenerator.java:
##
@@ -42,7 +42,7 @@ protected RowGenerator[]
[
https://issues.apache.org/jira/browse/FLINK-31230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31230:
---
Labels: pull-request-available (was: )
> Improve YarnClusterDescriptor memory unit display
slfan1989 opened a new pull request, #22028:
URL: https://github.com/apache/flink/pull/22028
## What is the purpose of the change
JIRA: [FLINK-31230] Improve YarnClusterDescriptor memory unit display.
When we use the yarn-session.sh -q command, the basic information of
Shilun Fan created FLINK-31230:
--
Summary: Improve YarnClusterDescriptor memory unit display
Key: FLINK-31230
URL: https://issues.apache.org/jira/browse/FLINK-31230
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-31228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
CHEN Zhongpu updated FLINK-31228:
-
Labels: Docker (was: )
> flink-playgrounds is using a buggy zookeeper
>
[
https://issues.apache.org/jira/browse/FLINK-31109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17693699#comment-17693699
]
Martijn Visser commented on FLINK-31109:
Fixed in
Master:
MartijnVisser commented on PR #22009:
URL: https://github.com/apache/flink/pull/22009#issuecomment-1445455213
@venkata91 Can you also create a back port towards `release-1.17`?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
MartijnVisser merged PR #22009:
URL: https://github.com/apache/flink/pull/22009
--
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:
snuyanzin commented on PR #21500:
URL: https://github.com/apache/flink/pull/21500#issuecomment-1445435871
Rebased to resolve ci issue
```
Reading package lists...
E: Unsupported file ./libssl1.0.0_1.0.2n-1ubuntu5.10_amd64.deb given on
commandline
##[error]Bash exited with code
Daniel Collins created FLINK-31229:
--
Summary: Implement a Pub/Sub Lite source and sink
Key: FLINK-31229
URL: https://issues.apache.org/jira/browse/FLINK-31229
Project: Flink
Issue Type: New
flinkbot commented on PR #22027:
URL: https://github.com/apache/flink/pull/22027#issuecomment-1445401185
## CI report:
* 89a6f138c7518fe08dec0a6db6dc786d44c37f06 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
reswqa opened a new pull request, #22027:
URL: https://github.com/apache/flink/pull/22027
## What is the purpose of the change
Add GuardedBy annotation and some clean up for result partition.
## Brief change log
- *Add missing @GuardedBy annotation for
reswqa commented on PR #21998:
URL: https://github.com/apache/flink/pull/21998#issuecomment-1445394384
@jhkkhtd Sorry for the delay, you can request a jira account reference this
reswqa commented on PR #21999:
URL: https://github.com/apache/flink/pull/21999#issuecomment-1445393395
@RocMarshal Would you mind creating the `backport` pull request of
`release-1.17` and `release-1.16` after all reviewers approved.
--
This is an automated message from the Apache Git
flinkbot commented on PR #22026:
URL: https://github.com/apache/flink/pull/22026#issuecomment-1445392265
## CI report:
* 3604ca17dd3e38cb44fe3311f93c8269a8dbfebb UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31223:
---
Labels: pull-request-available (was: )
> sql-client.sh fails to start with ssl enabled
>
reswqa opened a new pull request, #22026:
URL: https://github.com/apache/flink/pull/22026
## What is the purpose of the change
*`SqlClient` now uses `SqlGateway` for job submission. It will connect to
the gateway's `RestServer` through the `RestClient` to interact. when we
create
[
https://issues.apache.org/jira/browse/FLINK-30720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17693657#comment-17693657
]
wgcn commented on FLINK-30720:
--
Hi [~mapohl] ,does this Exception occur in every test?
Could you tell me
flinkbot commented on PR #22025:
URL: https://github.com/apache/flink/pull/22025#issuecomment-1445374878
## CI report:
* 783eeac69dea012a596e12f906853e1836b0d2c8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
CHEN Zhongpu updated FLINK-31228:
-
Labels: (was: playground)
> flink-playgrounds is using a buggy zookeeper
>
1 - 100 of 118 matches
Mail list logo
