flinkbot commented on pull request #16754:
URL: https://github.com/apache/flink/pull/16754#issuecomment-894995035
## CI report:
* dc03d6c32befd6616f47ce6670c5034e967a7ecc UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot edited a comment on pull request #16753:
URL: https://github.com/apache/flink/pull/16753#issuecomment-894976098
## CI report:
* 9bdaac5b03db60848fbac4092931bef6291cc1eb Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #16752:
URL: https://github.com/apache/flink/pull/16752#issuecomment-894811682
## CI report:
* 15b5d81aa01c31fbf0573ccb7b30dacc7b5a6876 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #16691:
URL: https://github.com/apache/flink/pull/16691#issuecomment-891851095
## CI report:
* 037f03e8b64957efadc41f317311395fe1d6f6d5 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #16673:
URL: https://github.com/apache/flink/pull/16673#issuecomment-890927636
## CI report:
* a61847db3224d332b0b30c5d18cd421ca2a8a331 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #16371:
URL: https://github.com/apache/flink/pull/16371#issuecomment-873937708
## CI report:
* 29dc459b20dc9019a097a2b4906c6347ec5df98c Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-22059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17395855#comment-17395855
]
Yun Tang commented on FLINK-22059:
--
[~zhoujira86] What's the progress of your PR?
> ad
Myasuka commented on a change in pull request #16371:
URL: https://github.com/apache/flink/pull/16371#discussion_r684949446
##
File path: docs/content/docs/ops/state/state_backends.md
##
@@ -72,7 +72,7 @@ The EmbeddedRocksDBStateBackend always performs asynchronous
snapshots.
cuibo01 edited a comment on pull request #16745:
URL: https://github.com/apache/flink/pull/16745#issuecomment-894983624
> @cuibo01 I guess we have two questions here:
>
> 1. How to get the user name.
> 2. Whether user name should be a table-level or session-level setting.
>
cuibo01 edited a comment on pull request #16745:
URL: https://github.com/apache/flink/pull/16745#issuecomment-894983624
> @cuibo01 I guess we have two questions here:
>
> 1. How to get the user name.
> 2. Whether user name should be a table-level or session-level setting.
>
cuibo01 commented on pull request #16745:
URL: https://github.com/apache/flink/pull/16745#issuecomment-894983624
> @cuibo01 I guess we have two questions here:
>
> 1. How to get the user name.
> 2. Whether user name should be a table-level or session-level setting.
>
> For 1
flinkbot commented on pull request #16754:
URL: https://github.com/apache/flink/pull/16754#issuecomment-894980749
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-23289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-23289:
---
Labels: pull-request-available (was: )
> BinarySection should add null check in constructor
tsreaper opened a new pull request #16754:
URL: https://github.com/apache/flink/pull/16754
## What is the purpose of the change
`BinarySection` currently does not check if `MemorySegment[]` is null in its
constructor. This might cause NullPointerException somewhere else and makes it
Myasuka commented on a change in pull request #16371:
URL: https://github.com/apache/flink/pull/16371#discussion_r684938626
##
File path: docs/content/docs/ops/state/state_backends.md
##
@@ -72,7 +72,7 @@ The EmbeddedRocksDBStateBackend always performs asynchronous
snapshots.
flinkbot commented on pull request #16753:
URL: https://github.com/apache/flink/pull/16753#issuecomment-894976098
## CI report:
* 9bdaac5b03db60848fbac4092931bef6291cc1eb UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot edited a comment on pull request #16752:
URL: https://github.com/apache/flink/pull/16752#issuecomment-894811682
## CI report:
* 15b5d81aa01c31fbf0573ccb7b30dacc7b5a6876 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #16740:
URL: https://github.com/apache/flink/pull/16740#issuecomment-894176423
## CI report:
* c084abda71df7c5e1b0118dcbbd8761f89691526 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #16368:
URL: https://github.com/apache/flink/pull/16368#issuecomment-873854539
## CI report:
* d79db15ab05c86dcd82fe88dc7247fd413f5c0bf UNKNOWN
* a43db750e998ee75179abbd1fe24ff45842be6f4 Azure:
[SUCCESS](https://dev.azure.com/apache-fl
flinkbot edited a comment on pull request #16371:
URL: https://github.com/apache/flink/pull/16371#issuecomment-873937708
## CI report:
* 29dc459b20dc9019a097a2b4906c6347ec5df98c Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-23674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17395843#comment-17395843
]
Arvid Heise commented on FLINK-23674:
-
Can you please provide the full log?
> flink
[
https://issues.apache.org/jira/browse/FLINK-23683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise reassigned FLINK-23683:
---
Assignee: Fabian Paul
> KafkaSinkITCase hangs on azure
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-23678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise reassigned FLINK-23678:
---
Assignee: Fabian Paul
> KafkaSinkITCase.testWriteRecordsToKafkaWithExactlyOnceGuarantee fai
[
https://issues.apache.org/jira/browse/FLINK-23684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise reassigned FLINK-23684:
---
Assignee: Fabian Paul
> KafkaITCase.testAutoOffsetRetrievalAndCommitToKafka fails with
> N
[
https://issues.apache.org/jira/browse/FLINK-23675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lihangfei reopened FLINK-23675:
---
> flink1.13 cumulate unable use with compare function
>
[
https://issues.apache.org/jira/browse/FLINK-23675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lihangfei updated FLINK-23675:
--
Description:
select count(clicknum) as num
from table(
cumulate(table KafkaSource, desctiptor(app_d
[
https://issues.apache.org/jira/browse/FLINK-16200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ingo Bürk reassigned FLINK-16200:
-
Assignee: Ingo Bürk
> Support JSON_EXISTS for blink planner
> -
flinkbot commented on pull request #16753:
URL: https://github.com/apache/flink/pull/16753#issuecomment-894969777
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-23685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-23685:
---
Labels: pull-request-available (was: )
> Translate "Java Lambda Expressions" page into Chin
hapihu opened a new pull request #16753:
URL: https://github.com/apache/flink/pull/16753
Translate "Java Lambda Expressions" page into Chinese'
--
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 th
Airblader commented on pull request #16745:
URL: https://github.com/apache/flink/pull/16745#issuecomment-894963011
> i think the patch don't need FLINK-22878，because the options of
catalogTable is Map, and then we just need to convert map to hiveConfig
But these "passthrough" options
Thesharing commented on a change in pull request #16687:
URL: https://github.com/apache/flink/pull/16687#discussion_r684919002
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/LocalInputPreferredSlotSharingStrategy.java
##
@@ -214,87 +245,87 @@ priv
Airblader commented on pull request #16603:
URL: https://github.com/apache/flink/pull/16603#issuecomment-894960676
@yangjunhan Yes, the NOTICE file @twalthr mentioned needs to be updated as
well.
--
This is an automated message from the Apache Git Service.
To respond to the message, plea
lirui-apache commented on pull request #16745:
URL: https://github.com/apache/flink/pull/16745#issuecomment-894959489
@cuibo01 I guess we have two questions here:
1. How to get the user name.
2. Whether user name should be a table-level or session-level setting.
For 1st question
flinkbot edited a comment on pull request #16732:
URL: https://github.com/apache/flink/pull/16732#issuecomment-893984711
## CI report:
* 478cd2f5873830700bec057e02d30dcaf3fd35f7 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
wuguihu created FLINK-23685:
---
Summary: Translate "Java Lambda Expressions" page into Chinese
Key: FLINK-23685
URL: https://issues.apache.org/jira/browse/FLINK-23685
Project: Flink
Issue Type: Sub-t
flinkbot edited a comment on pull request #16732:
URL: https://github.com/apache/flink/pull/16732#issuecomment-893984711
## CI report:
* 478cd2f5873830700bec057e02d30dcaf3fd35f7 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #16699:
URL: https://github.com/apache/flink/pull/16699#issuecomment-892415455
## CI report:
* fb666804b2cf16e3aefac6dc51026384749f589f Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #16599:
URL: https://github.com/apache/flink/pull/16599#issuecomment-886750468
## CI report:
* b3e7026169e39a12c7fe8629a358cd3bf66a7153 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-23048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng updated FLINK-23048:
Component/s: (was: Table SQL / Runtime)
Runtime / Coordination
> GroupWindowI
flinkbot edited a comment on pull request #16699:
URL: https://github.com/apache/flink/pull/16699#issuecomment-892415455
## CI report:
* fb666804b2cf16e3aefac6dc51026384749f589f Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #16669:
URL: https://github.com/apache/flink/pull/16669#issuecomment-890847741
## CI report:
* 889dfbb1b28097728eea054580fa4e0e6bb61c22 UNKNOWN
* 26a9f1ad70ba1a7f1231bdc8cd8b62fef6510472 Azure:
[FAILURE](https://dev.azure.com/apache-fl
flinkbot edited a comment on pull request #16599:
URL: https://github.com/apache/flink/pull/16599#issuecomment-886750468
## CI report:
* b3e7026169e39a12c7fe8629a358cd3bf66a7153 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
godfreyhe commented on pull request #459:
URL: https://github.com/apache/flink-web/pull/459#issuecomment-894933141
@carp84 please take another look, 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 abov
cuibo01 commented on pull request #16745:
URL: https://github.com/apache/flink/pull/16745#issuecomment-894932918
> Can you take a look at
[FLINK-22878](https://issues.apache.org/jira/browse/FLINK-22878)? I think this
can be implemented with map types now, which would properly use the confi
flinkbot edited a comment on pull request #16669:
URL: https://github.com/apache/flink/pull/16669#issuecomment-890847741
## CI report:
* 889dfbb1b28097728eea054580fa4e0e6bb61c22 UNKNOWN
* 26a9f1ad70ba1a7f1231bdc8cd8b62fef6510472 Azure:
[FAILURE](https://dev.azure.com/apache-fl
[
https://issues.apache.org/jira/browse/FLINK-23512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao reassigned FLINK-23512:
---
Assignee: Yun Gao
> Check for illegal modifications of JobGraph with partially finished operators
>
cuibo01 edited a comment on pull request #16745:
URL: https://github.com/apache/flink/pull/16745#issuecomment-894931284
--
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
cuibo01 commented on pull request #16745:
URL: https://github.com/apache/flink/pull/16745#issuecomment-894931284
@lirui-apache thx for your review
Or in what situation would a user want to connect to HMS using one identity
and create tables with another?
--> in secure cluster, this i
Xintong Song created FLINK-23684:
Summary: KafkaITCase.testAutoOffsetRetrievalAndCommitToKafka fails
with NoSuchElementException
Key: FLINK-23684
URL: https://issues.apache.org/jira/browse/FLINK-23684
gaoyunhaii commented on pull request #16655:
URL: https://github.com/apache/flink/pull/16655#issuecomment-894930752
Hi @StephanEwen very thanks for the review!
> You can only change the JobGraph operator chains from a checkpoint if it
has no partially finished tasks.
I also a
[
https://issues.apache.org/jira/browse/FLINK-22889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17395733#comment-17395733
]
Xintong Song commented on FLINK-22889:
--
https://dev.azure.com/apache-flink/apache-f
Xintong Song created FLINK-23683:
Summary: KafkaSinkITCase hangs on azure
Key: FLINK-23683
URL: https://issues.apache.org/jira/browse/FLINK-23683
Project: Flink
Issue Type: Bug
Comp
[
https://issues.apache.org/jira/browse/FLINK-23678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17395732#comment-17395732
]
Xintong Song commented on FLINK-23678:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-22387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17395731#comment-17395731
]
Xintong Song commented on FLINK-22387:
--
https://dev.azure.com/apache-flink/apache-f
Xintong Song created FLINK-23682:
Summary:
HAQueryableStateFsBackendITCase.testCustomKryoSerializerHandling fails due to
AskTimeoutException
Key: FLINK-23682
URL: https://issues.apache.org/jira/browse/FLINK-23682
[
https://issues.apache.org/jira/browse/FLINK-16069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-16069.
---
Resolution: Duplicate
> Creation of TaskDeploymentDescriptor can block main thread for long time
> -
[
https://issues.apache.org/jira/browse/FLINK-23493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17395729#comment-17395729
]
Xintong Song commented on FLINK-23493:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-16069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17395728#comment-17395728
]
Zhu Zhu commented on FLINK-16069:
-
Thanks for making the improvements and sharing the re
[
https://issues.apache.org/jira/browse/FLINK-23602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17395727#comment-17395727
]
Yao Zhang commented on FLINK-23602:
---
Hi [~TsReaper],
I reproduced what you commen
[
https://issues.apache.org/jira/browse/FLINK-22194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-22194:
-
Priority: Major (was: Minor)
> KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers fail
[
https://issues.apache.org/jira/browse/FLINK-22194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-22194:
-
Labels: test-stability (was: auto-deprioritized-critical
auto-deprioritized-major test-stabilit
[
https://issues.apache.org/jira/browse/FLINK-22194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17395725#comment-17395725
]
Xintong Song commented on FLINK-22194:
--
https://dev.azure.com/apache-flink/apache-f
Yun Gao created FLINK-23681:
---
Summary: Rename the field name of OperatorIDPair to avoid the
confusion
Key: FLINK-23681
URL: https://issues.apache.org/jira/browse/FLINK-23681
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-23681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-23681:
Affects Version/s: 1.14.0
> Rename the field name of OperatorIDPair to avoid the confusion
> -
[
https://issues.apache.org/jira/browse/FLINK-22889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17395723#comment-17395723
]
Xintong Song commented on FLINK-22889:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-23681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao reassigned FLINK-23681:
---
Assignee: Yun Gao
> Rename the field name of OperatorIDPair to avoid the confusion
> --
[
https://issues.apache.org/jira/browse/FLINK-23680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17395722#comment-17395722
]
Xintong Song commented on FLINK-23680:
--
[~akalashnikov], this seems to be related t
Xintong Song created FLINK-23680:
Summary: StreamTaskTimerTest.testOpenCloseAndTimestamps fails on
azure
Key: FLINK-23680
URL: https://issues.apache.org/jira/browse/FLINK-23680
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-23671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-23671:
--
Description:
Please also turn off the assert by running the query *without* jvm parameter
-e
[
https://issues.apache.org/jira/browse/FLINK-23671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-23671:
--
Attachment: screenshot-1.png
> Failed to inference type in correlate
> --
[
https://issues.apache.org/jira/browse/FLINK-23678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17395718#comment-17395718
]
Xintong Song commented on FLINK-23678:
--
https://dev.azure.com/apache-flink/apache-f
Xintong Song created FLINK-23679:
Summary: PyFlink end-to-end test fail due to test script contains
errors
Key: FLINK-23679
URL: https://issues.apache.org/jira/browse/FLINK-23679
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-23671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17395717#comment-17395717
]
Shengkai Fang commented on FLINK-23671:
---
[~twalthr] I have updated the description
[
https://issues.apache.org/jira/browse/FLINK-23671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-23671:
--
Description:
{code:java}
CREATE FUNCTION func111 AS
'org.apache.flink.table.client.gateway.ut
Myasuka commented on a change in pull request #16371:
URL: https://github.com/apache/flink/pull/16371#discussion_r684881212
##
File path: docs/content/docs/ops/state/state_backends.md
##
@@ -293,29 +293,38 @@ Below is an example how to define a custom
ConfigurableOptionsFactor
flinkbot edited a comment on pull request #16368:
URL: https://github.com/apache/flink/pull/16368#issuecomment-873854539
## CI report:
* d79db15ab05c86dcd82fe88dc7247fd413f5c0bf UNKNOWN
* adf2f29416eaf6f819cbb2a7944ecec4c1be0eb2 Azure:
[SUCCESS](https://dev.azure.com/apache-fl
[
https://issues.apache.org/jira/browse/FLINK-23579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17395716#comment-17395716
]
Jingsong Lee commented on FLINK-23579:
--
master: 0d2b945729df8f0a0149d02ca24633ae52a
[
https://issues.apache.org/jira/browse/FLINK-23579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-23579:
Assignee: Caizhi Weng
> SELECT SHA2(CAST(NULL AS VARBINARY), CAST(NULL AS INT)) AS ref0 c
Myasuka commented on a change in pull request #16371:
URL: https://github.com/apache/flink/pull/16371#discussion_r684880764
##
File path: docs/content.zh/docs/ops/state/state_backends.md
##
@@ -233,7 +233,7 @@ Flink还提供了两个参数来控制*写路径*（MemTable）和*读路径*（
- `state.backend.rocksdb
JingsongLi merged pull request #16718:
URL: https://github.com/apache/flink/pull/16718
--
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-unsu
[
https://issues.apache.org/jira/browse/FLINK-23678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17395711#comment-17395711
]
Xintong Song commented on FLINK-23678:
--
[~fabian.paul], could you help take a look
tsreaper commented on a change in pull request #16699:
URL: https://github.com/apache/flink/pull/16699#discussion_r684878442
##
File path:
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/typeutils/LinkedListSerializer.java
##
@@ -110,17 +124,40 @@
Xintong Song created FLINK-23678:
Summary:
KafkaSinkITCase.testWriteRecordsToKafkaWithExactlyOnceGuarantee fails on azure
Key: FLINK-23678
URL: https://issues.apache.org/jira/browse/FLINK-23678
Projec
[
https://issues.apache.org/jira/browse/FLINK-23675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17395708#comment-17395708
]
Leonard Xu edited comment on FLINK-23675 at 8/9/21, 2:54 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-16556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17395709#comment-17395709
]
Liebing Yu commented on FLINK-16556:
I have a question: why more changes are needed
[
https://issues.apache.org/jira/browse/FLINK-23675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu closed FLINK-23675.
--
Resolution: Invalid
Please use English in issue, thanks
> flink1.13 cumulate 函数不能和部分比较函数连用
>
[
https://issues.apache.org/jira/browse/FLINK-23493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17395707#comment-17395707
]
Xintong Song commented on FLINK-23493:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-23556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17395706#comment-17395706
]
Xintong Song commented on FLINK-23556:
--
https://dev.azure.com/apache-flink/apache-f
[
https://issues.apache.org/jira/browse/FLINK-23493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17395705#comment-17395705
]
Xintong Song commented on FLINK-23493:
--
https://dev.azure.com/apache-flink/apache-f
tsreaper commented on a change in pull request #16740:
URL: https://github.com/apache/flink/pull/16740#discussion_r684875945
##
File path:
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/sql/FlinkSqlOperatorTable.java
##
@@ -224,6 +224,15
Xintong Song created FLINK-23677:
Summary:
KafkaTableITCase.testKafkaSourceSinkWithKeyAndPartialValue fails due to timeout
Key: FLINK-23677
URL: https://issues.apache.org/jira/browse/FLINK-23677
Proje
flinkbot edited a comment on pull request #16740:
URL: https://github.com/apache/flink/pull/16740#issuecomment-894176423
## CI report:
* aceb2a25e00797b20ed5e3356f168ea12df0a8de Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-23493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17395704#comment-17395704
]
Xintong Song commented on FLINK-23493:
--
https://dev.azure.com/apache-flink/apache-f
JingsongLi commented on a change in pull request #16699:
URL: https://github.com/apache/flink/pull/16699#discussion_r684875870
##
File path:
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/typeutils/LinkedListSerializer.java
##
@@ -110,17 +124,40 @
Xintong Song created FLINK-23676:
Summary:
ReduceOnNeighborMethodsITCase.testSumOfOutNeighborsNoValue fails due to
AskTimeoutException
Key: FLINK-23676
URL: https://issues.apache.org/jira/browse/FLINK-23676
wuchong commented on pull request #16295:
URL: https://github.com/apache/flink/pull/16295#issuecomment-894916866
@tsreaper are you interested in reviewing this?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/FLINK-12438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-12438.
---
Fix Version/s: 1.14.0
Resolution: Fixed
Fixed in master: 3efd5d167a25da2b5d85a9e855acafe3449cea7b
>
wuchong merged pull request #16304:
URL: https://github.com/apache/flink/pull/16304
--
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-unsubsc
lirui-apache commented on pull request #16745:
URL: https://github.com/apache/flink/pull/16745#issuecomment-894916366
Thanks @cuibo01 for working on this. However, I'm not sure whether we need
table-level property to set the owner. Hive code uses current UGI (either
simple or kerberized) w
1 - 100 of 150 matches
Mail list logo
