wsry commented on code in PR #19653:
URL: https://github.com/apache/flink/pull/19653#discussion_r882374093
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/TaskExecutorPartitionTrackerImpl.java:
##
@@ -131,6 +135,7 @@ public ClusterPartitionReport
cr
wsry commented on code in PR #19653:
URL: https://github.com/apache/flink/pull/19653#discussion_r882373238
##
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java:
##
@@ -901,7 +901,12 @@ public void releaseOrPromotePartitions(
try {
LadyForest commented on code in PR #138:
URL: https://github.com/apache/flink-table-store/pull/138#discussion_r882372928
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/TableStoreManagedFactory.java:
##
@@ -183,6 +200,70 @@ public void onDropT
LadyForest commented on code in PR #138:
URL: https://github.com/apache/flink-table-store/pull/138#discussion_r882370652
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/TableStoreManagedFactory.java:
##
@@ -183,6 +200,70 @@ public void onDropT
wsry commented on code in PR #19653:
URL: https://github.com/apache/flink/pull/19653#discussion_r882353820
##
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/partition/ClusterPartitionReport.java:
##
@@ -57,12 +59,21 @@ public static class ClusterPartitionRepor
fredia commented on code in PR #19448:
URL: https://github.com/apache/flink/pull/19448#discussion_r882367014
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistryImpl.java:
##
@@ -137,8 +146,8 @@ public StreamStateHandle registerReference(
re
LadyForest commented on code in PR #138:
URL: https://github.com/apache/flink-table-store/pull/138#discussion_r882366370
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/FileStoreReadImpl.java:
##
@@ -55,14 +56,14 @@ public FileStoreReadImpl(
fredia commented on code in PR #19448:
URL: https://github.com/apache/flink/pull/19448#discussion_r882366289
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointsCleaner.java:
##
@@ -65,6 +72,36 @@ public void cleanCheckpoint(
cleanup(checkpoint
fredia commented on code in PR #19448:
URL: https://github.com/apache/flink/pull/19448#discussion_r882360519
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistryImpl.java:
##
@@ -156,16 +165,40 @@ public void unregisterUnusedState(long
lowestCheckpo
LadyForest commented on code in PR #138:
URL: https://github.com/apache/flink-table-store/pull/138#discussion_r882357901
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/AbstractTableStoreFactory.java:
##
@@ -155,7 +155,7 @@ static Map
filterL
wsry commented on code in PR #19653:
URL: https://github.com/apache/flink/pull/19653#discussion_r882354232
##
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/partition/ClusterPartitionReport.java:
##
@@ -57,12 +59,21 @@ public static class ClusterPartitionRepor
wsry commented on code in PR #19653:
URL: https://github.com/apache/flink/pull/19653#discussion_r882353820
##
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/partition/ClusterPartitionReport.java:
##
@@ -57,12 +59,21 @@ public static class ClusterPartitionRepor
wsry commented on code in PR #19653:
URL: https://github.com/apache/flink/pull/19653#discussion_r882351486
##
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/partition/ClusterPartitionReport.java:
##
@@ -57,12 +59,21 @@ public static class ClusterPartitionRepor
wsry commented on code in PR #19653:
URL: https://github.com/apache/flink/pull/19653#discussion_r882350485
##
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/partition/ClusterPartitionReport.java:
##
@@ -57,12 +59,21 @@ public static class ClusterPartitionRepor
wsry commented on code in PR #19653:
URL: https://github.com/apache/flink/pull/19653#discussion_r882347966
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ClusterPartitionManager.java:
##
@@ -39,4 +41,14 @@ public interface ClusterPartitionManager {
curcur commented on PR #540:
URL: https://github.com/apache/flink-web/pull/540#issuecomment-1138164698
I do not have other questions & have accepted the blog post.
Please do not forget to rebuild the website before merging.
--
This is an automated message from the Apache Git Service
curcur commented on code in PR #540:
URL: https://github.com/apache/flink-web/pull/540#discussion_r879488407
##
_posts/2022-05-20-changelog-state-backend.md:
##
@@ -0,0 +1,353 @@
+---
+layout: post
+title: "Improving speed and stability of checkpointing with generic log-based
[
https://issues.apache.org/jira/browse/FLINK-27722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17542352#comment-17542352
]
Xintong Song commented on FLINK-27722:
--
I tried but couldn't update it.
- w/o check
Zixuan Rao created FLINK-27796:
--
Summary: Document approaches to updating existing instances of
stateful functions
Key: FLINK-27796
URL: https://issues.apache.org/jira/browse/FLINK-27796
Project: Flink
rovboyko commented on PR #19648:
URL: https://github.com/apache/flink/pull/19648#issuecomment-1138154479
Hi Timo @twalthr !
I've rewritten the solution according to your idea to use the `generateCast`
method.
I had to change the `CodeGeneratorCastRule` to it be able to declare not
on
[
https://issues.apache.org/jira/browse/FLINK-27794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dusukang updated FLINK-27794:
-
Description:
I want to use MysqlCatalog to get the primary key of the database table `user`.
The databa
[
https://issues.apache.org/jira/browse/FLINK-27795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linqichen updated FLINK-27795:
--
Description:
Hello , I found a problem， when i try to insert null value.
i think it is very common t
[
https://issues.apache.org/jira/browse/FLINK-27795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linqichen updated FLINK-27795:
--
Description:
i found a problem， when i try to insert null value.
i think it is very common to insert
[
https://issues.apache.org/jira/browse/FLINK-27794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dusukang updated FLINK-27794:
-
Description:
I want to use MysqlCatalog to get the primary key of the database table `user`.
The databa
linqichen created FLINK-27795:
-
Summary: SqlValidatorException when insert null value
Key: FLINK-27795
URL: https://issues.apache.org/jira/browse/FLINK-27795
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-27794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dusukang updated FLINK-27794:
-
Labels: pull-request-available (was: )
> The primary key obtained from MySQL is incorrect by using Mysq
[
https://issues.apache.org/jira/browse/FLINK-27794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dusukang updated FLINK-27794:
-
Description:
I want to use MysqlCatalog to get the primary key of the database table `user`.
The databa
[
https://issues.apache.org/jira/browse/FLINK-27794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dusukang updated FLINK-27794:
-
Description:
I want to use MysqlCatalog to get the primary key of the database table `user`.
The databa
[
https://issues.apache.org/jira/browse/FLINK-27794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dusukang updated FLINK-27794:
-
Attachment: 167908239-c6f3f0ad-af06-436f-87e2-85c60428b400.png
> The primary key obtained from MySQL is
[
https://issues.apache.org/jira/browse/FLINK-27794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dusukang updated FLINK-27794:
-
Description:
I want to use MysqlCatalog to get the primary key of the database table `user`.
The databa
[
https://issues.apache.org/jira/browse/FLINK-27794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dusukang updated FLINK-27794:
-
Description:
I want to use MysqlCatalog to get the primary key of the database table `user`.
The databa
[
https://issues.apache.org/jira/browse/FLINK-27794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dusukang updated FLINK-27794:
-
Description:
I want to use MysqlCatalog to get the primary key of the database table `user`.
The databa
[
https://issues.apache.org/jira/browse/FLINK-27794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dusukang updated FLINK-27794:
-
Description:
I want to use MysqlCatalog to get the information of the database table `user`.
The databa
dusukang created FLINK-27794:
Summary: The primary key obtained from MySQL is incorrect by using
MysqlCatalog
Key: FLINK-27794
URL: https://issues.apache.org/jira/browse/FLINK-27794
Project: Flink
jinshuangxian created FLINK-27793:
-
Summary: After upgrading to flink-1.15.0, flink jobmanager cannot
shutdown
Key: FLINK-27793
URL: https://issues.apache.org/jira/browse/FLINK-27793
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-27734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17542320#comment-17542320
]
Feifan Wang commented on FLINK-27734:
-
Hi [~junhany] ， can you help me confirm this
[
https://issues.apache.org/jira/browse/FLINK-26621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17542312#comment-17542312
]
Huang Xingbo commented on FLINK-26621:
--
https://dev.azure.com/apache-flink/apache-f
Huang Xingbo created FLINK-27792:
Summary: WindowDistinctAggregateITCase. testTumbleWindow_Rollup
failed with InterruptedException
Key: FLINK-27792
URL: https://issues.apache.org/jira/browse/FLINK-27792
[
https://issues.apache.org/jira/browse/FLINK-27667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17542311#comment-17542311
]
Huang Xingbo commented on FLINK-27667:
--
https://dev.azure.com/apache-flink/apache-f
Huang Xingbo created FLINK-27791:
Summary: SlotCountExceedingParallelismTest tests failed with
NoResourceAvailableException
Key: FLINK-27791
URL: https://issues.apache.org/jira/browse/FLINK-27791
Proj
dependabot[bot] opened a new pull request, #32:
URL: https://github.com/apache/flink-statefun-playground/pull/32
Bumps [undertow-core](https://github.com/undertow-io/undertow) from
1.4.18.Final to 2.2.11.Final.
Commits
https://github.com/undertow-io/undertow/commit/df0f10c6e620
JingsongLi commented on code in PR #138:
URL: https://github.com/apache/flink-table-store/pull/138#discussion_r882251162
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/AbstractTableStoreFactory.java:
##
@@ -155,7 +155,7 @@ static Map
filterL
dependabot[bot] opened a new pull request, #31:
URL: https://github.com/apache/flink-statefun-playground/pull/31
Bumps [undertow-core](https://github.com/undertow-io/undertow) from
1.4.18.Final to 2.2.11.Final.
Commits
https://github.com/undertow-io/undertow/commit/df0f10c6e620
dependabot[bot] opened a new pull request, #30:
URL: https://github.com/apache/flink-statefun-playground/pull/30
Bumps [undertow-core](https://github.com/undertow-io/undertow) from
1.4.18.Final to 2.2.11.Final.
Commits
https://github.com/undertow-io/undertow/commit/df0f10c6e620
dependabot[bot] opened a new pull request, #29:
URL: https://github.com/apache/flink-statefun-playground/pull/29
Bumps [undertow-core](https://github.com/undertow-io/undertow) from
1.4.18.Final to 2.2.11.Final.
Commits
https://github.com/undertow-io/undertow/commit/df0f10c6e620
[
https://issues.apache.org/jira/browse/FLINK-2?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Small Wong updated FLINK-2:
---
Description:
flink.version: 1.13
After set {*}table.exec.hive.fallback-mapred-writer=false{*}, then
dalongliu created FLINK-27790:
-
Summary: Move ADD/Remove Jar syntax code implementation from
SqlClient to TableEnvironment side
Key: FLINK-27790
URL: https://issues.apache.org/jira/browse/FLINK-27790
Proj
fanrui created FLINK-27789:
--
Summary: LegacySource compatible with overdraft buffer
Key: FLINK-27789
URL: https://issues.apache.org/jira/browse/FLINK-27789
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-27721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17542309#comment-17542309
]
Xintong Song commented on FLINK-27721:
--
bq. Which server are we going to use for th
[
https://issues.apache.org/jira/browse/FLINK-27760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-27760.
---
Fix Version/s: 1.13.7
1.14.5
1.16.0
1.15.1
Re
dianfu closed pull request #19816: [FLINK-27760][python] Fix the issue that NPE
is thrown when executing PyFlink Table API jobs in batch mode
URL: https://github.com/apache/flink/pull/19816
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on t
flinkbot commented on PR #19820:
URL: https://github.com/apache/flink/pull/19820#issuecomment-1138019010
## CI report:
* 57553025921f2fb7db332973b0d88c75aa0d32bc UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
liuzhuang2017 opened a new pull request, #19820:
URL: https://github.com/apache/flink/pull/19820
## What is the purpose of the change
- **This is the English document：**
(was: kubernetes-opera
Jaganathan Asokan created FLINK-27788:
-
Summary: Adding annotation to k8 operator Pod
Key: FLINK-27788
URL: https://issues.apache.org/jira/browse/FLINK-27788
Project: Flink
Issue Type: Im
[
https://issues.apache.org/jira/browse/FLINK-27787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephen Patel updated FLINK-27787:
--
Description:
I think I've found a bug with new task restoration from savepoints.
I have some
Stephen Patel created FLINK-27787:
-
Summary: New tasks think they've been restored from savepoint
(even when they weren't present in that savepoint)
Key: FLINK-27787
URL: https://issues.apache.org/jira/browse/FLIN
Sxnan commented on PR #19653:
URL: https://github.com/apache/flink/pull/19653#issuecomment-1137495948
@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.
To
fredia commented on code in PR #19448:
URL: https://github.com/apache/flink/pull/19448#discussion_r881847122
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistry.java:
##
@@ -57,13 +63,30 @@ public interface SharedStateRegistry extends AutoCloseable
fredia commented on code in PR #19448:
URL: https://github.com/apache/flink/pull/19448#discussion_r881839740
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointsCleaner.java:
##
@@ -107,6 +144,7 @@ private void maybeCompleteCloseUnsafe() {
if (
akalash commented on PR #19702:
URL: https://github.com/apache/flink/pull/19702#issuecomment-1137472221
It is not really that way. jobManagerTaskRestore ->
InflightDataRescalingDescriptor -> Virtual Channel is the current logic that
says that we need Virtual Channel only if we need rescalin
morhidi commented on code in PR #237:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/237#discussion_r881784524
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/FlinkService.java:
##
@@ -618,32 +623,51 @@ public SavepointFetc
[
https://issues.apache.org/jira/browse/FLINK-27779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Preuss reassigned FLINK-27779:
Assignee: Alexander Preuss
> Connectors should not depend on `flink-table-planner
SteNicholas commented on code in PR #237:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/237#discussion_r881766813
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/FlinkService.java:
##
@@ -618,32 +623,51 @@ public Savepoint
Alexander Preuss created FLINK-27786:
Summary: Connector-hive should not depend on `flink-table-planner`
Key: FLINK-27786
URL: https://issues.apache.org/jira/browse/FLINK-27786
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-27784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Preuss updated FLINK-27784:
-
Priority: Minor (was: Major)
> Connector-jdbc should not depend on `flink-table-planner
rkhachatryan commented on code in PR #19819:
URL: https://github.com/apache/flink/pull/19819#discussion_r881765652
##
flink-tests/src/test/java/org/apache/flink/runtime/operators/lifecycle/TestJobExecutor.java:
##
@@ -77,28 +77,28 @@ private TestJobExecutor(
public static T
[
https://issues.apache.org/jira/browse/FLINK-27784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Preuss updated FLINK-27784:
-
Component/s: Connectors / JDBC
> Connector-jdbc should not depend on `flink-table-planne
[
https://issues.apache.org/jira/browse/FLINK-27781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Preuss updated FLINK-27781:
-
Component/s: Connectors / Kafka
> Connector-kafka should not depend on `flink-table-plan
Alexander Preuss created FLINK-27784:
Summary: Connector-jdbc should not depend on `flink-table-planner`
Key: FLINK-27784
URL: https://issues.apache.org/jira/browse/FLINK-27784
Project: Flink
Alexander Preuss created FLINK-27783:
Summary: Connector-aws-kinesis should not depend on
`flink-table-planner`
Key: FLINK-27783
URL: https://issues.apache.org/jira/browse/FLINK-27783
Project: Fli
Alexander Preuss created FLINK-27785:
Summary: Connector-hbase should not depend on `flink-table-planner`
Key: FLINK-27785
URL: https://issues.apache.org/jira/browse/FLINK-27785
Project: Flink
Alexander Preuss created FLINK-27782:
Summary: Connector-kinesis should not depend on
`flink-table-planner`
Key: FLINK-27782
URL: https://issues.apache.org/jira/browse/FLINK-27782
Project: Flink
Alexander Preuss created FLINK-27781:
Summary: Connector-kafka should not depend on `flink-table-planner`
Key: FLINK-27781
URL: https://issues.apache.org/jira/browse/FLINK-27781
Project: Flink
Alexander Preuss created FLINK-27780:
Summary: Connector-cassandra should not depend on
`flink-table-planner`
Key: FLINK-27780
URL: https://issues.apache.org/jira/browse/FLINK-27780
Project: Flink
rkhachatryan commented on code in PR #19448:
URL: https://github.com/apache/flink/pull/19448#discussion_r881739752
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointsCleaner.java:
##
@@ -50,6 +54,9 @@ public class CheckpointsCleaner implements Serializ
Alexander Preuss created FLINK-27779:
Summary: Connectors should not depend on `flink-table-planner`
Key: FLINK-27779
URL: https://issues.apache.org/jira/browse/FLINK-27779
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-27740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-27740.
Fix Version/s: 1.16.0
Assignee: Sergey Nuyanzin
Resolution: Fixed
master:
zentol merged PR #19792:
URL: https://github.com/apache/flink/pull/19792
--
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
[
https://issues.apache.org/jira/browse/FLINK-27557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27557:
---
Labels: pull-request-available (was: )
> Submit compaction when prepareCommit is triggered
LadyForest opened a new pull request, #139:
URL: https://github.com/apache/flink-table-store/pull/139
Currently, `FileStoreWrite` will scan and plan files when creating a
non-empty writer. We should also create a non-empty writer for non-rescale
compaction cases but instead use the pre-plan
[
https://issues.apache.org/jira/browse/FLINK-27557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-27557:
--
Summary: Trigger compaction when prepareCommit is triggered (was: Let
FileStoreWrite accept pre-plann
[
https://issues.apache.org/jira/browse/FLINK-27557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-27557:
--
Summary: Submit compaction when prepareCommit is triggered (was: Trigger
compaction when prepareCommi
[
https://issues.apache.org/jira/browse/FLINK-27557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-27557:
--
Description:
Currently, FileStoreWrite will scan and plan files when creating a non-empty
writer. We
zentol commented on PR #19815:
URL: https://github.com/apache/flink/pull/19815#issuecomment-1137302619
Do we want to maintain a second image that is capable of building the docs
(beyond the CI image)? The CI image is a bit heavier than a purpose-built hugo
image, but I'm not sure that is su
[
https://issues.apache.org/jira/browse/FLINK-27557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-27557:
--
Summary: Let FileStoreWrite accept pre-planned manifest entries and let
MergeTreeWriter trigger compac
[
https://issues.apache.org/jira/browse/FLINK-27557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-27557:
--
Summary: Let FileStoreWrite accept pre-planned manifest entries and trigger
compaction when commit (w
zentol commented on code in PR #19819:
URL: https://github.com/apache/flink/pull/19819#discussion_r881697420
##
flink-tests/src/test/java/org/apache/flink/runtime/operators/lifecycle/TestJobExecutor.java:
##
@@ -77,28 +77,28 @@ private TestJobExecutor(
public static TestJob
csviri commented on PR #239:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/239#issuecomment-1137278874
Hi, thank you @morhidi for reporting this issue. On the main it's already
fixed. After we merged an additional related improvement:
https://github.com/java-operator-sdk/j
[
https://issues.apache.org/jira/browse/FLINK-27745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17542062#comment-17542062
]
Chesnay Schepler commented on FLINK-27745:
--
https://dev.azure.com/chesnay/flink
[
https://issues.apache.org/jira/browse/FLINK-27169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27169:
---
Labels: pull-request-available test-stability (was: test-stability)
> PartiallyFinishedSour
flinkbot commented on PR #19819:
URL: https://github.com/apache/flink/pull/19819#issuecomment-1137257175
## CI report:
* 85506ac60575794e4db49523554655aefaa0c7a2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
rkhachatryan opened a new pull request, #19819:
URL: https://github.com/apache/flink/pull/19819
## What is the purpose of the change
Fix test instability caused by changelog write timeouts.
## Verifying this change
This change is a trivial rework without any test coverage
MartijnVisser commented on PR #19815:
URL: https://github.com/apache/flink/pull/19815#issuecomment-1137245208
> Yeah, I'd be curious if we could come up with an alternative to that
image, because it seems kinda eh.
We could decide to fork it and remove the hardwire + add bash.
--
[
https://issues.apache.org/jira/browse/FLINK-27778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-27778:
-
Description:
The {{table-planner}} has a direct dependency on the {{table-code-splitter}
Chesnay Schepler created FLINK-27778:
Summary: table-planner should explicitly depend on
table-code-splitter
Key: FLINK-27778
URL: https://issues.apache.org/jira/browse/FLINK-27778
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-27169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17542043#comment-17542043
]
Roman Khachatryan edited comment on FLINK-27169 at 5/25/22 1:21 PM:
--
flinkbot commented on PR #19818:
URL: https://github.com/apache/flink/pull/19818#issuecomment-1137232047
## CI report:
* 872487e870162441de9fc69faca7d349e9f59327 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17542046#comment-17542046
]
Robert Metzger commented on FLINK-27721:
I agree, let's not block the effort on
1 - 100 of 233 matches
Mail list logo
