mbalassi opened a new pull request, #142:
URL: https://github.com/apache/flink-docker/pull/142
I kept 1.15 around for the time being
--
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
morhidi commented on PR #142:
URL: https://github.com/apache/flink-docker/pull/142#issuecomment-1332316470
+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 comment.
To
[
https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17641393#comment-17641393
]
Matthias Pohl commented on FLINK-29427:
---
aaand we're back:
reswqa commented on PR #21437:
URL: https://github.com/apache/flink/pull/21437#issuecomment-1332561864
Hi @pnowojski, Would you mind helping me to take a look this pull request
when you have time? Thanks very much~
--
This is an automated message from the Apache Git Service.
To respond
[
https://issues.apache.org/jira/browse/FLINK-28648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi reassigned FLINK-28648:
--
Assignee: Balazs Varga
> Allow session deletion to block on any running job
>
XComp opened a new pull request, #21434:
URL: https://github.com/apache/flink/pull/21434
1.16 backport PR for parent PR #21428
--
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
flinkbot commented on PR #21434:
URL: https://github.com/apache/flink/pull/21434#issuecomment-1332385709
## CI report:
* d7e725b3e915de8349feb4e62e9740ff411ab119 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #21435:
URL: https://github.com/apache/flink/pull/21435#issuecomment-1332385887
## CI report:
* ea3e831616b40176f0cd9c73ab24c0902faf39f4 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
hdulay opened a new pull request, #21436:
URL: https://github.com/apache/flink/pull/21436
[FLINK-30093](https://github.com/hdulay/flink/tree/FLINK-30093)
## What is the purpose of the change
This PR enables support for Google Protobuf Timestamp datatypes and possibly
[
https://issues.apache.org/jira/browse/FLINK-30093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30093:
---
Labels: pull-request-available (was: )
> [Flink SQL][Protobuf] CompileException when
flinkbot commented on PR #21437:
URL: https://github.com/apache/flink/pull/21437#issuecomment-1332557385
## CI report:
* 945e55446238871a9c0e464296fa054749f6b097 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #21436:
URL: https://github.com/apache/flink/pull/21436#issuecomment-1332459601
## CI report:
* 869e061fb9120c4346f1cf978e38f6ad863a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
lincoln-lil opened a new pull request, #21433:
URL: https://github.com/apache/flink/pull/21433
This is a minor fix for test data of temporal join, the delete('-D') message
should have the same value with corresponding insert('+I') message:
```
changelogRow("+I", "RMB", "no1", 702L,
[
https://issues.apache.org/jira/browse/FLINK-28898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17641395#comment-17641395
]
Matthias Pohl commented on FLINK-28898:
---
XComp opened a new pull request, #21435:
URL: https://github.com/apache/flink/pull/21435
1.15 backport PR for parent PR #21428
--
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
gyfora opened a new pull request, #457:
URL: https://github.com/apache/flink-kubernetes-operator/pull/457
## What is the purpose of the change
Add detailed documentation for the core operator controller flow
## Does this pull request potentially affect one of the following
flinkbot commented on PR #21433:
URL: https://github.com/apache/flink/pull/21433#issuecomment-1332294797
## CI report:
* f9a348b7c610762092be5aaa004b2a70bc1557ea UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
morhidi merged PR #142:
URL: https://github.com/apache/flink-docker/pull/142
--
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:
zentol commented on PR #21416:
URL: https://github.com/apache/flink/pull/21416#issuecomment-1332429814
Another test relied on the previous (bugged) behavior :(
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
hdulay commented on PR #21436:
URL: https://github.com/apache/flink/pull/21436#issuecomment-1332456717
Hi @maosuhan . Since you were the originator of this code, I was hoping you
could check this enhancement to the protobuf work. Thanks
--
This is an automated message from the Apache
MartijnVisser merged PR #21390:
URL: https://github.com/apache/flink/pull/21390
--
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-30093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-30093:
--
Assignee: hubert dulay
> [Flink SQL][Protobuf] CompileException when querying Kafka
reswqa opened a new pull request, #21437:
URL: https://github.com/apache/flink/pull/21437
## What is the purpose of the change
*If a task has multiple input gates, It will create as many
`InputChannelMetrics` as the number of gates, so the corresponding metrics are
registered
MartijnVisser commented on PR #21436:
URL: https://github.com/apache/flink/pull/21436#issuecomment-1332588712
@hdulay Thanks for opening your first PR. Please check out the code style &
quality guide for naming conventions on commits
zentol commented on PR #21416:
URL: https://github.com/apache/flink/pull/21416#issuecomment-1332369793
> I think it would make sense to create a new Jira ticket for that. WDYT?
yes, it's a separate issue (and for the one in this ticket we at least
already have a test that shows the
Jingsong Lee created FLINK-30247:
Summary: Introduce Time Travel reading for table store
Key: FLINK-30247
URL: https://issues.apache.org/jira/browse/FLINK-30247
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-29937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-29937:
--
Issue Type: New Feature (was: Improvement)
> Enhanced DynamoDB Element Converter
>
[
https://issues.apache.org/jira/browse/FLINK-29614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-29614.
Resolution: Fixed
master: ab766ec41e6c3876b38da147a92a3844e9b2a774
> Introduce Spark writer for
jiangxin369 commented on code in PR #183:
URL: https://github.com/apache/flink-ml/pull/183#discussion_r1035581618
##
flink-ml-lib/src/main/resources/org/apache/flink/ml/feature/stopwords/README:
##
@@ -0,0 +1,12 @@
+Stopwords Corpus
+
+This corpus contains lists of stop words
Jingsong Lee created FLINK-30248:
Summary: Spark writer supports insert overwrite
Key: FLINK-30248
URL: https://issues.apache.org/jira/browse/FLINK-30248
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-30243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17641132#comment-17641132
]
Shilun Fan commented on FLINK-30243:
[~martijnvisser] Thanks for the documentation!
> Remove
[
https://issues.apache.org/jira/browse/FLINK-29729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17641142#comment-17641142
]
Jun Qin commented on FLINK-29729:
-
Thanks [~lsy]! Just to make it clear, it is not only ak/sk ( I
[
https://issues.apache.org/jira/browse/FLINK-29900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-29900:
--
Issue Type: New Feature (was: Improvement)
> Table API for DynamoDB Sink
>
[
https://issues.apache.org/jira/browse/FLINK-30244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17641162#comment-17641162
]
Gyula Fora commented on FLINK-30244:
When using the Native (active) kubernetes integration. Session
JingsongLi merged PR #394:
URL: https://github.com/apache/flink-table-store/pull/394
--
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-29729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17641142#comment-17641142
]
Jun Qin edited comment on FLINK-29729 at 11/30/22 8:16 AM:
---
Thanks [~lsy]!
slfan1989 commented on PR #21424:
URL: https://github.com/apache/flink/pull/21424#issuecomment-1331805652
@MartijnVisser I just followed the Flink community. Flink is a powerful
real-time technology, and I want to make some contributions to the community. I
read some articles, the author
[
https://issues.apache.org/jira/browse/FLINK-29729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17641160#comment-17641160
]
dalongliu commented on FLINK-29729:
---
[~qinjunjerry] Yes, I just cleared ak/sk here as an example. The
zentol commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-opensearch/pull/1#discussion_r1035727508
##
flink-connector-opensearch/src/test/java/org/apache/flink/streaming/connectors/opensearch/OpensearchSinkTest.java:
##
@@ -79,7 +82,15 @@ public void
pvary closed pull request #448: Show me every error
URL: https://github.com/apache/flink-kubernetes-operator/pull/448
--
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
pvary commented on PR #448:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/448#issuecomment-1331868564
Not needed anymore
--
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
hlteoh37 closed pull request #21425: Hotfix kinesis docs 15
URL: https://github.com/apache/flink/pull/21425
--
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,
flinkbot commented on PR #21426:
URL: https://github.com/apache/flink/pull/21426#issuecomment-1331910957
## CI report:
* 6285ebec07d56ab35b9b1540c796ab76d79ce5a8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #21427:
URL: https://github.com/apache/flink/pull/21427#issuecomment-1331911168
## CI report:
* 868bdbf7eec96f5371865e15e592671352e49f72 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17641223#comment-17641223
]
Wei Zhong commented on FLINK-30245:
---
The precision change (18 -> 19) is caused by
[
https://issues.apache.org/jira/browse/FLINK-30138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-30138:
-
Assignee: Matthias Pohl
> BlobServerCleanupTest utilizes failsWithin with a quite low
zhipeng93 commented on code in PR #186:
URL: https://github.com/apache/flink-ml/pull/186#discussion_r1035817144
##
README.md:
##
@@ -8,9 +8,11 @@ Flink](https://flink.apache.org/).
## Getting Started
-You can follow this [quick
+You can follow the [Python quick
[
https://issues.apache.org/jira/browse/FLINK-30138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30138:
---
Labels: pull-request-available starter (was: starter)
> BlobServerCleanupTest utilizes
XComp opened a new pull request, #21428:
URL: https://github.com/apache/flink/pull/21428
## What is the purpose of the change
The tests run the cleanup logic in a separate thread. The assert requires a
timeout which was not necessarily long enough for the exception to be caught.
[
https://issues.apache.org/jira/browse/FLINK-30245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17641235#comment-17641235
]
Wei Zhong commented on FLINK-30245:
---
[~jark] Could you help to take a look at this issue?
> NPE
zhipeng93 merged PR #186:
URL: https://github.com/apache/flink-ml/pull/186
--
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:
zhipeng93 commented on PR #188:
URL: https://github.com/apache/flink-ml/pull/188#issuecomment-1331977619
Can you help to review this PR @gaoyunhaii @lindong28?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
Rui Fan created FLINK-30250:
---
Summary: The flame graph type is wrong
Key: FLINK-30250
URL: https://issues.apache.org/jira/browse/FLINK-30250
Project: Flink
Issue Type: Bug
Components:
[
https://issues.apache.org/jira/browse/FLINK-30251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ming li updated FLINK-30251:
Description:
Currently when the {{checkpoint}} fails, we process the abort message in the
Task's
[
https://issues.apache.org/jira/browse/FLINK-30251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ming li updated FLINK-30251:
Description:
Currently when the {{checkpoint}} fails, we process the abort message in the
Task's
wangfanming opened a new pull request, #21431:
URL: https://github.com/apache/flink/pull/21431
获取更新
## 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
gaborgsomogyi commented on PR #438:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/438#issuecomment-1331864650
From directional perspective it looks good but I need to go through all the
details.
In the meantime I would like to ask you 2 things:
* Please rebase the
zjureel commented on PR #344:
URL:
https://github.com/apache/flink-table-store/pull/344#issuecomment-1331873268
@JingsongLi I found you have created an issue
https://issues.apache.org/jira/browse/FLINK-30247 to support read snapshot
specific by snapshot id, I'll close this PR
--
This
zjureel closed pull request #344: [FLINK-29823] Support to get schema of table
snapshot
URL: https://github.com/apache/flink-table-store/pull/344
--
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
HuangXingBo closed pull request #21363: [FLINK-29155][python] Improve the
default configuration to make gRPC server more stable
URL: https://github.com/apache/flink/pull/21363
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
pvary commented on code in PR #455:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/455#discussion_r1035737221
##
e2e-tests/utils.sh:
##
@@ -265,3 +270,75 @@ function create_namespace() {
fi;
}
+
+function install_cert_manager() {
+ if [[ -n ${DEBUG} ]];
Zhipeng Zhang created FLINK-30249:
-
Summary: TableUtils.getRowTypeInfo() creating wrong TypeInformation
Key: FLINK-30249
URL: https://issues.apache.org/jira/browse/FLINK-30249
Project: Flink
hlteoh37 opened a new pull request, #21425:
URL: https://github.com/apache/flink/pull/21425
## What is the purpose of the change
hotfix for Kinesis Table API docs.
Cherry pick of commits from https://github.com/apache/flink/pull/21370
## Brief change log
- Added missing
zhipeng93 opened a new pull request, #188:
URL: https://github.com/apache/flink-ml/pull/188
## What is the purpose of the change
Fix TableUtils.getRowTypeInfo() by avoiding using TypeInformation.of(...).
Type information created `TypeInformation.of()` may not be correctly passing
[
https://issues.apache.org/jira/browse/FLINK-30249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30249:
---
Labels: pull-request-available (was: )
> TableUtils.getRowTypeInfo() creating wrong
rgsriram commented on PR #438:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/438#issuecomment-1331948381
Sure, Gabor. I will complete it sometime.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
XComp commented on code in PR #21416:
URL: https://github.com/apache/flink/pull/21416#discussion_r1035801369
##
flink-connectors/flink-connector-datagen/src/test/java/org/apache/flink/connector/datagen/source/DataGeneratorSourceITCase.java:
##
@@ -195,40 +195,31 @@ void
WeiZhong94 opened a new pull request, #21429:
URL: https://github.com/apache/flink/pull/21429
## What is the purpose of the change
*This pull request fixes the NPE thrown when filtering decimal(18, x) values
after calling DecimalDataUtils.subtract method.*
##
[
https://issues.apache.org/jira/browse/FLINK-30245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30245:
---
Labels: pull-request-available (was: )
> NPE thrown when filtering decimal(18, 4) values
[
https://issues.apache.org/jira/browse/FLINK-30177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-30177:
---
Fix Version/s: jdbc-3.0.0
> Update pgjdbc to fix CVE-2022-41946
>
[
https://issues.apache.org/jira/browse/FLINK-16024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-16024:
---
Fix Version/s: jdbc-3.0.0
> support filter pushdown in jdbc connector
>
flinkbot commented on PR #21429:
URL: https://github.com/apache/flink/pull/21429#issuecomment-1331981855
## CI report:
* 49c9f3ddb1abaa6ed14a68c3cc94fbd8a2d5c60f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
HuangXingBo opened a new pull request, #21430:
URL: https://github.com/apache/flink/pull/21430
## What is the purpose of the change
*This pull request will change some configs to make grpc server stable in
PyFlink Process Mode.*
## Brief change log
- *Port Beam
[
https://issues.apache.org/jira/browse/FLINK-30247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30247:
---
Labels: pull-request-available (was: )
> Introduce Time Travel reading for table store
>
[
https://issues.apache.org/jira/browse/FLINK-14101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-14101:
---
Fix Version/s: jdbc-3.0.0
> Introduce SqlServerDialect
> --
>
>
flinkbot commented on PR #21430:
URL: https://github.com/apache/flink/pull/21430#issuecomment-1331988552
## CI report:
* 89f6ccd6d54fba4550263d547e6141e50763b36d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
zentol commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-opensearch/pull/1#discussion_r1035719128
##
flink-connector-opensearch/src/test/java/org/apache/flink/streaming/connectors/opensearch/OpensearchSinkTest.java:
##
@@ -0,0 +1,562 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-30249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhipeng Zhang reassigned FLINK-30249:
-
Assignee: Zhipeng Zhang
> TableUtils.getRowTypeInfo() creating wrong TypeInformation
>
hlteoh37 opened a new pull request, #21426:
URL: https://github.com/apache/flink/pull/21426
… configurations and synced chinese docs with non-chinese docs
## What is the purpose of the change
hotfix for Kinesis Table API docs.
Cherry pick of commits from
hlteoh37 opened a new pull request, #21427:
URL: https://github.com/apache/flink/pull/21427
… configurations and synced chinese docs with non-chinese docs
## What is the purpose of the change
hotfix for Kinesis Table API docs.
Cherry pick of commits from
flinkbot commented on PR #21428:
URL: https://github.com/apache/flink/pull/21428#issuecomment-1331975142
## CI report:
* 9851856df58193890cef4e7121412bf6f25870a5 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
zhipeng93 commented on PR #186:
URL: https://github.com/apache/flink-ml/pull/186#issuecomment-1331976083
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
zjureel opened a new pull request, #410:
URL: https://github.com/apache/flink-table-store/pull/410
Introduce time travel reading for 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 go to
[
https://issues.apache.org/jira/browse/FLINK-29466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-29466:
---
Fix Version/s: jdbc-3.0.0
> Update org.postgresql:postgresql to 42.5.0
>
[
https://issues.apache.org/jira/browse/FLINK-30046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17641239#comment-17641239
]
Tobias Hofer commented on FLINK-30046:
--
Hi [~mbalassi], I'm sorry for the situation. I try to
XComp commented on PR #21428:
URL: https://github.com/apache/flink/pull/21428#issuecomment-1331986138
I force-pushed a change where I got rid of the timeout entirely and use
`assertThatThrownBy`, instead.
--
This is an automated message from the Apache Git Service.
To respond to the
ming li created FLINK-30251:
---
Summary: Move the IO with DFS during abort checkpoint to an
asynchronous thread.
Key: FLINK-30251
URL: https://issues.apache.org/jira/browse/FLINK-30251
Project: Flink
wangfanming commented on PR #21431:
URL: https://github.com/apache/flink/pull/21431#issuecomment-1331994199
获取最新代码
--
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
[
https://issues.apache.org/jira/browse/FLINK-30221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17641291#comment-17641291
]
Martijn Visser commented on FLINK-30221:
[~lsy] No, the result should not be 12 from your
[
https://issues.apache.org/jira/browse/FLINK-30221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-30221.
--
Resolution: Not A Problem
Closing because this is not a bug, but intended design.
> Fix the
[
https://issues.apache.org/jira/browse/FLINK-30221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17641291#comment-17641291
]
Martijn Visser edited comment on FLINK-30221 at 11/30/22 1:02 PM:
--
Yun Tang created FLINK-30253:
Summary: Introduce io executor for standalone checkpoint store
Key: FLINK-30253
URL: https://issues.apache.org/jira/browse/FLINK-30253
Project: Flink
Issue Type:
reta commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-opensearch/pull/1#discussion_r1035955510
##
flink-connector-opensearch/src/test/java/org/apache/flink/streaming/connectors/opensearch/OpensearchSinkTest.java:
##
@@ -79,7 +82,15 @@ public void
reta commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-opensearch/pull/1#discussion_r1035956928
##
flink-connector-opensearch/src/test/java/org/apache/flink/streaming/connectors/opensearch/OpensearchSinkTest.java:
##
@@ -0,0 +1,562 @@
+/*
+ * Licensed
reta commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-opensearch/pull/1#discussion_r1035955510
##
flink-connector-opensearch/src/test/java/org/apache/flink/streaming/connectors/opensearch/OpensearchSinkTest.java:
##
@@ -79,7 +82,15 @@ public void
rgsriram commented on code in PR #438:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/438#discussion_r1035963451
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/reconciler/sessionjob/SessionJobReconcilerTest.java:
##
@@ -232,6
XComp commented on code in PR #21416:
URL: https://github.com/apache/flink/pull/21416#discussion_r1035964091
##
flink-connectors/flink-connector-datagen/src/test/java/org/apache/flink/connector/datagen/source/DataGeneratorSourceITCase.java:
##
@@ -195,40 +195,31 @@ void
rgsriram commented on code in PR #438:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/438#discussion_r1035964102
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/reconciler/sessionjob/SessionJobReconcilerTest.java:
##
@@ -232,6
[
https://issues.apache.org/jira/browse/FLINK-27944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17641316#comment-17641316
]
Weijie Guo commented on FLINK-27944:
[~pnowojski] Thanks for re-assigning this to me, I will take
[
https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17641318#comment-17641318
]
Matthias Pohl commented on FLINK-28440:
---
FLINK-28898 and FLINK-28440 both are caused by some
1 - 100 of 241 matches
Mail list logo
