[
https://issues.apache.org/jira/browse/FLINK-26515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17791935#comment-17791935
]
Matthias Pohl commented on FLINK-26515:
---
https://github.com/XComp/flink/actions/ru
Matthias Pohl created FLINK-33720:
-
Summary: Building Flink took suspiciously long in e2e1 stage with
Hadoop 3.1.3 enabled
Key: FLINK-33720
URL: https://issues.apache.org/jira/browse/FLINK-33720
Proje
[
https://issues.apache.org/jira/browse/FLINK-22765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17791926#comment-17791926
]
Matthias Pohl commented on FLINK-22765:
---
master (1.19):
https://dev.azure.com/apa
[
https://issues.apache.org/jira/browse/FLINK-22765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-22765:
--
Affects Version/s: 1.19.0
> ExceptionUtilsITCase.testIsMetaspaceOutOfMemoryError is unstable
>
[
https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17791925#comment-17791925
]
Matthias Pohl commented on FLINK-28440:
---
master (1.19):
https://dev.azure.com/apa
1996fanrui commented on code in PR #720:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/720#discussion_r1411546956
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/autoscaler/KubernetesScalingRealizerTest.java:
##
@@ -0,0 +1,53 @@
+
flinkbot commented on PR #23849:
URL: https://github.com/apache/flink/pull/23849#issuecomment-1835607763
## CI report:
* ef24fc5d7376102ac47fe8e4f12fef9af7a53682 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33266:
---
Labels: pull-request-available (was: )
> Support plan cache for DQL in SQL Gateway
> --
zoudan opened a new pull request, #23849:
URL: https://github.com/apache/flink/pull/23849
## What is the purpose of the change
Support plan cache for DQL in SQL Gateway, so that we could reuse the plan
and save time on SQL parsing, validation, and optimization.
## Brief change
LadyForest commented on code in PR #23678:
URL: https://github.com/apache/flink/pull/23678#discussion_r1410315513
##
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/connector/datagen/table/DataGenTableSourceFactory.java:
##
@@ -127,11 +132,53 @@ private Da
Jane Chan created FLINK-33719:
-
Summary: Cleanup the usage of deprecated
StreamTableEnvironment#toRetractStream
Key: FLINK-33719
URL: https://issues.apache.org/jira/browse/FLINK-33719
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-33716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-33716:
--
Summary: Cleanup the usage of deprecated
StreamTableEnvironment#createTemporaryView (was: Cleanup the
[
https://issues.apache.org/jira/browse/FLINK-33717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-33717:
--
Summary: Cleanup the usage of deprecated
StreamTableEnvironment#fromDataStream (was: Cleanup the usag
Jane Chan created FLINK-33718:
-
Summary: Cleanup the usage of deprecated
StreamTableEnvironment#toAppendStream
Key: FLINK-33718
URL: https://issues.apache.org/jira/browse/FLINK-33718
Project: Flink
flinkbot commented on PR #23848:
URL: https://github.com/apache/flink/pull/23848#issuecomment-1835568401
## CI report:
* 52ea8e42a7be0e6d8679bff1f47a5546617acc6c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-33717:
--
Description:
{code:java}
PythonScalarFunctionOperatorTestBase
AvroTypesITCase {code}
> Cleanup the us
Jane Chan created FLINK-33717:
-
Summary: Cleanup the usage of deprecated
StreamTableEnvironment#fromDataStream(DataStream, Expression...)
Key: FLINK-33717
URL: https://issues.apache.org/jira/browse/FLINK-33717
[
https://issues.apache.org/jira/browse/FLINK-33713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33713:
---
Labels: pull-request-available (was: )
> Deprecate RuntimeContext#getExecutionConfig
>
[
https://issues.apache.org/jira/browse/FLINK-33716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-33716:
--
Description:
{code:java}
ExpressionTestBase
HiveTableSinkITCase
{code}
> Cleanup the usage of depreca
JunRuiLee opened a new pull request, #23848:
URL: https://github.com/apache/flink/pull/23848
## What is the purpose of the change
Deprecate RuntimeContext#getExecutionConfig, and introduce the alternative
getter methods createSerializer(TypeInformation typeInformation),
getGl
Jane Chan created FLINK-33716:
-
Summary: Cleanup the usage of deprecated
StreamTableEnvironment#createTemporaryView(String, DataStream, Expression...)
Key: FLINK-33716
URL: https://issues.apache.org/jira/browse/FLINK-
[
https://issues.apache.org/jira/browse/FLINK-31596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-31596:
--
Description:
This is a preparation to remove the deprecated methods in Table API for Flink
v2.0. Curr
[
https://issues.apache.org/jira/browse/FLINK-32557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-32557:
--
Description:
As discussed in [1], we are deprecating multiple APIs in release 1.18, in order
to compl
[
https://issues.apache.org/jira/browse/FLINK-32557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-32557:
--
Description:
As discussed in [1], we are deprecating multiple APIs in release 1.18, in order
to compl
JunRuiLee commented on code in PR #23847:
URL: https://github.com/apache/flink/pull/23847#discussion_r1411664582
##
docs/content.zh/docs/deployment/filesystems/gcs.md:
##
@@ -44,7 +44,10 @@ env.readTextFile("gs:///");
stream.writeAsText("gs:///");
// Use GCS as checkpoint st
Myasuka commented on code in PR #23820:
URL: https://github.com/apache/flink/pull/23820#discussion_r1411573550
##
flink-runtime-web/web-dashboard/src/app/pages/job-manager/profiler/job-manager-profiler.component.html:
##
@@ -0,0 +1,108 @@
+
+
+
+
+
+
+Profili
JunRuiLee commented on code in PR #23847:
URL: https://github.com/apache/flink/pull/23847#discussion_r1411656511
##
docs/content.zh/docs/ops/state/state_backends.md:
##
@@ -538,14 +540,11 @@ state.checkpoint-storage: filesystem
{{< tabs "fsstatebackendmigration" >}}
{{< tab "J
[
https://issues.apache.org/jira/browse/FLINK-33715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dongwoo.kim updated FLINK-33715:
Description:
Hello Flink team,
I'd like to propose an improvement to how the job manager archives
dongwoo.kim created FLINK-33715:
---
Summary: Enhance history server to archive multiple histories per
jobid
Key: FLINK-33715
URL: https://issues.apache.org/jira/browse/FLINK-33715
Project: Flink
1996fanrui commented on code in PR #23847:
URL: https://github.com/apache/flink/pull/23847#discussion_r1411631989
##
docs/content.zh/docs/ops/state/state_backends.md:
##
@@ -538,14 +540,11 @@ state.checkpoint-storage: filesystem
{{< tabs "fsstatebackendmigration" >}}
{{< tab "
Junrui Li created FLINK-33714:
-
Summary: Update documentation about the usage of
RuntimeContext#getExecutionConfig
Key: FLINK-33714
URL: https://issues.apache.org/jira/browse/FLINK-33714
Project: Flink
Junrui Li created FLINK-33713:
-
Summary: Deprecate RuntimeContext#getExecutionConfig
Key: FLINK-33713
URL: https://issues.apache.org/jira/browse/FLINK-33713
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17791903#comment-17791903
]
Kevin Tseng commented on FLINK-33545:
-
Hi Mason,
thank you for the comment.
In the
[
https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17791903#comment-17791903
]
Kevin Tseng edited comment on FLINK-33545 at 12/1/23 5:16 AM:
JingGe merged PR #23815:
URL: https://github.com/apache/flink/pull/23815
--
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
JingGe commented on code in PR #23844:
URL: https://github.com/apache/flink/pull/23844#discussion_r1411611276
##
flink-filesystems/flink-s3-fs-hadoop/src/main/java/org/apache/flink/fs/s3hadoop/HadoopS3AccessHelper.java:
##
@@ -84,13 +84,14 @@ public UploadPartResult uploadPart(
pgaref commented on PR #22646:
URL: https://github.com/apache/flink/pull/22646#issuecomment-1835461622
Hey @dmvk this is now ready for review -- attached UI screenshots!
Please let me know what you think!
--
This is an automated message from the Apache Git Service.
To respond to the m
Junrui Li created FLINK-33712:
-
Summary: FLIP-391: Deprecate RuntimeContext#getExecutionConfig
Key: FLINK-33712
URL: https://issues.apache.org/jira/browse/FLINK-33712
Project: Flink
Issue Type: T
JingGe commented on code in PR #23847:
URL: https://github.com/apache/flink/pull/23847#discussion_r1411585747
##
docs/content.zh/docs/deployment/filesystems/gcs.md:
##
@@ -44,7 +44,10 @@ env.readTextFile("gs:///");
stream.writeAsText("gs:///");
// Use GCS as checkpoint stora
JingGe commented on PR #23809:
URL: https://github.com/apache/flink/pull/23809#issuecomment-1835434229
Thanks @fsk119 for your reviews! Appreciate it!
--
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
flinkbot commented on PR #23847:
URL: https://github.com/apache/flink/pull/23847#issuecomment-1835433869
## CI report:
* f586ad401d51d9f23acaa11e35ff90871b9bc5b2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
JingGe commented on code in PR #23826:
URL: https://github.com/apache/flink/pull/23826#discussion_r1411584321
##
flink-formats/flink-orc/pom.xml:
##
@@ -182,7 +182,7 @@ under the License.
test-jar
-
+
Revi
[
https://issues.apache.org/jira/browse/FLINK-33669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33669:
---
Labels: pull-request-available (was: )
> Update the documentation for RestartStrategy, Chec
JunRuiLee opened a new pull request, #23847:
URL: https://github.com/apache/flink/pull/23847
## What is the purpose of the change
After the deprecation of complex Java object getter and setter methods in
FLIP-381, Flink now recommends the use of ConfigOptions for the configura
[
https://issues.apache.org/jira/browse/FLINK-33702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17791883#comment-17791883
]
xiangyu feng commented on FLINK-33702:
--
Hi [~huwh] , would u kindly assign this to
orkhand closed pull request #719: Release 1.6 Added new Metrics for custom
autoscaler implementation
URL: https://github.com/apache/flink-kubernetes-operator/pull/719
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
liyubin117 commented on PR #23810:
URL: https://github.com/apache/flink/pull/23810#issuecomment-1835401600
@lincoln-lil Since update outdated chinese doc is seperated with var-len
feature, I have divided commits into two, Could you please retain the structure
to make commits clear, thanks :
[
https://issues.apache.org/jira/browse/FLINK-33297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-33297:
---
Labels: 2.0-related pull-request-available (was: pull-request-available)
> FLIP-366: Support standa
[
https://issues.apache.org/jira/browse/FLINK-33297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-33297:
---
Fix Version/s: 1.19.0
> FLIP-366: Support standard YAML for FLINK configuration
> --
[
https://issues.apache.org/jira/browse/FLINK-23620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-23620:
---
Labels: 2.0-related (was: pull-request-available stale-assigned)
> Introduce proper YAML parsing to
caodizhou commented on PR #23842:
URL: https://github.com/apache/flink/pull/23842#issuecomment-1835388181
@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 comm
[
https://issues.apache.org/jira/browse/FLINK-32383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-32383:
---
Labels: 2.0-related (was: )
> 2.0 Breaking configuration changes
>
1996fanrui commented on code in PR #720:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/720#discussion_r1411546956
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/autoscaler/KubernetesScalingRealizerTest.java:
##
@@ -0,0 +1,53 @@
+
[
https://issues.apache.org/jira/browse/FLINK-4602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-4602:
--
Labels: 2.0-related auto-unassigned (was: auto-unassigned)
> Move RocksDB backend to proper package
>
[
https://issues.apache.org/jira/browse/FLINK-33581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17791875#comment-17791875
]
Rui Fan commented on FLINK-33581:
-
Hey [~JunRuiLi] , thank you for the feedback! Great w
[
https://issues.apache.org/jira/browse/FLINK-29741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-29741:
---
Labels: 2.0-related (was: )
> [FLIP-265] Remove all Scala APIs
>
>
caodizhou commented on PR #23842:
URL: https://github.com/apache/flink/pull/23842#issuecomment-1835330908
@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 comm
[
https://issues.apache.org/jira/browse/FLINK-33711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33711:
---
Labels: pull-request-available (was: )
> Fix numbers of field of the taxi event / Fix brok
yoda-mon opened a new pull request, #66:
URL: https://github.com/apache/flink-training/pull/66
- Fix number of fields of the taxi event from 11 to 10.
- According to https://issues.apache.org/jira/browse/FLINK-23926, the
number of fields decreased from 11 to 10.
- Fix broken link
Leona Yoda created FLINK-33711:
--
Summary: Fix numbers of field of the taxi event / Fix broken link
Key: FLINK-33711
URL: https://issues.apache.org/jira/browse/FLINK-33711
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17791866#comment-17791866
]
Mason Chen edited comment on FLINK-33545 at 12/1/23 1:30 AM:
-
liyubin117 commented on PR #23810:
URL: https://github.com/apache/flink/pull/23810#issuecomment-1835257286
@lincoln-lil surely, I will finish the doc synchronization right now.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
[
https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17791866#comment-17791866
]
Mason Chen edited comment on FLINK-33545 at 12/1/23 1:29 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17791866#comment-17791866
]
Mason Chen edited comment on FLINK-33545 at 12/1/23 1:29 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17791866#comment-17791866
]
Mason Chen edited comment on FLINK-33545 at 12/1/23 1:24 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17791866#comment-17791866
]
Mason Chen edited comment on FLINK-33545 at 12/1/23 1:24 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17791866#comment-17791866
]
Mason Chen commented on FLINK-33545:
Hi all, I just saw this ticket. I've read throu
lincoln-lil commented on PR #23810:
URL: https://github.com/apache/flink/pull/23810#issuecomment-1835240650
@liyubin117 Could you also synchronize the latest changes to the
documentation to the Chinese version?
--
This is an automated message from the Apache Git Service.
To respond to the
bvarghese1 commented on code in PR #23814:
URL: https://github.com/apache/flink/pull/23814#discussion_r1411425256
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/LookupJoinTestPrograms.java:
##
@@ -0,0 +1,287 @@
+/*
+ * Lice
[
https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33545:
---
Labels: pull-request-available (was: )
> KafkaSink implementation can cause dataloss during
boring-cyborg[bot] commented on PR #70:
URL:
https://github.com/apache/flink-connector-kafka/pull/70#issuecomment-1834763669
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is a
aeolus811tw opened a new pull request, #70:
URL: https://github.com/apache/flink-connector-kafka/pull/70
## What is the purpose of the change
To address the current flow of KafkaProducer having exact same behavior for
`DeliveryGuarantee.NONE` and `DeliveryGuarantee.AT_LEAST_ON
flinkbot commented on PR #23846:
URL: https://github.com/apache/flink/pull/23846#issuecomment-1834595897
## CI report:
* 409279e0bb32062c49662db17b6958a9e017d241 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
dependabot[bot] closed pull request #23785: Bump @adobe/css-tools from 4.0.1 to
4.3.1 in /flink-runtime-web/web-dashboard
URL: https://github.com/apache/flink/pull/23785
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
dependabot[bot] commented on PR #23785:
URL: https://github.com/apache/flink/pull/23785#issuecomment-1834592317
Superseded by #23846.
--
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
dependabot[bot] opened a new pull request, #23846:
URL: https://github.com/apache/flink/pull/23846
Bumps [@adobe/css-tools](https://github.com/adobe/css-tools) from 4.0.1 to
4.3.2.
Changelog
Sourced from https://github.com/adobe/css-tools/blob/main/History.md";>@adobe/css-tools's
qingwei91 commented on code in PR #79:
URL:
https://github.com/apache/flink-connector-jdbc/pull/79#discussion_r1411250155
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcRowDataLookupFunction.java:
##
@@ -92,9 +104,18 @@ public JdbcRowDataLookupF
[
https://issues.apache.org/jira/browse/FLINK-33710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33710:
---
Labels: pull-request-available (was: )
> Autoscaler redeploys pipeline for a NOOP paralleli
mxm opened a new pull request, #720:
URL: https://github.com/apache/flink-kubernetes-operator/pull/720
The operator supports two modes to apply autoscaler changes:
# Use the internal Flink config {{pipeline.jobvertex-parallelism-overrides}}
# Make use of Flink's Rescale API
Maximilian Michels created FLINK-33710:
--
Summary: Autoscaler redeploys pipeline for a NOOP parallelism
change
Key: FLINK-33710
URL: https://issues.apache.org/jira/browse/FLINK-33710
Project: Flin
breezykermo closed pull request #718: Release 1.6
URL: https://github.com/apache/flink-kubernetes-operator/pull/718
--
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 unsubscri
breezykermo opened a new pull request, #718:
URL: https://github.com/apache/flink-kubernetes-operator/pull/718
## What is the purpose of the change
*(For example: This pull request adds a new feature to periodically create
and maintain savepoints through the `FlinkDeployment`
[
https://issues.apache.org/jira/browse/FLINK-33694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17791695#comment-17791695
]
Martijn Visser commented on FLINK-33694:
[~plucas] Just a question, you state th
echauchot commented on PR #25:
URL:
https://github.com/apache/flink-connector-shared-utils/pull/25#issuecomment-1834048030
@snuyanzin can you elaborate on the use cases you have in mind for
systemPropertyVariable surefire.module.config ?
--
This is an automated message from the Apache Gi
xiangyuf commented on code in PR #23830:
URL: https://github.com/apache/flink/pull/23830#discussion_r1410877781
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/retryable/AsyncRetryStrategies.java:
##
@@ -181,11 +180,12 @@ public boolean canRetry(int current
lincoln-lil commented on code in PR #23830:
URL: https://github.com/apache/flink/pull/23830#discussion_r1410826099
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/retryable/AsyncRetryStrategies.java:
##
@@ -181,11 +180,12 @@ public boolean canRetry(int curr
[
https://issues.apache.org/jira/browse/FLINK-33694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17791670#comment-17791670
]
Patrick Lucas commented on FLINK-33694:
---
[~martijnvisser] aye, have a PR open but
patricklucas commented on PR #23836:
URL: https://github.com/apache/flink/pull/23836#issuecomment-1833953627
@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 comme
lincoln-lil commented on code in PR #23810:
URL: https://github.com/apache/flink/pull/23810#discussion_r1410805913
##
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/connector/datagen/table/RandomGeneratorVisitor.java:
##
@@ -503,10 +524,14 @@ private stat
MartijnVisser merged PR #23837:
URL: https://github.com/apache/flink/pull/23837
--
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
[
https://issues.apache.org/jira/browse/FLINK-33422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17791666#comment-17791666
]
Dawid Wysakowicz commented on FLINK-33422:
--
Moved classes in
645afd89e90e3f52c
dawidwys merged PR #23822:
URL: https://github.com/apache/flink/pull/23822
--
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.apac
flinkbot commented on PR #23845:
URL: https://github.com/apache/flink/pull/23845#issuecomment-1833924058
## CI report:
* 40ca70685630bfc2173a6375f56781edceda00d7 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
JingGe commented on PR #23809:
URL: https://github.com/apache/flink/pull/23809#issuecomment-1833917568
@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.
T
[
https://issues.apache.org/jira/browse/FLINK-33708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33708:
---
Labels: pull-request-available (was: )
> Add Span and TraceReporter concepts
>
pnowojski opened a new pull request, #23845:
URL: https://github.com/apache/flink/pull/23845
## What is the purpose of the change
This PR adds a concept of `Span` and `TraceReporter` and uses that to report
checkpointing traces.
## Brief change log
Please check individua
Piotr Nowojski created FLINK-33709:
--
Summary: Report CheckpointStats as Spans
Key: FLINK-33709
URL: https://issues.apache.org/jira/browse/FLINK-33709
Project: Flink
Issue Type: Sub-task
Piotr Nowojski created FLINK-33708:
--
Summary: Add Span and TraceReporter concepts
Key: FLINK-33708
URL: https://issues.apache.org/jira/browse/FLINK-33708
Project: Flink
Issue Type: Sub-task
jnh5y commented on code in PR #23680:
URL: https://github.com/apache/flink/pull/23680#discussion_r1410763255
##
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/test/program/SinkTestStep.java:
##
@@ -106,6 +113,8 @@ public static final class Builder extends
pvary commented on code in PR #69:
URL:
https://github.com/apache/flink-connector-kafka/pull/69#discussion_r1410705227
##
.github/workflows/push_pr.yml:
##
@@ -29,3 +29,11 @@ jobs:
uses: apache/flink-connector-shared-utils/.github/workflows/ci.yml@ci_utils
with:
1 - 100 of 208 matches
Mail list logo
