zhipeng93 commented on code in PR #197:
URL: https://github.com/apache/flink-ml/pull/197#discussion_r1066673845
##
flink-ml-benchmark/src/main/resources/linearregression-benchmark.json:
##
@@ -0,0 +1,45 @@
+// Licensed to the Apache Software Foundation (ASF) under one or more
+/
[
https://issues.apache.org/jira/browse/FLINK-30552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17665060#comment-17665060
]
Zili Chen commented on FLINK-30552:
---
3.0.1 via https://github.com/apache/flink-connect
[
https://issues.apache.org/jira/browse/FLINK-30552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen reassigned FLINK-30552:
-
Assignee: Yufan Sheng
> Pulsar connector shouldn't assert the BatchMessageId size.
> --
[
https://issues.apache.org/jira/browse/FLINK-30552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen updated FLINK-30552:
--
Fix Version/s: pulsar-3.0.1
> Pulsar connector shouldn't assert the BatchMessageId size.
> ---
[
https://issues.apache.org/jira/browse/FLINK-30556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30556:
---
Labels: pull-request-available (was: )
> Improve the logic for enumerating splits for Hive
swuferhong commented on code in PR #21586:
URL: https://github.com/apache/flink/pull/21586#discussion_r1066676100
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchPhysicalHashAggregate.scala:
##
@@ -53,7 +53,8 @@ cla
xintongsong commented on code in PR #21603:
URL: https://github.com/apache/flink/pull/21603#discussion_r1066635610
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsFileDataIndexSpilledRegionManagerImpl.java:
##
@@ -0,0 +1,336 @@
+/*
+ * Licen
zhipeng93 commented on PR #197:
URL: https://github.com/apache/flink-ml/pull/197#issuecomment-1378366076
Thanks for the review @lindong28 . I have updated the PR in the latest PR.
Please take a look.
--
This is an automated message from the Apache Git Service.
To respond to the message, p
flinkbot commented on PR #21645:
URL: https://github.com/apache/flink/pull/21645#issuecomment-1378371092
## CI report:
* 7162b2dbc3219a744e6be798d5b11215dda5cf74 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
zhuzhurk commented on code in PR #21626:
URL: https://github.com/apache/flink/pull/21626#discussion_r1066677286
##
flink-core/src/main/java/org/apache/flink/configuration/JobManagerOptions.java:
##
@@ -582,14 +578,9 @@ public enum SchedulerType {
.withDescri
JingsongLi merged PR #478:
URL: https://github.com/apache/flink-table-store/pull/478
--
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-30615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-30615.
Fix Version/s: table-store-0.4.0
Assignee: yuzelin
Resolution: Fixed
master: 7417d
JingsongLi commented on code in PR #475:
URL: https://github.com/apache/flink-table-store/pull/475#discussion_r1066684828
##
flink-table-store-hive/flink-table-store-hive-catalog/src/main/java/org/apache/flink/table/store/hive/HiveCatalogOptions.java:
##
@@ -0,0 +1,34 @@
+/*
+ *
lindong28 commented on PR #197:
URL: https://github.com/apache/flink-ml/pull/197#issuecomment-1378376796
Thanks for the update! LGTM.
--
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
lindong28 closed pull request #197: [FLINK-30566] Add benchmark for
AgglomerativeClustering, HashingTF, IDF, KBinsDiscretizer, LinearRegression,
LinearSVC, LogisticRegression, NGram, RegexTokenizer, Tokenizer and
Vectorindexer
URL: https://github.com/apache/flink-ml/pull/197
--
This is
zhipeng93 commented on code in PR #198:
URL: https://github.com/apache/flink-ml/pull/198#discussion_r1066688256
##
flink-ml-benchmark/src/main/resources/elementwiseproduct-benchmark.json:
##
@@ -0,0 +1,41 @@
+// Licensed to the Apache Software Foundation (ASF) under one or more
[
https://issues.apache.org/jira/browse/FLINK-25916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17668604#comment-17668604
]
Yao Zhang commented on FLINK-25916:
---
Hi all，
Could someone help review the code pleas
Xintong Song created FLINK-30629:
Summary: ClientHeartbeatTest.testJobRunningIfClientReportHeartbeat
is unstable
Key: FLINK-30629
URL: https://issues.apache.org/jira/browse/FLINK-30629
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17670876#comment-17670876
]
Xintong Song commented on FLINK-30629:
--
[~Jiangang], could you please take a look a
[
https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17671517#comment-17671517
]
Matthias Pohl commented on FLINK-29427:
---
https://dev.azure.com/apache-flink/apache
Matthias Pohl created FLINK-30630:
-
Summary: Python: BatchModeDataStreamTests.test_keyed_map failed
Key: FLINK-30630
URL: https://issues.apache.org/jira/browse/FLINK-30630
Project: Flink
Issu
[
https://issues.apache.org/jira/browse/FLINK-30630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-30630:
--
Description:
{{BatchModeDataStreamTests.test_keyed_map}} failed in 1.15:
https://dev.azure.com
[
https://issues.apache.org/jira/browse/FLINK-30630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17672188#comment-17672188
]
Matthias Pohl edited comment on FLINK-30630 at 1/11/23 8:45 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-30630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-30630:
--
Priority: Critical (was: Major)
> Python: BatchModeDataStreamTests.test_keyed_map failed
> --
[
https://issues.apache.org/jira/browse/FLINK-30630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17672188#comment-17672188
]
Matthias Pohl commented on FLINK-30630:
---
[~dianfu][~hxbks2ks]
> Python: BatchMode
yuzelin commented on code in PR #21502:
URL: https://github.com/apache/flink/pull/21502#discussion_r1066716687
##
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/result/ResultFetcher.java:
##
@@ -220,4 +283,26 @@ public synchronized ResultSet f
Lijie Wang created FLINK-30631:
--
Summary: Limit the max number of subpartitons consumed by each
downstream task
Key: FLINK-30631
URL: https://issues.apache.org/jira/browse/FLINK-30631
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-30631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang reassigned FLINK-30631:
--
Assignee: Lijie Wang
> Limit the max number of subpartitons consumed by each downstream task
gaoyunhaii commented on code in PR #21546:
URL: https://github.com/apache/flink/pull/21546#discussion_r1066547072
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperator.java:
##
@@ -443,33 +445,53 @@ public RetryableResultHandlerDe
[
https://issues.apache.org/jira/browse/FLINK-30559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17672243#comment-17672243
]
luoyuxia commented on FLINK-30559:
--
Thanks [~miamiaoxyz] Please feel free to take it.
[
https://issues.apache.org/jira/browse/FLINK-30023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17672244#comment-17672244
]
Matthias Pohl commented on FLINK-30023:
---
We see a similar test failure in 1.15.
h
wanglijie95 opened a new pull request, #21646:
URL: https://github.com/apache/flink/pull/21646
## What is the purpose of the change
In the current
implementation([FLINK-25035](https://issues.apache.org/jira/browse/FLINK-25035)),
when the upstream vertex parallelism is much greater than t
[
https://issues.apache.org/jira/browse/FLINK-30631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30631:
---
Labels: pull-request-available (was: )
> Limit the max number of subpartitons consumed by e
Jingsong Lee created FLINK-30632:
Summary: Introduce DataType for table store
Key: FLINK-30632
URL: https://issues.apache.org/jira/browse/FLINK-30632
Project: Flink
Issue Type: Sub-task
JingsongLi opened a new pull request, #479:
URL: https://github.com/apache/flink-table-store/pull/479
Introduce table store own DataType to decouple Flink SQL LogicalType.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and us
[
https://issues.apache.org/jira/browse/FLINK-30632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30632:
---
Labels: pull-request-available (was: )
> Introduce DataType for table store
> -
luoyuxia commented on code in PR #21609:
URL: https://github.com/apache/flink/pull/21609#discussion_r1066727574
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/GenerateUtils.scala:
##
@@ -304,9 +304,10 @@ object GenerateUtils {
//
[
https://issues.apache.org/jira/browse/FLINK-30023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-30023:
--
Affects Version/s: 1.15.3
> ChangelogStorageMetricsTest#testTotalAttemptsPerUpload failed
> --
[
https://issues.apache.org/jira/browse/FLINK-30023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-30023:
--
Component/s: Runtime / State Backends
> ChangelogStorageMetricsTest#testTotalAttemptsPerUpload
[
https://issues.apache.org/jira/browse/FLINK-30023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-30023:
--
Affects Version/s: 1.16.0
1.17.0
> ChangelogStorageMetricsTest#testTota
flinkbot commented on PR #21646:
URL: https://github.com/apache/flink/pull/21646#issuecomment-1378428604
## CI report:
* 50715d0b007f8393d2a730e48a83426475535569 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17672251#comment-17672251
]
Matthias Pohl commented on FLINK-30023:
---
I updated the affected Version to also in
Danny Cranmer created FLINK-30633:
-
Summary: Update AWS SDKv2 to v2.19.14
Key: FLINK-30633
URL: https://issues.apache.org/jira/browse/FLINK-30633
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-30304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17672255#comment-17672255
]
Danny Cranmer commented on FLINK-30304:
---
This has been fixed in SDK v2.19.14, upgr
[
https://issues.apache.org/jira/browse/FLINK-30633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-30633:
-
Assignee: Danny Cranmer
> Update AWS SDKv2 to v2.19.14
>
>
[
https://issues.apache.org/jira/browse/FLINK-30304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-30304:
--
Affects Version/s: aws-connector-4.0.0
> Possible Deadlock in Kinesis/Firehose/DynamoDB Connec
[
https://issues.apache.org/jira/browse/FLINK-30304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-30304:
--
Fix Version/s: aws-connector-4.1.0
> Possible Deadlock in Kinesis/Firehose/DynamoDB Connector
link3280 commented on PR #21582:
URL: https://github.com/apache/flink/pull/21582#issuecomment-1378444635
@fsk119 Thanks a lot for your review! The PR is updated as suggested.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
[
https://issues.apache.org/jira/browse/FLINK-30533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17672260#comment-17672260
]
Yanfei Lei commented on FLINK-30533:
Hi [~lindong] , could you please help take a lo
link3280 commented on code in PR #21581:
URL: https://github.com/apache/flink/pull/21581#discussion_r1066752130
##
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/operation/OperationExecutor.java:
##
@@ -487,23 +487,22 @@ public ResultFetcher c
luoyuxia commented on code in PR #21629:
URL: https://github.com/apache/flink/pull/21629#discussion_r1066748204
##
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveSumAggFunction.java:
##
@@ -125,10 +126,16 @@ private DataType initRes
[
https://issues.apache.org/jira/browse/FLINK-30413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reopened FLINK-30413:
---
Can you please provide backports to 1.16 and 1.15? We've seen test
instabilities (the once coll
[
https://issues.apache.org/jira/browse/FLINK-30413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17672264#comment-17672264
]
Matthias Pohl edited comment on FLINK-30413 at 1/11/23 9:25 AM:
--
tsianglei closed pull request #19124: [FLINK-26694] LookupFunction doesn't
support multilevel inheritance.
URL: https://github.com/apache/flink/pull/19124
--
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 g
[
https://issues.apache.org/jira/browse/FLINK-30413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-30413:
--
Affects Version/s: 1.15.3
1.16.0
> Drop Shared and Key_Shared subscript
[
https://issues.apache.org/jira/browse/FLINK-30413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17672264#comment-17672264
]
Matthias Pohl edited comment on FLINK-30413 at 1/11/23 9:27 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17672265#comment-17672265
]
Matthias Pohl commented on FLINK-30629:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-30629:
--
Labels: test-stability (was: )
> ClientHeartbeatTest.testJobRunningIfClientReportHeartbeat is
[
https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-30629:
--
Priority: Critical (was: Major)
> ClientHeartbeatTest.testJobRunningIfClientReportHeartbeat i
swuferhong commented on code in PR #21586:
URL: https://github.com/apache/flink/pull/21586#discussion_r1066761596
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/agg/batch/HashAggCodeGenerator.scala:
##
@@ -202,11 +299,43 @@ class HashAgg
[
https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17672266#comment-17672266
]
Matthias Pohl commented on FLINK-29427:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-30141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17672267#comment-17672267
]
Matthias Pohl commented on FLINK-30141:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17672265#comment-17672265
]
Matthias Pohl edited comment on FLINK-30629 at 1/11/23 9:30 AM:
--
Matthias Pohl created FLINK-30634:
-
Summary: HiveTableSourceITCase.setupSourceDatabaseAndData fails
with InvalidObjectException
Key: FLINK-30634
URL: https://issues.apache.org/jira/browse/FLINK-30634
luoyuxia created FLINK-30635:
Summary: Fail to recover for row-format when writing to OSS using
FileSystemTable connector
Key: FLINK-30635
URL: https://issues.apache.org/jira/browse/FLINK-30635
Project: F
[
https://issues.apache.org/jira/browse/FLINK-30623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17672271#comment-17672271
]
Yanfei Lei commented on FLINK-30623:
For checkpointSingleInput.UNALIGNED and checkpo
swuferhong commented on code in PR #21586:
URL: https://github.com/apache/flink/pull/21586#discussion_r1066775534
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/GenerateUtils.scala:
##
@@ -610,6 +610,58 @@ object GenerateUtils {
g
[
https://issues.apache.org/jira/browse/FLINK-30635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-30635:
-
Attachment: image-2023-01-11-17-42-15-964.png
> Fail to recover for row-format when writing to OSS using
[
https://issues.apache.org/jira/browse/FLINK-30635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-30635:
-
Description:
When recover for row-format file such as csv/json, it will try to copy oss to
local which
[
https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song reassigned FLINK-30629:
Assignee: Liu
> ClientHeartbeatTest.testJobRunningIfClientReportHeartbeat is unstable
> -
[
https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17672277#comment-17672277
]
Xintong Song commented on FLINK-30629:
--
Offline reached out to [~Jiangang] and he s
[
https://issues.apache.org/jira/browse/FLINK-30621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17672278#comment-17672278
]
Matthias Pohl commented on FLINK-30621:
---
I true, that's what I should have checked
[
https://issues.apache.org/jira/browse/FLINK-30621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17672278#comment-17672278
]
Matthias Pohl edited comment on FLINK-30621 at 1/11/23 9:48 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-30623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17672279#comment-17672279
]
Martijn Visser commented on FLINK-30623:
[~Yanfei Lei] Thanks for helping out o
link3280 commented on code in PR #21581:
URL: https://github.com/apache/flink/pull/21581#discussion_r1066752130
##
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/operation/OperationExecutor.java:
##
@@ -487,23 +487,22 @@ public ResultFetcher c
[
https://issues.apache.org/jira/browse/FLINK-29231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-29231:
---
Assignee: Dian Fu (was: Xingbo Huang)
> PyFlink udtaf produces different results in the same slidi
[
https://issues.apache.org/jira/browse/FLINK-30618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17672280#comment-17672280
]
Matthias Pohl commented on FLINK-30618:
---
good catch, @yufan! We, indeed, had issue
Samrat002 commented on PR #21512:
URL: https://github.com/apache/flink/pull/21512#issuecomment-1378495537
Test failure . Associated known ticket
https://issues.apache.org/jira/browse/FLINK-30629
--
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/FLINK-30375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17672284#comment-17672284
]
Samrat Deb commented on FLINK-30375:
Please help review the pr.
> SqlClient leaks
LadyForest opened a new pull request, #21647:
URL: https://github.com/apache/flink/pull/21647
## What is the purpose of the change
This PR is a subtask of FLINK-21634 to add documentation.
## Brief change log
Add documentation for `ALTER TALBE [IF EXISTS] `
statement
[
https://issues.apache.org/jira/browse/FLINK-30231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17672287#comment-17672287
]
liad shachoach commented on FLINK-30231:
[~martijnvisser]
I tried building fli
[
https://issues.apache.org/jira/browse/FLINK-22320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-22320:
---
Labels: pull-request-available (was: )
> Add documentation for new introduced ALTER TABLE s
flinkbot commented on PR #21647:
URL: https://github.com/apache/flink/pull/21647#issuecomment-1378512863
## CI report:
* 1dbed20696b4185c1950d841e34958d8b7830c5e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
tsreaper commented on code in PR #21393:
URL: https://github.com/apache/flink/pull/21393#discussion_r1066708360
##
flink-table/flink-table-code-splitter/src/main/java/org/apache/flink/table/codesplit/BlockStatementGrouper.java:
##
@@ -0,0 +1,432 @@
+/*
+ * Licensed to the Apache
tsreaper commented on code in PR #21393:
URL: https://github.com/apache/flink/pull/21393#discussion_r1066817943
##
flink-table/flink-table-code-splitter/src/main/java/org/apache/flink/table/codesplit/BlockStatementGrouper.java:
##
@@ -0,0 +1,432 @@
+/*
+ * Licensed to the Apache
Gunnar Morling created FLINK-30636:
--
Summary: Typo fix: "to to" -> "to"
Key: FLINK-30636
URL: https://issues.apache.org/jira/browse/FLINK-30636
Project: Flink
Issue Type: Technical Debt
[
https://issues.apache.org/jira/browse/FLINK-30636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17672294#comment-17672294
]
Gunnar Morling commented on FLINK-30636:
Will send a PR for this shortly.
> Typ
gunnarmorling opened a new pull request, #21648:
URL: https://github.com/apache/flink/pull/21648
Just a fix of a surprisingly common typo in JavaDoc etc.
https://issues.apache.org/jira/browse/FLINK-30636
--
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-30636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30636:
---
Labels: pull-request-available (was: )
> Typo fix: "to to" -> "to"
> --
gunnarmorling commented on PR #21648:
URL: https://github.com/apache/flink/pull/21648#issuecomment-1378532036
// CC @rmetzger
--
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
[
https://issues.apache.org/jira/browse/FLINK-30636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-30636:
--
Assignee: Gunnar Morling
> Typo fix: "to to" -> "to"
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-30231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17672297#comment-17672297
]
Martijn Visser commented on FLINK-30231:
[~liadsh] In the future, it's better to
[
https://issues.apache.org/jira/browse/FLINK-28898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-28898.
---
Fix Version/s: 1.16.0
Resolution: Fixed
I took a look at the stacktraces: Only the is
[
https://issues.apache.org/jira/browse/FLINK-28898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17672299#comment-17672299
]
Matthias Pohl edited comment on FLINK-28898 at 1/11/23 10:27 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reopened FLINK-28440:
---
I'm reopneing this issue since closing it as a duplicate of FLINK-28440 was a
mistake. FLINK-28
flinkbot commented on PR #21648:
URL: https://github.com/apache/flink/pull/21648#issuecomment-1378543117
## CI report:
* 1b6d9da1b1667437af361b2614470c8dfe830754 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-28440:
--
Description:
{code:java}
Caused by: java.lang.Exception: Exception while creating
StreamOpera
[
https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-28440:
--
Priority: Critical (was: Major)
> EventTimeWindowCheckpointingITCase.testSlidingTimeWindow fa
[
https://issues.apache.org/jira/browse/FLINK-30102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl closed FLINK-30102.
-
Resolution: Duplicate
Closing this issue as a duplicate of FLINK-28440 as all the reported build
[
https://issues.apache.org/jira/browse/FLINK-30107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl closed FLINK-30107.
-
Resolution: Duplicate
Closing this issue in favor of FLINK-28440 after verifying that all test
1 - 100 of 258 matches
Mail list logo
