zhuzhurk commented on a change in pull request #10832:
[FLINK-14163][runtime]Enforce synchronous registration of
Execution#producedPartitions
URL: https://github.com/apache/flink/pull/10832#discussion_r366734687
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/ex
[
https://issues.apache.org/jira/browse/FLINK-15431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-15431.
Resolution: Fixed
Implemented in 8d8e708b5df8b3bedc33935765ab87f426917a7d
> Add numLateRe
[
https://issues.apache.org/jira/browse/FLINK-15431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz updated FLINK-15431:
-
Fix Version/s: 1.11.0
> Add numLateRecordsDropped metric in CepOperator
> --
dawidwys merged pull request #10713: [FLINK-15431][CEP] Add
numLateRecordsDropped/lateRecordsDroppedRate/watermarkLatency in CepOperator
URL: https://github.com/apache/flink/pull/10713
This is an automated message from the A
[
https://issues.apache.org/jira/browse/FLINK-15431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015702#comment-17015702
]
Dawid Wysakowicz commented on FLINK-15431:
--
I updated the description to only c
[
https://issues.apache.org/jira/browse/FLINK-15431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz updated FLINK-15431:
-
Summary: Add numLateRecordsDropped in CepOperator (was: Add
numLateRecordsDropped/lateR
[
https://issues.apache.org/jira/browse/FLINK-15431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz updated FLINK-15431:
-
Description:
I find that current CepOperator has no metric indicates numLateRecordsDropp
[
https://issues.apache.org/jira/browse/FLINK-15431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz updated FLINK-15431:
-
Summary: Add numLateRecordsDropped metric in CepOperator (was: Add
numLateRecordsDroppe
flinkbot edited a comment on issue #10848: [FLINK-15307][failover]Rename
Subclasses of FailoverStrategy
URL: https://github.com/apache/flink/pull/10848#issuecomment-573958003
## CI report:
* a3f83df73af74cf8509f084e860ab88e63129ac8 Travis:
[SUCCESS](https://travis-ci.com/flink-c
flinkbot edited a comment on issue #10832: [FLINK-14163][runtime]Enforce
synchronous registration of Execution#producedPartitions
URL: https://github.com/apache/flink/pull/10832#issuecomment-573276729
## CI report:
* 5eb1599945f1bee35c342f762cc25684013d2d83 Travis:
[SUCCESS](htt
flinkbot edited a comment on issue #10857: [FLINK-15593][doc] add doc to remind
users not using Hive aggregate f…
URL: https://github.com/apache/flink/pull/10857#issuecomment-574504899
## CI report:
* 016ef5f198f7bb200cdacf81fb1df0537951f4c5 Travis:
[SUCCESS](https://travis-ci.c
flinkbot edited a comment on issue #10848: [FLINK-15307][failover]Rename
Subclasses of FailoverStrategy
URL: https://github.com/apache/flink/pull/10848#issuecomment-573958003
## CI report:
* a3f83df73af74cf8509f084e860ab88e63129ac8 Travis:
[SUCCESS](https://travis-ci.com/flink-c
[
https://issues.apache.org/jira/browse/FLINK-15595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015673#comment-17015673
]
Jingsong Lee edited comment on FLINK-15595 at 1/15/20 7:09 AM:
---
flinkbot edited a comment on issue #10857: [FLINK-15593][doc] add doc to remind
users not using Hive aggregate f…
URL: https://github.com/apache/flink/pull/10857#issuecomment-574504899
## CI report:
* 016ef5f198f7bb200cdacf81fb1df0537951f4c5 Travis:
[SUCCESS](https://travis-ci.c
[
https://issues.apache.org/jira/browse/FLINK-13758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015615#comment-17015615
]
Yang Wang edited comment on FLINK-13758 at 1/15/20 6:44 AM:
flinkbot edited a comment on issue #10848: [FLINK-15307][failover]Rename
Subclasses of FailoverStrategy
URL: https://github.com/apache/flink/pull/10848#issuecomment-573958003
## CI report:
* a3f83df73af74cf8509f084e860ab88e63129ac8 Travis:
[SUCCESS](https://travis-ci.com/flink-c
[
https://issues.apache.org/jira/browse/FLINK-13758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015615#comment-17015615
]
Yang Wang edited comment on FLINK-13758 at 1/15/20 6:43 AM:
flinkbot edited a comment on issue #10832: [FLINK-14163][runtime]Enforce
synchronous registration of Execution#producedPartitions
URL: https://github.com/apache/flink/pull/10832#issuecomment-573276729
## CI report:
* 5eb1599945f1bee35c342f762cc25684013d2d83 Travis:
[SUCCESS](htt
[
https://issues.apache.org/jira/browse/FLINK-15579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015674#comment-17015674
]
Jark Wu commented on FLINK-15579:
-
In old planner, {{UpsertStreamTableSink}} is only use
[
https://issues.apache.org/jira/browse/FLINK-15595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015673#comment-17015673
]
Jingsong Lee commented on FLINK-15595:
--
Hi [~phoenixjiangnan], yes, what I mean is
[
https://issues.apache.org/jira/browse/FLINK-15592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015672#comment-17015672
]
Jark Wu commented on FLINK-15592:
-
I got what you mean [~lzljs3620320]. {{ROW_NUMBER}} a
[
https://issues.apache.org/jira/browse/FLINK-15593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015671#comment-17015671
]
Jingsong Lee commented on FLINK-15593:
--
Hi [~phoenixjiangnan], I think you misunder
[
https://issues.apache.org/jira/browse/FLINK-15592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015669#comment-17015669
]
Jingsong Lee commented on FLINK-15592:
--
> Shouldn't we add ROW_NUMBER into {{BuiltI
[
https://issues.apache.org/jira/browse/FLINK-15579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015665#comment-17015665
]
Shu Li Zheng commented on FLINK-15579:
--
[~jark] Hi jark, I'm wondering why BatchExe
[
https://issues.apache.org/jira/browse/FLINK-15595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015662#comment-17015662
]
Jark Wu commented on FLINK-15595:
-
I think a lot of blink planner functions is not defin
[
https://issues.apache.org/jira/browse/FLINK-10934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-10934:
--
Description:
The Kubernetes do not have a default distributed storage and provide public api
to ship
[
https://issues.apache.org/jira/browse/FLINK-15596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015658#comment-17015658
]
Jark Wu commented on FLINK-15596:
-
Yes, support to read and write the key-part of kafka
[
https://issues.apache.org/jira/browse/FLINK-15592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015656#comment-17015656
]
Jark Wu commented on FLINK-15592:
-
Shouldn't we add ROW_NUMBER into {{BuiltInFunctionDef
flinkbot edited a comment on issue #10857: [FLINK-15593][doc] add doc to remind
users not using Hive aggregate f…
URL: https://github.com/apache/flink/pull/10857#issuecomment-574504899
## CI report:
* 016ef5f198f7bb200cdacf81fb1df0537951f4c5 Travis:
[PENDING](https://travis-ci.c
flinkbot edited a comment on issue #10848: [FLINK-15307][failover]Rename
Subclasses of FailoverStrategy
URL: https://github.com/apache/flink/pull/10848#issuecomment-573958003
## CI report:
* a3f83df73af74cf8509f084e860ab88e63129ac8 Travis:
[SUCCESS](https://travis-ci.com/flink-c
flinkbot edited a comment on issue #10832: [FLINK-14163][runtime]Enforce
synchronous registration of Execution#producedPartitions
URL: https://github.com/apache/flink/pull/10832#issuecomment-573276729
## CI report:
* 5eb1599945f1bee35c342f762cc25684013d2d83 Travis:
[SUCCESS](htt
flinkbot edited a comment on issue #10824: [FLINK-15152][checkpointing]
Restatrt CheckpointCoordinator if StopWithSavepoint failed
URL: https://github.com/apache/flink/pull/10824#issuecomment-572926550
## CI report:
* 7a61978007a5a02723a561ee145d82e2413e51ae Travis:
[SUCCESS](ht
[
https://issues.apache.org/jira/browse/FLINK-15593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015654#comment-17015654
]
Jark Wu commented on FLINK-15593:
-
Is it possible to throw exception by framework if Hiv
[
https://issues.apache.org/jira/browse/FLINK-15595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015649#comment-17015649
]
Bowen Li commented on FLINK-15595:
--
The current behavior is actually exactly what FLIP-
[
https://issues.apache.org/jira/browse/FLINK-14843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Li updated FLINK-14843:
--
Priority: Major (was: Critical)
Thanks for the investigation [~banmoy]. Downgrading priority here and will
t
[
https://issues.apache.org/jira/browse/FLINK-15596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-15596:
--
Description:
!image-2020-01-15-13-58-00-535.png|width=732,height=570!
!image-2020-01-15-13-58-39-073.
yanghua commented on issue #10833: [FLINK-15535][documentation] Add usage of
ProcessFunctionTestHarnesses for testing documentation
URL: https://github.com/apache/flink/pull/10833#issuecomment-574509612
@kl0u Thanks for your review. I have addressed your suggestion.
---
[
https://issues.apache.org/jira/browse/FLINK-15596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-15596:
--
Description:
!image-2020-01-15-13-58-00-535.png|width=732,height=570!
!image-2020-01-15-13-58-39-073.
[
https://issues.apache.org/jira/browse/FLINK-15596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-15596:
--
Attachment: image-2020-01-15-13-59-05-399.png
> Support key-value messages for KafkaTableSink for fl
[
https://issues.apache.org/jira/browse/FLINK-15592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015646#comment-17015646
]
Rui Li commented on FLINK-15592:
[~phoenixjiangnan] row_number is defined in {{FlinkSqlO
[
https://issues.apache.org/jira/browse/FLINK-15596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-15596:
--
Attachment: image-2020-01-15-13-58-39-073.png
> Support key-value messages for KafkaTableSink for fl
[
https://issues.apache.org/jira/browse/FLINK-15596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-15596:
--
Attachment: image-2020-01-15-13-58-00-535.png
> Support key-value messages for KafkaTableSink for fl
[
https://issues.apache.org/jira/browse/FLINK-15596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-15596:
--
Summary: Support key-value messages for KafkaTableSink for flink SQL
\Table (was: Support key-val
hehuiyuan created FLINK-15596:
-
Summary: Support key-value messages for kafka producer for flink
SQL \Tbale
Key: FLINK-15596
URL: https://issues.apache.org/jira/browse/FLINK-15596
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-14843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015645#comment-17015645
]
PengFei Li commented on FLINK-14843:
[~liyu] Output hash mismatch for SQL Client end
[
https://issues.apache.org/jira/browse/FLINK-15594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
PengFei Li closed FLINK-15594.
--
Resolution: Duplicate
> SQL Client end-to-end test for Kafka 0.10 failed with output hash mismatch
> -
zjffdu edited a comment on issue #10857: [FLINK-15593][doc] add doc to remind
users not using Hive aggregate f…
URL: https://github.com/apache/flink/pull/10857#issuecomment-574504495
Document is necessary, but may not be enough, is it possible to throw
exception and display this error mess
[
https://issues.apache.org/jira/browse/FLINK-15595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-15595:
-
Description:
First of all, the implementation is problematic. CoreModule returns
BuiltinFunctio
[
https://issues.apache.org/jira/browse/FLINK-14505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015644#comment-17015644
]
PengFei Li edited comment on FLINK-14505 at 1/15/20 5:43 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-14505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015644#comment-17015644
]
PengFei Li commented on FLINK-14505:
[~openinx] and [~dwysakowicz] Can you take a lo
[
https://issues.apache.org/jira/browse/FLINK-14505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
PengFei Li reopened FLINK-14505:
Output hash mismatch happened again in the latest release-1.10 nightly build
[https://travis-ci.org/a
flinkbot commented on issue #10857: [FLINK-15593][doc] add doc to remind users
not using Hive aggregate f…
URL: https://github.com/apache/flink/pull/10857#issuecomment-574504899
## CI report:
* 016ef5f198f7bb200cdacf81fb1df0537951f4c5 UNKNOWN
Bot commands
The @fli
[
https://issues.apache.org/jira/browse/FLINK-15595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-15595:
-
Summary: Resolution Order is chaotic not as FLIP-68 defined (was:
Resolution Order is chaotic
flinkbot edited a comment on issue #10833: [FLINK-15535][documentation] Add
usage of ProcessFunctionTestHarnesses for testing documentation
URL: https://github.com/apache/flink/pull/10833#issuecomment-573278988
## CI report:
* f4701fe75def6307564a3b533c0bc165ae6b8bab Travis:
[SU
flinkbot edited a comment on issue #10823: [FLINK-15497][table-planner-blink]
Reduce outputs when rank number is not required in Retractable topN
URL: https://github.com/apache/flink/pull/10823#issuecomment-572926510
## CI report:
* 98b6f5aa1f7623e1aba1d1531a0a2973dbdc5873 Travis
zjffdu commented on issue #10857: [FLINK-15593][doc] add doc to remind users
not using Hive aggregate f…
URL: https://github.com/apache/flink/pull/10857#issuecomment-574504495
Document is good, but may not be enough, is it possible to throw exception
and display this error message at runt
[
https://issues.apache.org/jira/browse/FLINK-15592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015641#comment-17015641
]
Jingsong Lee commented on FLINK-15592:
--
Create FLINK-15595 to solve module problem.
[
https://issues.apache.org/jira/browse/FLINK-15595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015639#comment-17015639
]
Jingsong Lee commented on FLINK-15595:
--
CC: [~phoenixjiangnan]
> Resolution Order
Jingsong Lee created FLINK-15595:
Summary: Resolution Order is chaotic not FLIP-68 defined
Key: FLINK-15595
URL: https://issues.apache.org/jira/browse/FLINK-15595
Project: Flink
Issue Type:
flinkbot commented on issue #10857: [FLINK-15593][doc] add doc to remind users
not using Hive aggregate f…
URL: https://github.com/apache/flink/pull/10857#issuecomment-574503085
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to re
[
https://issues.apache.org/jira/browse/FLINK-15593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-15593:
---
Labels: pull-request-available (was: )
> add doc to remind users not using Hive aggregate f
bowenli86 commented on issue #10857: [FLINK-15593][doc] add doc to remind users
not using Hive aggregate f…
URL: https://github.com/apache/flink/pull/10857#issuecomment-574502516
@xuefuz @lirui-apache @JingsongLi @zjffdu
Thi
bowenli86 opened a new pull request #10857: [FLINK-15593][doc] add doc to
remind users not using Hive aggregate f…
URL: https://github.com/apache/flink/pull/10857
…unctions in streaming mode
## What is the purpose of the change
Due to that Hive functions are all built for batc
[
https://issues.apache.org/jira/browse/FLINK-15594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
PengFei Li updated FLINK-15594:
---
Fix Version/s: 1.10.0
> SQL Client end-to-end test for Kafka 0.10 failed with output hash mismatch
>
[
https://issues.apache.org/jira/browse/FLINK-15594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
PengFei Li updated FLINK-15594:
---
Description:
SQL Client end-to-end test for Kafka 0.10
failed with output hash mismatch in the ins
[
https://issues.apache.org/jira/browse/FLINK-15594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
PengFei Li updated FLINK-15594:
---
Description:
SQL Client end-to-end test for Kafka 0.10 failed with output hash mismatch in
the ins
[
https://issues.apache.org/jira/browse/FLINK-15592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015637#comment-17015637
]
Bowen Li commented on FLINK-15592:
--
I checked BuiltInFunctionDefinitions and there's no
[
https://issues.apache.org/jira/browse/FLINK-15594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
PengFei Li updated FLINK-15594:
---
Summary: SQL Client end-to-end test for Kafka 0.10 failed with output hash
mismatch (was: Streaming
PengFei Li created FLINK-15594:
--
Summary: Streaming SQL end-to-end test (Blink planner) failed with
output hash mismatch
Key: FLINK-15594
URL: https://issues.apache.org/jira/browse/FLINK-15594
Project: F
Bowen Li created FLINK-15593:
Summary: add doc to remind users not using Hive aggregate
functions in streaming mode
Key: FLINK-15593
URL: https://issues.apache.org/jira/browse/FLINK-15593
Project: Flink
flinkbot edited a comment on issue #10332: [FLINK-13905][checkpointing]
Separate checkpoint triggering into several asynchronous stages
URL: https://github.com/apache/flink/pull/10332#issuecomment-559012596
## CI report:
* 3198d4f64415b0d257733b7d214dece64c392081 Travis:
[FAILUR
flinkbot edited a comment on issue #10823: [FLINK-15497][table-planner-blink]
Reduce outputs when rank number is not required in Retractable topN
URL: https://github.com/apache/flink/pull/10823#issuecomment-572926510
## CI report:
* 98b6f5aa1f7623e1aba1d1531a0a2973dbdc5873 Travis
flinkbot edited a comment on issue #10824: [FLINK-15152][checkpointing]
Restatrt CheckpointCoordinator if StopWithSavepoint failed
URL: https://github.com/apache/flink/pull/10824#issuecomment-572926550
## CI report:
* 7a61978007a5a02723a561ee145d82e2413e51ae Travis:
[SUCCESS](ht
[
https://issues.apache.org/jira/browse/FLINK-15532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Li reassigned FLINK-15532:
-
Assignee: Yun Tang
> Enable strict capacity limit for memory usage for RocksDB
> --
[
https://issues.apache.org/jira/browse/FLINK-14843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015629#comment-17015629
]
Yu Li commented on FLINK-14843:
---
Disclaimer: the latest release-1.10 nightly build fails a
[
https://issues.apache.org/jira/browse/FLINK-11747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015627#comment-17015627
]
limbo commented on FLINK-11747:
---
yes, if we need sniffer function we would like do a lot
[
https://issues.apache.org/jira/browse/FLINK-14843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Li updated FLINK-14843:
--
Priority: Critical (was: Major)
Upgrading to Critical since it reproduces in release-1.10 nightly build, and
[
https://issues.apache.org/jira/browse/FLINK-14843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015623#comment-17015623
]
Yu Li commented on FLINK-14843:
---
Another instance which fails release-1.10 nightly build:
flinkbot edited a comment on issue #10332: [FLINK-13905][checkpointing]
Separate checkpoint triggering into several asynchronous stages
URL: https://github.com/apache/flink/pull/10332#issuecomment-559012596
## CI report:
* 3198d4f64415b0d257733b7d214dece64c392081 Travis:
[FAILUR
flinkbot edited a comment on issue #10824: [FLINK-15152][checkpointing]
Restatrt CheckpointCoordinator if StopWithSavepoint failed
URL: https://github.com/apache/flink/pull/10824#issuecomment-572926550
## CI report:
* 7a61978007a5a02723a561ee145d82e2413e51ae Travis:
[SUCCESS](ht
beyond1920 commented on a change in pull request #10823:
[FLINK-15497][table-planner-blink] Reduce outputs when rank number is not
required in Retractable topN
URL: https://github.com/apache/flink/pull/10823#discussion_r366692062
##
File path:
flink-table/flink-table-planner-blink
beyond1920 commented on a change in pull request #10823:
[FLINK-15497][table-planner-blink] Reduce outputs when rank number is not
required in Retractable topN
URL: https://github.com/apache/flink/pull/10823#discussion_r366692026
##
File path:
flink-table/flink-table-runtime-blink
flinkbot edited a comment on issue #10833: [FLINK-15535][documentation] Add
usage of ProcessFunctionTestHarnesses for testing documentation
URL: https://github.com/apache/flink/pull/10833#issuecomment-573278988
## CI report:
* f4701fe75def6307564a3b533c0bc165ae6b8bab Travis:
[SU
[
https://issues.apache.org/jira/browse/FLINK-15592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015618#comment-17015618
]
Jingsong Lee commented on FLINK-15592:
--
CC: [~danny0405] What is the mechanism that
[
https://issues.apache.org/jira/browse/FLINK-15592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015617#comment-17015617
]
Jingsong Lee commented on FLINK-15592:
--
Hi [~jark], ROW_NUMBER should not be resolv
[
https://issues.apache.org/jira/browse/FLINK-13758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015615#comment-17015615
]
Yang Wang commented on FLINK-13758:
---
[~luoguohao] Are you still working on this? I am
flinkbot edited a comment on issue #10856: [FLINK-15589][doc] remove beta tag
from catalog and hive doc
URL: https://github.com/apache/flink/pull/10856#issuecomment-574458271
## CI report:
* ae2320519843f3a881aa926f932f2ea1091cc3d8 Travis:
[SUCCESS](https://travis-ci.com/flink-c
flinkbot edited a comment on issue #10332: [FLINK-13905][checkpointing]
Separate checkpoint triggering into several asynchronous stages
URL: https://github.com/apache/flink/pull/10332#issuecomment-559012596
## CI report:
* 3198d4f64415b0d257733b7d214dece64c392081 Travis:
[FAILUR
flinkbot edited a comment on issue #10833: [FLINK-15535][documentation] Add
usage of ProcessFunctionTestHarnesses for testing documentation
URL: https://github.com/apache/flink/pull/10833#issuecomment-573278988
## CI report:
* f4701fe75def6307564a3b533c0bc165ae6b8bab Travis:
[SU
flinkbot edited a comment on issue #10824: [FLINK-15152][checkpointing]
Restatrt CheckpointCoordinator if StopWithSavepoint failed
URL: https://github.com/apache/flink/pull/10824#issuecomment-572926550
## CI report:
* 7a61978007a5a02723a561ee145d82e2413e51ae Travis:
[SUCCESS](ht
[
https://issues.apache.org/jira/browse/FLINK-15592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015611#comment-17015611
]
Rui Li commented on FLINK-15592:
[~zjffdu] Are you using hive module? Or is it possible
[
https://issues.apache.org/jira/browse/FLINK-15591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-15591:
-
Fix Version/s: (was: 1.10.0)
1.11.0
> make up for feature parity by supporting CR
zhuzhurk commented on a change in pull request #10832:
[FLINK-14163][runtime]Enforce synchronous registration of
Execution#producedPartitions
URL: https://github.com/apache/flink/pull/10832#discussion_r366685145
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/ex
[
https://issues.apache.org/jira/browse/FLINK-15591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-15591:
-
Description: make up for feature parity by supporting CREATE TEMPORARY
TABLE/VIEW in DDL as correspondin
[
https://issues.apache.org/jira/browse/FLINK-15591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-15591:
-
Summary: make up for feature parity by supporting CREATE TEMPORARY
TABLE/VIEW in DDL (was: support CREA
[
https://issues.apache.org/jira/browse/FLINK-15591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-15591:
-
Fix Version/s: (was: 1.11.0)
1.10.0
> make up for feature parity by supporting CR
[
https://issues.apache.org/jira/browse/FLINK-15592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015607#comment-17015607
]
Jark Wu commented on FLINK-15592:
-
cc [~lirui] [~bli], it seems that the ModuleManager r
[
https://issues.apache.org/jira/browse/FLINK-15582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-15582:
---
Assignee: Zhu Zhu
> Enable batch scheduling tests in LegacySchedulerBatchSchedulingTest for
> Defa
[
https://issues.apache.org/jira/browse/FLINK-15582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-15582:
Affects Version/s: 1.11.0
> Enable batch scheduling tests in LegacySchedulerBatchSchedulingTest for
> Def
curcur commented on a change in pull request #10832:
[FLINK-14163][runtime]Enforce synchronous registration of
Execution#producedPartitions
URL: https://github.com/apache/flink/pull/10832#discussion_r366683268
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/exec
1 - 100 of 390 matches
Mail list logo