Yun Gao created FLINK-26322:
---
Summary: Test FileSink compaction manually
Key: FLINK-26322
URL: https://issues.apache.org/jira/browse/FLINK-26322
Project: Flink
Issue Type: Sub-task
flinkbot edited a comment on pull request #18894:
URL: https://github.com/apache/flink/pull/18894#issuecomment-1048496813
## CI report:
* c67d1af5d5b7e08a85ca19723a70c60dc1caab46 Azure:
matriv commented on a change in pull request #18858:
URL: https://github.com/apache/flink/pull/18858#discussion_r812629262
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinition.java
##
@@ -177,8 +177,9 @@ public
twalthr commented on a change in pull request #18858:
URL: https://github.com/apache/flink/pull/18858#discussion_r812628434
##
File path:
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/sql/BuiltInSqlOperator.java
##
@@ -74,4 +74,16 @@
flinkbot edited a comment on pull request #18894:
URL: https://github.com/apache/flink/pull/18894#issuecomment-1048496813
## CI report:
* c67d1af5d5b7e08a85ca19723a70c60dc1caab46 Azure:
flinkbot edited a comment on pull request #18883:
URL: https://github.com/apache/flink/pull/18883#issuecomment-1047924923
## CI report:
* 76e198f476cd1128551b64c3715040e1feb5b969 Azure:
twalthr commented on a change in pull request #18858:
URL: https://github.com/apache/flink/pull/18858#discussion_r812626974
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinition.java
##
@@ -177,8 +177,9 @@ public
[
https://issues.apache.org/jira/browse/FLINK-26315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz updated FLINK-26315:
-
Component/s: (was: Runtime / Task)
> Stream job which have multily region would not
flinkbot edited a comment on pull request #18894:
URL: https://github.com/apache/flink/pull/18894#issuecomment-1048496813
## CI report:
* c67d1af5d5b7e08a85ca19723a70c60dc1caab46 Azure:
flinkbot edited a comment on pull request #18883:
URL: https://github.com/apache/flink/pull/18883#issuecomment-1047924923
## CI report:
* 76e198f476cd1128551b64c3715040e1feb5b969 Azure:
[
https://issues.apache.org/jira/browse/FLINK-26196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz updated FLINK-26196:
-
Component/s: (was: Runtime / Checkpointing)
> error when Incremental Checkpoints
[
https://issues.apache.org/jira/browse/FLINK-26308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17496542#comment-17496542
]
Yang Wang commented on FLINK-26308:
---
If we change to use a role instead of cluster role, is is
[
https://issues.apache.org/jira/browse/FLINK-26239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz updated FLINK-26239:
-
Component/s: Runtime / State Backends
>
[
https://issues.apache.org/jira/browse/FLINK-26239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz updated FLINK-26239:
-
Component/s: (was: Runtime / Checkpointing)
>
[
https://issues.apache.org/jira/browse/FLINK-26239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17496541#comment-17496541
]
Dawid Wysakowicz commented on FLINK-26239:
--
cc [~roman] [~ym] Do you mind taking a look? It
twalthr commented on a change in pull request #18858:
URL: https://github.com/apache/flink/pull/18858#discussion_r812624863
##
File path:
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/functions/utils/ScalarSqlFunction.scala
##
@@ -42,7 +44,10
flinkbot edited a comment on pull request #18894:
URL: https://github.com/apache/flink/pull/18894#issuecomment-1048496813
## CI report:
* c67d1af5d5b7e08a85ca19723a70c60dc1caab46 Azure:
Matthias Pohl created FLINK-26321:
-
Summary:
KafkaSinkITCase.testWriteRecordsToKafkaWithExactlyOnceGuarantee fails on azure
Key: FLINK-26321
URL: https://issues.apache.org/jira/browse/FLINK-26321
dawidwys commented on pull request #18883:
URL: https://github.com/apache/flink/pull/18883#issuecomment-1048517409
@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
[
https://issues.apache.org/jira/browse/FLINK-26314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17496536#comment-17496536
]
Matthias Pohl commented on FLINK-26314:
---
[
https://issues.apache.org/jira/browse/FLINK-26115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17496535#comment-17496535
]
Yun Gao commented on FLINK-26115:
-
KafkaShuffleExactlyOnceITCase@1.13
flinkbot edited a comment on pull request #18894:
URL: https://github.com/apache/flink/pull/18894#issuecomment-1048496813
## CI report:
* c67d1af5d5b7e08a85ca19723a70c60dc1caab46 Azure:
hehuiyuan commented on pull request #18768:
URL: https://github.com/apache/flink/pull/18768#issuecomment-1048514864
Hi @lirui-apache , Take a look at this sometime
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
[
https://issues.apache.org/jira/browse/FLINK-26319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17496534#comment-17496534
]
Matthias Pohl commented on FLINK-26319:
---
hehuiyuan created FLINK-26320:
-
Summary: Update hive doc for 1 m->1 min
Key: FLINK-26320
URL: https://issues.apache.org/jira/browse/FLINK-26320
Project: Flink
Issue Type: Improvement
flinkbot edited a comment on pull request #18894:
URL: https://github.com/apache/flink/pull/18894#issuecomment-1048496813
## CI report:
* c67d1af5d5b7e08a85ca19723a70c60dc1caab46 Azure:
flinkbot edited a comment on pull request #18894:
URL: https://github.com/apache/flink/pull/18894#issuecomment-1048496813
## CI report:
* c67d1af5d5b7e08a85ca19723a70c60dc1caab46 Azure:
[
https://issues.apache.org/jira/browse/FLINK-23944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17496530#comment-17496530
]
Yun Gao commented on FLINK-23944:
-
1.14:
flinkbot edited a comment on pull request #18894:
URL: https://github.com/apache/flink/pull/18894#issuecomment-1048496813
## CI report:
* c67d1af5d5b7e08a85ca19723a70c60dc1caab46 Azure:
[
https://issues.apache.org/jira/browse/FLINK-26260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-26260.
--
> Support watching specific namespace for FlinkDeployments
>
[
https://issues.apache.org/jira/browse/FLINK-26290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-26290.
--
> Revisit serviceAccount and taskSlots direct fields in CRD
>
[
https://issues.apache.org/jira/browse/FLINK-26183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-26183.
--
> Support kubernetes-operator metrics using the Flink metric system
>
[
https://issues.apache.org/jira/browse/FLINK-26163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-26163.
--
> Refactor FlinkUtils#getEffectiveConfig into smaller pieces
>
[
https://issues.apache.org/jira/browse/FLINK-26142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-26142.
--
> Integrate flink-kubernetes-operator repo with CI/CD
>
[
https://issues.apache.org/jira/browse/FLINK-26216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-26216.
--
> Make 'replicas' work in JobManager Spec
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-26135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-26135.
--
> Separate job and deployment errors in FlinkDeployment status
>
[
https://issues.apache.org/jira/browse/FLINK-26319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-26319:
Priority: Blocker (was: Critical)
> CastFunctionITCase.testFunction failed on azure
>
[
https://issues.apache.org/jira/browse/FLINK-26078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-26078.
--
> Initial Kubernetes Operator Prototype contribution
> --
[
https://issues.apache.org/jira/browse/FLINK-26319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17496529#comment-17496529
]
Yun Gao commented on FLINK-26319:
-
[
https://issues.apache.org/jira/browse/FLINK-26319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17496526#comment-17496526
]
Yun Gao edited comment on FLINK-26319 at 2/23/22, 7:27 AM:
---
Perhaps cc
[
https://issues.apache.org/jira/browse/FLINK-26193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang closed FLINK-26193.
-
Resolution: Fixed
Fixed via:
main: 13024bdbdc50e43212c3efc0cadf3f117a717708
> Commit generated CRD
[
https://issues.apache.org/jira/browse/FLINK-26319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17496527#comment-17496527
]
Yun Gao commented on FLINK-26319:
-
flinkbot edited a comment on pull request #18894:
URL: https://github.com/apache/flink/pull/18894#issuecomment-1048496813
## CI report:
* c67d1af5d5b7e08a85ca19723a70c60dc1caab46 Azure:
[
https://issues.apache.org/jira/browse/FLINK-26319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17496526#comment-17496526
]
Yun Gao commented on FLINK-26319:
-
Perhaps cc [~twalthr]
> CastFunctionITCase.testFunction failed on
[
https://issues.apache.org/jira/browse/FLINK-26319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17496525#comment-17496525
]
Yun Gao commented on FLINK-26319:
-
[
https://issues.apache.org/jira/browse/FLINK-26319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-26319:
Priority: Critical (was: Major)
> CastFunctionITCase.testFunction failed on azure
>
Yun Gao created FLINK-26319:
---
Summary: CastFunctionITCase.testFunction failed on azure
Key: FLINK-26319
URL: https://issues.apache.org/jira/browse/FLINK-26319
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-26308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17496523#comment-17496523
]
Márton Balassi commented on FLINK-26308:
Hi [~ZhenqiuHuang],
The code is in a separate
flinkbot edited a comment on pull request #18894:
URL: https://github.com/apache/flink/pull/18894#issuecomment-1048496813
## CI report:
* c67d1af5d5b7e08a85ca19723a70c60dc1caab46 Azure:
snuyanzin commented on pull request #18874:
URL: https://github.com/apache/flink/pull/18874#issuecomment-1048505279
@slinkydeveloper thank you for your feedback, I addressed all the comments.
Please have a look once you have time.
Please let me know if I need to squash commits
--
[
https://issues.apache.org/jira/browse/FLINK-26318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17496522#comment-17496522
]
Yun Gao commented on FLINK-26318:
-
Perhaps cc [~roman] [~ym]
>
snuyanzin commented on a change in pull request #18874:
URL: https://github.com/apache/flink/pull/18874#discussion_r812611192
##
File path:
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/operations/SqlToOperationConverterTest.java
##
@@ -1660,6
snuyanzin commented on a change in pull request #18874:
URL: https://github.com/apache/flink/pull/18874#discussion_r812611073
##
File path:
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/operations/SqlToOperationConverterTest.java
##
@@ -1660,6
Yun Gao created FLINK-26318:
---
Summary: ChangelogCompatibilityITCase.testRestore failed on azure
Key: FLINK-26318
URL: https://issues.apache.org/jira/browse/FLINK-26318
Project: Flink
Issue Type:
snuyanzin commented on a change in pull request #18874:
URL: https://github.com/apache/flink/pull/18874#discussion_r812610956
##
File path:
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/parse/ClearOperationParseStrategy.java
##
@@ -29,7 +29,7 @@
flinkbot edited a comment on pull request #18894:
URL: https://github.com/apache/flink/pull/18894#issuecomment-1048496813
## CI report:
* c67d1af5d5b7e08a85ca19723a70c60dc1caab46 Azure:
flinkbot edited a comment on pull request #18656:
URL: https://github.com/apache/flink/pull/18656#issuecomment-1032337760
## CI report:
* efe514e108e0b2dfa752693f7b7b56e98285944d Azure:
flinkbot edited a comment on pull request #18894:
URL: https://github.com/apache/flink/pull/18894#issuecomment-1048496813
## CI report:
* c67d1af5d5b7e08a85ca19723a70c60dc1caab46 Azure:
flinkbot edited a comment on pull request #18656:
URL: https://github.com/apache/flink/pull/18656#issuecomment-1032337760
## CI report:
* efe514e108e0b2dfa752693f7b7b56e98285944d Azure:
[
https://issues.apache.org/jira/browse/FLINK-26314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17496519#comment-17496519
]
Yun Gao commented on FLINK-26314:
-
[
https://issues.apache.org/jira/browse/FLINK-26314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-26314:
Priority: Critical (was: Major)
> StreamingCompactingFileSinkITCase.testFileSink failed on azure
>
[
https://issues.apache.org/jira/browse/FLINK-23391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17496518#comment-17496518
]
Yun Gao commented on FLINK-23391:
-
zjureel commented on a change in pull request #18303:
URL: https://github.com/apache/flink/pull/18303#discussion_r812608394
##
File path:
flink-rpc/flink-rpc-core/src/main/java/org/apache/flink/runtime/rpc/RpcEndpoint.java
##
@@ -401,38 +451,90 @@ public void
Yun Gao created FLINK-26317:
---
Summary: flink-yarn-tests Exit code 137 returned from process
Key: FLINK-26317
URL: https://issues.apache.org/jira/browse/FLINK-26317
Project: Flink
Issue Type: Bug
flinkbot edited a comment on pull request #18894:
URL: https://github.com/apache/flink/pull/18894#issuecomment-1048496813
## CI report:
* c67d1af5d5b7e08a85ca19723a70c60dc1caab46 Azure:
[
https://issues.apache.org/jira/browse/FLINK-25782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao closed FLINK-25782.
---
Fix Version/s: 1.15.0
Resolution: Fixed
> Translate datastream filesystem.md page into Chinese.
>
[
https://issues.apache.org/jira/browse/FLINK-25782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17496516#comment-17496516
]
Yun Gao commented on FLINK-25782:
-
Merged on master via e4d2fb3848054f045ca2b0d4856d5d456a7dcd69.
>
gaoyunhaii closed pull request #18718:
URL: https://github.com/apache/flink/pull/18718
--
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:
flinkbot edited a comment on pull request #18894:
URL: https://github.com/apache/flink/pull/18894#issuecomment-1048496813
## CI report:
* c67d1af5d5b7e08a85ca19723a70c60dc1caab46 Azure:
zjureel commented on a change in pull request #18303:
URL: https://github.com/apache/flink/pull/18303#discussion_r812605460
##
File path:
flink-rpc/flink-rpc-core/src/main/java/org/apache/flink/runtime/concurrent/ComponentMainThreadExecutor.java
##
@@ -30,11 +31,15 @@
*
flinkbot commented on pull request #18894:
URL: https://github.com/apache/flink/pull/18894#issuecomment-1048496775
--
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
[
https://issues.apache.org/jira/browse/FLINK-26042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-26042:
---
Labels: pull-request-available test-stability (was: test-stability)
>
HuangXingBo opened a new pull request #18894:
URL: https://github.com/apache/flink/pull/18894
## What is the purpose of the change
*This pull request will raise exception when python version does not meet
requirements.*
## Brief change log
- *Raise exception when
infoverload commented on pull request #18765:
URL: https://github.com/apache/flink/pull/18765#issuecomment-1048492576
I think expanding the definitions under the table is fine.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
infoverload commented on a change in pull request #18765:
URL: https://github.com/apache/flink/pull/18765#discussion_r812599908
##
File path: docs/content/docs/ops/state/checkpoints.md
##
@@ -175,6 +175,35 @@ above).
$ bin/flink run -s :checkpointMetaDataPath [:runArgs]
```
infoverload commented on a change in pull request #18765:
URL: https://github.com/apache/flink/pull/18765#discussion_r812599226
##
File path: docs/content/docs/ops/state/checkpoints.md
##
@@ -175,6 +175,35 @@ above).
$ bin/flink run -s :checkpointMetaDataPath [:runArgs]
```
infoverload commented on a change in pull request #18765:
URL: https://github.com/apache/flink/pull/18765#discussion_r812595377
##
File path: docs/content/docs/ops/state/checkpoints.md
##
@@ -175,6 +175,35 @@ above).
$ bin/flink run -s :checkpointMetaDataPath [:runArgs]
```
infoverload commented on a change in pull request #18765:
URL: https://github.com/apache/flink/pull/18765#discussion_r812598191
##
File path: docs/content/docs/ops/state/checkpoints.md
##
@@ -175,6 +175,35 @@ above).
$ bin/flink run -s :checkpointMetaDataPath [:runArgs]
```
infoverload commented on a change in pull request #18765:
URL: https://github.com/apache/flink/pull/18765#discussion_r812597946
##
File path: docs/content/docs/ops/state/checkpoints.md
##
@@ -175,6 +175,35 @@ above).
$ bin/flink run -s :checkpointMetaDataPath [:runArgs]
```
infoverload commented on a change in pull request #18765:
URL: https://github.com/apache/flink/pull/18765#discussion_r812597875
##
File path: docs/content/docs/ops/state/checkpoints.md
##
@@ -175,6 +175,35 @@ above).
$ bin/flink run -s :checkpointMetaDataPath [:runArgs]
```
infoverload commented on a change in pull request #18765:
URL: https://github.com/apache/flink/pull/18765#discussion_r812597693
##
File path: docs/content/docs/ops/state/checkpoints.md
##
@@ -175,6 +175,35 @@ above).
$ bin/flink run -s :checkpointMetaDataPath [:runArgs]
```
[
https://issues.apache.org/jira/browse/FLINK-26306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17496504#comment-17496504
]
Yun Tang commented on FLINK-26306:
--
[~roman] After materialization, I think the new checkpoint would be
infoverload commented on a change in pull request #18765:
URL: https://github.com/apache/flink/pull/18765#discussion_r812595920
##
File path: docs/content/docs/ops/state/checkpoints.md
##
@@ -175,6 +175,35 @@ above).
$ bin/flink run -s :checkpointMetaDataPath [:runArgs]
```
infoverload commented on a change in pull request #18765:
URL: https://github.com/apache/flink/pull/18765#discussion_r812595377
##
File path: docs/content/docs/ops/state/checkpoints.md
##
@@ -175,6 +175,35 @@ above).
$ bin/flink run -s :checkpointMetaDataPath [:runArgs]
```
infoverload commented on a change in pull request #18765:
URL: https://github.com/apache/flink/pull/18765#discussion_r812594170
##
File path: docs/content/docs/ops/state/checkpoints.md
##
@@ -175,6 +175,35 @@ above).
$ bin/flink run -s :checkpointMetaDataPath [:runArgs]
```
infoverload commented on a change in pull request #18765:
URL: https://github.com/apache/flink/pull/18765#discussion_r812593954
##
File path: docs/content/docs/ops/state/checkpoints.md
##
@@ -175,6 +175,35 @@ above).
$ bin/flink run -s :checkpointMetaDataPath [:runArgs]
```
infoverload commented on a change in pull request #18765:
URL: https://github.com/apache/flink/pull/18765#discussion_r812591710
##
File path: docs/content/docs/ops/state/checkpoints.md
##
@@ -175,6 +175,35 @@ above).
$ bin/flink run -s :checkpointMetaDataPath [:runArgs]
```
infoverload commented on a change in pull request #18765:
URL: https://github.com/apache/flink/pull/18765#discussion_r812591052
##
File path: docs/content/docs/ops/state/checkpoints.md
##
@@ -175,6 +175,35 @@ above).
$ bin/flink run -s :checkpointMetaDataPath [:runArgs]
```
[
https://issues.apache.org/jira/browse/FLINK-26307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu closed FLINK-26307.
--
Resolution: Invalid
Please use English in JIRA, feel free to reopen after changing the description
>
[
https://issues.apache.org/jira/browse/FLINK-26316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-26316:
--
Description:
Reported by user in this [ML
[
https://issues.apache.org/jira/browse/FLINK-26316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-26316:
--
Description:
Reported by user in this [ML
[
https://issues.apache.org/jira/browse/FLINK-26316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-26316:
--
Description:
Reported by user in this [ML
Yang Wang created FLINK-26316:
-
Summary: Savepoint restore setting does not take effect when
configured via dynamic config options
Key: FLINK-26316
URL: https://issues.apache.org/jira/browse/FLINK-26316
[
https://issues.apache.org/jira/browse/FLINK-26216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora resolved FLINK-26216.
Resolution: Fixed
Merged:
5bd3b346c378e1562ac9d0cb4725e1e0189265da
> Make 'replicas' work in
flinkbot edited a comment on pull request #18833:
URL: https://github.com/apache/flink/pull/18833#issuecomment-1044070440
## CI report:
* 41981982dc01f99adaab5c8149c59811073b024f Azure:
flinkbot edited a comment on pull request #18831:
URL: https://github.com/apache/flink/pull/18831#issuecomment-1044063238
## CI report:
* c5c4dcc8b806030379039285bd24daef604c652b Azure:
[
https://issues.apache.org/jira/browse/FLINK-26307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
郭元方 updated FLINK-26307:
Description:
对于底层实现窗口时，求其开启窗口起始时间的方法有一个问题：
public static long getWindowStartWithOffset(long timestamp, long
[
https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-18356:
Summary: flink-table-planner Exit code 137 returned from process (was:
Exit code 137 returned from
[ https://issues.apache.org/jira/browse/FLINK-18356 ]
Yun Gao deleted comment on FLINK-18356:
-
was (Author: gaoyunhaii):
xintongsong commented on a change in pull request #18303:
URL: https://github.com/apache/flink/pull/18303#discussion_r812525319
##
File path:
flink-rpc/flink-rpc-core/src/main/java/org/apache/flink/runtime/concurrent/ComponentMainThreadExecutor.java
##
@@ -30,11 +31,15 @@
*
1 - 100 of 783 matches
Mail list logo
