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

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

[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

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

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

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

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

[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 #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] tillrohrmann commented on issue #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

tillrohrmann commented on issue #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping URL: https://github.com/apache/flink/pull/10682#issuecomment-573141077 @azagrebin is the PR ready for another round of review?

[GitHub] [flink] tillrohrmann commented on a change in pull request #10665: [FLINK-15354] Start and stop minikube only in kubernetes related e2e tests

tillrohrmann commented on a change in pull request #10665: [FLINK-15354] Start and stop minikube only in kubernetes related e2e tests URL: https://github.com/apache/flink/pull/10665#discussion_r365354460 ## File path: flink-end-to-end-tests/test-scripts/common_kubernetes.sh

[GitHub] [flink] tillrohrmann commented on a change in pull request #10665: [FLINK-15354] Start and stop minikube only in kubernetes related e2e tests

tillrohrmann commented on a change in pull request #10665: [FLINK-15354] Start and stop minikube only in kubernetes related e2e tests URL: https://github.com/apache/flink/pull/10665#discussion_r365356272 ## File path: flink-end-to-end-tests/test-scripts/test_kubernetes_session.sh

[GitHub] [flink] tillrohrmann commented on a change in pull request #10665: [FLINK-15354] Start and stop minikube only in kubernetes related e2e tests

tillrohrmann commented on a change in pull request #10665: [FLINK-15354] Start and stop minikube only in kubernetes related e2e tests URL: https://github.com/apache/flink/pull/10665#discussion_r365354011 ## File path: flink-end-to-end-tests/test-scripts/common_kubernetes.sh

[GitHub] [flink] tillrohrmann commented on a change in pull request #10665: [FLINK-15354] Start and stop minikube only in kubernetes related e2e tests

tillrohrmann commented on a change in pull request #10665: [FLINK-15354] Start and stop minikube only in kubernetes related e2e tests URL: https://github.com/apache/flink/pull/10665#discussion_r365354033 ## File path: flink-end-to-end-tests/test-scripts/common_kubernetes.sh

[GitHub] [flink] tillrohrmann commented on a change in pull request #10665: [FLINK-15354] Start and stop minikube only in kubernetes related e2e tests

tillrohrmann commented on a change in pull request #10665: [FLINK-15354] Start and stop minikube only in kubernetes related e2e tests URL: https://github.com/apache/flink/pull/10665#discussion_r365355152 ## File path: flink-end-to-end-tests/test-scripts/common_kubernetes.sh

[GitHub] [flink] tillrohrmann commented on a change in pull request #10665: [FLINK-15354] Start and stop minikube only in kubernetes related e2e tests

tillrohrmann commented on a change in pull request #10665: [FLINK-15354] Start and stop minikube only in kubernetes related e2e tests URL: https://github.com/apache/flink/pull/10665#discussion_r365355603 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #10658: [FLINK-15359] Remove unused YarnConfigOptions, Tests, Docs

tillrohrmann commented on a change in pull request #10658: [FLINK-15359] Remove unused YarnConfigOptions, Tests, Docs URL: https://github.com/apache/flink/pull/10658#discussion_r365352138 ## File path: flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java

[jira] [Commented] (FLINK-12122) Spread out tasks evenly across all available registered TaskManagers

[ https://issues.apache.org/jira/browse/FLINK-12122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17013089#comment-17013089 ] Till Rohrmann commented on FLINK-12122: --- [~ethanli] there are no plan to backport this feature to

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

[jira] [Commented] (FLINK-15527) can not control the number of container on yarn single job module

[ https://issues.apache.org/jira/browse/FLINK-15527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17013086#comment-17013086 ] Till Rohrmann commented on FLINK-15527: --- Isn't the problem that the Hive component does some

[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=17013076#comment-17013076 ] Till Rohrmann commented on FLINK-13613: --- Not sure whether it makes sense to move all migration

[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=17013070#comment-17013070 ] Till Rohrmann commented on FLINK-15529: --- Sounds good to me [~liyu]. Go ahead. > Update upgrade

[jira] [Commented] (FLINK-15504) Flink suppresses stdout/stderr during JobGraph generation from JAR

[ https://issues.apache.org/jira/browse/FLINK-15504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17013068#comment-17013068 ] Maximilian Michels commented on FLINK-15504: Backporting this also to {{release-1.10}}. >

[jira] [Updated] (FLINK-15504) Flink suppresses stdout/stderr during JobGraph generation from JAR

[ https://issues.apache.org/jira/browse/FLINK-15504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-15504: --- Fix Version/s: (was: 1.10.0) 1.11.0 > Flink suppresses

[jira] [Closed] (FLINK-15504) Flink suppresses stdout/stderr during JobGraph generation from JAR

[ https://issues.apache.org/jira/browse/FLINK-15504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-15504. -- Fix Version/s: 1.10.0 Release Note: Allow outputting to stdout/stderr during

[GitHub] [flink] mxm merged pull request #10811: [FLINK-15504] Allow output to stdout/stderr during execution of PackagedProgram

mxm merged pull request #10811: [FLINK-15504] Allow output to stdout/stderr during execution of PackagedProgram URL: https://github.com/apache/flink/pull/10811 This is an automated message from the Apache Git Service. To

[GitHub] [flink] tillrohrmann commented on a change in pull request #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9

tillrohrmann commented on a change in pull request #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9 URL: https://github.com/apache/flink/pull/10762#discussion_r365323005 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9

tillrohrmann commented on a change in pull request #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9 URL: https://github.com/apache/flink/pull/10762#discussion_r365321100 ## File path: docs/dev/connectors/kafka.zh.md ## @@ -161,22 +151,18 @@ Flink 的 Kafka consumer 称为

[GitHub] [flink] tillrohrmann commented on a change in pull request #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9

tillrohrmann commented on a change in pull request #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9 URL: https://github.com/apache/flink/pull/10762#discussion_r365328481 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9

tillrohrmann commented on a change in pull request #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9 URL: https://github.com/apache/flink/pull/10762#discussion_r365322652 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9

tillrohrmann commented on a change in pull request #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9 URL: https://github.com/apache/flink/pull/10762#discussion_r365318969 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9

tillrohrmann commented on a change in pull request #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9 URL: https://github.com/apache/flink/pull/10762#discussion_r365331071 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9

tillrohrmann commented on a change in pull request #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9 URL: https://github.com/apache/flink/pull/10762#discussion_r365328689 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9

tillrohrmann commented on a change in pull request #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9 URL: https://github.com/apache/flink/pull/10762#discussion_r365318960 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9

tillrohrmann commented on a change in pull request #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9 URL: https://github.com/apache/flink/pull/10762#discussion_r365322000 ## File path: tools/travis/stage.sh ## @@ -128,11 +128,6 @@

[GitHub] [flink] tillrohrmann commented on a change in pull request #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9

tillrohrmann commented on a change in pull request #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9 URL: https://github.com/apache/flink/pull/10762#discussion_r365327750 ## File path: flink-connectors/flink-connector-kafka-0.10/pom.xml ## @@ -46,7 +46,7 @@ under the

[GitHub] [flink] tillrohrmann commented on a change in pull request #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9

tillrohrmann commented on a change in pull request #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9 URL: https://github.com/apache/flink/pull/10762#discussion_r365326108 ## File path: docs/dev/connectors/kafka.md ## @@ -263,7 +255,7 @@ Example: {% highlight java %} final

[GitHub] [flink] tillrohrmann commented on a change in pull request #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9

tillrohrmann commented on a change in pull request #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9 URL: https://github.com/apache/flink/pull/10762#discussion_r365331143 ## File path:

[GitHub] [flink] GJL commented on issue #10814: [FLINK-15434][Tests]Fix unstable tests in JobMasterTest

GJL commented on issue #10814: [FLINK-15434][Tests]Fix unstable tests in JobMasterTest URL: https://github.com/apache/flink/pull/10814#issuecomment-573109310 Sorry, didn't have time to look at your PR yet but I will in the next days.

[GitHub] [flink] flinkbot edited a comment on issue #10831: [FLINK-13465][legal] Update javassist licensing

flinkbot edited a comment on issue #10831: [FLINK-13465][legal] Update javassist licensing URL: https://github.com/apache/flink/pull/10831#issuecomment-573065869 ## CI report: * d8c12a81e919646eb5cda292cfd5a70744c6c7ed Travis:

[GitHub] [flink] GJL commented on a change in pull request #10804: [FLINK-15488] Obtain the JVM and TM param correctly

GJL commented on a change in pull request #10804: [FLINK-15488] Obtain the JVM and TM param correctly URL: https://github.com/apache/flink/pull/10804#discussion_r365322482 ## File path: flink-dist/src/test/java/org/apache/flink/dist/BashJavaUtilsITCase.java ## @@ -34,21

[jira] [Comment Edited] (FLINK-15368) Add end-to-end test for controlling RocksDB memory usage

[ https://issues.apache.org/jira/browse/FLINK-15368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007221#comment-17007221 ] Yu Li edited comment on FLINK-15368 at 1/10/20 4:26 PM: Thanks for the efforts

[GitHub] [flink] tillrohrmann commented on a change in pull request #10748: [FLINK-15458][conf][docs] Add support for whitelisting ambiguous options

tillrohrmann commented on a change in pull request #10748: [FLINK-15458][conf][docs] Add support for whitelisting ambiguous options URL: https://github.com/apache/flink/pull/10748#discussion_r365309969 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10830: [FLINK-15554][azure] Bump jetty-util to 3.1.2

flinkbot edited a comment on issue #10830: [FLINK-15554][azure] Bump jetty-util to 3.1.2 URL: https://github.com/apache/flink/pull/10830#issuecomment-573052596 ## CI report: * 8aba8ccd54ff402b95b302453317d534febb5df9 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10831: [FLINK-13465][legal] Update javassist licensing

flinkbot edited a comment on issue #10831: [FLINK-13465][legal] Update javassist licensing URL: https://github.com/apache/flink/pull/10831#issuecomment-573065869 ## CI report: * d8c12a81e919646eb5cda292cfd5a70744c6c7ed Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10828: [FLINK-15460][JDBC] planner dependencies won't be necessary for JDBC …

flinkbot edited a comment on issue #10828: [FLINK-15460][JDBC] planner dependencies won't be necessary for JDBC … URL: https://github.com/apache/flink/pull/10828#issuecomment-573039067 ## CI report: * 2715875b652966235103eac77e95f1e4bc345c73 Travis:

[jira] [Resolved] (FLINK-15490) KafkaITCase.testOneSourceMultiplePartitions fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-15490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved FLINK-15490. -- Resolution: Fixed Merged. master: f0f9343a35ff21017e2406614b34a9b1f2712330 release-1.10:

[GitHub] [flink] becketqin commented on issue #10794: [FLINK-15490][kafka][test-stability] Enable idempotence producing in …

becketqin commented on issue #10794: [FLINK-15490][kafka][test-stability] Enable idempotence producing in … URL: https://github.com/apache/flink/pull/10794#issuecomment-573092217 Merged. master: f0f9343a35ff21017e2406614b34a9b1f2712330 release-1.10:

[GitHub] [flink] becketqin closed pull request #10794: [FLINK-15490][kafka][test-stability] Enable idempotence producing in …

becketqin closed pull request #10794: [FLINK-15490][kafka][test-stability] Enable idempotence producing in … URL: https://github.com/apache/flink/pull/10794 This is an automated message from the Apache Git Service. To

[GitHub] [flink] tillrohrmann commented on a change in pull request #10830: [FLINK-15554][azure] Bump jetty-util to 3.1.2

tillrohrmann commented on a change in pull request #10830: [FLINK-15554][azure] Bump jetty-util to 3.1.2 URL: https://github.com/apache/flink/pull/10830#discussion_r365294294 ## File path: flink-filesystems/flink-azure-fs-hadoop/pom.xml ## @@ -36,6 +36,7 @@ under the

[GitHub] [flink] StephanEwen commented on issue #10812: [FLINK-15523][conf] Japicmp checks ConfigConstants

StephanEwen commented on issue #10812: [FLINK-15523][conf] Japicmp checks ConfigConstants URL: https://github.com/apache/flink/pull/10812#issuecomment-573082392 Looks good, thank you for fixing this. This is an automated

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

flinkbot edited a comment 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-573052559 ## CI report: * c289f16e336e54931105f5c3ec143f8a9fd69021

[GitHub] [flink] flinkbot edited a comment on issue #10831: [FLINK-13465][legal] Update javassist licensing

flinkbot edited a comment on issue #10831: [FLINK-13465][legal] Update javassist licensing URL: https://github.com/apache/flink/pull/10831#issuecomment-573065869 ## CI report: * d8c12a81e919646eb5cda292cfd5a70744c6c7ed Travis:

[GitHub] [flink] StephanEwen commented on issue #10560: FLINK-15174 added certificate pinning for SSL mutual auth to further protect cluster

StephanEwen commented on issue #10560: FLINK-15174 added certificate pinning for SSL mutual auth to further protect cluster URL: https://github.com/apache/flink/pull/10560#issuecomment-573075148 @flinkbot approve all +1 to merge this, looks good from my side! I would add a

[GitHub] [flink] Myasuka commented on a change in pull request #10820: [FLINK-15512][statebackend] Refactor the mechanism to calculate the cache capacity shared among RocksDB instance(s)

Myasuka commented on a change in pull request #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#discussion_r365275814 ## File path:

[GitHub] [flink] link3280 edited a comment on issue #10674: [FLINK-15220][Connector/Kafka][Table] Add startFromTimestamp in KafkaTableSource

link3280 edited a comment on issue #10674: [FLINK-15220][Connector/Kafka][Table] Add startFromTimestamp in KafkaTableSource URL: https://github.com/apache/flink/pull/10674#issuecomment-573066105 @dawidwys I agree that `OffsetDateTime` is more deterministic and reliable. I didn't give much

[GitHub] [flink] flinkbot commented on issue #10831: [FLINK-13465][legal] Update javassist licensing

flinkbot commented on issue #10831: [FLINK-13465][legal] Update javassist licensing URL: https://github.com/apache/flink/pull/10831#issuecomment-573065869 ## CI report: * d8c12a81e919646eb5cda292cfd5a70744c6c7ed UNKNOWN Bot commands The @flinkbot bot supports the

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

link3280 commented on issue #10674: [FLINK-15220][Connector/Kafka][Table] Add startFromTimestamp in KafkaTableSource URL: https://github.com/apache/flink/pull/10674#issuecomment-573066105 @dawidwys I agree that `OffsetDateTime` is more deterministic and reliable. I didn't give much

[GitHub] [flink] flinkbot edited a comment on issue #10830: [FLINK-15554][azure] Bump jetty-util to 3.1.2

flinkbot edited a comment on issue #10830: [FLINK-15554][azure] Bump jetty-util to 3.1.2 URL: https://github.com/apache/flink/pull/10830#issuecomment-573052596 ## CI report: * 8aba8ccd54ff402b95b302453317d534febb5df9 Travis:

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

flinkbot edited a comment 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-573052559 ## CI report: * c289f16e336e54931105f5c3ec143f8a9fd69021

[GitHub] [flink] flinkbot edited a comment on issue #10828: [FLINK-15460][JDBC] planner dependencies won't be necessary for JDBC …

flinkbot edited a comment on issue #10828: [FLINK-15460][JDBC] planner dependencies won't be necessary for JDBC … URL: https://github.com/apache/flink/pull/10828#issuecomment-573039067 ## CI report: * 2715875b652966235103eac77e95f1e4bc345c73 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:

[jira] [Closed] (FLINK-12004) Consider about POJO using method chaining when extract TypeInformation

[ https://issues.apache.org/jira/browse/FLINK-12004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-12004. Fix Version/s: 1.11.0 Resolution: Implemented Implemented in

[jira] [Assigned] (FLINK-12004) Consider about POJO using method chaining when extract TypeInformation

[ https://issues.apache.org/jira/browse/FLINK-12004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-12004: Assignee: jiawei chen > Consider about POJO using method chaining when extract

[GitHub] [flink] dawidwys commented on issue #8045: [FLINK-12004][TypeInformation] analyze pojo using method chaining

dawidwys commented on issue #8045: [FLINK-12004][TypeInformation] analyze pojo using method chaining URL: https://github.com/apache/flink/pull/8045#issuecomment-573062515 Thank you for your contribution @fmyblack. Merged

[GitHub] [flink] dawidwys closed pull request #8045: [FLINK-12004][TypeInformation] analyze pojo using method chaining

dawidwys closed pull request #8045: [FLINK-12004][TypeInformation] analyze pojo using method chaining URL: https://github.com/apache/flink/pull/8045 This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] flinkbot commented on issue #10831: [FLINK-13465][legal] Update licensing

flinkbot commented on issue #10831: [FLINK-13465][legal] Update licensing URL: https://github.com/apache/flink/pull/10831#issuecomment-573061824 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will

[GitHub] [flink] zentol opened a new pull request #10831: [FLINK-13465][legal] Update licensing

zentol opened a new pull request #10831: [FLINK-13465][legal] Update licensing URL: https://github.com/apache/flink/pull/10831 Javassist was bumped in FLINK-13465 but I forgot to update the NOTICE file of flink-dist. This is

[jira] [Commented] (FLINK-15534) YARNSessionCapacitySchedulerITCase#perJobYarnClusterWithParallelism failed due to NPE

[ https://issues.apache.org/jira/browse/FLINK-15534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17012912#comment-17012912 ] Yang Wang commented on FLINK-15534: --- [~liyu] Thanks. 

[GitHub] [flink] GJL commented on a change in pull request #10804: [FLINK-15488] Obtain the JVM and TM param correctly

GJL commented on a change in pull request #10804: [FLINK-15488] Obtain the JVM and TM param correctly URL: https://github.com/apache/flink/pull/10804#discussion_r365249851 ## File path: flink-dist/src/test/java/org/apache/flink/dist/BashJavaUtilsITCase.java ## @@ -34,21

[jira] [Created] (FLINK-15556) Add a switch for PushProjectIntoTableSourceScanRule

hailong wang created FLINK-15556: Summary: Add a switch for PushProjectIntoTableSourceScanRule Key: FLINK-15556 URL: https://issues.apache.org/jira/browse/FLINK-15556 Project: Flink Issue

[GitHub] [flink] KarmaGYZ commented on a change in pull request #10804: [FLINK-15488] Obtain the JVM and TM param correctly

KarmaGYZ commented on a change in pull request #10804: [FLINK-15488] Obtain the JVM and TM param correctly URL: https://github.com/apache/flink/pull/10804#discussion_r365253539 ## File path: flink-dist/src/test/java/org/apache/flink/dist/BashJavaUtilsITCase.java ## @@

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

flinkbot 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-573052559 ## CI report: * c289f16e336e54931105f5c3ec143f8a9fd69021 UNKNOWN

[GitHub] [flink] flinkbot commented on issue #10830: [FLINK-15554][azure] Bump jetty-util to 3.1.2

flinkbot commented on issue #10830: [FLINK-15554][azure] Bump jetty-util to 3.1.2 URL: https://github.com/apache/flink/pull/10830#issuecomment-573052596 ## CI report: * 8aba8ccd54ff402b95b302453317d534febb5df9 UNKNOWN Bot commands The @flinkbot bot supports the

[GitHub] [flink] flinkbot edited a comment on issue #10828: [FLINK-15460][JDBC] planner dependencies won't be necessary for JDBC …

flinkbot edited a comment on issue #10828: [FLINK-15460][JDBC] planner dependencies won't be necessary for JDBC … URL: https://github.com/apache/flink/pull/10828#issuecomment-573039067 ## CI report: * 2715875b652966235103eac77e95f1e4bc345c73 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] GJL commented on issue #10804: [FLINK-15488] Obtain the JVM and TM param correctly

GJL commented on issue #10804: [FLINK-15488] Obtain the JVM and TM param correctly URL: https://github.com/apache/flink/pull/10804#issuecomment-573049886 LGTM. Merging This is an automated message from the Apache Git

[GitHub] [flink] GJL commented on a change in pull request #10804: [FLINK-15488] Obtain the JVM and TM param correctly

GJL commented on a change in pull request #10804: [FLINK-15488] Obtain the JVM and TM param correctly URL: https://github.com/apache/flink/pull/10804#discussion_r365249851 ## File path: flink-dist/src/test/java/org/apache/flink/dist/BashJavaUtilsITCase.java ## @@ -34,21

[GitHub] [flink] langdangjushi commented on issue #8400: [FLINK-12472][yarn] Support setting attemptFailuresValidityInterval o…

langdangjushi commented on issue #8400: [FLINK-12472][yarn] Support setting attemptFailuresValidityInterval o… URL: https://github.com/apache/flink/pull/8400#issuecomment-573049344 @jiasheng55 大哥, 测试过没啊?? 你写的默认10s, 然后yarn max attempts 至少得是2吧, 那就是说如果在10s内没有做到失败2次, 那么app

[jira] [Created] (FLINK-15555) Delete TABLE_OPTIMIZER_REUSE_SOURCE_ENABLED option for subplaner reuse

hailong wang created FLINK-1: Summary: Delete TABLE_OPTIMIZER_REUSE_SOURCE_ENABLED option for subplaner reuse Key: FLINK-1 URL: https://issues.apache.org/jira/browse/FLINK-1 Project:

  1   2   3   >