[
https://issues.apache.org/jira/browse/FLINK-32069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aleksandr Iushmanov updated FLINK-32069:
Description:
Using zeppelin with remote cluster I came across some race condition
RyanSkraba commented on code in PR #22010:
URL: https://github.com/apache/flink/pull/22010#discussion_r1192511163
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/SequenceGenerator.java:
##
@@ -65,33 +72,46 @@ public void open(
RyanSkraba commented on code in PR #615:
URL: https://github.com/apache/flink-web/pull/615#discussion_r1192516634
##
docs/content/posts/2023-02-27-release-kubernetes-operator-1.4.0.md:
##
@@ -84,7 +84,7 @@ We rely on users to share feedback so we can improve and make
this a ver
[
https://issues.apache.org/jira/browse/FLINK-32066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge reassigned FLINK-32066:
---
Assignee: Jing Ge
> Flink CI service on Azure stops responding to pull requests
> -
[
https://issues.apache.org/jira/browse/FLINK-32066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722212#comment-17722212
]
Jing Ge commented on FLINK-32066:
-
working on it
> Flink CI service on Azure stops resp
flinkbot commented on PR #22572:
URL: https://github.com/apache/flink/pull/22572#issuecomment-1545955981
## CI report:
* 3e82df924333d6f676f20a50c068bb35fa7c3076 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #22573:
URL: https://github.com/apache/flink/pull/22573#issuecomment-1545956110
## CI report:
* dd980a1bfd99b12404368abd94d93f299ee72d74 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #22574:
URL: https://github.com/apache/flink/pull/22574#issuecomment-1545956251
## CI report:
* c7e02124129c26fbabb41f24e6f89d2dc848b510 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #22575:
URL: https://github.com/apache/flink/pull/22575#issuecomment-1545956373
## CI report:
* d0b8d571c4900d50f52744e3d622c476428bb5bf UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
usamj commented on code in PR #49:
URL:
https://github.com/apache/flink-connector-aws/pull/49#discussion_r1192556373
##
flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/KinesisStreamsSource.java:
##
@@ -0,0 +1,167 @@
+/*
+ * Licensed t
[
https://issues.apache.org/jira/browse/FLINK-32066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1776#comment-1776
]
Jing Ge commented on FLINK-32066:
-
should work now, please check and share the feedback
JTaky commented on PR #22394:
URL: https://github.com/apache/flink/pull/22394#issuecomment-1546005491
Thanks a lot for the review!
Sorry but I think I cannot merge this PR.
https://github.com/apache/flink/assets/1190166/b189cc24-b9ea-4b35-be12-c2b4a815d045";>
--
This is an a
[
https://issues.apache.org/jira/browse/FLINK-32066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge resolved FLINK-32066.
-
Fix Version/s: 1.18.0
Resolution: Fixed
> Flink CI service on Azure stops responding to pull requ
[
https://issues.apache.org/jira/browse/FLINK-31810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722245#comment-17722245
]
David Artiga commented on FLINK-31810:
--
Something quite similar just happened to us
reswqa commented on PR #73:
URL:
https://github.com/apache/flink-connector-aws/pull/73#issuecomment-1546060123
Thanks for the review! I will merge this after `FLINK-32024` merged.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitH
dannycranmer commented on code in PR #49:
URL:
https://github.com/apache/flink-connector-aws/pull/49#discussion_r1175101246
##
flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/config/SourceConfigConstants.java:
##
@@ -0,0 +1,369 @@
+/*
dannycranmer commented on code in PR #49:
URL:
https://github.com/apache/flink-connector-aws/pull/49#discussion_r1192668358
##
flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/KinesisStreamsSource.java:
##
@@ -0,0 +1,167 @@
+/*
+ * Lic
dannycranmer commented on code in PR #49:
URL:
https://github.com/apache/flink-connector-aws/pull/49#discussion_r1192670238
##
flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/config/SourceConfigUtil.java:
##
@@ -0,0 +1,61 @@
+/*
+ * L
[
https://issues.apache.org/jira/browse/FLINK-29533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sakshi Sharma updated FLINK-29533:
--
Attachment: image-2023-05-12-14-14-58-020.png
> Add proper table style to Flink website
>
[
https://issues.apache.org/jira/browse/FLINK-32069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722259#comment-17722259
]
Martijn Visser commented on FLINK-32069:
[~mapohl] Any thoughts?
> jobClient.ge
[
https://issues.apache.org/jira/browse/FLINK-29533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722260#comment-17722260
]
Sakshi Sharma commented on FLINK-29533:
---
Can you please guide me on where the issu
youngminz commented on code in PR #615:
URL: https://github.com/apache/flink-web/pull/615#discussion_r1192674124
##
docs/content/posts/2023-02-27-release-kubernetes-operator-1.4.0.md:
##
@@ -84,7 +84,7 @@ We rely on users to share feedback so we can improve and make
this a very
dannycranmer commented on code in PR #49:
URL:
https://github.com/apache/flink-connector-aws/pull/49#discussion_r1192703805
##
flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/assigner/UniformShardAssigner.java:
##
@@ -0,0 +
xuzhiwen1255 commented on code in PR #22010:
URL: https://github.com/apache/flink/pull/22010#discussion_r1192906438
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/SequenceGenerator.java:
##
@@ -65,33 +72,46 @@ public void open(
xuzhiwen1255 commented on code in PR #22010:
URL: https://github.com/apache/flink/pull/22010#discussion_r1192906502
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/SequenceGenerator.java:
##
@@ -65,33 +72,46 @@ public void open(
xuzhiwen1255 commented on code in PR #21971:
URL: https://github.com/apache/flink/pull/21971#discussion_r1192908722
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/SequenceGenerator.java:
##
@@ -111,11 +120,20 @@ public boolean hasNe
Zakelly Lan created FLINK-32070:
---
Summary: FLIP-306 Unified File Merging Mechanism for Checkpoints
Key: FLINK-32070
URL: https://issues.apache.org/jira/browse/FLINK-32070
Project: Flink
Issue T
Zakelly Lan created FLINK-32071:
---
Summary: Implement the snapshot manager for merged checkpoint
files in TM
Key: FLINK-32071
URL: https://issues.apache.org/jira/browse/FLINK-32071
Project: Flink
Zakelly Lan created FLINK-32072:
---
Summary: Create and wire FileMergingSnapshotManager with
TaskManagerServices
Key: FLINK-32072
URL: https://issues.apache.org/jira/browse/FLINK-32072
Project: Flink
Zakelly Lan created FLINK-32073:
---
Summary: Implement file merging in snapshot
Key: FLINK-32073
URL: https://issues.apache.org/jira/browse/FLINK-32073
Project: Flink
Issue Type: Sub-task
Zakelly Lan created FLINK-32074:
---
Summary: Support file merging across checkpoints
Key: FLINK-32074
URL: https://issues.apache.org/jira/browse/FLINK-32074
Project: Flink
Issue Type: Sub-task
Zakelly Lan created FLINK-32075:
---
Summary: Delete merged files on checkpoint abort
Key: FLINK-32075
URL: https://issues.apache.org/jira/browse/FLINK-32075
Project: Flink
Issue Type: Sub-task
Zakelly Lan created FLINK-32078:
---
Summary: Implement private state file merging
Key: FLINK-32078
URL: https://issues.apache.org/jira/browse/FLINK-32078
Project: Flink
Issue Type: Sub-task
Zakelly Lan created FLINK-32077:
---
Summary: Implement shared state file merging
Key: FLINK-32077
URL: https://issues.apache.org/jira/browse/FLINK-32077
Project: Flink
Issue Type: Sub-task
Zakelly Lan created FLINK-32076:
---
Summary: Add file pool for concurrent file reusing
Key: FLINK-32076
URL: https://issues.apache.org/jira/browse/FLINK-32076
Project: Flink
Issue Type: Sub-task
Zakelly Lan created FLINK-32080:
---
Summary: Restoration of FileMergingSnapshotManager
Key: FLINK-32080
URL: https://issues.apache.org/jira/browse/FLINK-32080
Project: Flink
Issue Type: Sub-task
Zakelly Lan created FLINK-32079:
---
Summary: Read/write checkpoint metadata of merged files
Key: FLINK-32079
URL: https://issues.apache.org/jira/browse/FLINK-32079
Project: Flink
Issue Type: Sub-
Zakelly Lan created FLINK-32081:
---
Summary: Compatibility between file-merging on and off across job
runs
Key: FLINK-32081
URL: https://issues.apache.org/jira/browse/FLINK-32081
Project: Flink
Zakelly Lan created FLINK-32082:
---
Summary: Documentation of checkpoint file-merging
Key: FLINK-32082
URL: https://issues.apache.org/jira/browse/FLINK-32082
Project: Flink
Issue Type: Sub-task
Zakelly Lan created FLINK-32083:
---
Summary: Chinese translation of documentation of checkpoint
file-merging
Key: FLINK-32083
URL: https://issues.apache.org/jira/browse/FLINK-32083
Project: Flink
Zakelly Lan created FLINK-32085:
---
Summary: Implement and migrate batch uploading in changelog files
into the file merging framework
Key: FLINK-32085
URL: https://issues.apache.org/jira/browse/FLINK-32085
Zakelly Lan created FLINK-32086:
---
Summary: Cleanup non-reported managed directory on exit of TM
Key: FLINK-32086
URL: https://issues.apache.org/jira/browse/FLINK-32086
Project: Flink
Issue Type
Zakelly Lan created FLINK-32084:
---
Summary: Migrate current file merging of channel state into the
file merging framework
Key: FLINK-32084
URL: https://issues.apache.org/jira/browse/FLINK-32084
Project:
Zakelly Lan created FLINK-32087:
---
Summary: Space amplification statistics of file merging
Key: FLINK-32087
URL: https://issues.apache.org/jira/browse/FLINK-32087
Project: Flink
Issue Type: Sub-
Zakelly Lan created FLINK-32088:
---
Summary: Re-uploading in state file-merging for space
amplification control
Key: FLINK-32088
URL: https://issues.apache.org/jira/browse/FLINK-32088
Project: Flink
Zakelly Lan created FLINK-32090:
---
Summary: Python API for enabling and configuring file merging
snapshot
Key: FLINK-32090
URL: https://issues.apache.org/jira/browse/FLINK-32090
Project: Flink
Zakelly Lan created FLINK-32089:
---
Summary: Do fast copy in best-effort during first checkpoint after
restoration
Key: FLINK-32089
URL: https://issues.apache.org/jira/browse/FLINK-32089
Project: Flink
Zakelly Lan created FLINK-32092:
---
Summary: Integrate snapshot file-merging with existing IT cases
Key: FLINK-32092
URL: https://issues.apache.org/jira/browse/FLINK-32092
Project: Flink
Issue Ty
Zakelly Lan created FLINK-32091:
---
Summary: Add necessary metrics for file-merging
Key: FLINK-32091
URL: https://issues.apache.org/jira/browse/FLINK-32091
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-32072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan updated FLINK-32072:
Fix Version/s: 1.18.0
> Create and wire FileMergingSnapshotManager with TaskManagerServices
>
Mrart commented on code in PR #21527:
URL: https://github.com/apache/flink/pull/21527#discussion_r1192918839
##
flink-kubernetes/src/test/java/org/apache/flink/kubernetes/KubernetesClientTestBase.java:
##
@@ -143,6 +147,34 @@ protected void mockGetDeploymentWithError() {
reswqa commented on PR #21:
URL:
https://github.com/apache/flink-connector-opensearch/pull/21#issuecomment-1546537951
Thanks for the review!
--
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 s
reswqa merged PR #21:
URL: https://github.com/apache/flink-connector-opensearch/pull/21
--
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.
[
https://issues.apache.org/jira/browse/FLINK-27518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722035#comment-17722035
]
Yun Gao commented on FLINK-27518:
-
Merged on master via 82fb74e23b1dfa46fa98c89a58d7f312
[
https://issues.apache.org/jira/browse/FLINK-27518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao closed FLINK-27518.
---
Fix Version/s: 1.18.0
Resolution: Fixed
> Refactor migration tests to support version update automati
zhuzhurk commented on code in PR #22506:
URL: https://github.com/apache/flink/pull/22506#discussion_r1191985909
##
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/ExecutionFailureHandler.java:
##
@@ -121,6 +122,7 @@ private FailureHandlingResul
echauchot commented on PR #643:
URL: https://github.com/apache/flink-web/pull/643#issuecomment-1545283430
> I took a quick look over it. I feel especially for the IT case it would be
nice to first provide an overview over the differnet parts that make up a test
"There's a test framework; We
XComp commented on PR #22394:
URL: https://github.com/apache/flink/pull/22394#issuecomment-1545294936
@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
Wencong Liu created FLINK-32066:
---
Summary: Flink Ci service on Azure stops responding to pull
requests
Key: FLINK-32066
URL: https://issues.apache.org/jira/browse/FLINK-32066
Project: Flink
Is
echauchot commented on code in PR #643:
URL: https://github.com/apache/flink-web/pull/643#discussion_r1192004345
##
docs/content/posts/howto-test-batch-source.md:
##
@@ -0,0 +1,202 @@
+---
+title: "Howto test a batch source with the new Source framework"
+date: "2023-04-14T08:0
echauchot commented on code in PR #643:
URL: https://github.com/apache/flink-web/pull/643#discussion_r1192003814
##
docs/content/posts/howto-test-batch-source.md:
##
@@ -0,0 +1,202 @@
+---
+title: "Howto test a batch source with the new Source framework"
+date: "2023-04-14T08:0
[
https://issues.apache.org/jira/browse/FLINK-32066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wencong Liu updated FLINK-32066:
Summary: Flink CI service on Azure stops responding to pull requests (was:
Flink Ci service on Az
XComp commented on PR #22572:
URL: https://github.com/apache/flink/pull/22572#issuecomment-1545304968
Based on what observation do you conclude that CI is broken? Because [no CI
build](https://dev.azure.com/apache-flink/apache-flink/_build?definitionId=2)
was picked up since yesterday? :thi
WencongLiu commented on PR #22572:
URL: https://github.com/apache/flink/pull/22572#issuecomment-1545314729
Yes. No CI build is triggered anymore in the passed ten hours. I proposed it
on https://issues.apache.org/jira/browse/FLINK-32066
--
This is an automated message from the Apache Git
echauchot commented on code in PR #643:
URL: https://github.com/apache/flink-web/pull/643#discussion_r1192021200
##
docs/content/posts/howto-test-batch-source.md:
##
@@ -0,0 +1,202 @@
+---
+title: "Howto test a batch source with the new Source framework"
+date: "2023-04-14T08:0
[
https://issues.apache.org/jira/browse/FLINK-32066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-32066:
---
Priority: Blocker (was: Major)
> Flink CI service on Azure stops responding to pull request
[
https://issues.apache.org/jira/browse/FLINK-32066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722056#comment-17722056
]
Matthias Pohl commented on FLINK-32066:
---
Thanks for reporting this, [~Wencong Liu]
[
https://issues.apache.org/jira/browse/FLINK-32066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722057#comment-17722057
]
Martijn Visser commented on FLINK-32066:
I've raised this to a Blocker.
> Flin
WenDing-Y commented on PR #62:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/62#issuecomment-1545323241
Support for FilterPushDown, ProjectPushDown, and LimitPushDown to optimize
query performance. Have these functions been implemented? I don't seem to have
seen this pa
xishuaidelin commented on code in PR #22539:
URL: https://github.com/apache/flink/pull/22539#discussion_r1192027937
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/CompiledPlan.java:
##
@@ -109,6 +109,8 @@ default void writeToFile(File file) {
xishuaidelin commented on code in PR #22539:
URL: https://github.com/apache/flink/pull/22539#discussion_r1192028319
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/CompiledPlan.java:
##
@@ -109,6 +109,8 @@ default void writeToFile(File file) {
echauchot commented on code in PR #643:
URL: https://github.com/apache/flink-web/pull/643#discussion_r1192029322
##
docs/content/posts/howto-test-batch-source.md:
##
@@ -0,0 +1,202 @@
+---
+title: "Howto test a batch source with the new Source framework"
+date: "2023-04-14T08:0
echauchot commented on code in PR #643:
URL: https://github.com/apache/flink-web/pull/643#discussion_r1192030443
##
docs/content/posts/howto-test-batch-source.md:
##
@@ -0,0 +1,202 @@
+---
+title: "Howto test a batch source with the new Source framework"
+date: "2023-04-14T08:0
TanYuxin-tyx opened a new pull request, #22573:
URL: https://github.com/apache/flink/pull/22573
## What is the purpose of the change
*Migrate the subclasses of BatchAbstractTestBase in runtime.batch.sql to
JUnit5.*
## Brief change log
- *Migrate the
[
https://issues.apache.org/jira/browse/FLINK-32058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32058:
---
Labels: pull-request-available (was: )
> Migrate subclasses of BatchAbstractTestBase in run
[
https://issues.apache.org/jira/browse/FLINK-32065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722070#comment-17722070
]
Zhilong Hong commented on FLINK-32065:
--
Hi, [~SpongebobZ] Would you please upload t
reswqa opened a new pull request, #22574:
URL: https://github.com/apache/flink/pull/22574
## What is the purpose of the change
*Migrate subclasses of BatchAbstractTestBase in table and other modules to
JUnit5*
## Brief change log
- *Migrate subclasses of BatchAbstr
echauchot commented on code in PR #643:
URL: https://github.com/apache/flink-web/pull/643#discussion_r1192083594
##
docs/content/posts/howto-test-batch-source.md:
##
@@ -0,0 +1,202 @@
+---
+title: "Howto test a batch source with the new Source framework"
+date: "2023-04-14T08:0
[
https://issues.apache.org/jira/browse/FLINK-32060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32060:
---
Labels: pull-request-available (was: )
> Migrate subclasses of BatchAbstractTestBase in tab
[
https://issues.apache.org/jira/browse/FLINK-32063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722072#comment-17722072
]
Ahmed Hamdy commented on FLINK-32063:
-
So apparently the CI patches the changes to m
complone commented on PR #62:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/62#issuecomment-1545440640
> Support for FilterPushDown, ProjectPushDown, and LimitPushDown to optimize
query performance. Have these functions been implemented? I don't seem to have
seen this p
Gyula Fora created FLINK-32067:
--
Summary: When no pod template configured, an invalid null pod
template is configured
Key: FLINK-32067
URL: https://issues.apache.org/jira/browse/FLINK-32067
Project: Fli
[
https://issues.apache.org/jira/browse/FLINK-32065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob updated FLINK-32065:
--
Attachment: image-2023-05-12-17-37-09-002.png
> Got NoSuchFileException when initialize source functio
[
https://issues.apache.org/jira/browse/FLINK-32065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722094#comment-17722094
]
Spongebob commented on FLINK-32065:
---
Hi, [~Thesharing] , may be I could provide these
gyfora opened a new pull request, #592:
URL: https://github.com/apache/flink-kubernetes-operator/pull/592
## What is the purpose of the change
Recent changes broke the podTemplate configuration logic when no pod
template or ephemeral storage is configured resulting in an invalid null
[
https://issues.apache.org/jira/browse/FLINK-32067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32067:
---
Labels: pull-request-available (was: )
> When no pod template configured, an invalid null p
zhuzhurk commented on code in PR #22506:
URL: https://github.com/apache/flink/pull/22506#discussion_r1192155460
##
flink-core/src/main/java/org/apache/flink/util/concurrent/FutureUtils.java:
##
@@ -1289,4 +1293,59 @@ public static CompletableFuture switchExecutor(
echauchot commented on code in PR #643:
URL: https://github.com/apache/flink-web/pull/643#discussion_r1192157171
##
docs/content/posts/howto-test-batch-source.md:
##
@@ -0,0 +1,202 @@
+---
+title: "Howto test a batch source with the new Source framework"
+date: "2023-04-14T08:0
echauchot commented on code in PR #643:
URL: https://github.com/apache/flink-web/pull/643#discussion_r1192157171
##
docs/content/posts/howto-test-batch-source.md:
##
@@ -0,0 +1,202 @@
+---
+title: "Howto test a batch source with the new Source framework"
+date: "2023-04-14T08:0
echauchot commented on code in PR #643:
URL: https://github.com/apache/flink-web/pull/643#discussion_r1192162301
##
docs/content/posts/howto-test-batch-source.md:
##
@@ -0,0 +1,202 @@
+---
+title: "Howto test a batch source with the new Source framework"
+date: "2023-04-14T08:0
echauchot commented on code in PR #643:
URL: https://github.com/apache/flink-web/pull/643#discussion_r1192167315
##
docs/content/posts/howto-test-batch-source.md:
##
@@ -0,0 +1,202 @@
+---
+title: "Howto test a batch source with the new Source framework"
+date: "2023-04-14T08:0
gaborgsomogyi commented on PR #22550:
URL: https://github.com/apache/flink/pull/22550#issuecomment-1545492583
The change itself looks good, could you plz show which test failed and how?
(some log)
--
This is an automated message from the Apache Git Service.
To respond to the message, plea
echauchot commented on code in PR #643:
URL: https://github.com/apache/flink-web/pull/643#discussion_r1192171185
##
docs/content/posts/howto-test-batch-source.md:
##
@@ -0,0 +1,202 @@
+---
+title: "Howto test a batch source with the new Source framework"
+date: "2023-04-14T08:0
[
https://issues.apache.org/jira/browse/FLINK-32065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722100#comment-17722100
]
Zhilong Hong commented on FLINK-32065:
--
It's hard to investigate the root cause wit
godfreyhe commented on code in PR #22492:
URL: https://github.com/apache/flink/pull/22492#discussion_r1192099873
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/ExecNodeConfig.java:
##
@@ -55,7 +55,7 @@ private ExecNodeConfig(
[
https://issues.apache.org/jira/browse/FLINK-31966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722104#comment-17722104
]
Gyula Fora commented on FLINK-31966:
[~adrianalexvasiliu] new configuration changes
leishuiyu created FLINK-32068:
-
Summary: flink-connector-jdbc support clickhouse
Key: FLINK-32068
URL: https://issues.apache.org/jira/browse/FLINK-32068
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-32068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722107#comment-17722107
]
leishuiyu commented on FLINK-32068:
---
This function can be implemented by me as a PR ？
echauchot commented on PR #643:
URL: https://github.com/apache/flink-web/pull/643#issuecomment-1545544022
> > I took a quick look over it. I feel especially for the IT case it would
be nice to first provide an overview over the differnet parts that make up a
test "There's a test framework;
echauchot commented on PR #643:
URL: https://github.com/apache/flink-web/pull/643#issuecomment-1545554335
@zentol Thanks for your review (once again). I addressed all your comments
PTAL
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on t
1 - 100 of 122 matches
Mail list logo
