flinkbot edited a comment on pull request #17660:
URL: https://github.com/apache/flink/pull/17660#issuecomment-958945516
## CI report:
* 25019a610a6391a10e2ad1535ea0122cd44273f6 Azure:
[
https://issues.apache.org/jira/browse/FLINK-24898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao updated FLINK-24898:
Issue Type: Improvement (was: Bug)
> Some further improvements of sort-shuffle
>
flinkbot edited a comment on pull request #17501:
URL: https://github.com/apache/flink/pull/17501#issuecomment-944297212
## CI report:
* b3c4a89278761f5d995bb7e7c03c0bc80e0d8cfe Azure:
Yingjie Cao created FLINK-24898:
---
Summary: Some further improvements of sort-shuffle
Key: FLINK-24898
URL: https://issues.apache.org/jira/browse/FLINK-24898
Project: Flink
Issue Type: Bug
gaurav726 commented on a change in pull request #17754:
URL: https://github.com/apache/flink/pull/17754#discussion_r749171434
##
File path:
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcRowDataLookupFunction.java
##
@@ -146,10
flinkbot edited a comment on pull request #17501:
URL: https://github.com/apache/flink/pull/17501#issuecomment-944297212
## CI report:
* b3c4a89278761f5d995bb7e7c03c0bc80e0d8cfe Azure:
flinkbot edited a comment on pull request #17501:
URL: https://github.com/apache/flink/pull/17501#issuecomment-944297212
## CI report:
* b3c4a89278761f5d995bb7e7c03c0bc80e0d8cfe Azure:
flinkbot edited a comment on pull request #17519:
URL: https://github.com/apache/flink/pull/17519#issuecomment-946579332
## CI report:
* 1b8f20ef7a9389445c75c0f2b623c6ab0f627870 Azure:
flinkbot edited a comment on pull request #17519:
URL: https://github.com/apache/flink/pull/17519#issuecomment-946579332
## CI report:
* 1b8f20ef7a9389445c75c0f2b623c6ab0f627870 Azure:
JingGe commented on a change in pull request #17773:
URL: https://github.com/apache/flink/pull/17773#discussion_r749161803
##
File path:
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReaderTest.java
##
flinkbot edited a comment on pull request #17501:
URL: https://github.com/apache/flink/pull/17501#issuecomment-944297212
## CI report:
* b3c4a89278761f5d995bb7e7c03c0bc80e0d8cfe Azure:
flinkbot edited a comment on pull request #17501:
URL: https://github.com/apache/flink/pull/17501#issuecomment-944297212
## CI report:
* b3c4a89278761f5d995bb7e7c03c0bc80e0d8cfe Azure:
[
https://issues.apache.org/jira/browse/FLINK-24811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443687#comment-17443687
]
Arvid Heise commented on FLINK-24811:
-
[~renqs] can you please take a look if this allows effects
flinkbot edited a comment on pull request #17501:
URL: https://github.com/apache/flink/pull/17501#issuecomment-944297212
## CI report:
* b3c4a89278761f5d995bb7e7c03c0bc80e0d8cfe Azure:
[
https://issues.apache.org/jira/browse/FLINK-24763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443685#comment-17443685
]
Jingsong Lee commented on FLINK-24763:
--
> How does the fetcher thread determines if there are
flinkbot edited a comment on pull request #17501:
URL: https://github.com/apache/flink/pull/17501#issuecomment-944297212
## CI report:
* b3c4a89278761f5d995bb7e7c03c0bc80e0d8cfe Azure:
flinkbot edited a comment on pull request #17640:
URL: https://github.com/apache/flink/pull/17640#issuecomment-957264269
## CI report:
* 4a9dc503d534287eee41c54d8857930443df1b3b UNKNOWN
* e42513c53faab9d042a6a6379f58c52185fe63d5 Azure:
flinkbot edited a comment on pull request #17640:
URL: https://github.com/apache/flink/pull/17640#issuecomment-957264269
## CI report:
* 4a9dc503d534287eee41c54d8857930443df1b3b UNKNOWN
* e42513c53faab9d042a6a6379f58c52185fe63d5 Azure:
[
https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443680#comment-17443680
]
Biao Geng commented on FLINK-24897:
---
Hi, [~trohrmann] [~wangyang0918] [~xtsong], very sorry to bother
rkhachatryan commented on pull request #17462:
URL: https://github.com/apache/flink/pull/17462#issuecomment-968702444
I see, you removed 2nd `awaitMaterialization` call, thanks for clarifying.
I think it makes sense to preserve the scenario with two materializations
(shouldn't be
[
https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443678#comment-17443678
]
john commented on FLINK-24897:
--
我们自己实现了 on yarn
[
https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443678#comment-17443678
]
john edited comment on FLINK-24897 at 11/15/21, 9:33 AM:
-
我们自己实现了 on yarn
flinkbot edited a comment on pull request #17640:
URL: https://github.com/apache/flink/pull/17640#issuecomment-957264269
## CI report:
* 4a9dc503d534287eee41c54d8857930443df1b3b UNKNOWN
* e42513c53faab9d042a6a6379f58c52185fe63d5 Azure:
[
https://issues.apache.org/jira/browse/FLINK-24896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-24896.
Resolution: Fixed
I have reverted FLINK-24724. The updated dependencies were just not
[
https://issues.apache.org/jira/browse/FLINK-24724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-24724.
Fix Version/s: (was: 1.15.0)
Resolution: Later
Reverted in
[
https://issues.apache.org/jira/browse/FLINK-24724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reopened FLINK-24724:
--
> Update japicmp jaxb dependencies
>
>
>
flinkbot edited a comment on pull request #17640:
URL: https://github.com/apache/flink/pull/17640#issuecomment-957264269
## CI report:
* 4a9dc503d534287eee41c54d8857930443df1b3b UNKNOWN
* e42513c53faab9d042a6a6379f58c52185fe63d5 Azure:
flinkbot edited a comment on pull request #17761:
URL: https://github.com/apache/flink/pull/17761#issuecomment-965943227
## CI report:
* 34ba01994ce91f93f6cf224f004e21ba4a1a505a Azure:
flinkbot edited a comment on pull request #17640:
URL: https://github.com/apache/flink/pull/17640#issuecomment-957264269
## CI report:
* 4a9dc503d534287eee41c54d8857930443df1b3b UNKNOWN
* e42513c53faab9d042a6a6379f58c52185fe63d5 Azure:
[
https://issues.apache.org/jira/browse/FLINK-24859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443672#comment-17443672
]
Etienne Chauchot commented on FLINK-24859:
--
thanks, my pleasure !
> Document new File formats
fapaul commented on a change in pull request #17776:
URL: https://github.com/apache/flink/pull/17776#discussion_r749126367
##
File path:
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/src/FileSourceSplit.java
##
@@ -91,9 +98,17 @@
*
rkhachatryan commented on a change in pull request #17462:
URL: https://github.com/apache/flink/pull/17462#discussion_r749136798
##
File path:
flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/ChangelogStateBackendTestUtils.java
flinkbot edited a comment on pull request #17761:
URL: https://github.com/apache/flink/pull/17761#issuecomment-965943227
## CI report:
* 34ba01994ce91f93f6cf224f004e21ba4a1a505a Azure:
[
https://issues.apache.org/jira/browse/FLINK-24896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443668#comment-17443668
]
Fabian Paul commented on FLINK-24896:
-
I suspect it is caused by
flinkbot edited a comment on pull request #17640:
URL: https://github.com/apache/flink/pull/17640#issuecomment-957264269
## CI report:
* 4a9dc503d534287eee41c54d8857930443df1b3b UNKNOWN
* e42513c53faab9d042a6a6379f58c52185fe63d5 Azure:
echauchot commented on pull request #17640:
URL: https://github.com/apache/flink/pull/17640#issuecomment-968690779
> Do you want to wrap up this PR and leave the follow-up of the secondary
ticket to another PR then?
@AHeise fair enough, done, PTAL
--
This is an automated message
[
https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Biao Geng updated FLINK-24897:
--
Description:
Hi there,
I am working to utilize application mode to submit flink jobs to YARN cluster
[
https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Biao Geng updated FLINK-24897:
--
Description:
Hi there,
I am working to utilize application mode to submit flink jobs to YARN cluster
flinkbot edited a comment on pull request #17637:
URL: https://github.com/apache/flink/pull/17637#issuecomment-957122792
## CI report:
* 8f68a316bd96c317619d264fe8818f558253b97b Azure:
[
https://issues.apache.org/jira/browse/FLINK-24896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443666#comment-17443666
]
Chesnay Schepler commented on FLINK-24896:
--
[~MartijnVisser] It fails the Java 11 compile phase
[
https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Biao Geng updated FLINK-24897:
--
Description:
Hi there,
I am working to utilize application mode to submit flink jobs to YARN cluster
[
https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Biao Geng updated FLINK-24897:
--
Description:
Hi there,
I am working to utilize application mode to submit flink jobs to YARN cluster
[
https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Biao Geng updated FLINK-24897:
--
Description:
Hi there,
I am working to utilize application mode to submit flink jobs to YARN cluster
xiangqiao123 commented on pull request #17761:
URL: https://github.com/apache/flink/pull/17761#issuecomment-968686122
@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
Biao Geng created FLINK-24897:
-
Summary: Enable application mode on YARN to use usrlib
Key: FLINK-24897
URL: https://issues.apache.org/jira/browse/FLINK-24897
Project: Flink
Issue Type:
rkhachatryan commented on a change in pull request #17462:
URL: https://github.com/apache/flink/pull/17462#discussion_r749129094
##
File path:
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java
##
[
https://issues.apache.org/jira/browse/FLINK-24896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443661#comment-17443661
]
Martijn Visser commented on FLINK-24896:
Checked it myself, it's multiple. Let's revert
PatrickRen commented on pull request #17765:
URL: https://github.com/apache/flink/pull/17765#issuecomment-968681924
Thanks for the patch and sorry for my late response!
Basically I think this is not a bug and I left some comments in
wenlong88 commented on a change in pull request #17754:
URL: https://github.com/apache/flink/pull/17754#discussion_r749126345
##
File path:
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcRowDataLookupFunction.java
##
@@ -146,10
flinkbot edited a comment on pull request #17501:
URL: https://github.com/apache/flink/pull/17501#issuecomment-944297212
## CI report:
* b3c4a89278761f5d995bb7e7c03c0bc80e0d8cfe Azure:
[
https://issues.apache.org/jira/browse/FLINK-24894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443658#comment-17443658
]
john commented on FLINK-24894:
--
[~guoyangze] But there is a problem with this mechanism: the modification
[
https://issues.apache.org/jira/browse/FLINK-24896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443657#comment-17443657
]
Martijn Visser commented on FLINK-24896:
[~fabian.paul] That is a suspicious one yes.
[
https://issues.apache.org/jira/browse/FLINK-24851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443656#comment-17443656
]
Qingsheng Ren edited comment on FLINK-24851 at 11/15/21, 9:06 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-24851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443656#comment-17443656
]
Qingsheng Ren commented on FLINK-24851:
---
Thanks for reporting this [~tashoyan] ! Generally I think
JingGe commented on pull request #17501:
URL: https://github.com/apache/flink/pull/17501#issuecomment-968676739
@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 edited a comment on pull request #17501:
URL: https://github.com/apache/flink/pull/17501#issuecomment-944297212
## CI report:
* b3c4a89278761f5d995bb7e7c03c0bc80e0d8cfe Azure:
flinkbot edited a comment on pull request #17794:
URL: https://github.com/apache/flink/pull/17794#issuecomment-968669934
## CI report:
* 6187b16c51fad3fb3ac4180736999804f84c9871 Azure:
[
https://issues.apache.org/jira/browse/FLINK-24896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443654#comment-17443654
]
Fabian Paul commented on FLINK-24896:
-
[~MartijnVisser] maybe it is related to
[
https://issues.apache.org/jira/browse/FLINK-24896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443652#comment-17443652
]
Yun Gao commented on FLINK-24896:
-
But I tried the plugin locally, it does not cause throws the
flinkbot commented on pull request #17794:
URL: https://github.com/apache/flink/pull/17794#issuecomment-968670345
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
[
https://issues.apache.org/jira/browse/FLINK-24846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443651#comment-17443651
]
Dawid Wysakowicz commented on FLINK-24846:
--
[~gaoyunhaii] We won't call {{finish}} for
Yun Gao created FLINK-24896:
---
Summary: Failed to execute goal
com.github.siom79.japicmp:japicmp-maven-plugin:0.11.0:cmp (default) on project
flink-metrics-core
Key: FLINK-24896
URL:
[
https://issues.apache.org/jira/browse/FLINK-24896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-24896:
Description:
{code:java}
[ERROR] Failed to execute goal
flinkbot commented on pull request #17794:
URL: https://github.com/apache/flink/pull/17794#issuecomment-968669934
## CI report:
* 6187b16c51fad3fb3ac4180736999804f84c9871 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
JingGe commented on a change in pull request #17501:
URL: https://github.com/apache/flink/pull/17501#discussion_r749116740
##
File path:
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/src/reader/RecordFormat.java
##
@@ -0,0 +1,130 @@
+/*
gaurav726 commented on a change in pull request #17754:
URL: https://github.com/apache/flink/pull/17754#discussion_r749115508
##
File path:
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcRowDataLookupFunction.java
##
@@ -146,10
[
https://issues.apache.org/jira/browse/FLINK-24846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Kalashnikov reassigned FLINK-24846:
-
Assignee: Anton Kalashnikov
> AsyncWaitOperator fails during
[
https://issues.apache.org/jira/browse/FLINK-24885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-24885:
---
Labels: pull-request-available (was: )
> ProcessElement Interface parameter Collector :
[
https://issues.apache.org/jira/browse/FLINK-24763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443647#comment-17443647
]
Yun Gao commented on FLINK-24763:
-
tsreaper opened a new pull request #17794:
URL: https://github.com/apache/flink/pull/17794
## What is the purpose of the change
Currently `SinkConversion` (generated code) and `OutputConversionOperator`
are not handling the case when row time is null. This PR fixes the issue.
bx123 created FLINK-24895:
-
Summary: SqlTimestampSerializer#deserialize forgets to fully read
from source when the record is null.
Key: FLINK-24895
URL: https://issues.apache.org/jira/browse/FLINK-24895
[
https://issues.apache.org/jira/browse/FLINK-24885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443644#comment-17443644
]
Caizhi Weng commented on FLINK-24885:
-
[~wangbaohua] This is because createTime might be null.
[
https://issues.apache.org/jira/browse/FLINK-24495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443645#comment-17443645
]
Yun Gao commented on FLINK-24495:
-
[
https://issues.apache.org/jira/browse/FLINK-24894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443643#comment-17443643
]
Yangze Guo commented on FLINK-24894:
[~long jiang] As recorded in [1], if you manually delete the
flinkbot edited a comment on pull request #17754:
URL: https://github.com/apache/flink/pull/17754#issuecomment-965189525
## CI report:
* 44b2eeac1043438fcdad1a57c42b912b2628891d Azure:
fapaul commented on a change in pull request #17345:
URL: https://github.com/apache/flink/pull/17345#discussion_r749104858
##
File path: flink-connectors/pom.xml
##
@@ -54,6 +54,7 @@ under the License.
flink-connector-kafka
john created FLINK-24894:
Summary: Flink on k8s, open the HA mode based on
KubernetesHaServicesFactory ，When I deleted the job, the config map created
under the HA mechanism was not deleted.
Key: FLINK-24894
URL:
slinkydeveloper commented on pull request #17786:
URL: https://github.com/apache/flink/pull/17786#issuecomment-968654534
Hi, thank you for your pr.
`PrintUtils` doesn't exist anymore as part of the refactoring here
https://issues.apache.org/jira/browse/FLINK-21456. In order to support
rkhachatryan commented on a change in pull request #17462:
URL: https://github.com/apache/flink/pull/17462#discussion_r749101875
##
File path:
flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/ChangelogStateBackendTestUtils.java
lindong28 commented on pull request #35:
URL: https://github.com/apache/flink-ml/pull/35#issuecomment-968652401
@gaoyunhaii Could you help review this PR? Thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
lindong28 opened a new pull request #35:
URL: https://github.com/apache/flink-ml/pull/35
## What is the purpose of the change
This PR updates WithParams::set(...) to throw Exception if the given param
is not defined on this instance. This is because we don't have use-case where
RocMarshal edited a comment on pull request #16962:
URL: https://github.com/apache/flink/pull/16962#issuecomment-966782262
@twalthr @Airblader @tillrohrmann @StephanEwen @tisonkun @gaoyunhaii Excuse
me, Could you help me to check it if you have free time ? Thanks a lot.
--
This is an
[
https://issues.apache.org/jira/browse/FLINK-24532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443633#comment-17443633
]
lincoln lee commented on FLINK-24532:
-
[~twalthr] Could you give a specific case for this issue？I
[
https://issues.apache.org/jira/browse/FLINK-24685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-24685:
-
Release Note: The string representation of BOOLEAN columns from DDL results
(true/false ->
[
https://issues.apache.org/jira/browse/FLINK-24685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-24685.
Fix Version/s: 1.15.0
Release Note: The string representation of BOOLEAN columns from DDL
[
https://issues.apache.org/jira/browse/FLINK-23918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-23918:
--
Component/s: (was: Connectors / FileSystem)
(was: FileSystems)
>
[
https://issues.apache.org/jira/browse/FLINK-23918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443630#comment-17443630
]
Till Rohrmann commented on FLINK-23918:
---
cc [~twalthr]
> FileNotFoundException when open
[
https://issues.apache.org/jira/browse/FLINK-23918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-23918:
--
Component/s: Table SQL / Ecosystem
> FileNotFoundException when open auto-compact in
twalthr closed pull request #17739:
URL: https://github.com/apache/flink/pull/17739
--
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:
curcur edited a comment on pull request #17462:
URL: https://github.com/apache/flink/pull/17462#issuecomment-968497357
@rkhachatryan , Let's sync up offline?
To answer the questions above:
1. Why is the test single thread? Because the materialization is triggered
**manually**
curcur commented on a change in pull request #17462:
URL: https://github.com/apache/flink/pull/17462#discussion_r749082756
##
File path:
flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/ChangelogStateBackendTestUtils.java
##
@@
curcur edited a comment on pull request #17462:
URL: https://github.com/apache/flink/pull/17462#issuecomment-968497357
@rkhachatryan , Let's sync up offline?
To answer the questions above:
1. Why is the test single thread? Because the materialization is triggered
**manually**
curcur edited a comment on pull request #17462:
URL: https://github.com/apache/flink/pull/17462#issuecomment-968497357
@rkhachatryan , Let's sync up offline?
To answer the questions above:
1. Why is the test single thread? Because the materialization is triggered
**manually**
curcur edited a comment on pull request #17462:
URL: https://github.com/apache/flink/pull/17462#issuecomment-968497357
@rkhachatryan , Let's sync up offline?
To answer the questions above:
1. Why is the test single thread? Because the materialization is triggered
manually from
curcur edited a comment on pull request #17462:
URL: https://github.com/apache/flink/pull/17462#issuecomment-968497357
@rkhachatryan , Let's sync up offline?
To answer the question above:
1. Why is the test single thread? Because the materialization is triggered
manually from the
[
https://issues.apache.org/jira/browse/FLINK-24592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443615#comment-17443615
]
Sergey Nuyanzin commented on FLINK-24592:
-
[~jark], [~twalthr] since I'm going to work on this
Airblader commented on a change in pull request #17788:
URL: https://github.com/apache/flink/pull/17788#discussion_r749077975
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/Catalog.java
##
@@ -520,6 +520,20 @@ void alterFunction(
701 - 797 of 797 matches
Mail list logo
