flinkbot commented on PR #20920:
URL: https://github.com/apache/flink/pull/20920#issuecomment-1261806646
## CI report:
* 4c69f78d0646496c19c8e440ec1d8eea40a5a624 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #20919:
URL: https://github.com/apache/flink/pull/20919#issuecomment-1261803345
## CI report:
* 13768998641e373b578b2ad46b3369f854432b8d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
tisonkun commented on PR #20911:
URL: https://github.com/apache/flink/pull/20911#issuecomment-1261882204
Although test fails should be unrelated, IIRC someone said you should get CI
passed to merge a patch, lol. Rerun.
--
This is an automated message from the Apache Git Service.
To
MartijnVisser merged PR #20660:
URL: https://github.com/apache/flink/pull/20660
--
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-29465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17610875#comment-17610875
]
Gyula Fora commented on FLINK-29465:
What is the limit factor? What does the setting do?
> Supports
Martijn Visser created FLINK-29467:
--
Summary: Sync RabbitMQ CI setup with Elasticsearch CI setup
Key: FLINK-29467
URL: https://issues.apache.org/jira/browse/FLINK-29467
Project: Flink
Issue
flinkbot commented on PR #20922:
URL: https://github.com/apache/flink/pull/20922#issuecomment-1261977337
## CI report:
* d373af8a09a0a1f89fd2adbdc539ca7e537ad8a9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Gyula Fora created FLINK-29464:
--
Summary: JobID generation logic could lead to state loss
Key: FLINK-29464
URL: https://issues.apache.org/jira/browse/FLINK-29464
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-29464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17610847#comment-17610847
]
Gyula Fora commented on FLINK-29464:
cc [~thw]
> JobID generation logic could lead to state loss
>
Xin Hao created FLINK-29465:
---
Summary: Supports limit factor in the resource definition
Key: FLINK-29465
URL: https://issues.apache.org/jira/browse/FLINK-29465
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-29307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29307:
---
Labels: pull-request-available (was: )
> Fix timeInQueue in CheckpointRequestDecider
>
Martijn Visser created FLINK-29466:
--
Summary: Update org.postgresql:postgresql to 42.5.0
Key: FLINK-29466
URL: https://issues.apache.org/jira/browse/FLINK-29466
Project: Flink
Issue Type:
flinkbot commented on PR #20923:
URL: https://github.com/apache/flink/pull/20923#issuecomment-1261984970
## CI report:
* 3c1dacd6ffe7cee58d73efa10527719c77ba5bf7 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
fredia commented on PR #20921:
URL: https://github.com/apache/flink/pull/20921#issuecomment-1262043427
Thanks for this PR, LGTM.
@curcur Would like to take a look?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
[
https://issues.apache.org/jira/browse/FLINK-29465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17610924#comment-17610924
]
Xin Hao commented on FLINK-29465:
-
yes, make sense, will give a try
> Supports limit factor in the
[
https://issues.apache.org/jira/browse/FLINK-29465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xin Hao closed FLINK-29465.
---
Resolution: Not A Problem
> Supports limit factor in the resource definition
>
[
https://issues.apache.org/jira/browse/FLINK-29307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17610841#comment-17610841
]
chenzihao commented on FLINK-29307:
---
[~Yanfei Lei] Thanks for your response. I will submit a PR to fix
[
https://issues.apache.org/jira/browse/FLINK-29465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xin Hao updated FLINK-29465:
Description:
Can we add limit factor supports in the resource definition?
{code:java}
public class
[
https://issues.apache.org/jira/browse/FLINK-28998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-28998.
--
Fix Version/s: 1.17.0
(was: 1.15.1)
Resolution: Fixed
Fixed in
[
https://issues.apache.org/jira/browse/FLINK-29465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17610891#comment-17610891
]
Xin Hao commented on FLINK-29465:
-
We currently set the pod resources request and limit the same base on
Aoboyan opened a new pull request, #20923:
URL: https://github.com/apache/flink/pull/20923
## 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
zentol merged PR #20911:
URL: https://github.com/apache/flink/pull/20911
--
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-29436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-29436.
Fix Version/s: 1.17.0
Resolution: Fixed
master:
[
https://issues.apache.org/jira/browse/FLINK-29436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-29436:
-
Summary: Upgrade Spotless Maven Plugin to 2.27.1 (was: Upgrade Spotless
Maven Plugin
[
https://issues.apache.org/jira/browse/FLINK-29308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17610914#comment-17610914
]
Zhu Zhu commented on FLINK-29308:
-
[~aitozi] would you share more details of the failed job?
- Flink
reswqa commented on PR #20918:
URL: https://github.com/apache/flink/pull/20918#issuecomment-1262012685
@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-29298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29298:
---
Labels: pull-request-available (was: )
> LocalBufferPool request buffer from
MartijnVisser commented on PR #20370:
URL: https://github.com/apache/flink/pull/20370#issuecomment-1261873888
@mas-chen There are a couple of holidays coming up, but I've asked
@PatrickRen for a review
--
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-29307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei reassigned FLINK-29307:
--
Assignee: chenzihao
> Fix timeInQueue in CheckpointRequestDecider
>
tisonkun commented on PR #20911:
URL: https://github.com/apache/flink/pull/20911#issuecomment-1261881712
@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.
chenzihao5 opened a new pull request, #20921:
URL: https://github.com/apache/flink/pull/20921
## What is the purpose of the change
Fix timeInQueue in CheckpointRequestDecider so that the log can be output
correctly.
## Brief change log
Modify the time in
[
https://issues.apache.org/jira/browse/FLINK-29465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17610891#comment-17610891
]
Xin Hao edited comment on FLINK-29465 at 9/29/22 8:42 AM:
--
We currently set the
[
https://issues.apache.org/jira/browse/FLINK-29465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17610895#comment-17610895
]
Xin Hao commented on FLINK-29465:
-
This is useful for decreasing cloud costs. :)
> Supports limit
[
https://issues.apache.org/jira/browse/FLINK-29465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17610906#comment-17610906
]
Gyula Fora commented on FLINK-29465:
You can already set this easily through `flinkConfiguration`
flinkbot commented on PR #20921:
URL: https://github.com/apache/flink/pull/20921#issuecomment-1261910598
## CI report:
* 8fe7ef59c4a6268e4aa7240b7f299c8e66a6948b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xin Hao updated FLINK-29465:
Description:
Can we add limit factor supports in the resource definition?
{code:java}
public class
snuyanzin opened a new pull request, #20922:
URL: https://github.com/apache/flink/pull/20922
## 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
reswqa opened a new pull request, #20924:
URL: https://github.com/apache/flink/pull/20924
## What is the purpose of the change
*when the task thread polled out the last buffer in `LocalBufferPool` and
triggered the `onGlobalPoolAvailable` callback itself, it will skip this
flinkbot commented on PR #20924:
URL: https://github.com/apache/flink/pull/20924#issuecomment-1262026277
## CI report:
* 89f58fe1ce383343272fd4b45c11d6e477a6623d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Sergey Nuyanzin created FLINK-29468:
---
Summary: Update jackson-bom to 2.13.4
Key: FLINK-29468
URL: https://issues.apache.org/jira/browse/FLINK-29468
Project: Flink
Issue Type: Technical
tisonkun commented on PR #20584:
URL: https://github.com/apache/flink/pull/20584#issuecomment-1262707166
Root cause located: https://github.com/apache/pulsar/issues/17876.
Workaround pushed by @syhily
--
This is an automated message from the Apache Git Service.
To respond to the
tisonkun commented on PR #20584:
URL: https://github.com/apache/flink/pull/20584#issuecomment-1262706618
@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-29474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-29474.
--
Resolution: Fixed
> Name collision: Group already contains a Metric with the name
>
gyfora merged PR #392:
URL: https://github.com/apache/flink-kubernetes-operator/pull/392
--
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:
gyfora merged PR #387:
URL: https://github.com/apache/flink-kubernetes-operator/pull/387
--
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 code in PR #40:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/40#discussion_r983963215
##
pom.xml:
##
@@ -901,484 +417,25 @@ under the License.
maven-compiler-plugin
-
zentol commented on code in PR #40:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/40#discussion_r983961297
##
pom.xml:
##
@@ -68,45 +50,25 @@ under the License.
-
UTF-8
-
UTF-8
-
gyfora merged PR #389:
URL: https://github.com/apache/flink-kubernetes-operator/pull/389
--
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 code in PR #40:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/40#discussion_r983962292
##
pom.xml:
##
@@ -408,380 +370,15 @@ under the License.
flink-sql-connector-elasticsearch7
morhidi commented on PR #390:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/390#issuecomment-1262563044
+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
[
https://issues.apache.org/jira/browse/FLINK-29474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29474:
---
Labels: pull-request-available (was: )
> Name collision: Group already contains a Metric
[
https://issues.apache.org/jira/browse/FLINK-29471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29471:
---
Labels: pull-request-available (was: )
> Create a flink-connector-parent pom
>
[
https://issues.apache.org/jira/browse/FLINK-28875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-28875:
---
Fix Version/s: kubernetes-operator-1.3.0
(was: kubernetes-operator-1.2.0)
>
[
https://issues.apache.org/jira/browse/FLINK-28645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-28645:
---
Fix Version/s: kubernetes-operator-1.3.0
(was: kubernetes-operator-1.2.0)
>
zentol commented on code in PR #40:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/40#discussion_r983955227
##
.github/workflows/ci.yml:
##
@@ -69,7 +69,7 @@ jobs:
- name: Check licensing
run: |
- mvn ${MVN_COMMON_OPTIONS}
zentol commented on code in PR #40:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/40#discussion_r983961607
##
pom.xml:
##
@@ -408,380 +370,15 @@ under the License.
flink-sql-connector-elasticsearch7
sap1ens commented on PR #390:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/390#issuecomment-1262585572
Perfect, thanks It does look pretty easy.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
zentol commented on code in PR #40:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/40#discussion_r983959761
##
pom.xml:
##
@@ -68,45 +50,25 @@ under the License.
-
UTF-8
-
UTF-8
-
gyfora commented on PR #391:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/391#issuecomment-1262609759
cc @morhidi
--
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, #391:
URL: https://github.com/apache/flink-kubernetes-operator/pull/391
## What is the purpose of the change
Fix the metric group of the global lifecycle metric histograms to contain
resource type and thus avoid collision.
## Brief change log
zentol opened a new pull request, #40:
URL: https://github.com/apache/flink-connector-elasticsearch/pull/40
Also increases CI timeouts a little bit since they are too strict.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
zentol commented on code in PR #40:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/40#discussion_r98392
##
pom.xml:
##
@@ -20,9 +20,9 @@ under the License.
xmlns="http://maven.apache.org/POM/4.0.0;
[
https://issues.apache.org/jira/browse/FLINK-29474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611200#comment-17611200
]
Gyula Fora commented on FLINK-29474:
merged to main 3ae66dbddd4126a19c1e8f0105027bc370f5e753
> Name
[
https://issues.apache.org/jira/browse/FLINK-29464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-29464.
--
Resolution: Fixed
merged to main c33e3ef06296974af47b24f499aef71944c60a4d
> JobID generation logic
gyfora merged PR #390:
URL: https://github.com/apache/flink-kubernetes-operator/pull/390
--
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-29469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-29469.
--
Resolution: Fixed
merged to main ed433cea2b2ea079b9966fa15c31dc5177e46961
> Generate noop.jar
xintongsong closed pull request #20918: [FLINK-29460] fix the unstable test
HsResultPartitionTest.testRelease
URL: https://github.com/apache/flink/pull/20918
--
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
tisonkun commented on PR #20915:
URL: https://github.com/apache/flink/pull/20915#issuecomment-1263012489
@HuangXingBo This patch adds end-to-end tests for Flink Pulsar connector and
I think it's good for backporting to 1.16. However, to pass the end-to-end
tests it adjusts some production
tisonkun commented on PR #20916:
URL: https://github.com/apache/flink/pull/20916#issuecomment-1263010622
@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.
Juntao Hu created FLINK-29477:
-
Summary: ClassCastException when collect primitive array to Python
Key: FLINK-29477
URL: https://issues.apache.org/jira/browse/FLINK-29477
Project: Flink
Issue
HuangXingBo commented on PR #20915:
URL: https://github.com/apache/flink/pull/20915#issuecomment-1263069145
Yes. Make sense to me.
--
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-29308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611349#comment-17611349
]
Zhu Zhu commented on FLINK-29308:
-
It's possible that the released resource cannot fulfill the new slot
[
https://issues.apache.org/jira/browse/FLINK-29479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611358#comment-17611358
]
jackylau commented on FLINK-29479:
--
hi [~dianfu] [~hxbks2ks] , what do you think?
> support whether
[
https://issues.apache.org/jira/browse/FLINK-29479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611359#comment-17611359
]
jackylau commented on FLINK-29479:
--
{code:java}
// conf like
/** Whether preserves system env of
jackylau created FLINK-29479:
Summary: support whether using system env for pythonpath
Key: FLINK-29479
URL: https://issues.apache.org/jira/browse/FLINK-29479
Project: Flink
Issue Type: Bug
HuangXingBo commented on PR #20915:
URL: https://github.com/apache/flink/pull/20915#issuecomment-1263059241
@tisonkun Thanks a lot for the info. I prepared rc1 and have pushed the tag
yesterday. When the release announcement is ready in the form of PR, I will
send the vote email today.
[
https://issues.apache.org/jira/browse/FLINK-29308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611337#comment-17611337
]
Aitozi commented on FLINK-29308:
In our use case, we just ignore the {{NoResourceAvailableException}}
[
https://issues.apache.org/jira/browse/FLINK-29088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611341#comment-17611341
]
Aitozi commented on FLINK-29088:
Hi, [~twalthr] looking forward to your feedback, thanks :)
> Project
[
https://issues.apache.org/jira/browse/FLINK-29381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen closed FLINK-29381.
-
Assignee: Yufan Sheng
Resolution: Fixed
> Key_Shared subscription isn't works in the latest
gyfora merged PR #391:
URL: https://github.com/apache/flink-kubernetes-operator/pull/391
--
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-26182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen updated FLINK-26182:
--
Fix Version/s: 1.17.0
> E2E test for PulsarSink on new Flink sink testing tools
>
tisonkun merged PR #20584:
URL: https://github.com/apache/flink/pull/20584
--
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-29445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
liuzhiyong closed FLINK-29445.
--
Resolution: Abandoned
> When the decimal table column field is printed，program is error
>
[
https://issues.apache.org/jira/browse/FLINK-29308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611332#comment-17611332
]
Zhu Zhu commented on FLINK-29308:
-
That may be the cause.
If using fine grained resource,
Vancior opened a new pull request, #20928:
URL: https://github.com/apache/flink/pull/20928
## What is the purpose of the change
This PR fixes a bug that throwing ClassCastException when
`execute_and_collect` Java primitive array back to Python.
## Verifying this change
[
https://issues.apache.org/jira/browse/FLINK-29460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-29460.
Fix Version/s: 1.16.0
Resolution: Fixed
- master (1.17):
tisonkun merged PR #20916:
URL: https://github.com/apache/flink/pull/20916
--
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:
tisonkun commented on PR #20915:
URL: https://github.com/apache/flink/pull/20915#issuecomment-1263068281
> Does this PR need to cancel rc1
No.
Then I think I can merge this patch as a testing coverage improvement and
bugfix now while you can still vote on the rc1 you made
[
https://issues.apache.org/jira/browse/FLINK-26182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen updated FLINK-26182:
--
Fix Version/s: 1.15.3
(was: 1.17.0)
> E2E test for PulsarSink on new Flink
[
https://issues.apache.org/jira/browse/FLINK-29381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen updated FLINK-29381:
--
Fix Version/s: 1.15.3
> Key_Shared subscription isn't works in the latest Pulsar connector
>
tisonkun merged PR #20915:
URL: https://github.com/apache/flink/pull/20915
--
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-29381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen updated FLINK-29381:
--
Affects Version/s: 1.15.2
(was: 1.15.3)
> Key_Shared subscription isn't
[
https://issues.apache.org/jira/browse/FLINK-26182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen closed FLINK-26182.
-
Resolution: Fixed
> E2E test for PulsarSink on new Flink sink testing tools
>
[
https://issues.apache.org/jira/browse/FLINK-26182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen updated FLINK-26182:
--
Fix Version/s: 1.16.0
> E2E test for PulsarSink on new Flink sink testing tools
>
liuzhuang2017 commented on PR #20640:
URL: https://github.com/apache/flink/pull/20640#issuecomment-1263123390
@MartijnVisser , Sorry to bother you again, can you help me review this pull
request? grateful.
--
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-29445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611323#comment-17611323
]
liuzhiyong commented on FLINK-29445:
ok I will try.
> When the decimal table column field is
dianfu commented on code in PR #20742:
URL: https://github.com/apache/flink/pull/20742#discussion_r984165780
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/table/AggregateITCase.scala:
##
@@ -259,6 +259,30 @@ class
[
https://issues.apache.org/jira/browse/FLINK-28875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611338#comment-17611338
]
Aitozi commented on FLINK-28875:
Sorry [~gyfora], I have not start this work yet, I will try to push a
Samrat Deb created FLINK-29478:
--
Summary: Flink sql Connector hive to support 3.1.3
Key: FLINK-29478
URL: https://issues.apache.org/jira/browse/FLINK-29478
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-29477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29477:
---
Labels: pull-request-available (was: )
> ClassCastException when collect primitive array
1 - 100 of 162 matches
Mail list logo
