libenchao commented on code in PR #20140:
URL: https://github.com/apache/flink/pull/20140#discussion_r1009034445
##
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcFilterPushdownPreparedStatementVisitor.java:
##
@@ -0,0 +1,160 @@
Aitozi created FLINK-29800:
--
Summary: Continuous failover will leak the inprogress output file
Key: FLINK-29800
URL: https://issues.apache.org/jira/browse/FLINK-29800
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-29609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626372#comment-17626372
]
Hector Miuler Malpica Gallegos commented on FLINK-29609:
[~sriramgr] In my
[
https://issues.apache.org/jira/browse/FLINK-28539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626370#comment-17626370
]
Yanfei Lei commented on FLINK-28539:
[~usamj] Do you want to fix this? (I'd like to open a PR to
[
https://issues.apache.org/jira/browse/FLINK-28539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17566618#comment-17566618
]
Yanfei Lei edited comment on FLINK-28539 at 10/31/22 4:20 AM:
--
hi [~usamj]
reswqa commented on PR #21137:
URL: https://github.com/apache/flink/pull/21137#issuecomment-1296507911
> We might also want to check the other `LeaderContender` implementations
(as you already mentioned, `ResourceManagerImpl` does not suffer from this bug
but the others might because they
[
https://issues.apache.org/jira/browse/FLINK-29639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626366#comment-17626366
]
Xintong Song commented on FLINK-29639:
--
Hi [~Jiangang], is there any updates on this issue?
> Add
[
https://issues.apache.org/jira/browse/FLINK-28863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang reassigned FLINK-28863:
Assignee: Jinzhong Li
> Snapshot result of RocksDB native savepoint should have empty
[
https://issues.apache.org/jira/browse/FLINK-28863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626365#comment-17626365
]
Yun Tang commented on FLINK-28863:
--
[~lijinzhong] I think this idea should be correct, already assigned
[
https://issues.apache.org/jira/browse/FLINK-28390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626363#comment-17626363
]
Yanfei Lei commented on FLINK-28390:
[~Ming Li] As the bug has been fixed and the changes are minor,
[
https://issues.apache.org/jira/browse/FLINK-28889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-28889.
Resolution: Done
master (1.17): d11940c4a78c71548b5a06af50da2e5f9cb68918
> Hybrid shuffle should
xintongsong closed pull request #21122: [FLINK-28889] Hybrid shuffle supports
multiple consumer and broadcast optimization
URL: https://github.com/apache/flink/pull/21122
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
jiangxin369 commented on code in PR #162:
URL: https://github.com/apache/flink-ml/pull/162#discussion_r100968
##
flink-ml-lib/src/main/java/org/apache/flink/ml/common/util/QuantileSummary.java:
##
@@ -0,0 +1,400 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
jiangxin369 commented on code in PR #162:
URL: https://github.com/apache/flink-ml/pull/162#discussion_r1008999126
##
flink-ml-lib/src/main/java/org/apache/flink/ml/common/util/QuantileSummary.java:
##
@@ -0,0 +1,400 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
[
https://issues.apache.org/jira/browse/FLINK-29795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-29795:
---
Description: The {{source.file.stream.io-fetch-size}} is used in the bulk
format mode, but it is not
[
https://issues.apache.org/jira/browse/FLINK-29639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-29639:
-
Component/s: Runtime / Coordination
> Add ResourceId in TransportException for debugging
>
leonardBang commented on code in PR #21186:
URL: https://github.com/apache/flink/pull/21186#discussion_r1008991930
##
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java:
##
@@ -194,8 +194,10 @@
public void write(IN
godfreyhe merged PR #578:
URL: https://github.com/apache/flink-web/pull/578
--
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-28553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626350#comment-17626350
]
Yanfei Lei commented on FLINK-28553:
Thanks [~roman] for merging in master
[
https://issues.apache.org/jira/browse/FLINK-28581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei closed FLINK-28581.
--
Fix Version/s: 1.16.0
Resolution: Resolved
> Test Changelog StateBackend V2 Manually
>
[
https://issues.apache.org/jira/browse/FLINK-29748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626349#comment-17626349
]
Aitozi commented on FLINK-29748:
{noformat}
The rule will only apply once during the optimization
[
https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626347#comment-17626347
]
Caizhi Weng edited comment on FLINK-27246 at 10/31/22 2:18 AM:
---
Hi
[
https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626347#comment-17626347
]
Caizhi Weng edited comment on FLINK-27246 at 10/31/22 2:17 AM:
---
Hi
[
https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626347#comment-17626347
]
Caizhi Weng edited comment on FLINK-27246 at 10/31/22 2:15 AM:
---
Hi
[
https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626347#comment-17626347
]
Caizhi Weng edited comment on FLINK-27246 at 10/31/22 2:14 AM:
---
Hi
[
https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626347#comment-17626347
]
Caizhi Weng commented on FLINK-27246:
-
Hi [~KristoffSC]!
Thanks for your interest in solving this
[
https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626347#comment-17626347
]
Caizhi Weng edited comment on FLINK-27246 at 10/31/22 2:13 AM:
---
Hi
jiangxin369 commented on code in PR #166:
URL: https://github.com/apache/flink-ml/pull/166#discussion_r1008977825
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/imputer/Imputer.java:
##
@@ -0,0 +1,328 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
[
https://issues.apache.org/jira/browse/FLINK-29748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626343#comment-17626343
]
Shengkai Fang commented on FLINK-29748:
---
Yes. I think you are right.
But I am confused about
>
[
https://issues.apache.org/jira/browse/FLINK-29572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626342#comment-17626342
]
Xintong Song commented on FLINK-29572:
--
I'm still not convinced that this is a bug of Flink. Maybe
[
https://issues.apache.org/jira/browse/FLINK-29792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29792:
---
Labels: pull-request-available (was: )
> FileStoreCommitTest is unstable and may stuck
>
tsreaper opened a new pull request, #341:
URL: https://github.com/apache/flink-table-store/pull/341
`FileStoreCommitTest` may stuck because the `FileStoreCommit` in
`TestCommitThread` does not commit APPEND snapshot when no new files are
produced. In this case, if the following COMPACT
[
https://issues.apache.org/jira/browse/FLINK-29792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng reassigned FLINK-29792:
---
Assignee: Caizhi Weng
> FileStoreCommitTest is unstable and may stuck
>
[
https://issues.apache.org/jira/browse/FLINK-29728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-29728.
Fix Version/s: 1.17.0
1.16.1
Resolution: Fixed
- master (1.17):
[
https://issues.apache.org/jira/browse/FLINK-29728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-29728:
-
Component/s: Table SQL / Planner
(was: Runtime / Coordination)
>
[
https://issues.apache.org/jira/browse/FLINK-29728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song reassigned FLINK-29728:
Assignee: Weijie Guo
> TablePlanner prevents Flink from starting is working directory is
[
https://issues.apache.org/jira/browse/FLINK-28102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-28102.
Fix Version/s: 1.17.0
1.16.1
Resolution: Fixed
- master (1.17):
[
https://issues.apache.org/jira/browse/FLINK-28102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-28102:
-
Affects Version/s: 1.15.2
(was: 1.15.0)
xintongsong closed pull request #21125: [FLINK-28102] Flink AkkaRpcSystemLoader
fails when temporary directory is a symlink
URL: https://github.com/apache/flink/pull/21125
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
lindong28 commented on code in PR #162:
URL: https://github.com/apache/flink-ml/pull/162#discussion_r1008964931
##
flink-ml-lib/src/main/java/org/apache/flink/ml/common/util/QuantileSummary.java:
##
@@ -0,0 +1,400 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
lindong28 commented on code in PR #162:
URL: https://github.com/apache/flink-ml/pull/162#discussion_r1008964672
##
flink-ml-lib/src/main/java/org/apache/flink/ml/common/util/QuantileSummary.java:
##
@@ -0,0 +1,400 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
xintongsong commented on PR #21122:
URL: https://github.com/apache/flink/pull/21122#issuecomment-1296419534
@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
snuyanzin commented on code in PR #17649:
URL: https://github.com/apache/flink/pull/17649#discussion_r1008952683
##
docs/content/docs/dev/table/sqlClient.md:
##
@@ -91,6 +91,40 @@ The `SET` command allows you to tune the job execution and
the sql client behavi
After a query
snuyanzin commented on code in PR #17649:
URL: https://github.com/apache/flink/pull/17649#discussion_r1008952635
##
docs/content/docs/dev/table/sqlClient.md:
##
@@ -91,6 +91,40 @@ The `SET` command allows you to tune the job execution and
the sql client behavi
After a query
snuyanzin commented on code in PR #17649:
URL: https://github.com/apache/flink/pull/17649#discussion_r1008951197
##
docs/content/docs/dev/table/sqlClient.md:
##
@@ -91,6 +91,40 @@ The `SET` command allows you to tune the job execution and
the sql client behavi
After a query
qingwei91 commented on PR #20140:
URL: https://github.com/apache/flink/pull/20140#issuecomment-1296359376
@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
salvalcantara commented on PR #21186:
URL: https://github.com/apache/flink/pull/21186#issuecomment-1296333613
Initially, the ci pipeline passed successfully, I made some cosmetic changes
and then I got a failure which seems unrelated to my code changes, really. Can
you confirm
qingwei91 commented on code in PR #20140:
URL: https://github.com/apache/flink/pull/20140#discussion_r1008835739
##
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcFilterPushdownPreparedStatementVisitor.java:
##
@@ -0,0 +1,185 @@
salvalcantara commented on PR #21186:
URL: https://github.com/apache/flink/pull/21186#issuecomment-1296303288
@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
Cansu Kavili created FLINK-29799:
Summary: How to override ConfigMap values while deploying the
Operator via OLM?
Key: FLINK-29799
URL: https://issues.apache.org/jira/browse/FLINK-29799
Project:
flinkbot commented on PR #21195:
URL: https://github.com/apache/flink/pull/21195#issuecomment-1296283103
## CI report:
* bbfcc159bebcec8ad634c48ee8f39e975640696a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
ferenc-csaky opened a new pull request, #21195:
URL: https://github.com/apache/flink/pull/21195
## What is the purpose of the change
This is the actualized version of https://github.com/apache/flink/pull/19077.
Removes the `flink-sql-parser-hive` module from `flink-table` to
mbalassi commented on PR #21189:
URL: https://github.com/apache/flink/pull/21189#issuecomment-1296277519
@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.
mbalassi commented on PR #21180:
URL: https://github.com/apache/flink/pull/21180#issuecomment-1296277420
@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.
Márton Balassi created FLINK-29798:
--
Summary: Rename K8s operator client code module
Key: FLINK-29798
URL: https://issues.apache.org/jira/browse/FLINK-29798
Project: Flink
Issue Type:
qingwei91 commented on PR #20140:
URL: https://github.com/apache/flink/pull/20140#issuecomment-1296273034
@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
qingwei91 commented on PR #20140:
URL: https://github.com/apache/flink/pull/20140#issuecomment-1296238300
@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
qingwei91 commented on code in PR #20140:
URL: https://github.com/apache/flink/pull/20140#discussion_r1008835739
##
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcFilterPushdownPreparedStatementVisitor.java:
##
@@ -0,0 +1,185 @@
qingwei91 commented on code in PR #20140:
URL: https://github.com/apache/flink/pull/20140#discussion_r1008835739
##
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcFilterPushdownPreparedStatementVisitor.java:
##
@@ -0,0 +1,185 @@
qingwei91 commented on PR #20140:
URL: https://github.com/apache/flink/pull/20140#issuecomment-1296222402
@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
flinkbot commented on PR #21194:
URL: https://github.com/apache/flink/pull/21194#issuecomment-1296219332
## CI report:
* ff2dc1314335fa68e043980a5a4f1827803ab96b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
chandan1602 opened a new pull request, #21194:
URL: https://github.com/apache/flink/pull/21194
## 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
libenchao commented on code in PR #20140:
URL: https://github.com/apache/flink/pull/20140#discussion_r1008821587
##
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcFilterPushdownPreparedStatementVisitor.java:
##
@@ -0,0 +1,185 @@
mbalassi commented on PR #417:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/417#issuecomment-1296153291
@tweise has pointed out to me that we actually do not guarantee Java API
compatibility at this point, and consequently it is best to make the changes
now necessary to
xintongsong commented on PR #21122:
URL: https://github.com/apache/flink/pull/21122#issuecomment-1296144735
@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
[
https://issues.apache.org/jira/browse/FLINK-29480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626176#comment-17626176
]
Salva edited comment on FLINK-29480 at 10/30/22 7:08 AM:
-
[~mason6345]
[
https://issues.apache.org/jira/browse/FLINK-29480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626176#comment-17626176
]
Salva commented on FLINK-29480:
---
[~mason6345] [~leonard] [~renqs] [~martijnvisser] From my perspective,
xintongsong commented on PR #21122:
URL: https://github.com/apache/flink/pull/21122#issuecomment-1296137584
@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
salvalcantara commented on code in PR #21186:
URL: https://github.com/apache/flink/pull/21186#discussion_r1007933805
##
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaWriterITCase.java:
##
@@ -148,6 +148,13 @@ public void
69 matches
Mail list logo
