flinkbot edited a comment on pull request #16126:
URL: https://github.com/apache/flink/pull/16126#issuecomment-858225387
## CI report:
* 7e5a79a9b48f69dce3349c18afb8f266182748b4 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-22954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17360602#comment-17360602
]
Jark Wu commented on FLINK-22954:
-
Another way can be refactoring the join operator to b
Airblader commented on a change in pull request #16046:
URL: https://github.com/apache/flink/pull/16046#discussion_r648889963
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinition.java
##
@@ -53,19 +53,23 @@
[
https://issues.apache.org/jira/browse/FLINK-22954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17360591#comment-17360591
]
godfrey he commented on FLINK-22954:
[~jark] If we do not apply StreamPhysicalConsta
[
https://issues.apache.org/jira/browse/FLINK-14902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17360588#comment-17360588
]
Ada Wong commented on FLINK-14902:
--
I want to contribute this ticket. I want to use Ver
Ingo Bürk created FLINK-22958:
-
Summary: Reused content in docs causes confusing navigation jumps
Key: FLINK-22958
URL: https://issues.apache.org/jira/browse/FLINK-22958
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-22928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17360583#comment-17360583
]
Yun Gao commented on FLINK-22928:
-
Yes, indeed, it also looks to me to be the same issue
flinkbot edited a comment on pull request #16127:
URL: https://github.com/apache/flink/pull/16127#issuecomment-858327979
## CI report:
* 86b0b047914fe80e33a3b869594a07b0a8d8347f Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #15924:
URL: https://github.com/apache/flink/pull/15924#issuecomment-841943851
## CI report:
* d1b81032b6f735cb72fc862b35512b9126b83915 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
wangyang0918 commented on pull request #16127:
URL: https://github.com/apache/flink/pull/16127#issuecomment-85821
+1 for merging.
We could simply ignore the "Exception on heartbeat" and
`java.io.InterruptedIOException: Call interrupted` if all other verification
passed. It usual
[
https://issues.apache.org/jira/browse/FLINK-22457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17360575#comment-17360575
]
Qingsheng Ren commented on FLINK-22457:
---
[~xintongsong] Sure, trying to reproduce
[
https://issues.apache.org/jira/browse/FLINK-22954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-22954:
Component/s: (was: Table SQL / API)
Table SQL / Planner
> Don't support consuming upd
Airblader commented on a change in pull request #16046:
URL: https://github.com/apache/flink/pull/16046#discussion_r648871106
##
File path: docs/data/sql_functions.yml
##
@@ -485,6 +485,14 @@ temporal:
description: "Converts a epoch seconds or epoch milliseconds to a
TIME
[
https://issues.apache.org/jira/browse/FLINK-22457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17360574#comment-17360574
]
Xintong Song commented on FLINK-22457:
--
[~renqs], could you help take a look at thi
flinkbot commented on pull request #16127:
URL: https://github.com/apache/flink/pull/16127#issuecomment-858327979
## CI report:
* 86b0b047914fe80e33a3b869594a07b0a8d8347f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot edited a comment on pull request #16126:
URL: https://github.com/apache/flink/pull/16126#issuecomment-858225387
## CI report:
* 87bc102eb2c95bdf664739a3be933324e2e5c2d0 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #15924:
URL: https://github.com/apache/flink/pull/15924#issuecomment-841943851
## CI report:
* d1b81032b6f735cb72fc862b35512b9126b83915 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
wuchong commented on a change in pull request #16126:
URL: https://github.com/apache/flink/pull/16126#discussion_r648869048
##
File path: docs/content.zh/docs/dev/table/sql/queries/overview.md
##
@@ -393,7 +393,37 @@ Flink SQL uses a lexical policy for identifier (table,
attri
[
https://issues.apache.org/jira/browse/FLINK-22943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Li resolved FLINK-22943.
Resolution: Duplicate
> java.lang.ClassCastException: java.time.Instant cannot be cast to
> java.sql.Time
[
https://issues.apache.org/jira/browse/FLINK-22954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17360563#comment-17360563
]
Jark Wu commented on FLINK-22954:
-
Currently, this behavior is as expected. Becuase if t
Airblader commented on a change in pull request #16046:
URL: https://github.com/apache/flink/pull/16046#discussion_r648858367
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinition.java
##
@@ -53,19 +53,23 @@
flinkbot commented on pull request #16127:
URL: https://github.com/apache/flink/pull/16127#issuecomment-858312281
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the pro
[
https://issues.apache.org/jira/browse/FLINK-22312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-22312:
---
Labels: auto-deprioritized-critical pull-request-available test-stability
(was: auto-deprio
xintongsong opened a new pull request #16127:
URL: https://github.com/apache/flink/pull/16127
## 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 the
[
https://issues.apache.org/jira/browse/FLINK-22312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-22312:
-
Fix Version/s: 1.13.2
1.14.0
> YARNSessionFIFOSecuredITCase>YARNSessionFIFOIT
flinkbot edited a comment on pull request #16126:
URL: https://github.com/apache/flink/pull/16126#issuecomment-858225387
## CI report:
* 87bc102eb2c95bdf664739a3be933324e2e5c2d0 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
tweise commented on a change in pull request #15924:
URL: https://github.com/apache/flink/pull/15924#discussion_r648855430
##
File path:
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceReader.java
##
@@ -0,0 +1,194
[
https://issues.apache.org/jira/browse/FLINK-22312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17360551#comment-17360551
]
Xintong Song commented on FLINK-22312:
--
The InterruptedIOException is expected. It
[
https://issues.apache.org/jira/browse/FLINK-22312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song reassigned FLINK-22312:
Assignee: Xintong Song
> YARNSessionFIFOSecuredITCase>YARNSessionFIFOITCase.checkForProhi
[
https://issues.apache.org/jira/browse/FLINK-20926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Li resolved FLINK-20926.
Fix Version/s: 1.14.0
Assignee: Nicholas Jiang
Resolution: Implemented
Pushed to master: 4
lirui-apache closed pull request #16040:
URL: https://github.com/apache/flink/pull/16040
--
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.
For queries about this service, p
[
https://issues.apache.org/jira/browse/FLINK-18556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-18556:
Fix Version/s: 1.14.0
> Drop the unused options in TableConfig
> --
>
[
https://issues.apache.org/jira/browse/FLINK-22728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JYXL updated FLINK-22728:
-
Description:
hi:
I'm using the stream udf by python.
udf as bellow:
{code:python}
class MyKeySelector(KeySel
[
https://issues.apache.org/jira/browse/FLINK-22728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348967#comment-17348967
]
JYXL edited comment on FLINK-22728 at 6/10/21, 4:24 AM:
hi Dian:
[
https://issues.apache.org/jira/browse/FLINK-22728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348967#comment-17348967
]
JYXL edited comment on FLINK-22728 at 6/10/21, 4:23 AM:
hi Dian:
[
https://issues.apache.org/jira/browse/FLINK-22957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-22957:
-
Fix Version/s: 1.14.0
> Rank TTL should use enableTimeToLive of state instead of timer
> ---
Jingsong Lee created FLINK-22957:
Summary: Rank TTL should use enableTimeToLive of state instead of
timer
Key: FLINK-22957
URL: https://issues.apache.org/jira/browse/FLINK-22957
Project: Flink
Jingsong Lee created FLINK-22956:
Summary: Stream Over TTL should use enableTimeToLive of state
instead of timer
Key: FLINK-22956
URL: https://issues.apache.org/jira/browse/FLINK-22956
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-22728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348967#comment-17348967
]
JYXL edited comment on FLINK-22728 at 6/10/21, 4:22 AM:
hi Dian:
[
https://issues.apache.org/jira/browse/FLINK-22728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348967#comment-17348967
]
JYXL edited comment on FLINK-22728 at 6/10/21, 4:21 AM:
hi Dian:
[
https://issues.apache.org/jira/browse/FLINK-22728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JYXL updated FLINK-22728:
-
Description:
hi:
I'm using the stream udf by python.
udf as bellow:
{code:python}
class MyKeySelector(KeySel
[
https://issues.apache.org/jira/browse/FLINK-22678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17360533#comment-17360533
]
Zakelly Lan commented on FLINK-22678:
-
[~ym] Would you mind I take this one? Thanks.
[
https://issues.apache.org/jira/browse/FLINK-21301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he closed FLINK-21301.
--
Resolution: Fixed
Fixed in 1.14.0: 145502801c789143074536952f270bea56b30253
> Decouple window aggrega
[
https://issues.apache.org/jira/browse/FLINK-21301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he reassigned FLINK-21301:
--
Assignee: JING ZHANG
> Decouple window aggregate allow lateness with state ttl configuration
godfreyhe merged pull request #16022:
URL: https://github.com/apache/flink/pull/16022
--
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.
For queries about this service, plea
[
https://issues.apache.org/jira/browse/FLINK-22955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17360529#comment-17360529
]
godfrey he commented on FLINK-22955:
[~gsavl] Thanks for reporting this bug
> looku
[
https://issues.apache.org/jira/browse/FLINK-22955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cooper Luan updated FLINK-22955:
Fix Version/s: 1.13.2
> lookup join filter push down result to mismatch function signature
> -
[
https://issues.apache.org/jira/browse/FLINK-22955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cooper Luan updated FLINK-22955:
Fix Version/s: 1.12.5
1.11.4
> lookup join filter push down result to mismatch
[
https://issues.apache.org/jira/browse/FLINK-22457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17360528#comment-17360528
]
Xintong Song commented on FLINK-22457:
--
https://dev.azure.com/apache-flink/apache-f
Cooper Luan created FLINK-22955:
---
Summary: lookup join filter push down result to mismatch function
signature
Key: FLINK-22955
URL: https://issues.apache.org/jira/browse/FLINK-22955
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-22952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17360527#comment-17360527
]
Xintong Song commented on FLINK-22952:
--
https://dev.azure.com/apache-flink/apache-f
flinkbot edited a comment on pull request #16126:
URL: https://github.com/apache/flink/pull/16126#issuecomment-858225387
## CI report:
* 87bc102eb2c95bdf664739a3be933324e2e5c2d0 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-22312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17360526#comment-17360526
]
Xintong Song commented on FLINK-22312:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-22884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Li reassigned FLINK-22884:
--
Assignee: Rui Li
> Select view columns fail when store metadata with hive
> -
[
https://issues.apache.org/jira/browse/FLINK-22884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17360524#comment-17360524
]
Rui Li commented on FLINK-22884:
[~ELLEX_SHEN] Thanks for providing an example to reprod
JingsongLi commented on pull request #14280:
URL: https://github.com/apache/flink/pull/14280#issuecomment-858256816
Hi @wangxlong , You haven't responded for a long time. Do you want to
continue?
Or @leonardBang Can you continue to finish this PR?
--
This is an automated message f
[
https://issues.apache.org/jira/browse/FLINK-22900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-22900:
-
Component/s: (was: Table SQL / Runtime)
> flink 1.11.2 fileSystem source table read fileSys
[
https://issues.apache.org/jira/browse/FLINK-22900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-22900:
Assignee: bigdataf
> flink 1.11.2 fileSystem source table read fileSystem sink table pat
[
https://issues.apache.org/jira/browse/FLINK-22900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17360523#comment-17360523
]
Jingsong Lee commented on FLINK-22900:
--
+1 for just skip invalid paths instead of t
[
https://issues.apache.org/jira/browse/FLINK-22954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17360522#comment-17360522
]
Jingsong Lee commented on FLINK-22954:
--
What is the kafkaTableSource? Can you show
hehuiyuan created FLINK-22954:
-
Summary: Don't support consuming update and delete changes when
use table function that does not contain table field
Key: FLINK-22954
URL: https://issues.apache.org/jira/browse/FLINK-22
[
https://issues.apache.org/jira/browse/FLINK-22900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17360521#comment-17360521
]
Rui Li commented on FLINK-22900:
Hi [~bigdataf], please just go ahead and submit a PR. I
[
https://issues.apache.org/jira/browse/FLINK-22940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-22940:
---
Assignee: Svend Vanderveken
> Make SQL client column max width configurable
> -
wuchong commented on pull request #16126:
URL: https://github.com/apache/flink/pull/16126#issuecomment-858245190
Thanks for the contribution @RocMarshal . This escape syntax is not only
supported in SQL Client, but all the table-ecosystem including
TableEnvironment. So it would be better
[
https://issues.apache.org/jira/browse/FLINK-20329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17360514#comment-17360514
]
Yangze Guo commented on FLINK-20329:
It hangs while initializing the ES container. T
[
https://issues.apache.org/jira/browse/FLINK-22900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17360513#comment-17360513
]
bigdataf commented on FLINK-22900:
--
[~luoyuxia] ,Thank you very much for your reply. I
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17360510#comment-17360510
]
Xintong Song commented on FLINK-22085:
--
[~lindong], any updates on this one?
> Kaf
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17360509#comment-17360509
]
Xintong Song commented on FLINK-22085:
--
https://dev.azure.com/apache-flink/apache-f
awayne created FLINK-22953:
--
Summary: Using Types.LIST(Types.STRING()) in datastream result in
crash
Key: FLINK-22953
URL: https://issues.apache.org/jira/browse/FLINK-22953
Project: Flink
Issue Typ
[
https://issues.apache.org/jira/browse/FLINK-22702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17360508#comment-17360508
]
Xintong Song commented on FLINK-22702:
--
[~renqs], could you help take a look into t
[
https://issues.apache.org/jira/browse/FLINK-22702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17360507#comment-17360507
]
Xintong Song commented on FLINK-22702:
--
https://dev.azure.com/apache-flink/apache-f
flinkbot edited a comment on pull request #16126:
URL: https://github.com/apache/flink/pull/16126#issuecomment-858225387
## CI report:
* 87bc102eb2c95bdf664739a3be933324e2e5c2d0 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-22908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17360506#comment-17360506
]
Xintong Song commented on FLINK-22908:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-22952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17360504#comment-17360504
]
Xintong Song commented on FLINK-22952:
--
Seems to me there's a recent update from Az
[
https://issues.apache.org/jira/browse/FLINK-22952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17360502#comment-17360502
]
Xintong Song commented on FLINK-22952:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-22952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17360501#comment-17360501
]
Xintong Song commented on FLINK-22952:
--
https://dev.azure.com/apache-flink/apache-f
Xintong Song created FLINK-22952:
Summary: docs_404_check fail on azure due to ruby version not
available
Key: FLINK-22952
URL: https://issues.apache.org/jira/browse/FLINK-22952
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-22454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-22454:
---
Fix Version/s: 1.14.0
> Failed to translate Lookup Join when join on a CAST expression on dimention
[
https://issues.apache.org/jira/browse/FLINK-22454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he closed FLINK-22454.
--
Resolution: Fixed
Fixed in 1.14.0: f3936b20f488acf1b2592e4f0d5a5da02f444864
> Failed to translate Loo
godfreyhe merged pull request #16094:
URL: https://github.com/apache/flink/pull/16094
--
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.
For queries about this service, plea
[
https://issues.apache.org/jira/browse/FLINK-22951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17360496#comment-17360496
]
Jark Wu commented on FLINK-22951:
-
As a temporary workaround, you can use {{SELECT (now(
[
https://issues.apache.org/jira/browse/FLINK-22934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-22934:
---
Assignee: Roc Marshal
> Add instructions for using the " ' " escape syntax of SQL client
>
[
https://issues.apache.org/jira/browse/FLINK-22951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-22951.
---
Fix Version/s: (was: 1.14.0)
Resolution: Duplicate
> First parameter of ROW() function must be co
[
https://issues.apache.org/jira/browse/FLINK-22454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he reassigned FLINK-22454:
--
Assignee: Wenlong Lyu (was: wenlong liu)
> Failed to translate Lookup Join when join on a CA
[
https://issues.apache.org/jira/browse/FLINK-22454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he reassigned FLINK-22454:
--
Assignee: wenlong liu
> Failed to translate Lookup Join when join on a CAST expression on dim
[
https://issues.apache.org/jira/browse/FLINK-22946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guokuai Huang updated FLINK-22946:
--
Description:
We recently encountered deadlock when using unaligned checkpoint. Below are two
[
https://issues.apache.org/jira/browse/FLINK-22950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fu Kai updated FLINK-22950:
---
Summary: Back-pressure report of final sink operator is not accurate (was:
Back-pressure report final sink
[
https://issues.apache.org/jira/browse/FLINK-20329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17360494#comment-17360494
]
Xintong Song commented on FLINK-20329:
--
[~karmagyz], could you maybe take a look in
flinkbot commented on pull request #16126:
URL: https://github.com/apache/flink/pull/16126#issuecomment-858225387
## CI report:
* 87bc102eb2c95bdf664739a3be933324e2e5c2d0 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
Fu Kai created FLINK-22951:
--
Summary: First parameter of ROW() function must be constant
Key: FLINK-22951
URL: https://issues.apache.org/jira/browse/FLINK-22951
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-22943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17360491#comment-17360491
]
luoyuxia commented on FLINK-22943:
--
[~bigjar] fixed in https://issues.apache.org/jira/b
[
https://issues.apache.org/jira/browse/FLINK-20329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17360490#comment-17360490
]
Xintong Song commented on FLINK-20329:
--
https://dev.azure.com/apache-flink/apache-f
Fu Kai created FLINK-22950:
--
Summary: Back-pressure report final sink operator is not accurate
Key: FLINK-22950
URL: https://issues.apache.org/jira/browse/FLINK-22950
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-22703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17360488#comment-17360488
]
Xintong Song commented on FLINK-22703:
--
https://dev.azure.com/apache-flink/apache-f
flinkbot commented on pull request #16126:
URL: https://github.com/apache/flink/pull/16126#issuecomment-858217952
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the pro
[
https://issues.apache.org/jira/browse/FLINK-22933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17360309#comment-17360309
]
Fuyao Li edited comment on FLINK-22933 at 6/10/21, 1:46 AM:
[
https://issues.apache.org/jira/browse/FLINK-22949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ravikiran Borse updated FLINK-22949:
Fix Version/s: (was: 1.12.0)
> java.io.InvalidClassException With Flink Kafka Beam
> -
RocMarshal commented on a change in pull request #16126:
URL: https://github.com/apache/flink/pull/16126#discussion_r648789854
##
File path: docs/content.zh/docs/dev/table/sqlClient.md
##
@@ -153,6 +153,37 @@ Received a total of 5 rows
定义查询语句后，可以将其作为长时间运行的独立 Flink 作业提交给集群。[配
[
https://issues.apache.org/jira/browse/FLINK-22934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-22934:
---
Labels: pull-request-available (was: )
> Add instructions for using the " ' " escape syntax
RocMarshal opened a new pull request #16126:
URL: https://github.com/apache/flink/pull/16126
## What is the purpose of the change
*Add instructions for using the " ' " escape syntax of SQL client*
## Brief change log
*Add instructions for using the " ' " esca
1 - 100 of 423 matches
Mail list logo
