[
https://issues.apache.org/jira/browse/FLINK-24346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17561986#comment-17561986
]
Biao Geng edited comment on FLINK-24346 at 7/4/22 6:47 AM:
---
Hi
[
https://issues.apache.org/jira/browse/FLINK-28310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yangze Guo closed FLINK-28310.
--
Resolution: Fixed
> Introduce aggregating task metrics
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-28310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562032#comment-17562032
]
Yangze Guo commented on FLINK-28310:
master 94915d6c9e1b3a4e5f419d405a7d60c19b6bd483
KarmaGYZ closed pull request #20123: [FLINK-28310][rest] Introduce aggregating
task metrics
URL: https://github.com/apache/flink/pull/20123
--
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 specif
flinkbot commented on PR #20148:
URL: https://github.com/apache/flink/pull/20148#issuecomment-1173412566
## CI report:
* 9e8ec51bccfc20b5d384d4c9dc2bbf1d8ec640e8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
zoltar9264 commented on PR #19998:
URL: https://github.com/apache/flink/pull/19998#issuecomment-1173411039
Thanks @Myasuka , exactly as you said. I submit a new
[PR](https://github.com/apache/flink/pull/20148) .
@1996fanrui
--
This is an automated message from the Apache Git Service.
zoltar9264 opened a new pull request, #20148:
URL: https://github.com/apache/flink/pull/20148
…antees
## What is the purpose of the change
Translate the doc of checkpoint/savepoint guarantees to Chinese, described
in [FLINK-27822](https://issues.apache.org/jira/browse/FLINK-278
Myasuka commented on PR #19998:
URL: https://github.com/apache/flink/pull/19998#issuecomment-1173399426
@zoltar9264 I think this is because you used the same remote forked branch.
You might need to create another remote branch to submit another PR.
--
This is an automated message from the
zoltar9264 commented on PR #19998:
URL: https://github.com/apache/flink/pull/19998#issuecomment-1173392848
Hi @Myasuka , When I try to submit a new PR, github shows the previous PR
(this PR), and I can't find submit button.
https://user-images.githubusercontent.com/16664055/177092380-848d
knaufk commented on code in PR #554:
URL: https://github.com/apache/flink-web/pull/554#discussion_r912651898
##
_posts/2022-06-29-release-1.15.1.md:
##
@@ -0,0 +1,187 @@
+---
+layout: post
+title: "Apache Flink 1.15.1 Release Announcement"
+date: 2022-06-29T08:00:00.000Z
+categ
[
https://issues.apache.org/jira/browse/FLINK-27524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27524:
---
Labels: pull-request-available (was: )
> Introduce cache API to DataStream
> --
flinkbot commented on PR #20147:
URL: https://github.com/apache/flink/pull/20147#issuecomment-1173375305
## CI report:
* 0303561fbe09202f837f2f597dbf2ee1fe2ffc95 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Sxnan opened a new pull request, #20147:
URL: https://github.com/apache/flink/pull/20147
## What is the purpose of the change
Introduce cache API to DataStream.
## Brief change log
- Introduce `cache` method to `SingleOutputStreamOperator`.
- Introduce `Ca
[
https://issues.apache.org/jira/browse/FLINK-26086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
nyingping closed FLINK-26086.
-
Resolution: Fixed
> fixed some causing ambiguities including the 'shit' comment
> --
Myasuka commented on PR #19998:
URL: https://github.com/apache/flink/pull/19998#issuecomment-1173363015
@zoltar9264 I don't think Github could block submitting a new PR. We use
JIRA's issue system to track instead of Github's issue system, I don't know why
Github could block this.
@f
flinkbot commented on PR #20146:
URL: https://github.com/apache/flink/pull/20146#issuecomment-1173358960
## CI report:
* 1206b497fd29fd1b67e63981da5adbab16c7a0a1 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-28369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28369:
---
Labels: pull-request-available (was: )
> Support PARSE_URL bulit-in function in Table API
>
deadwind4 opened a new pull request, #20146:
URL: https://github.com/apache/flink/pull/20146
## What is the purpose of the change
Support instr and locate built-in functions in Table API.
## Brief change log
- *Support PARSE_URL built-in functions in Table API.*
-
LuNing Wang created FLINK-28369:
---
Summary: Support PARSE_URL bulit-in function in Table API
Key: FLINK-28369
URL: https://issues.apache.org/jira/browse/FLINK-28369
Project: Flink
Issue Type: Im
[
https://issues.apache.org/jira/browse/FLINK-28040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-28040:
-
Priority: Minor (was: Major)
> Introduce Trino reader for table store
> ---
[
https://issues.apache.org/jira/browse/FLINK-28040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562000#comment-17562000
]
Jingsong Lee commented on FLINK-28040:
--
Trino binary is using JDK 11.
> Introduce
[
https://issues.apache.org/jira/browse/FLINK-28063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-28063.
Assignee: Caizhi Weng
Resolution: Fixed
master: d11a287c756713c6b16a6c93291566a780f97b4a
>
JingsongLi merged PR #189:
URL: https://github.com/apache/flink-table-store/pull/189
--
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...@
flinkbot commented on PR #20145:
URL: https://github.com/apache/flink/pull/20145#issuecomment-1173319623
## CI report:
* db4fdb4f942b733539be83ef2eedc234a445c4ac UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
xintongsong commented on code in PR #20142:
URL: https://github.com/apache/flink/pull/20142#discussion_r912612048
##
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/DashboardConfiguration.java:
##
@@ -139,6 +146,11 @@ public boolean isWebCancelEnabled() {
JingsongLi commented on code in PR #104:
URL: https://github.com/apache/flink-table-store/pull/104#discussion_r912611645
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/compact/MergeFunctionHelper.java:
##
@@ -0,0 +1,73 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-28335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-28335.
Resolution: Fixed
master: c24d3d244b4ae00e599924fa8814498f98f74aab
> Delete topic after tests
> -
[
https://issues.apache.org/jira/browse/FLINK-28335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-28335:
Assignee: Nicholas Jiang
> Delete topic after tests
>
>
>
JingsongLi merged PR #188:
URL: https://github.com/apache/flink-table-store/pull/188
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@
[
https://issues.apache.org/jira/browse/FLINK-28327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-28327.
Resolution: Fixed
master: d29816af772a3507008815931a6afc3c72afe5a5
> Make table store src codes c
[
https://issues.apache.org/jira/browse/FLINK-28073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-28073.
Resolution: Fixed
> Table Store supports Flink 1.14
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-28073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-28073:
Assignee: Jingsong Lee
> Table Store supports Flink 1.14
> --
yuchengxin opened a new pull request, #20145:
URL: https://github.com/apache/flink/pull/20145
…migration
## What is the purpose of the change
This pull request adds new extensions and utils to help the Junit5 migration.
## Brief change log
- Add `Parame
JingsongLi merged PR #184:
URL: https://github.com/apache/flink-table-store/pull/184
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@
[
https://issues.apache.org/jira/browse/FLINK-27618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27618:
---
Labels: pull-request-available (was: )
> Suuport CumeDist
>
>
>
luoyuxia commented on PR #19727:
URL: https://github.com/apache/flink/pull/19727#issuecomment-1173307574
@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.
flinkbot commented on PR #20144:
URL: https://github.com/apache/flink/pull/20144#issuecomment-1173306587
## CI report:
* 5b4fd94b639113fbbed640ba890d38f03e23d971 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
zjuwangg commented on code in PR #20094:
URL: https://github.com/apache/flink/pull/20094#discussion_r912603500
##
docs/content/docs/connectors/datastream/filesystem.md:
##
@@ -315,9 +315,9 @@ final FileSink sink = FileSink
.forRowFormat(new Path(outputPath), new
SimpleStri
[
https://issues.apache.org/jira/browse/FLINK-27587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27587:
---
Labels: pull-request-available (was: )
> Support keyed co-broadcast processing in PyFlink
>
Vancior opened a new pull request, #20144:
URL: https://github.com/apache/flink/pull/20144
## What is the purpose of the change
This PR implements keyed broadcast processing (
`KeyedStream.connect(BroadcastStream).process(KeyedBroadcastProcessFunction)` )
in PyFlink.
#
[
https://issues.apache.org/jira/browse/FLINK-25315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17561989#comment-17561989
]
Yun Tang commented on FLINK-25315:
--
[~catyee] already assigned to you, please go ahead.
[
https://issues.apache.org/jira/browse/FLINK-28341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shen updated FLINK-28341:
-
Affects Version/s: 1.15.1
> Fix comment in BytesKeyNormalizationUtil.java
>
[
https://issues.apache.org/jira/browse/FLINK-25315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang reassigned FLINK-25315:
Assignee: Yuan Kui
> Add new extensions and classes to help the JUnit5 migration
> --
[
https://issues.apache.org/jira/browse/FLINK-25315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17561987#comment-17561987
]
Yuan Kui edited comment on FLINK-25315 at 7/4/22 3:25 AM:
--
I'm
[
https://issues.apache.org/jira/browse/FLINK-25315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17561987#comment-17561987
]
Yuan Kui commented on FLINK-25315:
--
I'm going to finish this work, could you assign thi
[
https://issues.apache.org/jira/browse/FLINK-24346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17561986#comment-17561986
]
Biao Geng commented on FLINK-24346:
---
Hi [~soberchi...@gamil.com] have you ever tried t
[
https://issues.apache.org/jira/browse/FLINK-28368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17561985#comment-17561985
]
Jark Wu commented on FLINK-28368:
-
It's by design. Nullability is a part of data type in
[
https://issues.apache.org/jira/browse/FLINK-28368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-28368.
---
Resolution: Not A Problem
> Get field type return result problem
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-25735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17561984#comment-17561984
]
DavidLiu commented on FLINK-25735:
--
The pull request is
[https://github.com/apache/fli
[
https://issues.apache.org/jira/browse/FLINK-28368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hunter updated FLINK-28368:
---
Component/s: Table SQL / API
(was: Client / Job Submission)
> Get field type return res
zoltar9264 commented on PR #19998:
URL: https://github.com/apache/flink/pull/19998#issuecomment-1173288658
Hi @1996fanrui , I tried to create a new PR , but github doesn't allow it
because there is already a PR for the same.
--
This is an automated message from the Apache Git Service.
To
zhuyufeng0809 commented on PR #19991:
URL: https://github.com/apache/flink/pull/19991#issuecomment-1173286177
OK, thank you for your 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 above to go to the spe
flinkbot commented on PR #20143:
URL: https://github.com/apache/flink/pull/20143#issuecomment-1173284952
## CI report:
* 8ddd8d5652744476536bc4eb7feb858a3a0d78b4 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17561979#comment-17561979
]
Jing Zhang edited comment on FLINK-27998 at 7/4/22 2:58 AM:
[
https://issues.apache.org/jira/browse/FLINK-27998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17561979#comment-17561979
]
Jing Zhang commented on FLINK-27998:
[~Sergey Nuyanzin] Sorry for late reponse.
> U
[
https://issues.apache.org/jira/browse/FLINK-25735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-25735:
---
Labels: chinese-translation pull-request-available (was:
chinese-translation)
> Chinese Tr
DavidLiu001 opened a new pull request, #20143:
URL: https://github.com/apache/flink/pull/20143
… KDS Async Sink
## What is the purpose of the change
Translate:
Connectors/Kinesis page to deprecate old sink
(docs/content/docs/connectors/datastream/kinesis.md)
Metri
[
https://issues.apache.org/jira/browse/FLINK-28368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17561976#comment-17561976
]
hunter commented on FLINK-28368:
If this is a bug, send it to me to fix it
> Get field
xintongsong commented on PR #19991:
URL: https://github.com/apache/flink/pull/19991#issuecomment-1173282190
I tend not to merge this change.
First of all, the sanity check is unnecessary for both the `if-` and the
`else-` branches here. For the `if-` branch, the sanity is guaranteed b
hunter created FLINK-28368:
--
Summary: Get field type return result problem
Key: FLINK-28368
URL: https://issues.apache.org/jira/browse/FLINK-28368
Project: Flink
Issue Type: Improvement
Co
suxinglee commented on PR #20134:
URL: https://github.com/apache/flink/pull/20134#issuecomment-1173279678
@flinkbot run azure
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
[
https://issues.apache.org/jira/browse/FLINK-28350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17561975#comment-17561975
]
Yang Wang commented on FLINK-28350:
---
AFAIK, we changed the HA format in the release-1.
flinkbot commented on PR #20142:
URL: https://github.com/apache/flink/pull/20142#issuecomment-1173273886
## CI report:
* c1a77ab9496ca0133de3a7ad94fa913399baef51 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-28291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jiulong.zhu updated FLINK-28291:
Labels: patch-available (was: pull-request-available)
> Add kerberos delegation token renewer fea
[
https://issues.apache.org/jira/browse/FLINK-28291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jiulong.zhu updated FLINK-28291:
Labels: pull-request-available (was: )
> Add kerberos delegation token renewer feature instead of
[
https://issues.apache.org/jira/browse/FLINK-28291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jiulong.zhu updated FLINK-28291:
Attachment: FLINK-28291.0001.patch
> Add kerberos delegation token renewer feature instead of logg
[
https://issues.apache.org/jira/browse/FLINK-28291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jiulong.zhu updated FLINK-28291:
Attachment: (was:
0001-add-KerberosDelegationTokenManager-to-renew-token-pe.patch)
> Add kerb
[
https://issues.apache.org/jira/browse/FLINK-28313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28313:
---
Labels: pull-request-available (was: )
> Add history server flag to DashboardConfiguration
KarmaGYZ opened a new pull request, #20142:
URL: https://github.com/apache/flink/pull/20142
## 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 them o
fredia commented on PR #20091:
URL: https://github.com/apache/flink/pull/20091#issuecomment-1173269329
@rkhachatryan could you please take a 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 above to go t
dianfu merged PR #22:
URL: https://github.com/apache/flink-connector-elasticsearch/pull/22
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubs
[
https://issues.apache.org/jira/browse/FLINK-28298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-28298.
---
Assignee: LuNing Wang
Resolution: Fixed
Merged to master via da720c3b97d5c3e781abb1e910a8337f6a5ee0e4
[
https://issues.apache.org/jira/browse/FLINK-28238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang closed FLINK-28238.
-
Resolution: Fixed
Fix in master: 7974e81ec51a2071b9658f768f651ffc371b15b0
> Fix unstable testCa
dianfu merged PR #20104:
URL: https://github.com/apache/flink/pull/20104
--
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
fsk119 merged PR #20063:
URL: https://github.com/apache/flink/pull/20063
--
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
[
https://issues.apache.org/jira/browse/FLINK-28063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28063:
---
Labels: pull-request-available (was: )
> Optimize PredicateBuilder.in for lots of parameter
tsreaper opened a new pull request, #189:
URL: https://github.com/apache/flink-table-store/pull/189
The current treatment of in is to expand into multiple equals and join them
using or.
But this does not perform well if there are particularly many parameters, we
need to introduce In'
xintongsong commented on PR #20042:
URL: https://github.com/apache/flink/pull/20042#issuecomment-1173261576
No concerns from my side.
--
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
KarmaGYZ commented on PR #20123:
URL: https://github.com/apache/flink/pull/20123#issuecomment-1173255081
PR updated.
--
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 unsu
KarmaGYZ commented on PR #20042:
URL: https://github.com/apache/flink/pull/20042#issuecomment-1173254922
@wangyang0918 @xintongsong If there's no further comment, I'll merge it.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
Myasuka commented on PR #19992:
URL: https://github.com/apache/flink/pull/19992#issuecomment-1173253243
@flinkbot run azure
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
[
https://issues.apache.org/jira/browse/FLINK-27570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17561840#comment-17561840
]
Underwood edited comment on FLINK-27570 at 7/4/22 1:53 AM:
---
[~
[
https://issues.apache.org/jira/browse/FLINK-28337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17561962#comment-17561962
]
wei commented on FLINK-28337:
-
Ok, thanks~
> java.lang.IllegalArgumentException: Table iden
Vancior commented on PR #20124:
URL: https://github.com/apache/flink/pull/20124#issuecomment-1173252406
@flinkbot run azure
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
[
https://issues.apache.org/jira/browse/FLINK-28344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17561961#comment-17561961
]
Dian Fu commented on FLINK-28344:
-
Hi, [~elademir]
There are two choices:
1) Use [ES Ta
[
https://issues.apache.org/jira/browse/FLINK-28322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-28322:
-
Description:
In FLINK-25990 ,
Add a method "DataStream produceDataStream(ProviderContext
provi
[
https://issues.apache.org/jira/browse/FLINK-28322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-28322:
-
Description:
In FLINK-25990 ,
Add a method "DataStream produceDataStream(ProviderContext
provi
[
https://issues.apache.org/jira/browse/FLINK-28355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo reassigned FLINK-28355:
Assignee: Huang Xingbo
> Python Bash e2e tests don't clean-up after they've ran, causing
[
https://issues.apache.org/jira/browse/FLINK-28322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-28322:
-
Description:
In FLINK-25990 ,
Add a method "DataStream produceDataStream(ProviderContext
provi
JingsongLi commented on code in PR #20119:
URL: https://github.com/apache/flink/pull/20119#discussion_r912568525
##
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/sink/DataStreamSinkProvider.java:
##
@@ -54,8 +54,10 @@
*
* @see
[
https://issues.apache.org/jira/browse/FLINK-28367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17561943#comment-17561943
]
Lim Qing Wei edited comment on FLINK-28367 at 7/3/22 9:30 PM:
[
https://issues.apache.org/jira/browse/FLINK-28367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17561943#comment-17561943
]
Lim Qing Wei commented on FLINK-28367:
--
I had a look, I think part of it is that we
qingwei91 commented on code in PR #20119:
URL: https://github.com/apache/flink/pull/20119#discussion_r912527749
##
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/sink/DataStreamSinkProvider.java:
##
@@ -54,8 +54,10 @@
*
* @see
knaufk merged PR #313:
URL: https://github.com/apache/flink-statefun/pull/313
--
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.a
qingwei91 commented on code in PR #20138:
URL: https://github.com/apache/flink/pull/20138#discussion_r912524224
##
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config/PulsarClientFactory.java:
##
@@ -153,8 +153,8 @@ public static
[
https://issues.apache.org/jira/browse/FLINK-28367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henrik Laxhuber updated FLINK-28367:
Priority: Minor (was: Major)
> OffsetDateTime does not work with keyBy
>
[
https://issues.apache.org/jira/browse/FLINK-28367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17561912#comment-17561912
]
Henrik Laxhuber commented on FLINK-28367:
-
A workaround is to register a custom
[
https://issues.apache.org/jira/browse/FLINK-28364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-28364:
---
Priority: Major (was: Minor)
> Python Job support for Kubernetes Operator
> ---
[
https://issues.apache.org/jira/browse/FLINK-28364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17561899#comment-17561899
]
Gyula Fora commented on FLINK-28364:
I think this would be relatively easy to add fo
[
https://issues.apache.org/jira/browse/FLINK-28364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-28364:
---
Summary: Python Job support for Kubernetes Operator (was: Job types
support Python)
> Python Job s
1 - 100 of 141 matches
Mail list logo
