[GitHub] [flink] flinkbot edited a comment on issue #10820: [FLINK-15512][statebackend] Refactor the mechanism to calculate the cache capacity shared among RocksDB instance(s)

flinkbot edited a comment on issue #10820: [FLINK-15512][statebackend] Refactor the mechanism to calculate the cache capacity shared among RocksDB instance(s) URL: https://github.com/apache/flink/pull/10820#issuecomment-572715611 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #10820: [FLINK-15512][statebackend] Refactor the mechanism to calculate the cache capacity shared among RocksDB instance(s)

flinkbot edited a comment on issue #10820: [FLINK-15512][statebackend] Refactor the mechanism to calculate the cache capacity shared among RocksDB instance(s) URL: https://github.com/apache/flink/pull/10820#issuecomment-572715611 ## CI report: *

[GitHub] [flink] lukess commented on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx

lukess commented on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx URL: https://github.com/apache/flink/pull/9848#issuecomment-573252493 @aljoscha I'm running the new SignalFXReporter in our environments. Current implementation: 1. current metric full

[jira] [Created] (FLINK-15557) Cannot connect to Azure Event Hub/Kafka since Jan 5th 2020. Kafka version issue

Chris created FLINK-15557: - Summary: Cannot connect to Azure Event Hub/Kafka since Jan 5th 2020. Kafka version issue Key: FLINK-15557 URL: https://issues.apache.org/jira/browse/FLINK-15557 Project: Flink

[GitHub] [flink] flinkbot edited a comment on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx

flinkbot edited a comment on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx URL: https://github.com/apache/flink/pull/9848#issuecomment-538885706 ## CI report: * dd22d245973b8caf25f8f26a392a1ca95f863736 Travis:

[jira] [Commented] (FLINK-15549) integer overflow in SpillingResettableMutableObjectIterator

[ https://issues.apache.org/jira/browse/FLINK-15549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17013348#comment-17013348 ] caojian0613 commented on FLINK-15549: - We have fixed this problem and could someone assign this

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

flinkbot commented 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 UNKNOWN

[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-15533) Writing DataStream as text file fails due to output path already exists

[ https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17013392#comment-17013392 ] Rui Li commented on FLINK-15533: [~kkl0u] I just tried the latest branch and it fixes the issue, no

[GitHub] [flink] flinkbot edited a comment on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx

flinkbot edited a comment on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx URL: https://github.com/apache/flink/pull/9848#issuecomment-538885706 ## CI report: * dd22d245973b8caf25f8f26a392a1ca95f863736 Travis:

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

flinkbot commented on issue #10833: [FLINK-15535][documentation] Add usage of ProcessFunctionTestHarnesses for testing documentation URL: https://github.com/apache/flink/pull/10833#issuecomment-573276966 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[jira] [Updated] (FLINK-14163) Execution#producedPartitions is possibly not assigned when used

[ https://issues.apache.org/jira/browse/FLINK-14163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14163: --- Labels: pull-request-available (was: ) > Execution#producedPartitions is possibly not

[GitHub] [flink] curcur opened a new pull request #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions

curcur opened a new pull request #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions URL: https://github.com/apache/flink/pull/10832 ## What is the purpose of the change `Execution#producedPartitions` are registered through an asynchronous

[jira] [Updated] (FLINK-15549) integer overflow in SpillingResettableMutableObjectIterator

[ https://issues.apache.org/jira/browse/FLINK-15549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] caojian0613 updated FLINK-15549: Affects Version/s: (was: 1.9.1) (was: 1.9.0)

[GitHub] [flink] xintongsong commented on issue #10829: [FLINK-14853][docs] Use higher granularity units in generated docs for Duration & MemorySize if possible

xintongsong commented on issue #10829: [FLINK-14853][docs] Use higher granularity units in generated docs for Duration & MemorySize if possible URL: https://github.com/apache/flink/pull/10829#issuecomment-573274699 Thanks for pointing me to this, @zentol. Hi @dawidwys, thanks for

[GitHub] [flink] yanghua opened a new pull request #10833: [FLINK-15535][documentation] Add usage of ProcessFunctionTestHarnesses for testing documentation

yanghua opened a new pull request #10833: [FLINK-15535][documentation] Add usage of ProcessFunctionTestHarnesses for testing documentation URL: https://github.com/apache/flink/pull/10833 ## What is the purpose of the change *This pull request adds usage of

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

flinkbot commented 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 UNKNOWN Bot

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

flinkbot commented on issue #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions URL: https://github.com/apache/flink/pull/10832#issuecomment-573275694 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[jira] [Commented] (FLINK-14163) Execution#producedPartitions is possibly not assigned when used

[ https://issues.apache.org/jira/browse/FLINK-14163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17013353#comment-17013353 ] Yuan Mei commented on FLINK-14163: -- PR: pull request #10832 > Execution#producedPartitions is possibly

[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 #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 #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 #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 #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx

flinkbot edited a comment on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx URL: https://github.com/apache/flink/pull/9848#issuecomment-538885706 ## CI report: * dd22d245973b8caf25f8f26a392a1ca95f863736 Travis:

[jira] [Updated] (FLINK-15535) Add usage of ProcessFunctionTestHarnesses for testing documentation

[ https://issues.apache.org/jira/browse/FLINK-15535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15535: --- Labels: pull-request-available (was: ) > Add usage of ProcessFunctionTestHarnesses for

[jira] [Commented] (FLINK-13613) Update state migration tests for Flink 1.9

[ https://issues.apache.org/jira/browse/FLINK-13613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17013338#comment-17013338 ] vinoyang commented on FLINK-13613: -- bq. Not sure whether it makes sense to move all migration tests

[jira] [Commented] (FLINK-15514) Bump Elasticsearch version from 6.3.1 to 6.8.6 for es6 connector

[ https://issues.apache.org/jira/browse/FLINK-15514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17013357#comment-17013357 ] vinoyang commented on FLINK-15514: -- [~aljoscha] thanks for your opinion. I have created another for ES

[jira] [Created] (FLINK-15558) Bump Elasticsearch version from 7.3.2 to 7.5.1 for es7 connector

vinoyang created FLINK-15558: Summary: Bump Elasticsearch version from 7.3.2 to 7.5.1 for es7 connector Key: FLINK-15558 URL: https://issues.apache.org/jira/browse/FLINK-15558 Project: Flink

[jira] [Commented] (FLINK-15533) Writing DataStream as text file fails due to output path already exists

[ https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17012633#comment-17012633 ] Kostas Kloudas commented on FLINK-15533: Hi [~lirui], I tried it on the {{master}} (without my

[GitHub] [flink] lirui-apache commented on a change in pull request #10709: [FLINK-13437][test] Add Hive SQL E2E test

lirui-apache commented on a change in pull request #10709: [FLINK-13437][test] Add Hive SQL E2E test URL: https://github.com/apache/flink/pull/10709#discussion_r365150036 ## File path:

[GitHub] [flink] lirui-apache commented on a change in pull request #10709: [FLINK-13437][test] Add Hive SQL E2E test

lirui-apache commented on a change in pull request #10709: [FLINK-13437][test] Add Hive SQL E2E test URL: https://github.com/apache/flink/pull/10709#discussion_r365137287 ## File path:

[GitHub] [flink] lirui-apache commented on a change in pull request #10709: [FLINK-13437][test] Add Hive SQL E2E test

lirui-apache commented on a change in pull request #10709: [FLINK-13437][test] Add Hive SQL E2E test URL: https://github.com/apache/flink/pull/10709#discussion_r365152997 ## File path:

[GitHub] [flink] lirui-apache commented on a change in pull request #10709: [FLINK-13437][test] Add Hive SQL E2E test

lirui-apache commented on a change in pull request #10709: [FLINK-13437][test] Add Hive SQL E2E test URL: https://github.com/apache/flink/pull/10709#discussion_r365143456 ## File path:

[GitHub] [flink] lirui-apache commented on a change in pull request #10709: [FLINK-13437][test] Add Hive SQL E2E test

lirui-apache commented on a change in pull request #10709: [FLINK-13437][test] Add Hive SQL E2E test URL: https://github.com/apache/flink/pull/10709#discussion_r365154431 ## File path:

[GitHub] [flink] lirui-apache commented on a change in pull request #10709: [FLINK-13437][test] Add Hive SQL E2E test

lirui-apache commented on a change in pull request #10709: [FLINK-13437][test] Add Hive SQL E2E test URL: https://github.com/apache/flink/pull/10709#discussion_r365148227 ## File path:

[GitHub] [flink] lirui-apache commented on a change in pull request #10709: [FLINK-13437][test] Add Hive SQL E2E test

lirui-apache commented on a change in pull request #10709: [FLINK-13437][test] Add Hive SQL E2E test URL: https://github.com/apache/flink/pull/10709#discussion_r365160531 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10826: [FLINK-15355][plugins] Fixed parsing of plugin parent-first patterns.

flinkbot edited a comment on issue #10826: [FLINK-15355][plugins] Fixed parsing of plugin parent-first patterns. URL: https://github.com/apache/flink/pull/10826#issuecomment-572950777 ## CI report: * 4c10a80b7326d1d99c2d89fb2cc423c32bb04afe Travis:

[jira] [Updated] (FLINK-15549) integer overflow in SpillingResettableMutableObjectIterator

[ https://issues.apache.org/jira/browse/FLINK-15549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] caojian0613 updated FLINK-15549: Description: The SpillingResettableMutableObjectIterator has a data overflow problem if the 

[jira] [Created] (FLINK-15550) testCancelTaskExceptionAfterTaskMarkedFailed failed on azure

Yun Tang created FLINK-15550: Summary: testCancelTaskExceptionAfterTaskMarkedFailed failed on azure Key: FLINK-15550 URL: https://issues.apache.org/jira/browse/FLINK-15550 Project: Flink Issue

[GitHub] [flink] jrthe42 opened a new pull request #10827: [FLINK-15548] [table-runtime-blink] Make KeyedCoProcessOperatorWithWatermarkDelay extends KeyedCoProcessOperator instead of LegacyKeyedCoProc

jrthe42 opened a new pull request #10827: [FLINK-15548] [table-runtime-blink] Make KeyedCoProcessOperatorWithWatermarkDelay extends KeyedCoProcessOperator instead of LegacyKeyedCoProcessOperator URL: https://github.com/apache/flink/pull/10827 ## What is the purpose of the change

[jira] [Updated] (FLINK-15548) Make KeyedCoProcessOperatorWithWatermarkDelay extends KeyedCoProcessOperator instead of LegacyKeyedCoProcessOperator

[ https://issues.apache.org/jira/browse/FLINK-15548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15548: --- Labels: pull-request-available (was: ) > Make KeyedCoProcessOperatorWithWatermarkDelay

[jira] [Updated] (FLINK-15551) Streaming File Sink s3 end-to-end test FAIL

[ https://issues.apache.org/jira/browse/FLINK-15551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-15551: --- Description: This issue happens in latest release-1.10 branch[1], this issue is similar to 

[jira] [Commented] (FLINK-15551) Streaming File Sink s3 end-to-end test FAIL

[ https://issues.apache.org/jira/browse/FLINK-15551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17012777#comment-17012777 ] Leonard Xu commented on FLINK-15551: CC:[~gjy]  > Streaming File Sink s3 end-to-end test FAIL >

[GitHub] [flink] dawidwys commented on issue #10713: [FLINK-15431][CEP] Add numLateRecordsDropped/lateRecordsDroppedRate/watermarkLatency in CepOperator

dawidwys commented on issue #10713: [FLINK-15431][CEP] Add numLateRecordsDropped/lateRecordsDroppedRate/watermarkLatency in CepOperator URL: https://github.com/apache/flink/pull/10713#issuecomment-573013933 Hi @libenchao I added a comment in the corresponding JIRA. Let's discuss the scope

[jira] [Commented] (FLINK-15431) Add numLateRecordsDropped/lateRecordsDroppedRate/watermarkLatency in CepOperator

[ https://issues.apache.org/jira/browse/FLINK-15431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17012783#comment-17012783 ] Dawid Wysakowicz commented on FLINK-15431: -- Hi [~libenchao], I think it makes sense to add

[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 #10779: [FLINK-15327][runtime] No warning of InterruptedException during cancel.

flinkbot edited a comment on issue #10779: [FLINK-15327][runtime] No warning of InterruptedException during cancel. URL: https://github.com/apache/flink/pull/10779#issuecomment-571250275 ## CI report: * b30a4d297496a904582cb24d036cbb4c5b647149 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 #10825: [FLINK-15522][runtime] JobResult takes ExecutionGraph failure cause as its failure cause only if job is FAILED

flinkbot edited a comment on issue #10825: [FLINK-15522][runtime] JobResult takes ExecutionGraph failure cause as its failure cause only if job is FAILED URL: https://github.com/apache/flink/pull/10825#issuecomment-572937976 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #10826: [FLINK-15355][plugins] Fixed parsing of plugin parent-first patterns.

flinkbot edited a comment on issue #10826: [FLINK-15355][plugins] Fixed parsing of plugin parent-first patterns. URL: https://github.com/apache/flink/pull/10826#issuecomment-572950777 ## CI report: * 4c10a80b7326d1d99c2d89fb2cc423c32bb04afe 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:

[jira] [Closed] (FLINK-15543) Apache Camel not bundled but listed in flink-dist NOTICE

[ https://issues.apache.org/jira/browse/FLINK-15543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-15543. Resolution: Fixed master: 7ec228a5225eda68701f6a6b5713727ed5232eb9 1.10:

[GitHub] [flink] flinkbot commented on issue #10827: [FLINK-15548] [table-runtime-blink] Make KeyedCoProcessOperatorWithWatermarkDelay extends KeyedCoProcessOperator instead of LegacyKeyedCoProcessOpe

flinkbot commented on issue #10827: [FLINK-15548] [table-runtime-blink] Make KeyedCoProcessOperatorWithWatermarkDelay extends KeyedCoProcessOperator instead of LegacyKeyedCoProcessOperator URL: https://github.com/apache/flink/pull/10827#issuecomment-573006993 ## CI report: *

[jira] [Created] (FLINK-15551) Streaming File Sink s3 end-to-end test FAIL

Leonard Xu created FLINK-15551: -- Summary: Streaming File Sink s3 end-to-end test FAIL Key: FLINK-15551 URL: https://issues.apache.org/jira/browse/FLINK-15551 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-15431) Add numLateRecordsDropped/lateRecordsDroppedRate/watermarkLatency in CepOperator

[ https://issues.apache.org/jira/browse/FLINK-15431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-15431: Assignee: Benchao Li > Add

[jira] [Closed] (FLINK-15551) Streaming File Sink s3 end-to-end test FAIL

[ https://issues.apache.org/jira/browse/FLINK-15551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-15551. Fix Version/s: (was: 1.10.0) Resolution: Duplicate > Streaming File Sink s3

[GitHub] [flink] dawidwys commented on issue #9050: [FLINK-13181][Table]Add Builder to build CsvTableSink instances

dawidwys commented on issue #9050: [FLINK-13181][Table]Add Builder to build CsvTableSink instances URL: https://github.com/apache/flink/pull/9050#issuecomment-573014543 Hi @hehuiyuan, Could you rebase the change to the current master? Moreover I don't think we need a whole IT

[jira] [Comment Edited] (FLINK-15533) Writing DataStream as text file fails due to output path already exists

[ https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17012633#comment-17012633 ] Kostas Kloudas edited comment on FLINK-15533 at 1/10/20 9:45 AM: - Hi

[jira] [Comment Edited] (FLINK-15533) Writing DataStream as text file fails due to output path already exists

[ https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17012633#comment-17012633 ] Kostas Kloudas edited comment on FLINK-15533 at 1/10/20 9:58 AM: - Hi

[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] [Created] (FLINK-15549) integer overflow in SpillingResettableMutableObjectIterator

caojian0613 created FLINK-15549: --- Summary: integer overflow in SpillingResettableMutableObjectIterator Key: FLINK-15549 URL: https://issues.apache.org/jira/browse/FLINK-15549 Project: Flink

[GitHub] [flink] TsReaper commented on a change in pull request #10797: [FLINK-15172][table-blink] Optimize the operator algorithm to lazily allocate memory

TsReaper commented on a change in pull request #10797: [FLINK-15172][table-blink] Optimize the operator algorithm to lazily allocate memory URL: https://github.com/apache/flink/pull/10797#discussion_r365168981 ## File path:

[GitHub] [flink] ifndef-SleePy commented on issue #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages

ifndef-SleePy commented on issue #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages URL: https://github.com/apache/flink/pull/10332#issuecomment-572982657 Hi @pnowojski , thanks for patiently reviewing. I have addressed most of the

[GitHub] [flink] zhijiangW merged pull request #10826: [FLINK-15355][plugins] Fixed parsing of plugin parent-first patterns.

zhijiangW merged pull request #10826: [FLINK-15355][plugins] Fixed parsing of plugin parent-first patterns. URL: https://github.com/apache/flink/pull/10826 This is an automated message from the Apache Git Service. To

[jira] [Commented] (FLINK-15549) integer overflow in SpillingResettableMutableObjectIterator

[ https://issues.apache.org/jira/browse/FLINK-15549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17012755#comment-17012755 ] Yangze Guo commented on FLINK-15549: Same issue is also exist in _SpillingResettableIterator_ . I'd

[GitHub] [flink] klion26 commented on issue #10329: [FLINK-12785][StateBackend] RocksDB savepoint recovery can use a lot of unmanaged memory

klion26 commented on issue #10329: [FLINK-12785][StateBackend] RocksDB savepoint recovery can use a lot of unmanaged memory URL: https://github.com/apache/flink/pull/10329#issuecomment-573001668 @carp84 @StephanEwen thanks for review and merging

[jira] [Commented] (FLINK-15533) Writing DataStream as text file fails due to output path already exists

[ https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17012781#comment-17012781 ] Rui Li commented on FLINK-15533: Hi [~kkl0u], just confirmed the job succeeds if I write the program as

[jira] [Commented] (FLINK-12785) RocksDB savepoint recovery can use a lot of unmanaged memory

[ https://issues.apache.org/jira/browse/FLINK-12785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17012786#comment-17012786 ] Congxian Qiu(klion26) commented on FLINK-12785: --- Already added the release not, closing

[jira] [Closed] (FLINK-12785) RocksDB savepoint recovery can use a lot of unmanaged memory

[ https://issues.apache.org/jira/browse/FLINK-12785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) closed FLINK-12785. - Resolution: Fixed > RocksDB savepoint recovery can use a lot of unmanaged

[GitHub] [flink] twalthr closed pull request #10781: [FLINK-15281][table-planner-blink] Map Flink's TypeInference to Calcite's interfaces

twalthr closed pull request #10781: [FLINK-15281][table-planner-blink] Map Flink's TypeInference to Calcite's interfaces URL: https://github.com/apache/flink/pull/10781 This is an automated message from the Apache Git

[GitHub] [flink] flinkbot edited a comment on issue #10825: [FLINK-15522][runtime] JobResult takes ExecutionGraph failure cause as its failure cause only if job is FAILED

flinkbot edited a comment on issue #10825: [FLINK-15522][runtime] JobResult takes ExecutionGraph failure cause as its failure cause only if job is FAILED URL: https://github.com/apache/flink/pull/10825#issuecomment-572937976 ## CI report: *

[jira] [Commented] (FLINK-12785) RocksDB savepoint recovery can use a lot of unmanaged memory

[ https://issues.apache.org/jira/browse/FLINK-12785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17012720#comment-17012720 ] Yu Li commented on FLINK-12785: --- Fixed via master: 6df2e0e6db6d58819fcec9a9dd1e9cf1c632af0a release-1.10:

[GitHub] [flink] flinkbot edited a comment on issue #10779: [FLINK-15327][runtime] No warning of InterruptedException during cancel.

flinkbot edited a comment on issue #10779: [FLINK-15327][runtime] No warning of InterruptedException during cancel. URL: https://github.com/apache/flink/pull/10779#issuecomment-571250275 ## CI report: * b30a4d297496a904582cb24d036cbb4c5b647149 Travis:

[jira] [Closed] (FLINK-15542) lz4-java licensing is incorrect

[ https://issues.apache.org/jira/browse/FLINK-15542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-15542. Resolution: Fixed master: 75cded93430f9c1fbb325e95c2c4795451199ae4 1.10:

[GitHub] [flink] zentol merged pull request #10818: [FLINK-15543][legal] Remove Apache Camel NOTICE entries

zentol merged pull request #10818: [FLINK-15543][legal] Remove Apache Camel NOTICE entries URL: https://github.com/apache/flink/pull/10818 This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] zentol merged pull request #10817: [FLINK-15542][legal] Move NOTICE entry for lz4-java

zentol merged pull request #10817: [FLINK-15542][legal] Move NOTICE entry for lz4-java URL: https://github.com/apache/flink/pull/10817 This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on issue #10779: [FLINK-15327][runtime] No warning of InterruptedException during cancel.

flinkbot edited a comment on issue #10779: [FLINK-15327][runtime] No warning of InterruptedException during cancel. URL: https://github.com/apache/flink/pull/10779#issuecomment-571250275 ## CI report: * b30a4d297496a904582cb24d036cbb4c5b647149 Travis:

[jira] [Closed] (FLINK-15281) Map Flink's TypeInference to Calcite's interfaces

[ https://issues.apache.org/jira/browse/FLINK-15281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-15281. Fix Version/s: 1.11.0 Resolution: Fixed Fixed in 1.11.0:

[GitHub] [flink] ifndef-SleePy commented on a change in pull request #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages

ifndef-SleePy commented on a change in pull request #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages URL: https://github.com/apache/flink/pull/10332#discussion_r365171167 ## File path:

[jira] [Commented] (FLINK-12785) RocksDB savepoint recovery can use a lot of unmanaged memory

[ https://issues.apache.org/jira/browse/FLINK-12785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17012723#comment-17012723 ] Yu Li commented on FLINK-12785: --- [~klion26] Please add some release notes about the newly introduced

[GitHub] [flink] flinkbot commented on issue #10827: [FLINK-15548] [table-runtime-blink] Make KeyedCoProcessOperatorWithWatermarkDelay extends KeyedCoProcessOperator instead of LegacyKeyedCoProcessOpe

flinkbot commented on issue #10827: [FLINK-15548] [table-runtime-blink] Make KeyedCoProcessOperatorWithWatermarkDelay extends KeyedCoProcessOperator instead of LegacyKeyedCoProcessOperator URL: https://github.com/apache/flink/pull/10827#issuecomment-572996855 Thanks a lot for your

[jira] [Comment Edited] (FLINK-15355) Nightly streaming file sink fails with unshaded hadoop

[ https://issues.apache.org/jira/browse/FLINK-15355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17012387#comment-17012387 ] zhijiang edited comment on FLINK-15355 at 1/10/20 11:29 AM: Merged in

[jira] [Commented] (FLINK-15529) Update upgrade compatibility table (docs/ops/upgrading.md) for 1.10.0

[ https://issues.apache.org/jira/browse/FLINK-15529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17012748#comment-17012748 ] Congxian Qiu(klion26) commented on FLINK-15529: --- Currently. I've tested using Pojo

[jira] [Updated] (FLINK-12785) RocksDB savepoint recovery can use a lot of unmanaged memory

[ https://issues.apache.org/jira/browse/FLINK-12785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-12785: -- Release Note: Before FLINK-12785, user may encounter OOM if there are huge KV

[jira] [Updated] (FLINK-12785) RocksDB savepoint recovery can use a lot of unmanaged memory

[ https://issues.apache.org/jira/browse/FLINK-12785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-12785: -- Release Note: Before FLINK-12785, user may encounter OOM if there are huge KV

[jira] [Updated] (FLINK-12040) Remove unused akka dependencies in pom.xml

[ https://issues.apache.org/jira/browse/FLINK-12040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12040: - Fix Version/s: 1.8.4 > Remove unused akka dependencies in pom.xml >

[GitHub] [flink] flinkbot edited a comment on issue #10827: [FLINK-15548] [table-runtime-blink] Make KeyedCoProcessOperatorWithWatermarkDelay extends KeyedCoProcessOperator instead of LegacyKeyedCoPro

flinkbot edited a comment on issue #10827: [FLINK-15548] [table-runtime-blink] Make KeyedCoProcessOperatorWithWatermarkDelay extends KeyedCoProcessOperator instead of LegacyKeyedCoProcessOperator URL: https://github.com/apache/flink/pull/10827#issuecomment-573006993 ## CI report:

[jira] [Commented] (FLINK-15431) Add numLateRecordsDropped/lateRecordsDroppedRate/watermarkLatency in CepOperator

[ https://issues.apache.org/jira/browse/FLINK-15431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17012799#comment-17012799 ] Benchao Li commented on FLINK-15431: [~dwysakowicz] Thanks for your comment. I agree not to add 

[jira] [Updated] (FLINK-15552) SQL Client can not correctly create kafka table using --library to indicate a kafka connector directory

[ https://issues.apache.org/jira/browse/FLINK-15552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-15552: --- Description: How to Reproduce: first, I start a sql client and using `-l` to point to a kafka

[GitHub] [flink] dawidwys commented on issue #10674: [FLINK-15220][Connector/Kafka][Table] Add startFromTimestamp in KafkaTableSource

dawidwys commented on issue #10674: [FLINK-15220][Connector/Kafka][Table] Add startFromTimestamp in KafkaTableSource URL: https://github.com/apache/flink/pull/10674#issuecomment-573030241 The changes look mostly good. I have some concerns regarding using a `LocalDateTime` as an `Instant`.

[jira] [Updated] (FLINK-15319) Add configurable download timeout/retry to AbstractDownloadCache

[ https://issues.apache.org/jira/browse/FLINK-15319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-15319: - Component/s: (was: Connectors / Kafka) Test Infrastructure > Add

[jira] [Updated] (FLINK-15319) Add configurable download timeout/retry to AbstractDownloadCache

[ https://issues.apache.org/jira/browse/FLINK-15319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-15319: - Fix Version/s: 1.10.0 > Add configurable download timeout/retry to

[jira] [Updated] (FLINK-15319) Add configurable download timeout/retry to AbstractDownloadCache

[ https://issues.apache.org/jira/browse/FLINK-15319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-15319: - Affects Version/s: (was: 1.11.0) > Add configurable download timeout/retry to

[jira] [Updated] (FLINK-15319) Add configurable download timeout/retry to AbstractDownloadCache

[ https://issues.apache.org/jira/browse/FLINK-15319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-15319: - Issue Type: Improvement (was: Bug) > Add configurable download timeout/retry to

[jira] [Updated] (FLINK-15319) Add configurable download timeout/retry to AbstractDownloadCache

[ https://issues.apache.org/jira/browse/FLINK-15319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-15319: - Summary: Add configurable download timeout/retry to AbstractDownloadCache (was:

[jira] [Assigned] (FLINK-15319) flink-end-to-end-tests-common-kafka fails due to timeout

[ https://issues.apache.org/jira/browse/FLINK-15319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-15319: Assignee: Zheng Hu > flink-end-to-end-tests-common-kafka fails due to timeout >

[jira] [Closed] (FLINK-15520) Prometheus E2E test should use DownloadCache

[ https://issues.apache.org/jira/browse/FLINK-15520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-15520. Resolution: Fixed master: 2339924adb97450bfcc5b66b24e48a0592c6c079 1.10:

[jira] [Created] (FLINK-15554) Bump jetty-util-ajax to 9.3.24

Chesnay Schepler created FLINK-15554: Summary: Bump jetty-util-ajax to 9.3.24 Key: FLINK-15554 URL: https://issues.apache.org/jira/browse/FLINK-15554 Project: Flink Issue Type:

[GitHub] [flink] zentol opened a new pull request #10830: [FLINK-x][azure] Bump jetty-util to 3.1.2

zentol opened a new pull request #10830: [FLINK-x][azure] Bump jetty-util to 3.1.2 URL: https://github.com/apache/flink/pull/10830 `flink-fs-hadoop-azure` has transitive dependency on jetty-util-ajax:9.3.19, which has a security vulnerability:

  1   2   3   >