[jira] [Updated] (FLINK-15745) KafkaITCase.testKeyValueSupport failure due to assertion error.

[ https://issues.apache.org/jira/browse/FLINK-15745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-15745: - Description: The failure cause was: {code:java} Caused by: java.lang.AssertionError: Wrong

[jira] [Assigned] (FLINK-15745) KafkaITCase.testKeyValueSupport failure due to assertion error.

[ https://issues.apache.org/jira/browse/FLINK-15745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-15745: Assignee: Jiangjie Qin > KafkaITCase.testKeyValueSupport failure due to assertion error.

[jira] [Created] (FLINK-15745) KafkaITCase.testKeyValueSupport failure due to assertion error.

Jiangjie Qin created FLINK-15745: Summary: KafkaITCase.testKeyValueSupport failure due to assertion error. Key: FLINK-15745 URL: https://issues.apache.org/jira/browse/FLINK-15745 Project: Flink

[GitHub] [flink] flinkbot edited a comment on issue #10847: [FLINK-15578][connectors/jdbc] implement exactly once JDBC sink

flinkbot edited a comment on issue #10847: [FLINK-15578][connectors/jdbc] implement exactly once JDBC sink URL: https://github.com/apache/flink/pull/10847#issuecomment-573933799 ## CI report: * 1f19ab63df12c2a0cbc75644a34bcab26c08d7f6 Travis:

[jira] [Commented] (FLINK-11072) KafkaITCase.testKeyValueSupport failure

[ https://issues.apache.org/jira/browse/FLINK-11072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17022738#comment-17022738 ] Jiangjie Qin commented on FLINK-11072: -- [~gjy] To avoid confusion, should we create a new Jira

[jira] [Created] (FLINK-15744) Some TaskManager Task exception are logged as info

Jason Kania created FLINK-15744: --- Summary: Some TaskManager Task exception are logged as info Key: FLINK-15744 URL: https://issues.apache.org/jira/browse/FLINK-15744 Project: Flink Issue Type:

[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 ] Hequn Cheng updated FLINK-15549: Summary: Integer overflow in SpillingResettableMutableObjectIterator (was: integer overflow in

[jira] [Updated] (FLINK-15063) Input group and output group of the task metric are reversed

[ https://issues.apache.org/jira/browse/FLINK-15063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-15063: Summary: Input group and output group of the task metric are reversed (was: input group and

[jira] [Updated] (FLINK-15234) Hive table created from flink catalog table shouldn't have null properties in parameters

[ https://issues.apache.org/jira/browse/FLINK-15234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-15234: Summary: Hive table created from flink catalog table shouldn't have null properties in parameters

[jira] [Updated] (FLINK-14910) DisableAutoGeneratedUIDs fails on keyBy

[ https://issues.apache.org/jira/browse/FLINK-14910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14910: Summary: DisableAutoGeneratedUIDs fails on keyBy (was: disableAutoGeneratedUIDs fails on keyBy)

[jira] [Updated] (FLINK-14413) Shade-plugin ApacheNoticeResourceTransformer uses platform-dependent encoding

[ https://issues.apache.org/jira/browse/FLINK-14413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14413: Summary: Shade-plugin ApacheNoticeResourceTransformer uses platform-dependent encoding (was:

[jira] [Updated] (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:all-tabpanel ] Hequn Cheng updated FLINK-13758: Summary: Failed to submit JobGraph when registered hdfs file in DistributedCache (was: failed

[jira] [Updated] (FLINK-13827) Shell variable should be escaped in start-scala-shell.sh

[ https://issues.apache.org/jira/browse/FLINK-13827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-13827: Summary: Shell variable should be escaped in start-scala-shell.sh (was: shell variable should be

[jira] [Updated] (FLINK-13708) Transformations should be cleared because a table environment could execute multiple job

[ https://issues.apache.org/jira/browse/FLINK-13708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-13708: Summary: Transformations should be cleared because a table environment could execute multiple job

[jira] [Updated] (FLINK-14701) Slot leaks if SharedSlotOversubscribedException happens

[ https://issues.apache.org/jira/browse/FLINK-14701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14701: Fix Version/s: 1.11.0 > Slot leaks if SharedSlotOversubscribedException happens >

[GitHub] [flink] flinkbot edited a comment on issue #10936: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak in Elasticsearch connector when cluster is down

flinkbot edited a comment on issue #10936: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak in Elasticsearch connector when cluster is down URL: https://github.com/apache/flink/pull/10936#issuecomment-577765273 ## CI report: * f12dc4a4d0a8c88a303cc67a283824b01c84b6ec

[GitHub] [flink] flinkbot edited a comment on issue #10936: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak in Elasticsearch connector when cluster is down

flinkbot edited a comment on issue #10936: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak in Elasticsearch connector when cluster is down URL: https://github.com/apache/flink/pull/10936#issuecomment-577765273 ## CI report: * f12dc4a4d0a8c88a303cc67a283824b01c84b6ec

[GitHub] [flink] flinkbot edited a comment on issue #10936: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak in Elasticsearch connector when cluster is down

flinkbot edited a comment on issue #10936: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak in Elasticsearch connector when cluster is down URL: https://github.com/apache/flink/pull/10936#issuecomment-577765273 ## CI report: * f12dc4a4d0a8c88a303cc67a283824b01c84b6ec

[GitHub] [flink] flinkbot edited a comment on issue #10936: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak in Elasticsearch connector when cluster is down

flinkbot edited a comment on issue #10936: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak in Elasticsearch connector when cluster is down URL: https://github.com/apache/flink/pull/10936#issuecomment-577765273 ## CI report: * f12dc4a4d0a8c88a303cc67a283824b01c84b6ec

[GitHub] [flink] flinkbot edited a comment on issue #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

flinkbot edited a comment on issue #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#issuecomment-577792274 ## CI report: * 91aa4fb6f751281910c9e470aa780fa7abe43aa1 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

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

[GitHub] [flink] flinkbot edited a comment on issue #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

flinkbot edited a comment on issue #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#issuecomment-577792274 ## CI report: * 91aa4fb6f751281910c9e470aa780fa7abe43aa1 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

flinkbot edited a comment on issue #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#issuecomment-577792274 ## CI report: * 91aa4fb6f751281910c9e470aa780fa7abe43aa1 Travis:

[GitHub] [flink] flinkbot commented on issue #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

flinkbot commented on issue #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#issuecomment-577792274 ## CI report: * 91aa4fb6f751281910c9e470aa780fa7abe43aa1 UNKNOWN Bot commands The @flinkbot bot

[GitHub] [flink] flinkbot edited a comment on issue #10936: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak in Elasticsearch connector when cluster is down

flinkbot edited a comment on issue #10936: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak in Elasticsearch connector when cluster is down URL: https://github.com/apache/flink/pull/10936#issuecomment-577765273 ## CI report: * f12dc4a4d0a8c88a303cc67a283824b01c84b6ec

[GitHub] [flink] flinkbot edited a comment on issue #10935: [FLINK-15603][web] Expose checkpointStartDelayNanos metric in the WebUI

flinkbot edited a comment on issue #10935: [FLINK-15603][web] Expose checkpointStartDelayNanos metric in the WebUI URL: https://github.com/apache/flink/pull/10935#issuecomment-577747488 ## CI report: * d23cbb62a92aeacecabdad080c3d062dcaa7ddba Travis:

[jira] [Closed] (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:all-tabpanel ] Bowen Li closed FLINK-15592. Resolution: Fixed 1.10: 6afd2874aa0ab2578692fb0e71ab0a5c2137ff82 > Streaming sql throw hive exception

[GitHub] [flink] bowenli86 closed pull request #10894: [FLINK-15592][hive] Add black list for Hive built-in functions

bowenli86 closed pull request #10894: [FLINK-15592][hive] Add black list for Hive built-in functions URL: https://github.com/apache/flink/pull/10894 This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] bowenli86 commented on issue #10894: [FLINK-15592][hive] Add black list for Hive built-in functions

bowenli86 commented on issue #10894: [FLINK-15592][hive] Add black list for Hive built-in functions URL: https://github.com/apache/flink/pull/10894#issuecomment-577789535 LGTM, merging This is an automated message from the

[GitHub] [flink] GJL commented on issue #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

GJL commented on issue #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#issuecomment-577784526 @morsapaes This is an automated message from the Apache Git Service.

[GitHub] [flink] GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#discussion_r370253396 ## File path: docs/release-notes/flink-1.10.md ## @@ -0,0 +1,287 @@ +--- +title: "Release Notes -

[GitHub] [flink] GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#discussion_r370252957 ## File path: docs/release-notes/flink-1.10.md ## @@ -0,0 +1,287 @@ +--- +title: "Release Notes -

[GitHub] [flink] GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#discussion_r370252425 ## File path: docs/release-notes/flink-1.10.zh.md ## @@ -0,0 +1,287 @@ +--- +title: "Release Notes

[GitHub] [flink] GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#discussion_r370252746 ## File path: docs/release-notes/flink-1.10.md ## @@ -0,0 +1,287 @@ +--- +title: "Release Notes -

[GitHub] [flink] GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#discussion_r370252187 ## File path: docs/release-notes/flink-1.10.zh.md ## @@ -0,0 +1,287 @@ +--- +title: "Release Notes

[GitHub] [flink] GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#discussion_r370252275 ## File path: docs/release-notes/flink-1.10.zh.md ## @@ -0,0 +1,287 @@ +--- +title: "Release Notes

[GitHub] [flink] GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#discussion_r370252425 ## File path: docs/release-notes/flink-1.10.zh.md ## @@ -0,0 +1,287 @@ +--- +title: "Release Notes

[GitHub] [flink] GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#discussion_r370252187 ## File path: docs/release-notes/flink-1.10.zh.md ## @@ -0,0 +1,287 @@ +--- +title: "Release Notes

[GitHub] [flink] GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#discussion_r370252275 ## File path: docs/release-notes/flink-1.10.zh.md ## @@ -0,0 +1,287 @@ +--- +title: "Release Notes

[GitHub] [flink] GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#discussion_r370251049 ## File path: docs/release-notes/flink-1.10.md ## @@ -0,0 +1,287 @@ +--- +title: "Release Notes -

[GitHub] [flink] GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#discussion_r370251253 ## File path: docs/release-notes/flink-1.10.md ## @@ -0,0 +1,287 @@ +--- +title: "Release Notes -

[GitHub] [flink] GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#discussion_r370250929 ## File path: docs/release-notes/flink-1.10.md ## @@ -0,0 +1,287 @@ +--- +title: "Release Notes -

[GitHub] [flink] GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#discussion_r370250677 ## File path: docs/release-notes/flink-1.10.md ## @@ -0,0 +1,287 @@ +--- +title: "Release Notes -

[GitHub] [flink] GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#discussion_r370250677 ## File path: docs/release-notes/flink-1.10.md ## @@ -0,0 +1,287 @@ +--- +title: "Release Notes -

[GitHub] [flink] GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#discussion_r370250434 ## File path: docs/release-notes/flink-1.10.md ## @@ -0,0 +1,287 @@ +--- +title: "Release Notes -

[GitHub] [flink] GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#discussion_r370250337 ## File path: docs/release-notes/flink-1.10.md ## @@ -0,0 +1,287 @@ +--- +title: "Release Notes -

[GitHub] [flink] flinkbot commented on issue #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

flinkbot commented on issue #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#issuecomment-577781448 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[GitHub] [flink] GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#discussion_r370249170 ## File path: docs/release-notes/flink-1.10.md ## @@ -0,0 +1,287 @@ +--- +title: "Release Notes -

[jira] [Updated] (FLINK-15743) Add Flink 1.10 release notes to documentation

[ https://issues.apache.org/jira/browse/FLINK-15743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15743: --- Labels: pull-request-available (was: ) > Add Flink 1.10 release notes to documentation >

[GitHub] [flink] GJL opened a new pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

GJL opened a new pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937 ## What is the purpose of the change *This adds release notes for Flink 1.10.* ## Brief change log - *Add release notes for

[GitHub] [flink] flinkbot edited a comment on issue #10931: [FLINK-15603][metrics] Add checkpointStartDelay metric

flinkbot edited a comment on issue #10931: [FLINK-15603][metrics] Add checkpointStartDelay metric URL: https://github.com/apache/flink/pull/10931#issuecomment-577584540 ## CI report: * b43b813c97413608b68d0672c312b92b23e1d4e0 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10936: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak in Elasticsearch connector when cluster is down

flinkbot edited a comment on issue #10936: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak in Elasticsearch connector when cluster is down URL: https://github.com/apache/flink/pull/10936#issuecomment-577765273 ## CI report: * f12dc4a4d0a8c88a303cc67a283824b01c84b6ec

[GitHub] [flink] flinkbot edited a comment on issue #10933: [FLINK-15651][tests] Refactor JarHandlerTest

flinkbot edited a comment on issue #10933: [FLINK-15651][tests] Refactor JarHandlerTest URL: https://github.com/apache/flink/pull/10933#issuecomment-577727666 ## CI report: * d4f96c8adca468e957e724a22344da42501c5f85 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10934: [FLINK-15741][docs][TTL] Fix TTL docs after enabling RocksDB compaction filter by default

flinkbot edited a comment on issue #10934: [FLINK-15741][docs][TTL] Fix TTL docs after enabling RocksDB compaction filter by default URL: https://github.com/apache/flink/pull/10934#issuecomment-577727721 ## CI report: * 04f05418536e63811ba5ac63aa53b915901001de Travis:

[jira] [Created] (FLINK-15743) Add Flink 1.10 release notes to documentation

Gary Yao created FLINK-15743: Summary: Add Flink 1.10 release notes to documentation Key: FLINK-15743 URL: https://issues.apache.org/jira/browse/FLINK-15743 Project: Flink Issue Type: Task

[jira] [Updated] (FLINK-13885) Remove HighAvailabilityOptions#HA_JOB_DELAY which is no longer used

[ https://issues.apache.org/jira/browse/FLINK-13885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-13885: - Release Note: The configuration option `high-availability.job.delay` has been removed since it is no

[GitHub] [flink] flinkbot edited a comment on issue #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

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

[GitHub] [flink] flinkbot commented on issue #10936: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak in Elasticsearch connector when cluster is down

flinkbot commented on issue #10936: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak in Elasticsearch connector when cluster is down URL: https://github.com/apache/flink/pull/10936#issuecomment-577765273 ## CI report: * f12dc4a4d0a8c88a303cc67a283824b01c84b6ec UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #10935: [FLINK-15603][web] Expose checkpointStartDelayNanos metric in the WebUI

flinkbot edited a comment on issue #10935: [FLINK-15603][web] Expose checkpointStartDelayNanos metric in the WebUI URL: https://github.com/apache/flink/pull/10935#issuecomment-577747488 ## CI report: * d23cbb62a92aeacecabdad080c3d062dcaa7ddba Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10932: [FLINK-15614][docs] Consolidate Hadoop documentation

flinkbot edited a comment on issue #10932: [FLINK-15614][docs] Consolidate Hadoop documentation URL: https://github.com/apache/flink/pull/10932#issuecomment-577700244 ## CI report: * fb34b16d701e65ee2edcaa082869af08b4ee0482 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10867: [FLINK-14701][runtime] Fix MultiTaskSlot to not remove slots which are not its children

flinkbot edited a comment on issue #10867: [FLINK-14701][runtime] Fix MultiTaskSlot to not remove slots which are not its children URL: https://github.com/apache/flink/pull/10867#issuecomment-574982744 ## CI report: * 3d94fa8f5a675706dcb974b397452d165bcee987 Travis:

[jira] [Updated] (FLINK-14490) Add methods for interacting with temporary tables & views

[ https://issues.apache.org/jira/browse/FLINK-14490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-14490: - Release Note: Methods such as registerTable/registerDataStream/registerDataSet become

[jira] [Commented] (FLINK-15671) Provide one place for Docker Images with all supported cluster modes

[ https://issues.apache.org/jira/browse/FLINK-15671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17022252#comment-17022252 ] Stephan Ewen commented on FLINK-15671: -- [~rongr] Thanks. Please feel free to share your thoughts on

[GitHub] [flink] flinkbot edited a comment on issue #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

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

[GitHub] [flink] zhuzhurk commented on a change in pull request #10867: [FLINK-14701][runtime] Fix MultiTaskSlot to not remove slots which are not its children

zhuzhurk commented on a change in pull request #10867: [FLINK-14701][runtime] Fix MultiTaskSlot to not remove slots which are not its children URL: https://github.com/apache/flink/pull/10867#discussion_r370213639 ## File path:

[GitHub] [flink] flinkbot commented on issue #10936: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak in Elasticsearch connector when cluster is down

flinkbot commented on issue #10936: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak in Elasticsearch connector when cluster is down URL: https://github.com/apache/flink/pull/10936#issuecomment-577750433 Thanks a lot for your contribution to the Apache Flink project. I'm the

[GitHub] [flink] static-max opened a new pull request #10936: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak in Elasticsearch connector when cluster is down

static-max opened a new pull request #10936: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak in Elasticsearch connector when cluster is down URL: https://github.com/apache/flink/pull/10936 ## What is the purpose of the change Fixes thread leaks caused by unclosed

[jira] [Commented] (FLINK-14807) Add Table#collect api for fetching data to client

[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17022231#comment-17022231 ] Aljoscha Krettek commented on FLINK-14807: -- I'm trying to continue the discussion here:

[GitHub] [flink] flinkbot edited a comment on issue #10934: [FLINK-15741][docs][TTL] Fix TTL docs after enabling RocksDB compaction filter by default

flinkbot edited a comment on issue #10934: [FLINK-15741][docs][TTL] Fix TTL docs after enabling RocksDB compaction filter by default URL: https://github.com/apache/flink/pull/10934#issuecomment-577727721 ## CI report: * 04f05418536e63811ba5ac63aa53b915901001de Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10931: [FLINK-15603][metrics] Add checkpointStartDelay metric

flinkbot edited a comment on issue #10931: [FLINK-15603][metrics] Add checkpointStartDelay metric URL: https://github.com/apache/flink/pull/10931#issuecomment-577584540 ## CI report: * b43b813c97413608b68d0672c312b92b23e1d4e0 Travis:

[GitHub] [flink] flinkbot commented on issue #10935: [FLINK-15603][web] Expose checkpointStartDelayNanos metric in the WebUI

flinkbot commented on issue #10935: [FLINK-15603][web] Expose checkpointStartDelayNanos metric in the WebUI URL: https://github.com/apache/flink/pull/10935#issuecomment-577747488 ## CI report: * d23cbb62a92aeacecabdad080c3d062dcaa7ddba UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on issue #10933: [FLINK-15651][tests] Refactor JarHandlerTest

flinkbot edited a comment on issue #10933: [FLINK-15651][tests] Refactor JarHandlerTest URL: https://github.com/apache/flink/pull/10933#issuecomment-577727666 ## CI report: * d4f96c8adca468e957e724a22344da42501c5f85 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10932: [FLINK-15614][docs] Consolidate Hadoop documentation

flinkbot edited a comment on issue #10932: [FLINK-15614][docs] Consolidate Hadoop documentation URL: https://github.com/apache/flink/pull/10932#issuecomment-577700244 ## CI report: * fb34b16d701e65ee2edcaa082869af08b4ee0482 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10847: [FLINK-15578][connectors/jdbc] implement exactly once JDBC sink

flinkbot edited a comment on issue #10847: [FLINK-15578][connectors/jdbc] implement exactly once JDBC sink URL: https://github.com/apache/flink/pull/10847#issuecomment-573933799 ## CI report: * 1f19ab63df12c2a0cbc75644a34bcab26c08d7f6 Travis:

[jira] [Commented] (FLINK-10819) JobManagerHAProcessFailureRecoveryITCase.testDispatcherProcessFailure is unstable

[ https://issues.apache.org/jira/browse/FLINK-10819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17022202#comment-17022202 ] Aljoscha Krettek commented on FLINK-10819: -- [~chesnay] added a different variant of

[jira] [Comment Edited] (FLINK-14807) Add Table#collect api for fetching data to client

[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17022084#comment-17022084 ] Kostas Kloudas edited comment on FLINK-14807 at 1/23/20 3:45 PM: - I have

[jira] [Commented] (FLINK-7009) dogstatsd mode in statsd reporter

[ https://issues.apache.org/jira/browse/FLINK-7009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17022198#comment-17022198 ] Rafi Aroch commented on FLINK-7009: --- I developed similar functionality as a separate reporter and added

[jira] [Resolved] (FLINK-15602) Blink planner does not respect the precision when casting timestamp to varchar

[ https://issues.apache.org/jira/browse/FLINK-15602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-15602. - Resolution: Fixed Fixed in 1.11.0: 84e76b0149187be3e3237a004c3f08a515168315 1.10.0:

[jira] [Commented] (FLINK-14807) Add Table#collect api for fetching data to client

[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17022193#comment-17022193 ] Stephan Ewen commented on FLINK-14807: -- I would like to understand this a bit more. Having two ways

[GitHub] [flink] flinkbot edited a comment on issue #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

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

[GitHub] [flink] flinkbot commented on issue #10934: [FLINK-15741][docs][TTL] Fix TTL docs after enabling RocksDB compaction filter by default

flinkbot commented on issue #10934: [FLINK-15741][docs][TTL] Fix TTL docs after enabling RocksDB compaction filter by default URL: https://github.com/apache/flink/pull/10934#issuecomment-577727721 ## CI report: * 04f05418536e63811ba5ac63aa53b915901001de UNKNOWN Bot

[GitHub] [flink] flinkbot commented on issue #10933: [FLINK-15651][tests] Refactor JarHandlerTest

flinkbot commented on issue #10933: [FLINK-15651][tests] Refactor JarHandlerTest URL: https://github.com/apache/flink/pull/10933#issuecomment-577727666 ## CI report: * d4f96c8adca468e957e724a22344da42501c5f85 UNKNOWN Bot commands The @flinkbot bot supports the

[GitHub] [flink] flinkbot edited a comment on issue #10931: [FLINK-15603][metrics] Add checkpointStartDelay metric

flinkbot edited a comment on issue #10931: [FLINK-15603][metrics] Add checkpointStartDelay metric URL: https://github.com/apache/flink/pull/10931#issuecomment-577584540 ## CI report: * b43b813c97413608b68d0672c312b92b23e1d4e0 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10867: [FLINK-14701][runtime] Fix MultiTaskSlot to not remove slots which are not its children

flinkbot edited a comment on issue #10867: [FLINK-14701][runtime] Fix MultiTaskSlot to not remove slots which are not its children URL: https://github.com/apache/flink/pull/10867#issuecomment-574982744 ## CI report: * 3d94fa8f5a675706dcb974b397452d165bcee987 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10847: [FLINK-15578][connectors/jdbc] implement exactly once JDBC sink

flinkbot edited a comment on issue #10847: [FLINK-15578][connectors/jdbc] implement exactly once JDBC sink URL: https://github.com/apache/flink/pull/10847#issuecomment-573933799 ## CI report: * 1f19ab63df12c2a0cbc75644a34bcab26c08d7f6 Travis:

[GitHub] [flink] pnowojski commented on issue #10935: [FLINK-15603][web] Expose checkpointStartDelayNanos metric in the WebUI

pnowojski commented on issue #10935: [FLINK-15603][web] Expose checkpointStartDelayNanos metric in the WebUI URL: https://github.com/apache/flink/pull/10935#issuecomment-577722243 CC @vthinkxie This is an automated message

[GitHub] [flink] flinkbot commented on issue #10935: [FLINK-15603][web] Expose checkpointStartDelayNanos metric in the WebUI

flinkbot commented on issue #10935: [FLINK-15603][web] Expose checkpointStartDelayNanos metric in the WebUI URL: https://github.com/apache/flink/pull/10935#issuecomment-577722314 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Closed] (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:all-tabpanel ] Stephan Ewen closed FLINK-15368. > Add end-to-end test for controlling RocksDB memory usage >

[GitHub] [flink] tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

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

[GitHub] [flink] tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

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

[GitHub] [flink] tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

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

[GitHub] [flink] tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

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

[GitHub] [flink] tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

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

[GitHub] [flink] tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

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

[GitHub] [flink] tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

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

[GitHub] [flink] tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

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

[GitHub] [flink] tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

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

[jira] [Resolved] (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:all-tabpanel ] Stephan Ewen resolved FLINK-15368. -- Resolution: Fixed Fixed in - 1.10 via ab16448ba855ce0794b2f0630e300f829b69a403 and

[GitHub] [flink] tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

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

[GitHub] [flink] GJL commented on a change in pull request #10934: [FLINK-15741][docs][TTL] Fix TTL docs after enabling RocksDB compaction filter by default

GJL commented on a change in pull request #10934: [FLINK-15741][docs][TTL] Fix TTL docs after enabling RocksDB compaction filter by default URL: https://github.com/apache/flink/pull/10934#discussion_r370166970 ## File path: docs/dev/stream/state/state.md ## @@ -511,7

  1   2   3   >