[
https://issues.apache.org/jira/browse/FLINK-29385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-29385.
Fix Version/s: table-store-0.3.0
table-store-0.2.1
Resolution: Fixed
mas
JingsongLi merged PR #302:
URL: https://github.com/apache/flink-table-store/pull/302
--
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...@
RyanSkraba commented on PR #20805:
URL: https://github.com/apache/flink/pull/20805#issuecomment-1254602564
> Thanks for the contribution. I think it would be great to have a test here
confirming that the change fixes the issue
Thanks Sergey, especially for the collaboration! This was
[
https://issues.apache.org/jira/browse/FLINK-29380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiechenling updated FLINK-29380:
Attachment: screenshot-2.png
> Two streams union, watermark error, not the minimum value
> ---
[
https://issues.apache.org/jira/browse/FLINK-29380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiechenling updated FLINK-29380:
Description:
Two streams union, watermark error, not the minimum value, connect operator
waterma
[
https://issues.apache.org/jira/browse/FLINK-29380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiechenling updated FLINK-29380:
Description:
Two streams union, watermark error, not the minimum value, connect operator
waterma
zjureel commented on PR #302:
URL:
https://github.com/apache/flink-table-store/pull/302#issuecomment-1254600956
Thanks @JingsongLi @SteNicholas I have updated the codes
--
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-29380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiechenling updated FLINK-29380:
Description:
Two streams union, watermark error, not the minimum value, connect operator
waterma
[
https://issues.apache.org/jira/browse/FLINK-29380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiechenling updated FLINK-29380:
Attachment: screenshot-1.png
> Two streams union, watermark error, not the minimum value
> ---
[
https://issues.apache.org/jira/browse/FLINK-29349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17608100#comment-17608100
]
lincoln lee commented on FLINK-29349:
-
[~lsy] I took a look at the FLINK-22956, ther
zjureel commented on code in PR #302:
URL: https://github.com/apache/flink-table-store/pull/302#discussion_r977248865
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/schema/SchemaManager.java:
##
@@ -173,6 +174,15 @@ public TableSchema commitChanges(Lis
JingsongLi commented on code in PR #301:
URL: https://github.com/apache/flink-table-store/pull/301#discussion_r977245473
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/FileStoreCommitImpl.java:
##
@@ -182,26 +187,61 @@ public void commit(Mani
JingsongLi commented on code in PR #301:
URL: https://github.com/apache/flink-table-store/pull/301#discussion_r977242850
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/FileStoreCommitImpl.java:
##
@@ -479,32 +526,39 @@ private boolean tryComm
lsyldliu commented on PR #20246:
URL: https://github.com/apache/flink/pull/20246#issuecomment-1254579074
Thanks for your contribution, I will take a look as soon as possible.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
wanglijie95 commented on PR #20867:
URL: https://github.com/apache/flink/pull/20867#issuecomment-1254576835
Following configuration options are missing：
`kubernetes.jobmanager.cpu` `kubernetes.jobmanager.cpu.limit-factor`
`kubernetes.taskmanager.cpu` `kubernetes.taskmanager.cpu.limit-fa
flinkbot commented on PR #20879:
URL: https://github.com/apache/flink/pull/20879#issuecomment-1254570892
## CI report:
* 2d13d9a1ee7e775bed2a47d4037159e587efc090 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
JingsongLi commented on code in PR #302:
URL: https://github.com/apache/flink-table-store/pull/302#discussion_r977230937
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/schema/SchemaManager.java:
##
@@ -173,6 +174,15 @@ public TableSchema commitChanges(
SteNicholas commented on code in PR #302:
URL: https://github.com/apache/flink-table-store/pull/302#discussion_r977219669
##
flink-table-store-core/src/test/java/org/apache/flink/table/store/table/SchemaEvolutionTest.java:
##
@@ -120,6 +122,28 @@ public void testAddField() throw
SteNicholas commented on code in PR #302:
URL: https://github.com/apache/flink-table-store/pull/302#discussion_r977218529
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/schema/SchemaManager.java:
##
@@ -173,6 +174,15 @@ public TableSchema commitChanges
SteNicholas commented on code in PR #302:
URL: https://github.com/apache/flink-table-store/pull/302#discussion_r977217137
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/schema/SchemaManager.java:
##
@@ -173,6 +174,15 @@ public TableSchema commitChanges
sap1ens commented on code in PR #370:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/370#discussion_r977209625
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/validation/DefaultValidator.java:
##
@@ -180,10 +180,6 @@ private Option
[
https://issues.apache.org/jira/browse/FLINK-13703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17608063#comment-17608063
]
Andrei Leib commented on FLINK-13703:
-
Just hit this issue as well when setting
{co
flinkbot commented on PR #20878:
URL: https://github.com/apache/flink/pull/20878#issuecomment-1254480559
## CI report:
* 4a7c35a242f47b6345a2ab25bb1480741a9a2ee4 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
lindong28 commented on code in PR #157:
URL: https://github.com/apache/flink-ml/pull/157#discussion_r977119140
##
flink-ml-core/src/main/java/org/apache/flink/ml/common/window/WindowUtils.java:
##
@@ -0,0 +1,162 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under o
[
https://issues.apache.org/jira/browse/FLINK-29385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-29385:
Assignee: Shammon
> AddColumn in flink table store should check the duplicate field names
fsk119 opened a new pull request, #20878:
URL: https://github.com/apache/flink/pull/20878
Cherry pick fix.
--
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
[
https://issues.apache.org/jira/browse/FLINK-29385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29385:
---
Labels: pull-request-available (was: )
> AddColumn in flink table store should check the du
zjureel opened a new pull request, #302:
URL: https://github.com/apache/flink-table-store/pull/302
When we execute AddColumn ddl, we should check whether the column name is
exist. Otherwise, the ddl will be successful and the job reads this table will
create source of flink store table fail
fsk119 closed pull request #20790: [FLINK-29228][hive] Align the schema of the
HiveServer2 getMetadata with JDBC
URL: https://github.com/apache/flink/pull/20790
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
[
https://issues.apache.org/jira/browse/FLINK-29349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17608056#comment-17608056
]
dalongliu commented on FLINK-29349:
---
This is duplicated with FLINK-22956?
> Use state
[
https://issues.apache.org/jira/browse/FLINK-6573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17608051#comment-17608051
]
Leonard Xu commented on FLINK-6573:
---
I've assigned this ticket to [~jiabao.sun] as he h
[
https://issues.apache.org/jira/browse/FLINK-6573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-6573:
-
Assignee: Jiabao Sun (was: ZhuoYu Chen)
> Flink MongoDB Connector
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-27101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17606485#comment-17606485
]
Jiale Tan edited comment on FLINK-27101 at 9/22/22 3:12 AM:
[
https://issues.apache.org/jira/browse/FLINK-27101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17606485#comment-17606485
]
Jiale Tan edited comment on FLINK-27101 at 9/22/22 3:11 AM:
[
https://issues.apache.org/jira/browse/FLINK-29384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17608044#comment-17608044
]
Yang Wang commented on FLINK-29384:
---
The {{org.yaml:snakeyaml:jar:1.30}} is introduces
leletan commented on PR #20852:
URL: https://github.com/apache/flink/pull/20852#issuecomment-1254461989
@pnowojski @zentol Addressed the code comments (at least I thought I did)
and generated the docs. Please take a look whenever you have time. Thanks!
--
This is an automated message from
Shammon created FLINK-29385:
---
Summary: AddColumn in flink table store should check the duplicate
field names
Key: FLINK-29385
URL: https://issues.apache.org/jira/browse/FLINK-29385
Project: Flink
fsk119 commented on code in PR #20790:
URL: https://github.com/apache/flink/pull/20790#discussion_r977139059
##
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/endpoint/hive/HiveServer2EndpointITCase.java:
##
@@ -572,6 +595,107 @@ public void testGetIn
Sxnan commented on PR #20862:
URL: https://github.com/apache/flink/pull/20862#issuecomment-125163
@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.
To
[
https://issues.apache.org/jira/browse/FLINK-29329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17608037#comment-17608037
]
Yun Tang commented on FLINK-29329:
--
I think the problem of not triggering the checkpoin
[
https://issues.apache.org/jira/browse/FLINK-29367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29367:
---
Labels: pull-request-available (was: )
> Avoid manifest corruption for incorrect checkpoint
tsreaper opened a new pull request, #301:
URL: https://github.com/apache/flink-table-store/pull/301
When the job runs to checkpoint N, if the user recovers from an old
checkpoint (such as checkpoint N-5), the sink of the current FTS will cause a
manifest corruption because duplicate files m
wuchong commented on code in PR #20653:
URL: https://github.com/apache/flink/pull/20653#discussion_r976628561
##
docs/content/docs/dev/table/sql/create.md:
##
@@ -513,6 +516,48 @@ If you provide no like options, `INCLUDING ALL OVERWRITING
OPTIONS` will be used
**NOTE** The `
lsyldliu commented on PR #20869:
URL: https://github.com/apache/flink/pull/20869#issuecomment-1254386573
@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 #20877:
URL: https://github.com/apache/flink/pull/20877#issuecomment-1254372949
## CI report:
* acffaacb43a79c5a22771e076e52af94bfa7b94c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
liuml07 opened a new pull request, #20877:
URL: https://github.com/apache/flink/pull/20877
## What is the purpose of the change
Make doc file ide_setup.md format better after e48abd38
### Before:
https://user-images.githubusercontent.com/159186/191633961-1cd7f135-
flinkbot commented on PR #20876:
URL: https://github.com/apache/flink/pull/20876#issuecomment-1254277324
## CI report:
* 417ffb9e3b582ebc1c5741d04876f1ab33ab4b61 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
afedulov opened a new pull request, #20876:
URL: https://github.com/apache/flink/pull/20876
This is a trivial docs fix.
--
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 u
[
https://issues.apache.org/jira/browse/FLINK-18647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17607948#comment-17607948
]
Piotr Nowojski commented on FLINK-18647:
[~dkapoor1], is there some other ticket
gyfora commented on code in PR #375:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/375#discussion_r976892681
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/AbstractFlinkService.java:
##
@@ -182,7 +184,13 @@ public JobID s
HuangZhenQiu commented on code in PR #375:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/375#discussion_r976868309
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/AbstractFlinkService.java:
##
@@ -165,7 +165,8 @@ public vo
gyfora commented on code in PR #370:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/370#discussion_r976840850
##
flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/kubeclient/parameters/StandaloneKubernetesJobManagerParameters.java:
##
James Busche created FLINK-29384:
Summary: snakeyaml version 1.30 in
flink-kubernetes-operator-1.2-SNAPSHOT-shaded.jar has vulnerabilities
Key: FLINK-29384
URL: https://issues.apache.org/jira/browse/FLINK-29384
[
https://issues.apache.org/jira/browse/FLINK-18647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17607914#comment-17607914
]
Divye Kapoor edited comment on FLINK-18647 at 9/21/22 5:48 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-18647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17607914#comment-17607914
]
Divye Kapoor edited comment on FLINK-18647 at 9/21/22 5:47 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-18647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17607914#comment-17607914
]
Divye Kapoor edited comment on FLINK-18647 at 9/21/22 5:46 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-18647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17607914#comment-17607914
]
Divye Kapoor commented on FLINK-18647:
--
Since this is an improvement ticket that co
[
https://issues.apache.org/jira/browse/FLINK-18647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17607907#comment-17607907
]
Divye Kapoor commented on FLINK-18647:
--
[~pnowojski] – if the only implementation w
HuangZhenQiu commented on code in PR #20875:
URL: https://github.com/apache/flink/pull/20875#discussion_r976801184
##
flink-runtime-web/web-dashboard/src/app/app.interceptor.ts:
##
@@ -39,6 +46,16 @@ export class AppInterceptor implements HttpInterceptor {
return next.han
usamj commented on code in PR #370:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/370#discussion_r976786813
##
flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/kubeclient/parameters/StandaloneKubernetesJobManagerParameters.java:
##
[
https://issues.apache.org/jira/browse/FLINK-14896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-14896:
--
Release Note: Shade and relocate transitive Jackson dependencies of
{{flink-connector-kinesis}
[
https://issues.apache.org/jira/browse/FLINK-14896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-14896:
--
Fix Version/s: 1.17.0
> Kinesis connector doesn't shade jackson dependency
> -
[
https://issues.apache.org/jira/browse/FLINK-14896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-14896:
--
Affects Version/s: 1.15.2
> Kinesis connector doesn't shade jackson dependency
> -
[
https://issues.apache.org/jira/browse/FLINK-14896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-14896:
-
Assignee: Danny Cranmer
> Kinesis connector doesn't shade jackson dependency
>
gaborgsomogyi commented on code in PR #20875:
URL: https://github.com/apache/flink/pull/20875#discussion_r976740976
##
flink-runtime-web/web-dashboard/src/app/app.interceptor.ts:
##
@@ -39,6 +46,16 @@ export class AppInterceptor implements HttpInterceptor {
return next.ha
sap1ens commented on code in PR #370:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/370#discussion_r976723478
##
flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/kubeclient/parameters/StandaloneKubernetesJobManagerParameters.java:
#
[
https://issues.apache.org/jira/browse/FLINK-29363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17607848#comment-17607848
]
Gabor Somogyi commented on FLINK-29363:
---
I've had a deeper look at this issue and
[
https://issues.apache.org/jira/browse/FLINK-29370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17607841#comment-17607841
]
Suhan Mao commented on FLINK-29370:
---
[~libenchao] What about removing all com.google.
[
https://issues.apache.org/jira/browse/FLINK-29383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xin Hao updated FLINK-29383:
Summary: Add additionalPrinterColumns definition (PrinterColumn annotation)
for some status fields (was:
[
https://issues.apache.org/jira/browse/FLINK-29383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xin Hao updated FLINK-29383:
Summary: Add additionalPrinterColumns definition for some status fields
(was: Add additionalPrinterColumn
Xin Hao created FLINK-29383:
---
Summary: Add additionalPrinterColumns for some status fields
Key: FLINK-29383
URL: https://issues.apache.org/jira/browse/FLINK-29383
Project: Flink
Issue Type: Improve
haoxins opened a new pull request, #378:
URL: https://github.com/apache/flink-kubernetes-operator/pull/378
## What is the purpose of the change
*(For example: This pull request adds a new feature to periodically create
and maintain savepoints through the `FlinkDeployment` cust
[
https://issues.apache.org/jira/browse/FLINK-29363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17607823#comment-17607823
]
Zhenqiu Huang commented on FLINK-29363:
---
Yes, our scenarios is exactly the same as
flinkbot commented on PR #20875:
URL: https://github.com/apache/flink/pull/20875#issuecomment-1253876906
## CI report:
* 4a8f9f9f850c33780f9f0d306cd8d3842b67658e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29363:
---
Labels: pull-request-available (was: )
> Allow web ui to fully redirect to other page
> ---
HuangZhenQiu opened a new pull request, #20875:
URL: https://github.com/apache/flink/pull/20875
What is the purpose of the change
allow fully redirection in web dashboard when response status code is
MovedPermanently, TemporaryRedirect or SeeOther.
Brief change log
chang
[
https://issues.apache.org/jira/browse/FLINK-29152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-29152.
---
Fix Version/s: 1.16.0
1.17.0
Assignee: luoyuxia
Resolution: Fixed
Fixed i
wuchong merged PR #20789:
URL: https://github.com/apache/flink/pull/20789
--
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-29151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-29151.
---
Resolution: Fixed
> SHOW CREATE TABLE doesn't work for Hive dialect
> --
[
https://issues.apache.org/jira/browse/FLINK-29151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17607566#comment-17607566
]
Jark Wu edited comment on FLINK-29151 at 9/21/22 3:09 PM:
--
Fixe
gyfora commented on PR #313:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/313#issuecomment-1253848089
Yes @tedhtchang please do that. If you could write a small proposal of the
benefits and what it would mean with regards to maintenance, release process
etc compared to wha
[
https://issues.apache.org/jira/browse/FLINK-28755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-28755.
--
Resolution: Fixed
merged to main 1eca2c5e6a62bd9f1c9e752191f8a7477903d73c
> Error when switching from
wuchong merged PR #20866:
URL: https://github.com/apache/flink/pull/20866
--
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
gyfora merged PR #376:
URL: https://github.com/apache/flink-kubernetes-operator/pull/376
--
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
wuchong commented on PR #20869:
URL: https://github.com/apache/flink/pull/20869#issuecomment-1253845113
@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.
wuchong commented on code in PR #20653:
URL: https://github.com/apache/flink/pull/20653#discussion_r976322033
##
docs/content/docs/dev/table/sql/create.md:
##
@@ -513,6 +516,48 @@ If you provide no like options, `INCLUDING ALL OVERWRITING
OPTIONS` will be used
**NOTE** The `
snuyanzin commented on PR #20805:
URL: https://github.com/apache/flink/pull/20805#issuecomment-1253826144
Thanks for the contribution.
I think it would be great to have a test here confirming that the change
fixes the issue
--
This is an automated message from the Apache Git Service.
T
[
https://issues.apache.org/jira/browse/FLINK-29373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-29373:
---
Affects Version/s: (was: 1.17.0)
> DataStream to table not support BigDecimalTypeInfo
>
[
https://issues.apache.org/jira/browse/FLINK-29373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17607791#comment-17607791
]
Martijn Visser commented on FLINK-29373:
[~hk__lrzy] Which version of Flink are
[
https://issues.apache.org/jira/browse/FLINK-26203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-26203:
--
Assignee: Yufei Zhang
> Support Table API in Pulsar Connector
> -
[
https://issues.apache.org/jira/browse/FLINK-26203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17607789#comment-17607789
]
Martijn Visser commented on FLINK-26203:
[~syhily] Done.
> Support Table API i
gyfora commented on PR #377:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/377#issuecomment-1253794569
Also since now we support standalone integration we should probably add the
owner reference for both JM and TM deployments there. That should be part of
the PR
+ so
[
https://issues.apache.org/jira/browse/FLINK-29278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-29278.
Assignee: Nicholas Jiang
Resolution: Fixed
master: 422ea6072b251b04041b6ca8a738316a30069aad
[
https://issues.apache.org/jira/browse/FLINK-29375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29375:
---
Labels: pull-request-available (was: )
> Move getSelfGateway into RpcService
>
XComp commented on code in PR #20870:
URL: https://github.com/apache/flink/pull/20870#discussion_r976555879
##
flink-rpc/flink-rpc-akka/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcService.java:
##
@@ -197,6 +197,20 @@ public int getPort() {
return port;
[
https://issues.apache.org/jira/browse/FLINK-29382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17607770#comment-17607770
]
Barisa commented on FLINK-29382:
You are right, I'm not running on the minikube, I'm usi
gyfora commented on PR #377:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/377#issuecomment-1253749120
What I don't understand is how this would interact with the CR deletion
process. Currently when the user deletes a Flink CR the operator itself cleans
up the dependent res
zezaeoh commented on PR #377:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/377#issuecomment-1253728010
Hi there, thanks for comments!
We can find out what an owner reference is, and what it can do in kubernetes
in the following docs:
*
https://kubernetes.io/docs/
[
https://issues.apache.org/jira/browse/FLINK-29382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-29382:
---
Affects Version/s: kubernetes-operator-1.1.0
(was: 1.15.2)
> Flink fails
[
https://issues.apache.org/jira/browse/FLINK-29382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17607757#comment-17607757
]
Gyula Fora commented on FLINK-29382:
What environment are you running in? the quicks
1 - 100 of 249 matches
Mail list logo
