[GitHub] [flink] zhuzhurk commented on a change in pull request #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions

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:

[jira] [Closed] (FLINK-15431) Add numLateRecordsDropped metric in CepOperator

[ 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

[jira] [Updated] (FLINK-15431) Add numLateRecordsDropped metric in CepOperator

[ 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 >

[GitHub] [flink] dawidwys merged pull request #10713: [FLINK-15431][CEP] Add numLateRecordsDropped/lateRecordsDroppedRate/watermarkLatency 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

[jira] [Commented] (FLINK-15431) Add numLateRecordsDropped metric in CepOperator

[ https://issues.apache.org/jira/browse/FLINK-15431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015702#comment-17015702 ] Dawid Wysakowicz commented on FLINK-15431: -- I updated the description to only cover

[jira] [Updated] (FLINK-15431) Add numLateRecordsDropped in CepOperator

[ 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

[jira] [Updated] (FLINK-15431) Add numLateRecordsDropped metric in CepOperator

[ 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 

[jira] [Updated] (FLINK-15431) Add numLateRecordsDropped metric in CepOperator

[ 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

[GitHub] [flink] flinkbot edited a comment on issue #10848: [FLINK-15307][failover]Rename Subclasses of FailoverStrategy

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:

[GitHub] [flink] flinkbot edited a comment on issue #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions

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:

[GitHub] [flink] flinkbot edited a comment on issue #10857: [FLINK-15593][doc] add doc to remind users not using Hive aggregate f…

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:

[GitHub] [flink] flinkbot edited a comment on issue #10848: [FLINK-15307][failover]Rename Subclasses of FailoverStrategy

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:

[jira] [Comment Edited] (FLINK-15595) Resolution Order is chaotic not as FLIP-68 defined

[ https://issues.apache.org/jira/browse/FLINK-15595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015673#comment-17015673 ] Jingsong Lee edited comment on FLINK-15595 at 1/15/20 7:09 AM: --- Hi

[GitHub] [flink] flinkbot edited a comment on issue #10857: [FLINK-15593][doc] add doc to remind users not using Hive aggregate f…

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:

[jira] [Comment Edited] (FLINK-13758) failed to submit JobGraph when registered hdfs file in DistributedCache

[ https://issues.apache.org/jira/browse/FLINK-13758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015615#comment-17015615 ] Yang Wang edited comment on FLINK-13758 at 1/15/20 6:44 AM: [~luoguohao] Are

[GitHub] [flink] flinkbot edited a comment on issue #10848: [FLINK-15307][failover]Rename Subclasses of FailoverStrategy

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:

[jira] [Comment Edited] (FLINK-13758) failed to submit JobGraph when registered hdfs file in DistributedCache

[ https://issues.apache.org/jira/browse/FLINK-13758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015615#comment-17015615 ] Yang Wang edited comment on FLINK-13758 at 1/15/20 6:43 AM: [~luoguohao] Are

[GitHub] [flink] flinkbot edited a comment on issue #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions

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:

[jira] [Commented] (FLINK-15579) Support UpsertStreamTableSink on Blink batch mode

[ https://issues.apache.org/jira/browse/FLINK-15579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015674#comment-17015674 ] Jark Wu commented on FLINK-15579: - In old planner, {{UpsertStreamTableSink}} is only used for streaming

[jira] [Commented] (FLINK-15595) Resolution Order is chaotic not as FLIP-68 defined

[ https://issues.apache.org/jira/browse/FLINK-15595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015673#comment-17015673 ] Jingsong Lee commented on FLINK-15595: -- Hi [~phoenixjiangnan], yes, what I mean is that it is

[jira] [Commented] (FLINK-15592) Streaming sql throw hive exception when it doesn't use any hive table

[ https://issues.apache.org/jira/browse/FLINK-15592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015672#comment-17015672 ] Jark Wu commented on FLINK-15592: - I got what you mean [~lzljs3620320]. {{ROW_NUMBER}} and {{RANK}} and

[jira] [Commented] (FLINK-15593) add doc to remind users not using Hive aggregate functions in streaming mode

[ https://issues.apache.org/jira/browse/FLINK-15593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015671#comment-17015671 ] Jingsong Lee commented on FLINK-15593: -- Hi [~phoenixjiangnan], I think you misunderstood 

[jira] [Commented] (FLINK-15592) Streaming sql throw hive exception when it doesn't use any hive table

[ https://issues.apache.org/jira/browse/FLINK-15592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015669#comment-17015669 ] Jingsong Lee commented on FLINK-15592: -- > Shouldn't we add ROW_NUMBER into 

[jira] [Commented] (FLINK-15579) Support UpsertStreamTableSink on Blink batch mode

[ https://issues.apache.org/jira/browse/FLINK-15579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015665#comment-17015665 ] Shu Li Zheng commented on FLINK-15579: -- [~jark] Hi jark, I'm wondering why BatchExecSink do not

[jira] [Commented] (FLINK-15595) Resolution Order is chaotic not as FLIP-68 defined

[ https://issues.apache.org/jira/browse/FLINK-15595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015662#comment-17015662 ] Jark Wu commented on FLINK-15595: - I think a lot of blink planner functions is not defined in

[jira] [Updated] (FLINK-10934) Support per-job mode in kubernetes

[ 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

[jira] [Commented] (FLINK-15596) Support key-value messages for KafkaTableSink for flink SQL \Table

[ https://issues.apache.org/jira/browse/FLINK-15596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015658#comment-17015658 ] Jark Wu commented on FLINK-15596: - Yes, support to read and write the key-part of kafka messages is on

[jira] [Commented] (FLINK-15592) Streaming sql throw hive exception when it doesn't use any hive table

[ https://issues.apache.org/jira/browse/FLINK-15592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015656#comment-17015656 ] Jark Wu commented on FLINK-15592: - Shouldn't we add ROW_NUMBER into {{BuiltInFunctionDefinitions}} and

[GitHub] [flink] flinkbot edited a comment on issue #10857: [FLINK-15593][doc] add doc to remind users not using Hive aggregate f…

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:

[GitHub] [flink] flinkbot edited a comment on issue #10848: [FLINK-15307][failover]Rename Subclasses of FailoverStrategy

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:

[GitHub] [flink] flinkbot edited a comment on issue #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions

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:

[GitHub] [flink] flinkbot edited a comment on issue #10824: [FLINK-15152][checkpointing] Restatrt CheckpointCoordinator if StopWithSavepoint failed

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:

[jira] [Commented] (FLINK-15593) add doc to remind users not using Hive aggregate functions in streaming mode

[ https://issues.apache.org/jira/browse/FLINK-15593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015654#comment-17015654 ] Jark Wu commented on FLINK-15593: - Is it possible to throw exception by framework if Hive UDAF is used

[jira] [Commented] (FLINK-15595) Resolution Order is chaotic not as FLIP-68 defined

[ https://issues.apache.org/jira/browse/FLINK-15595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015649#comment-17015649 ] Bowen Li commented on FLINK-15595: -- The current behavior is actually exactly what FLIP-68 defines with

[jira] [Updated] (FLINK-14843) Streaming bucketing end-to-end test can fail with Output hash mismatch

[ 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

[jira] [Updated] (FLINK-15596) Support key-value messages for KafkaTableSink for flink SQL \Table

[ 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!

[GitHub] [flink] yanghua commented on issue #10833: [FLINK-15535][documentation] Add usage of ProcessFunctionTestHarnesses for testing documentation

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.

[jira] [Updated] (FLINK-15596) Support key-value messages for KafkaTableSink for flink SQL \Table

[ 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!

[jira] [Updated] (FLINK-15596) Support key-value messages for KafkaTableSink for flink SQL \Table

[ 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

[jira] [Commented] (FLINK-15592) Streaming sql throw hive exception when it doesn't use any hive table

[ https://issues.apache.org/jira/browse/FLINK-15592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015646#comment-17015646 ] Rui Li commented on FLINK-15592: [~phoenixjiangnan] row_number is defined in {{FlinkSqlOperatorTable}}.

[jira] [Updated] (FLINK-15596) Support key-value messages for KafkaTableSink for flink SQL \Table

[ 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

[jira] [Updated] (FLINK-15596) Support key-value messages for KafkaTableSink for flink SQL \Table

[ 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

[jira] [Updated] (FLINK-15596) Support key-value messages for KafkaTableSink for flink SQL \Table

[ 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

[jira] [Created] (FLINK-15596) Support key-value messages for kafka producer for flink SQL \Tbale

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

[jira] [Commented] (FLINK-14843) Streaming bucketing end-to-end test can fail with Output hash mismatch

[ https://issues.apache.org/jira/browse/FLINK-14843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015645#comment-17015645 ] PengFei Li commented on FLINK-14843: [~liyu] Output hash mismatch for SQL Client end-to-end test for

[jira] [Closed] (FLINK-15594) 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 closed FLINK-15594. -- Resolution: Duplicate > SQL Client end-to-end test for Kafka 0.10 failed with output hash mismatch >

[GitHub] [flink] zjffdu edited a comment on issue #10857: [FLINK-15593][doc] add doc to remind users not using Hive aggregate f…

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

[jira] [Updated] (FLINK-15595) Resolution Order is chaotic not as FLIP-68 defined

[ 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

[jira] [Comment Edited] (FLINK-14505) SQL Client end-to-end test for Kafka 0.10 nightly end-to-end test failed on travis

[ https://issues.apache.org/jira/browse/FLINK-14505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015644#comment-17015644 ] PengFei Li edited comment on FLINK-14505 at 1/15/20 5:43 AM: - [~openinx] and

[jira] [Commented] (FLINK-14505) SQL Client end-to-end test for Kafka 0.10 nightly end-to-end test failed on travis

[ https://issues.apache.org/jira/browse/FLINK-14505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015644#comment-17015644 ] PengFei Li commented on FLINK-14505: [~openinx] and [~dwysakowicz] Can you take a look? > SQL

[jira] [Reopened] (FLINK-14505) SQL Client end-to-end test for Kafka 0.10 nightly end-to-end test failed on travis

[ 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 

[GitHub] [flink] flinkbot commented on issue #10857: [FLINK-15593][doc] add doc to remind users not using Hive aggregate f…

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

[jira] [Updated] (FLINK-15595) Resolution Order is chaotic not as FLIP-68 defined

[ 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

[GitHub] [flink] flinkbot edited a comment on issue #10833: [FLINK-15535][documentation] Add usage of ProcessFunctionTestHarnesses for testing documentation

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:

[GitHub] [flink] flinkbot edited a comment on issue #10823: [FLINK-15497][table-planner-blink] Reduce outputs when rank number is not required in Retractable topN

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

[GitHub] [flink] zjffdu commented on issue #10857: [FLINK-15593][doc] add doc to remind users not using Hive aggregate f…

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

[jira] [Commented] (FLINK-15592) Streaming sql throw hive exception when it doesn't use any hive table

[ https://issues.apache.org/jira/browse/FLINK-15592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015641#comment-17015641 ] Jingsong Lee commented on FLINK-15592: -- Create FLINK-15595 to solve module problem. Keep this

[jira] [Commented] (FLINK-15595) Resolution Order is chaotic not FLIP-68 defined

[ https://issues.apache.org/jira/browse/FLINK-15595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015639#comment-17015639 ] Jingsong Lee commented on FLINK-15595: -- CC: [~phoenixjiangnan] > Resolution Order is chaotic not

[jira] [Created] (FLINK-15595) Resolution Order is chaotic not FLIP-68 defined

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:

[GitHub] [flink] flinkbot commented on issue #10857: [FLINK-15593][doc] add doc to remind users not using Hive aggregate f…

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

[jira] [Updated] (FLINK-15593) add doc to remind users not using Hive aggregate functions in streaming mode

[ 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

[GitHub] [flink] bowenli86 commented on issue #10857: [FLINK-15593][doc] 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

[GitHub] [flink] bowenli86 opened a new pull request #10857: [FLINK-15593][doc] add doc to remind users not using Hive aggregate f…

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

[jira] [Updated] (FLINK-15594) 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: --- Fix Version/s: 1.10.0 > SQL Client end-to-end test for Kafka 0.10 failed with output hash mismatch

[jira] [Updated] (FLINK-15594) 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

[jira] [Updated] (FLINK-15594) 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

[jira] [Commented] (FLINK-15592) Streaming sql throw hive exception when it doesn't use any hive table

[ https://issues.apache.org/jira/browse/FLINK-15592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015637#comment-17015637 ] Bowen Li commented on FLINK-15592: -- I checked BuiltInFunctionDefinitions and there's no udf called

[jira] [Updated] (FLINK-15594) 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: --- Summary: SQL Client end-to-end test for Kafka 0.10 failed with output hash mismatch (was:

[jira] [Created] (FLINK-15594) Streaming SQL end-to-end test (Blink planner) failed with output hash mismatch

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:

[jira] [Created] (FLINK-15593) add doc to remind users not using Hive aggregate functions in streaming mode

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

[GitHub] [flink] flinkbot edited a comment on issue #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages

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:

[GitHub] [flink] flinkbot edited a comment on issue #10823: [FLINK-15497][table-planner-blink] Reduce outputs when rank number is not required in Retractable topN

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

[GitHub] [flink] flinkbot edited a comment on issue #10824: [FLINK-15152][checkpointing] Restatrt CheckpointCoordinator if StopWithSavepoint failed

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:

[jira] [Assigned] (FLINK-15532) Enable strict capacity limit for memory usage for RocksDB

[ 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 >

[jira] [Commented] (FLINK-14843) Streaming bucketing end-to-end test can fail with Output hash mismatch

[ https://issues.apache.org/jira/browse/FLINK-14843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015629#comment-17015629 ] Yu Li commented on FLINK-14843: --- Disclaimer: the latest release-1.10 nightly build fails at a different

[jira] [Commented] (FLINK-11747) Elasticsearch 6 connector - Expose RestHighLevelClient to allow for custom sniffing

[ https://issues.apache.org/jira/browse/FLINK-11747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015627#comment-17015627 ] limbo commented on FLINK-11747: --- yes, if we need sniffer function  we would like do a lot of work , so 

[jira] [Updated] (FLINK-14843) Streaming bucketing end-to-end test can fail with Output hash mismatch

[ 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

[jira] [Commented] (FLINK-14843) Streaming bucketing end-to-end test can fail with Output hash mismatch

[ https://issues.apache.org/jira/browse/FLINK-14843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015623#comment-17015623 ] Yu Li commented on FLINK-14843: --- Another instance which fails release-1.10 nightly build:

[GitHub] [flink] flinkbot edited a comment on issue #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages

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:

[GitHub] [flink] flinkbot edited a comment on issue #10824: [FLINK-15152][checkpointing] Restatrt CheckpointCoordinator if StopWithSavepoint failed

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:

[GitHub] [flink] 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

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:

[GitHub] [flink] 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

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:

[GitHub] [flink] flinkbot edited a comment on issue #10833: [FLINK-15535][documentation] Add usage of ProcessFunctionTestHarnesses for testing documentation

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:

[jira] [Commented] (FLINK-15592) Streaming sql throw hive exception when it doesn't use any hive table

[ https://issues.apache.org/jira/browse/FLINK-15592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015618#comment-17015618 ] Jingsong Lee commented on FLINK-15592: -- CC: [~danny0405] What is the mechanism that calcite parses

[jira] [Commented] (FLINK-15592) Streaming sql throw hive exception when it doesn't use any hive table

[ https://issues.apache.org/jira/browse/FLINK-15592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015617#comment-17015617 ] Jingsong Lee commented on FLINK-15592: -- Hi [~jark], ROW_NUMBER should not be resolved in

[jira] [Commented] (FLINK-13758) failed to submit JobGraph when registered hdfs file in DistributedCache

[ https://issues.apache.org/jira/browse/FLINK-13758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015615#comment-17015615 ] Yang Wang commented on FLINK-13758: --- [~luoguohao] Are you still working on this? I am pretty sure it

[GitHub] [flink] flinkbot edited a comment on issue #10856: [FLINK-15589][doc] remove beta tag from catalog and hive doc

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:

[GitHub] [flink] flinkbot edited a comment on issue #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages

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:

[GitHub] [flink] flinkbot edited a comment on issue #10833: [FLINK-15535][documentation] Add usage of ProcessFunctionTestHarnesses for testing documentation

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:

[jira] [Commented] (FLINK-15592) Streaming sql throw hive exception when it doesn't use any hive table

[ https://issues.apache.org/jira/browse/FLINK-15592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015611#comment-17015611 ] Rui Li commented on FLINK-15592: [~zjffdu] Are you using hive module? Or is it possible a function named

[GitHub] [flink] flinkbot edited a comment on issue #10824: [FLINK-15152][checkpointing] Restatrt CheckpointCoordinator if StopWithSavepoint failed

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:

[jira] [Updated] (FLINK-15591) make up for feature parity by supporting CREATE TEMPORARY TABLE/VIEW in DDL

[ 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

[GitHub] [flink] zhuzhurk commented on a change in pull request #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions

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:

[jira] [Updated] (FLINK-15591) make up for feature parity by supporting CREATE TEMPORARY TABLE/VIEW in DDL

[ 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

[jira] [Updated] (FLINK-15591) make up for feature parity by supporting CREATE TEMPORARY TABLE/VIEW in DDL

[ 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

[jira] [Updated] (FLINK-15591) make up for feature parity by supporting CREATE TEMPORARY TABLE/VIEW in DDL

[ 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

[jira] [Commented] (FLINK-15592) Streaming sql throw hive exception when it doesn't use any hive table

[ https://issues.apache.org/jira/browse/FLINK-15592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015607#comment-17015607 ] Jark Wu commented on FLINK-15592: - cc [~lirui] [~bli], it seems that the ModuleManager resolve the

[jira] [Assigned] (FLINK-15582) Enable batch scheduling tests in LegacySchedulerBatchSchedulingTest for DefaultScheduler as well

[ 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 >

[jira] [Updated] (FLINK-15582) Enable batch scheduling tests in LegacySchedulerBatchSchedulingTest for DefaultScheduler as well

[ 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 >

[GitHub] [flink] curcur commented on a change in pull request #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions

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:

  1   2   3   4   >