gyfora commented on code in PR #740:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/740#discussion_r1452029084
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/AbstractFlinkService.java:
##
@@ -369,16 +370,17 @@ protected vo
gyfora commented on code in PR #740:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/740#discussion_r1452031302
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/AbstractFlinkService.java:
##
@@ -369,16 +370,17 @@ protected vo
waywtdcc created FLINK-34086:
Summary: Native k8s session cannot specify port in nodeport mode
Key: FLINK-34086
URL: https://issues.apache.org/jira/browse/FLINK-34086
Project: Flink
Issue Type: B
[
https://issues.apache.org/jira/browse/FLINK-34076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiabao Sun updated FLINK-34076:
---
Attachment: screenshot-2.png
> flink-connector-base missing fails kinesis table sink to create
> ---
[
https://issues.apache.org/jira/browse/FLINK-34076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806677#comment-17806677
]
Jiabao Sun commented on FLINK-34076:
Hi [~khanhvu],
The flink-connector-base is alr
reswqa commented on code in PR #23927:
URL: https://github.com/apache/flink/pull/23927#discussion_r1452038225
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultSubpartitionIndexSet.java:
##
@@ -0,0 +1,73 @@
+/*
+ * Licensed to the Apache Software
zhuzhurk closed pull request #23852: [FLINK-33576][core] Introduce new Flink
conf file 'config.yaml' supporting standard YAML syntax.
URL: https://github.com/apache/flink/pull/23852
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
Sxnan opened a new pull request, #24089:
URL: https://github.com/apache/flink/pull/24089
## What is the purpose of the change
This PR updates ConfigConstants.java to deprecate and replace string
configuration keys and marks unused constants in ConfigConstants.java as
deprecated.
[
https://issues.apache.org/jira/browse/FLINK-34083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34083:
---
Labels: pull-request-available (was: )
> Deprecate string configuration keys and unused con
[
https://issues.apache.org/jira/browse/FLINK-33576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-33576.
---
Fix Version/s: 1.19.0
Resolution: Done
master/release-1.19:
ddc7171dd83ade50e6b551d3bc2d31acb5ff6451
gyfora commented on code in PR #741:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/741#discussion_r1452035678
##
flink-autoscaler-plugin-jdbc/src/main/java/org/apache/flink/autoscaler/jdbc/state/JDBCStore.java:
##
@@ -0,0 +1,92 @@
+/*
+ * Licensed to the Apache
xishuaidelin commented on code in PR #23827:
URL: https://github.com/apache/flink/pull/23827#discussion_r1451985731
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/aggregate/JsonObjectAggFunction.java:
##
@@ -128,6 +137,15 @@ public void
reswqa commented on code in PR #23927:
URL: https://github.com/apache/flink/pull/23927#discussion_r1452042605
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/BufferAccumulator.java:
##
@@ -65,4 +63,11 @@ void receive(
* Cl
reswqa commented on code in PR #23927:
URL: https://github.com/apache/flink/pull/23927#discussion_r1452042917
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/BufferAccumulator.java:
##
@@ -65,4 +63,11 @@ void receive(
* Cl
flinkbot commented on PR #24089:
URL: https://github.com/apache/flink/pull/24089#issuecomment-1891540555
## CI report:
* d143bfa73830c502047f51b2c4328337aa37ce06 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Sxnan opened a new pull request, #24090:
URL: https://github.com/apache/flink/pull/24090
## What is the purpose of the change
This PR updates FileInputFormat.java, FileOutputFormat.java,
BinaryInputFormat.java, and BinaryOutputFormat.java to deprecate unused string
configuration keys
[
https://issues.apache.org/jira/browse/FLINK-34084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34084:
---
Labels: pull-request-available (was: )
> Deprecate unused configuration in BinaryInput/Outp
flinkbot commented on PR #24090:
URL: https://github.com/apache/flink/pull/24090#issuecomment-1891562870
## CI report:
* e3a7bb6a816e6565dc81336e4ffa4167997c8d27 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
twalthr merged PR #24076:
URL: https://github.com/apache/flink/pull/24076
--
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.apach
[
https://issues.apache.org/jira/browse/FLINK-34067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-34067.
Fix Version/s: 1.19.0
Resolution: Fixed
Fixed in master: 96eea964d2a75d9d953bb14485ed40c9b3
yunfengzhou-hub commented on code in PR #23927:
URL: https://github.com/apache/flink/pull/23927#discussion_r1452075751
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultSubpartitionIndexSet.java:
##
@@ -0,0 +1,73 @@
+/*
+ * Licensed to the Apache
yunfengzhou-hub commented on code in PR #23927:
URL: https://github.com/apache/flink/pull/23927#discussion_r1452075751
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultSubpartitionIndexSet.java:
##
@@ -0,0 +1,73 @@
+/*
+ * Licensed to the Apache
yunfengzhou-hub commented on code in PR #23927:
URL: https://github.com/apache/flink/pull/23927#discussion_r1452075751
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultSubpartitionIndexSet.java:
##
@@ -0,0 +1,73 @@
+/*
+ * Licensed to the Apache
justin-chen opened a new pull request, #755:
URL: https://github.com/apache/flink-kubernetes-operator/pull/755
## What is the purpose of the change
https://issues.apache.org/jira/browse/FLINK-33803
This pull requests adds the `observedGeneration` field to the
`FlinkDeployme
gaborgsomogyi merged PR #23930:
URL: https://github.com/apache/flink/pull/23930
--
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
[
https://issues.apache.org/jira/browse/FLINK-33803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33803:
---
Labels: pull-request-available (was: )
> Add observedGeneration to Operator's status spec
>
[
https://issues.apache.org/jira/browse/FLINK-33268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi resolved FLINK-33268.
---
Resolution: Fixed
[{{19cb9de}}|https://github.com/apache/flink/commit/19cb9de5c54b9535be15ca
JunRuiLee opened a new pull request, #24091:
URL: https://github.com/apache/flink/pull/24091
## What is the purpose of the change
Because now FLINK shell scripts will read and modify the configuration file
in flink-docker scenarios or when executing e2e tests, the transition f
[
https://issues.apache.org/jira/browse/FLINK-33268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi closed FLINK-33268.
-
> Flink REST API response parsing throws exception on new fields
> -
[
https://issues.apache.org/jira/browse/FLINK-33268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi updated FLINK-33268:
--
Fix Version/s: 1.19.0
> Flink REST API response parsing throws exception on new fields
> -
[
https://issues.apache.org/jira/browse/FLINK-33721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33721:
---
Labels: pull-request-available (was: )
> Extend BashJavaUtils to Support Reading and Writin
[
https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806699#comment-17806699
]
Matthias Pohl edited comment on FLINK-34007 at 1/15/24 8:56 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806699#comment-17806699
]
Matthias Pohl commented on FLINK-34007:
---
If the annotation is the problem, I would
Jiabao Sun created FLINK-34087:
--
Summary: [JUnit5 Migration] Module: flink-dist
Key: FLINK-34087
URL: https://issues.apache.org/jira/browse/FLINK-34087
Project: Flink
Issue Type: Sub-task
Jiabao-Sun opened a new pull request, #24092:
URL: https://github.com/apache/flink/pull/24092
## What is the purpose of the change
[FLINK-34087][tests][JUnit5 Migration] Migarate to junit5 of flink-dist
module
## Brief change log
Migarate to junit5 of flink-dist
[
https://issues.apache.org/jira/browse/FLINK-34087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34087:
---
Labels: pull-request-available (was: )
> [JUnit5 Migration] Module: flink-dist
> --
[
https://issues.apache.org/jira/browse/FLINK-33816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806705#comment-17806705
]
Jiabao Sun commented on FLINK-33816:
Resuming the first breakpoint will unblock the
flinkbot commented on PR #24091:
URL: https://github.com/apache/flink/pull/24091#issuecomment-1891634125
## CI report:
* 261bba4cbdb30ded3a8052913d71d71b112bcc98 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
blackpighe created FLINK-34088:
--
Summary: [hotfix] fix the problems with special table name
characters of postgres and oracle and sqlserver.
Key: FLINK-34088
URL: https://issues.apache.org/jira/browse/FLINK-34088
[
https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806699#comment-17806699
]
Matthias Pohl edited comment on FLINK-34007 at 1/15/24 9:17 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-34088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
blackpighe updated FLINK-34088:
---
Remaining Estimate: 48h (was: 2h)
Original Estimate: 48h (was: 2h)
> [hotfix] fix the problem
flinkbot commented on PR #24092:
URL: https://github.com/apache/flink/pull/24092#issuecomment-1891655576
## CI report:
* bc1b87e8dd30159713c219f489d6e9b5a8e6c70c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806714#comment-17806714
]
Yang Wang commented on FLINK-34007:
---
Maybe this issue is related with fabric8 K8s clie
[
https://issues.apache.org/jira/browse/FLINK-33849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge closed FLINK-33849.
---
Resolution: Won't Fix
> No need for patch release - Update reference data for Migration Tests
>
[
https://issues.apache.org/jira/browse/FLINK-33849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge reassigned FLINK-33849:
---
Assignee: (was: Sergey Nuyanzin)
> No need for patch release - Update reference data for Migrat
[
https://issues.apache.org/jira/browse/FLINK-34076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806720#comment-17806720
]
Khanh Vu commented on FLINK-34076:
--
I'm aware of the IntelliJ feature, it wont work wit
[
https://issues.apache.org/jira/browse/FLINK-33839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge updated FLINK-33839:
Summary: Deploy Python artifacts to PyPI (was: Deploy Python artifacts to
PyPI (need PMC role))
> Deploy
[
https://issues.apache.org/jira/browse/FLINK-34076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806720#comment-17806720
]
Khanh Vu edited comment on FLINK-34076 at 1/15/24 9:46 AM:
---
I'
[
https://issues.apache.org/jira/browse/FLINK-33839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge reassigned FLINK-33839:
---
Assignee: Jing Ge
> Deploy Python artifacts to PyPI
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-34076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiabao Sun updated FLINK-34076:
---
Attachment: screenshot-3.png
> flink-connector-base missing fails kinesis table sink to create
> ---
[
https://issues.apache.org/jira/browse/FLINK-34076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806723#comment-17806723
]
Jiabao Sun commented on FLINK-34076:
The purpose of "Stop bundling connector-base in
[
https://issues.apache.org/jira/browse/FLINK-34076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806725#comment-17806725
]
Khanh Vu commented on FLINK-34076:
--
hm, I dont see it's there:
https://github.com/apac
[
https://issues.apache.org/jira/browse/FLINK-34076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806727#comment-17806727
]
Khanh Vu commented on FLINK-34076:
--
> In fact, users do not need to explicitly declare
AncyRominus commented on PR #733:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/733#issuecomment-1891799251
Thank you @gyfora ! I have incorporated the review comments. Please re-review
--
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/FLINK-33679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806730#comment-17806730
]
Zakelly Lan commented on FLINK-33679:
-
Ah... I think the doc is misleading by the wo
[
https://issues.apache.org/jira/browse/FLINK-34071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806733#comment-17806733
]
Hong Liang Teoh commented on FLINK-34071:
-
As discussed offline, wonder if we ca
tanjialiang created FLINK-34089:
---
Summary: Missing check of subscribed and assigned topics at job
startup
Key: FLINK-34089
URL: https://issues.apache.org/jira/browse/FLINK-34089
Project: Flink
ljz2051 opened a new pull request, #24093:
URL: https://github.com/apache/flink/pull/24093
…e.state.heap to o.a.f.runtime.state package
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RP
[
https://issues.apache.org/jira/browse/FLINK-34078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34078:
---
Labels: pull-request-available (was: )
> Move InternalKeyContext classes from o.a.f.runtime
[
https://issues.apache.org/jira/browse/FLINK-34076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806736#comment-17806736
]
Khanh Vu commented on FLINK-34076:
--
The `flink-connector-base` is in `flink-connector-a
[
https://issues.apache.org/jira/browse/FLINK-20284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806739#comment-17806739
]
Thai Luong commented on FLINK-20284:
Dear [~hxbks2ks] , [~dian.fu] ,
This issue
[
https://issues.apache.org/jira/browse/FLINK-20284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806739#comment-17806739
]
Thai Luong edited comment on FLINK-20284 at 1/15/24 10:46 AM:
[
https://issues.apache.org/jira/browse/FLINK-34089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34089:
---
Labels: pull-request-available (was: )
> Missing check of subscribed and assigned topics at
flinkbot commented on PR #24093:
URL: https://github.com/apache/flink/pull/24093#issuecomment-1891865739
## CI report:
* 9ae5117d0de3ee3f62a221c0983fac45ed04c201 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Tan-JiaLiang opened a new pull request, #77:
URL: https://github.com/apache/flink-connector-kafka/pull/77
## What is the purpose of the change
When we unsubscribe a topic and still restore from the old state, the job
will still read data from the unsubscribed topic. I think we
[
https://issues.apache.org/jira/browse/FLINK-34076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806720#comment-17806720
]
Khanh Vu edited comment on FLINK-34076 at 1/15/24 10:48 AM:
1996fanrui commented on code in PR #741:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/741#discussion_r145878
##
flink-autoscaler-standalone/src/main/java/org/apache/flink/autoscaler/standalone/config/AutoscalerStandaloneOptions.java:
##
@@ -59,4 +64,47 @@ p
[
https://issues.apache.org/jira/browse/FLINK-34076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806747#comment-17806747
]
Jiabao Sun commented on FLINK-34076:
flink-connector-base has already been included
gyfora commented on PR #741:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/741#issuecomment-1891917454
@1996fanrui would be great if Flink had environment variable resolution in
the conf but an alternative would be an extra config called:
`state-store.jdbc.password-env` whe
Fang Yong created FLINK-34090:
-
Summary: Introduce SerializerConfig for serialization
Key: FLINK-34090
URL: https://issues.apache.org/jira/browse/FLINK-34090
Project: Flink
Issue Type: Sub-task
gyfora merged PR #733:
URL: https://github.com/apache/flink-kubernetes-operator/pull/733
--
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-33632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-33632.
--
Fix Version/s: kubernetes-operator-1.8.0
Resolution: Fixed
merged to main 70b2d9ef812fc951ce6f2
[
https://issues.apache.org/jira/browse/FLINK-34076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806756#comment-17806756
]
Danny Cranmer commented on FLINK-34076:
---
> flink-connector-base has already been i
[
https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806759#comment-17806759
]
Matthias Pohl commented on FLINK-34007:
---
But it should be an issue that is availab
[
https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806759#comment-17806759
]
Matthias Pohl edited comment on FLINK-34007 at 1/15/24 11:24 AM:
-
1996fanrui commented on PR #741:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/741#issuecomment-1891987378
> @1996fanrui would be great if Flink had environment variable resolution in
the conf but an alternative would be an extra config called:
`state-store.jdbc.password-en
[
https://issues.apache.org/jira/browse/FLINK-24332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806763#comment-17806763
]
Yang Wang commented on FLINK-24332:
---
We do not need this feature now since Kubernetes
[
https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806759#comment-17806759
]
Matthias Pohl edited comment on FLINK-34007 at 1/15/24 11:38 AM:
-
mxm commented on code in PR #751:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/751#discussion_r1452269988
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingExecutor.java:
##
@@ -247,6 +254,69 @@ private boolean isJobUnderMemoryPressure(
[
https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806759#comment-17806759
]
Matthias Pohl edited comment on FLINK-34007 at 1/15/24 11:41 AM:
-
mxm commented on code in PR #751:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/751#discussion_r1452274233
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/resources/ResourceCheck.java:
##
@@ -0,0 +1,39 @@
+/*
+ * Licensed to the Apache Software Fou
mxm commented on PR #754:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/754#issuecomment-1892013809
Thanks!
--
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.
mxm merged PR #754:
URL: https://github.com/apache/flink-kubernetes-operator/pull/754
--
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...
dawidwys merged PR #24070:
URL: https://github.com/apache/flink/pull/24070
--
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.apac
[
https://issues.apache.org/jira/browse/FLINK-32815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-32815.
Fix Version/s: 1.19.0
Resolution: Implemented
Implemented in
36542c134b1d4482b3785
[
https://issues.apache.org/jira/browse/FLINK-32815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz reassigned FLINK-32815:
Assignee: Hanyu Zheng
> Add HASHCODE support in Table API
> -
mxm commented on code in PR #755:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/755#discussion_r1452280124
##
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/status/FlinkDeploymentStatus.java:
##
@@ -55,4 +55,7 @@ public clas
dawidwys merged PR #23612:
URL: https://github.com/apache/flink/pull/23612
--
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.apac
eskabetxe commented on PR #87:
URL:
https://github.com/apache/flink-connector-jdbc/pull/87#issuecomment-1892023980
> @zhilinli123 I still don't understand the Jira ticket, so I can't really
review it. Perhaps @snuyanzin or @eskabetxe understand the goal of this PR.
For what I can ass
[
https://issues.apache.org/jira/browse/FLINK-31481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-31481.
Fix Version/s: 1.19.0
Resolution: Implemented
Implemented in 6c050e92040802f6866eb5
[
https://issues.apache.org/jira/browse/FLINK-31481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz reassigned FLINK-31481:
Assignee: Jeyhun Karimov
> Support enhanced show databases syntax
> -
[
https://issues.apache.org/jira/browse/FLINK-31481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz reassigned FLINK-31481:
Assignee: Jeyhun Karimov (was: Jeyhun Karimov)
> Support enhanced show databases
1996fanrui commented on code in PR #751:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/751#discussion_r1452286568
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/resources/ResourceCheck.java:
##
@@ -0,0 +1,39 @@
+/*
+ * Licensed to the Apache Softw
[
https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806759#comment-17806759
]
Matthias Pohl edited comment on FLINK-34007 at 1/15/24 11:57 AM:
-
eskabetxe commented on code in PR #2:
URL:
https://github.com/apache/flink-connector-jdbc/pull/2#discussion_r1452316648
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/sink/committer/JdbcCommitable.java:
##
@@ -0,0 +1,39 @@
+package org.apache.flink.connec
eskabetxe commented on code in PR #2:
URL:
https://github.com/apache/flink-connector-jdbc/pull/2#discussion_r1452316874
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/sink/committer/JdbcCommitableSerializer.java:
##
@@ -0,0 +1,37 @@
+package org.apache.fl
eskabetxe commented on code in PR #2:
URL:
https://github.com/apache/flink-connector-jdbc/pull/2#discussion_r1452321352
##
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/sink/writer/ExactlyOnceJdbcWriterTest.java:
##
@@ -0,0 +1,105 @@
+package org.apache.fli
eskabetxe commented on code in PR #2:
URL:
https://github.com/apache/flink-connector-jdbc/pull/2#discussion_r1452321599
##
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/sink/writer/AlLeastOnceJdbcWriterTest.java:
##
@@ -0,0 +1,88 @@
+package org.apache.flin
yangyijun created FLINK-34091:
-
Summary: Flink pulsar connect adds automatic failover capability
Key: FLINK-34091
URL: https://issues.apache.org/jira/browse/FLINK-34091
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806782#comment-17806782
]
Matthias Pohl commented on FLINK-34007:
---
{quote}
At least based on the reports of
1 - 100 of 329 matches
Mail list logo
