[
https://issues.apache.org/jira/browse/FLINK-31818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17712921#comment-17712921
]
SeungMin commented on FLINK-31818:
--
[~JunRuiLi]
Oh, I will test, and if this modifica
[
https://issues.apache.org/jira/browse/FLINK-31770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17712916#comment-17712916
]
Martijn Visser commented on FLINK-31770:
https://github.com/apache/flink-connect
[
https://issues.apache.org/jira/browse/FLINK-26522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-26522:
--
Summary: FLIP-285: Refactoring code for multiple component leader election
(was: Refactoring
[
https://issues.apache.org/jira/browse/FLINK-26522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17712914#comment-17712914
]
Matthias Pohl commented on FLINK-26522:
---
Sure, I added it to the title (y)
> FLIP
[
https://issues.apache.org/jira/browse/FLINK-31818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17712907#comment-17712907
]
Junrui Li edited comment on FLINK-31818 at 4/17/23 6:18 AM:
[
https://issues.apache.org/jira/browse/FLINK-31818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17712907#comment-17712907
]
Junrui Li commented on FLINK-31818:
---
[~seung-min] I think this issue is due to the typ
zhipeng93 commented on code in PR #215:
URL: https://github.com/apache/flink-ml/pull/215#discussion_r1168219732
##
flink-ml-core/src/main/java/org/apache/flink/ml/common/broadcast/operator/AbstractBroadcastWrapperOperator.java:
##
@@ -169,83 +144,39 @@
zhipeng93 commented on code in PR #215:
URL: https://github.com/apache/flink-ml/pull/215#discussion_r1168219732
##
flink-ml-core/src/main/java/org/apache/flink/ml/common/broadcast/operator/AbstractBroadcastWrapperOperator.java:
##
@@ -169,83 +144,39 @@
Myasuka merged PR #644:
URL: https://github.com/apache/flink-web/pull/644
--
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
zhipeng93 commented on code in PR #215:
URL: https://github.com/apache/flink-ml/pull/215#discussion_r1168210187
##
flink-ml-core/src/main/java/org/apache/flink/ml/common/broadcast/operator/AbstractBroadcastWrapperOperator.java:
##
@@ -269,138 +200,162 @@ private OperatorMetricGr
[
https://issues.apache.org/jira/browse/FLINK-31818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Seung-Min updated FLINK-31818:
--
Description:
There is a parsing error when I gave two or more hdfs namenodes URI separated
by commas
[
https://issues.apache.org/jira/browse/FLINK-31818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Seung-Min updated FLINK-31818:
--
Description:
There is a parsing error when I gave two or more hdfs namenodes URI separated
by commas
[
https://issues.apache.org/jira/browse/FLINK-31818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Seung-Min updated FLINK-31818:
--
Description:
There is a parsing error when I gave two or more hdfs namenodes URI separated
by commas
Seung-Min created FLINK-31818:
-
Summary: parsing error of
'security.kerberos.access.hadoopFileSystems' in flink-conf.yaml
Key: FLINK-31818
URL: https://issues.apache.org/jira/browse/FLINK-31818
Project: F
[
https://issues.apache.org/jira/browse/FLINK-26522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17712881#comment-17712881
]
Weijie Guo commented on FLINK-26522:
It seems that the work of FLIP-285 is being tra
zhipeng93 commented on code in PR #215:
URL: https://github.com/apache/flink-ml/pull/215#discussion_r1168137985
##
flink-ml-core/src/main/java/org/apache/flink/ml/common/broadcast/operator/AbstractBroadcastWrapperOperator.java:
##
@@ -269,138 +200,162 @@ private OperatorMetricGr
zhipeng93 commented on code in PR #215:
URL: https://github.com/apache/flink-ml/pull/215#discussion_r1168137985
##
flink-ml-core/src/main/java/org/apache/flink/ml/common/broadcast/operator/AbstractBroadcastWrapperOperator.java:
##
@@ -269,138 +200,162 @@ private OperatorMetricGr
flinkbot commented on PR #22407:
URL: https://github.com/apache/flink/pull/22407#issuecomment-1510670711
## CI report:
* eb664d384fdae1bf8bc050f39720e060895df5de UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-17337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17708727#comment-17708727
]
Alexander Smirnov edited comment on FLINK-17337 at 4/17/23 4:07 AM:
--
zhipeng93 commented on code in PR #215:
URL: https://github.com/apache/flink-ml/pull/215#discussion_r1168135056
##
flink-ml-core/src/main/java/org/apache/flink/ml/common/broadcast/operator/AbstractBroadcastWrapperOperator.java:
##
@@ -468,7 +425,9 @@ public void initializeState(
[
https://issues.apache.org/jira/browse/FLINK-31817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31817:
---
Labels: pull-request-available (was: )
> Skip meaningless testForUnsplittable in FileInputF
Zouxxyy opened a new pull request, #22407:
URL: https://github.com/apache/flink/pull/22407
## 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 on
[
https://issues.apache.org/jira/browse/FLINK-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17712878#comment-17712878
]
Zhihao Chen commented on FLINK-31135:
-
Hi [~Swathi Chandrashekar] , please see the a
wanglijie95 commented on code in PR #31:
URL:
https://github.com/apache/flink-connector-jdbc/pull/31#discussion_r1168131549
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/xa/JdbcXaSinkFunctionState.java:
##
@@ -53,7 +56,7 @@ private JdbcXaSinkFunctionStat
reswqa commented on PR #21876:
URL: https://github.com/apache/flink/pull/21876#issuecomment-1510659531
@paul8263 This
[ticket](https://issues.apache.org/jira/projects/FLINK/issues/FLINK-30888?filter=updatedrecently)
has been closed. It seems that this typo was fixed already.
--
This is a
[
https://issues.apache.org/jira/browse/FLINK-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhihao Chen updated FLINK-31135:
Attachment: dump_cm.yaml
> ConfigMap DataSize went > 1 MB and cluster stopped working
> --
zhipeng93 commented on code in PR #215:
URL: https://github.com/apache/flink-ml/pull/215#discussion_r1168127178
##
flink-ml-core/src/main/java/org/apache/flink/ml/common/broadcast/BroadcastUtils.java:
##
@@ -152,41 +155,52 @@ private static DataStream
cacheBroadcastVariables(
zhipeng93 commented on code in PR #215:
URL: https://github.com/apache/flink-ml/pull/215#discussion_r1168127178
##
flink-ml-core/src/main/java/org/apache/flink/ml/common/broadcast/BroadcastUtils.java:
##
@@ -152,41 +155,52 @@ private static DataStream
cacheBroadcastVariables(
zhipeng93 commented on code in PR #215:
URL: https://github.com/apache/flink-ml/pull/215#discussion_r1168127178
##
flink-ml-core/src/main/java/org/apache/flink/ml/common/broadcast/BroadcastUtils.java:
##
@@ -152,41 +155,52 @@ private static DataStream
cacheBroadcastVariables(
zhipeng93 commented on code in PR #215:
URL: https://github.com/apache/flink-ml/pull/215#discussion_r1168127178
##
flink-ml-core/src/main/java/org/apache/flink/ml/common/broadcast/BroadcastUtils.java:
##
@@ -152,41 +155,52 @@ private static DataStream
cacheBroadcastVariables(
Myasuka commented on PR #21822:
URL: https://github.com/apache/flink/pull/21822#issuecomment-1510638871
> Hi @Myasuka , may I request you help us review this pr ?
Sure, I'll take a review today.
--
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/FLINK-31817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zouxxyy updated FLINK-31817:
Description:
In `FileInputFormat`
The function of `testForUnsplittable` is to detect whether the pathFile
flinkbot commented on PR #22406:
URL: https://github.com/apache/flink/pull/22406#issuecomment-1510637569
## CI report:
* 7ff69b4084aed9098eefebfb8716bed67e29cfa4 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17712870#comment-17712870
]
Weijie Guo commented on FLINK-31779:
merged commit
[43bd5e5|https://github.com/apac
[
https://issues.apache.org/jira/browse/FLINK-31779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-31779.
--
Fix Version/s: 1.16.2
1.17.1
Resolution: Fixed
> Track stable branch of exte
[
https://issues.apache.org/jira/browse/FLINK-31779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31779:
---
Affects Version/s: 1.16.1
> Track stable branch of externalized connector instead of specific releas
[
https://issues.apache.org/jira/browse/FLINK-31817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zouxxyy updated FLINK-31817:
Description:
In `FileInputFormat`
The function of `testForUnsplittable` is to detect whether the pathFile
reswqa merged PR #22403:
URL: https://github.com/apache/flink/pull/22403
--
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
zouxxyy created FLINK-31817:
---
Summary: Skip meaningless testForUnsplittable in FileInputFormat
Key: FLINK-31817
URL: https://issues.apache.org/jira/browse/FLINK-31817
Project: Flink
Issue Type: Imp
reswqa merged PR #22402:
URL: https://github.com/apache/flink/pull/22402
--
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
flinkbot commented on PR #22405:
URL: https://github.com/apache/flink/pull/22405#issuecomment-1510635129
## CI report:
* 7064f5a7085451aab82f57f0bb9c6bb40674a9aa UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
reswqa opened a new pull request, #22406:
URL: https://github.com/apache/flink/pull/22406
Backport FLINK-31763 to release-1.17.
--
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 commen
reswqa opened a new pull request, #22405:
URL: https://github.com/apache/flink/pull/22405
Backport FLINK-31763 to release-1.16.
--
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 commen
[
https://issues.apache.org/jira/browse/FLINK-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17712861#comment-17712861
]
SwathiChandrashekar commented on FLINK-31135:
-
Thanks [~zhihaochen] , can yo
[
https://issues.apache.org/jira/browse/FLINK-31335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
felixzh updated FLINK-31335:
Fix Version/s: 1.17.1
> using sql-gateway to submit job to yarn cluster, sql-gateway don't support
> kerb
[
https://issues.apache.org/jira/browse/FLINK-31777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17712857#comment-17712857
]
Jark Wu commented on FLINK-31777:
-
I closed the issue because this is a by-design behavi
[
https://issues.apache.org/jira/browse/FLINK-31777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-31777.
---
Resolution: Not A Problem
> Upsert Kafka use Avro Confluent, key is ok, but all values are null.
> -
[
https://issues.apache.org/jira/browse/FLINK-31778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-31778:
---
Assignee: Ilya Soin
> Casting array of rows produces incorrect result
> ---
zoltar9264 commented on PR #21822:
URL: https://github.com/apache/flink/pull/21822#issuecomment-1510596889
Hi @Myasuka , may I request you help us review this pr ?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
[
https://issues.apache.org/jira/browse/FLINK-31778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17712856#comment-17712856
]
Jark Wu commented on FLINK-31778:
-
[~soin08] sure, I assigned this issue to you. Looking
leonardBang merged PR #22391:
URL: https://github.com/apache/flink/pull/22391
--
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
[
https://issues.apache.org/jira/browse/FLINK-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17712854#comment-17712854
]
Zhihao Chen edited comment on FLINK-31135 at 4/17/23 1:48 AM:
[
https://issues.apache.org/jira/browse/FLINK-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17712854#comment-17712854
]
Zhihao Chen commented on FLINK-31135:
-
I have encountered the same issue. Actually,
xuzhiwen1255 closed pull request #21925: FLINK-31053[Runtime] : Example Repair
the log output format of the CheckpointCoordinator
URL: https://github.com/apache/flink/pull/21925
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
[
https://issues.apache.org/jira/browse/FLINK-31777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17712853#comment-17712853
]
Alvin Ge commented on FLINK-31777:
--
[~jark] Thank you!
> Upsert Kafka use Avro Conflue
[
https://issues.apache.org/jira/browse/FLINK-30888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30888:
---
Labels: pull-request-available (was: )
> Flink Doc(zh version) has misspelled words
>
paul8263 commented on PR #21876:
URL: https://github.com/apache/flink/pull/21876#issuecomment-1510550558
Could someone help review this PR please?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to
[
https://issues.apache.org/jira/browse/FLINK-31778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17712839#comment-17712839
]
Ilya Soin commented on FLINK-31778:
---
Hi [~jark], thanks for the input! As I understand
flinkbot commented on PR #22404:
URL: https://github.com/apache/flink/pull/22404#issuecomment-1510444572
## CI report:
* 9ddb4ba7c1a9e53ce12e5922a044701ad9f4cce4 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31797:
---
Labels: pull-request-available (was: )
> Move LeaderElectionService out of LeaderContender
XComp opened a new pull request, #22404:
URL: https://github.com/apache/flink/pull/22404
## 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 on e
lindong28 commented on code in PR #216:
URL: https://github.com/apache/flink-ml/pull/216#discussion_r1167966461
##
flink-ml-tests/src/test/java/org/apache/flink/test/iteration/BoundedPerRoundCheckpointITCase.java:
##
@@ -106,7 +106,7 @@ public void testFailoverAndRestore() throw
[
https://issues.apache.org/jira/browse/FLINK-31816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17712806#comment-17712806
]
Matthias Pohl commented on FLINK-31816:
---
This is actually a legacy issue. I moved
[
https://issues.apache.org/jira/browse/FLINK-31816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-31816:
--
Component/s: Runtime / Coordination
> Refactor EmbeddedLeaderElectionService
> ---
[
https://issues.apache.org/jira/browse/FLINK-31816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-31816:
--
Parent: (was: FLINK-26522)
Issue Type: Technical Debt (was: Sub-task)
> Refactor
Matthias Pohl created FLINK-31816:
-
Summary: Refactor EmbeddedLeaderElectionService
Key: FLINK-31816
URL: https://issues.apache.org/jira/browse/FLINK-31816
Project: Flink
Issue Type: Sub-task
lindong28 commented on code in PR #215:
URL: https://github.com/apache/flink-ml/pull/215#discussion_r1167928810
##
flink-ml-core/src/main/java/org/apache/flink/ml/common/broadcast/operator/AbstractBroadcastWrapperOperator.java:
##
@@ -169,83 +144,39 @@
yangjf2019 commented on PR #22274:
URL: https://github.com/apache/flink/pull/22274#issuecomment-1510376552
Okay, I'll take care of it 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 use the
URL above t
[
https://issues.apache.org/jira/browse/FLINK-31815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31815:
---
Labels: pull-request-available (was: )
> Fixing the container vulnerability by upgrade the
yangjf2019 opened a new pull request, #567:
URL: https://github.com/apache/flink-kubernetes-operator/pull/567
## What is the purpose of the change
*Upgrade the SnakeYaml Maven dependency from 1.33 to 2.0 to fix the
container vulnerability
[CVE-2022-1471](https://github.com/ad
[
https://issues.apache.org/jira/browse/FLINK-31815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Yang updated FLINK-31815:
--
Description: _Fix the container vulnerability, here is
[cve|https://github.com/advisories/GHSA-mjmj-j4
Jeff Yang created FLINK-31815:
-
Summary: Fixing the container vulnerability by upgrade the
SnakeYaml Maven dependency
Key: FLINK-31815
URL: https://issues.apache.org/jira/browse/FLINK-31815
Project: Flink
boring-cyborg[bot] commented on PR #41:
URL:
https://github.com/apache/flink-connector-jdbc/pull/41#issuecomment-1510252301
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is an
libenchao commented on code in PR #638:
URL: https://github.com/apache/flink-web/pull/638#discussion_r1167802998
##
docs/data/release_archive.yml:
##
@@ -428,6 +428,11 @@ release_archive:
version: 1.0.0
release_date: 2022-12-21
filename: "opensearch"
+-
reswqa commented on code in PR #22403:
URL: https://github.com/apache/flink/pull/22403#discussion_r1167770727
##
docs/setup_docs.sh:
##
@@ -41,10 +41,10 @@ cd tmp
# Since there's no documentation yet available for a release branch,
# we only get the documentation from the ma
reswqa commented on code in PR #22403:
URL: https://github.com/apache/flink/pull/22403#discussion_r1167767444
##
docs/setup_docs.sh:
##
@@ -41,10 +41,10 @@ cd tmp
# Since there's no documentation yet available for a release branch,
# we only get the documentation from the ma
reswqa commented on code in PR #22403:
URL: https://github.com/apache/flink/pull/22403#discussion_r1167767444
##
docs/setup_docs.sh:
##
@@ -41,10 +41,10 @@ cd tmp
# Since there's no documentation yet available for a release branch,
# we only get the documentation from the ma
reswqa commented on code in PR #22403:
URL: https://github.com/apache/flink/pull/22403#discussion_r1167767444
##
docs/setup_docs.sh:
##
@@ -41,10 +41,10 @@ cd tmp
# Since there's no documentation yet available for a release branch,
# we only get the documentation from the ma
reswqa commented on code in PR #22403:
URL: https://github.com/apache/flink/pull/22403#discussion_r1167767444
##
docs/setup_docs.sh:
##
@@ -41,10 +41,10 @@ cd tmp
# Since there's no documentation yet available for a release branch,
# we only get the documentation from the ma
WencongLiu commented on PR #40:
URL:
https://github.com/apache/flink-connector-jdbc/pull/40#issuecomment-1510169834
Done. Thanks for your review! @MartijnVisser
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
Matthias Pohl created FLINK-31814:
-
Summary: Enable Precondition in DefaultLeaderElectionService.close
after the MultipleComponentLeaderElectionDriverAdapter is removed
Key: FLINK-31814
URL: https://issues.apache.
MosheElisha commented on PR #22393:
URL: https://github.com/apache/flink/pull/22393#issuecomment-1510138618
LGTM! 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.
To
[ https://issues.apache.org/jira/browse/FLINK-29368 ]
xiaochen zhou deleted comment on FLINK-29368:
---
was (Author: zxcoccer):
hi，I would like to deal with it. Can you assign this ticket to me ?:)
> Modify DESCRIBE statement docs for new synt
83 matches
Mail list logo
