[GitHub] [flink] rmetzger commented on pull request #12240: [FLINK-15792][k8s] Make Flink logs accessible via kubectl logs per default

2020-08-07 Thread GitBox
rmetzger commented on pull request #12240: URL: https://github.com/apache/flink/pull/12240#issuecomment-670344313 I will merge this change now This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] JingsongLi commented on a change in pull request #12985: [FLINK-18682][orc][hive] Vector orc reader cannot read Hive 2.0.0 table

2020-08-07 Thread GitBox
JingsongLi commented on a change in pull request #12985: URL: https://github.com/apache/flink/pull/12985#discussion_r466844085 ## File path: flink-formats/flink-orc/src/main/java/org/apache/flink/orc/vector/OrcLegacyTimestampColumnVector.java ## @@ -0,0 +1,168 @@ +/* + *

[jira] [Updated] (FLINK-17075) Add task status reconciliation between TM and JM

2020-08-07 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17075: Fix Version/s: (was: 1.10.2) 1.10.3 > Add task status reconciliation between TM

[jira] [Commented] (FLINK-18681) The jar package version conflict causes the task to continue to increase and grab resources

2020-08-07 Thread Tao Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17172932#comment-17172932 ] Tao Yang commented on FLINK-18681: -- I think you can check the log4j conf of RM to confirm whether all

[GitHub] [flink] rmetzger merged pull request #13064: [hotfix][docs]fix java code in scala snippet

2020-08-07 Thread GitBox
rmetzger merged pull request #13064: URL: https://github.com/apache/flink/pull/13064 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [flink] rmetzger commented on pull request #13076: [hotfix] Skip some e2e tests on aarch64

2020-08-07 Thread GitBox
rmetzger commented on pull request #13076: URL: https://github.com/apache/flink/pull/13076#issuecomment-670361970 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] rmetzger commented on pull request #13064: [hotfix][docs]fix java code in scala snippet

2020-08-07 Thread GitBox
rmetzger commented on pull request #13064: URL: https://github.com/apache/flink/pull/13064#issuecomment-670361296 Thanks for the fix! Merging ... This is an automated message from the Apache Git Service. To respond

[jira] [Commented] (FLINK-18694) Add unaligned checkpoint config to web ui

2020-08-07 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17172962#comment-17172962 ] Robert Metzger commented on FLINK-18694: [~AHeise] What's your take on this improvement? > Add

[GitHub] [flink] zhuzhurk commented on a change in pull request #13071: [FLINK-18751][Coordination] Implement SlotSharingExecutionSlotAllocator

2020-08-07 Thread GitBox
zhuzhurk commented on a change in pull request #13071: URL: https://github.com/apache/flink/pull/13071#discussion_r466874550 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/DualKeyLinkedMap.java ## @@ -43,63 +43,48 @@ * @param Type of key B. Key B

[jira] [Updated] (FLINK-18732) Update the hyperlink to the latest version

2020-08-07 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-18732: --- Component/s: chinese-translation > Update the hyperlink to the latest version >

[jira] [Commented] (FLINK-15793) Move kubernetes-entry.sh out of FLINK_HOME/bin

2020-08-07 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17172913#comment-17172913 ] Robert Metzger commented on FLINK-15793: +1 for using the {{docker-entrypoint.sh}} for the K8s

[GitHub] [flink] dianfu closed pull request #13083: [FLINK-18838][python] Support JdbcCatalog in Python Table API

2020-08-07 Thread GitBox
dianfu closed pull request #13083: URL: https://github.com/apache/flink/pull/13083 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[jira] [Closed] (FLINK-15792) Make Flink logs accessible via kubectl logs per default

2020-08-07 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-15792. -- Resolution: Fixed Merged to master in 6e8dd29eebf1bc51e7fb6d2322a0b9f41f01fd9a

[GitHub] [flink] rmetzger merged pull request #13060: [hotfix][docs] Rephrase the docs about file names in StreamingFileSink

2020-08-07 Thread GitBox
rmetzger merged pull request #13060: URL: https://github.com/apache/flink/pull/13060 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [flink] rmetzger commented on pull request #13060: [hotfix][docs] Rephrase the docs about file names in StreamingFileSink

2020-08-07 Thread GitBox
rmetzger commented on pull request #13060: URL: https://github.com/apache/flink/pull/13060#issuecomment-670356824 Thanks a lot for this fix! Merging ... This is an automated message from the Apache Git Service. To

[jira] [Updated] (FLINK-18843) Flink WEB-UI ISSUE

2020-08-07 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-18843: - Component/s: Runtime / Web Frontend > Flink WEB-UI ISSUE > -- > >

[GitHub] [flink] flinkbot edited a comment on pull request #13083: [FLINK-18838][python] Support JdbcCatalog in Python Table API

2020-08-07 Thread GitBox
flinkbot edited a comment on pull request #13083: URL: https://github.com/apache/flink/pull/13083#issuecomment-670281607 ## CI report: * ba39c1d4173aa7aebdc7348464ff8cea3d9d012e Azure:

[jira] [Commented] (FLINK-18795) Support for HBase 2

2020-08-07 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17172954#comment-17172954 ] Robert Metzger commented on FLINK-18795: Thanks a lot for opening this JIRA and the PR. Before

[jira] [Updated] (FLINK-18846) Set a meaningful operator name for the filesystem sink

2020-08-07 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-18846: - Labels: starter (was: ) > Set a meaningful operator name for the filesystem sink >

[GitHub] [flink] qinjunjerry commented on pull request #13068: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak in Elasticsearch connector when cluster is down

2020-08-07 Thread GitBox
qinjunjerry commented on pull request #13068: URL: https://github.com/apache/flink/pull/13068#issuecomment-670356197 I did not see any conflicts to master. This is an automated message from the Apache Git Service. To

[jira] [Commented] (FLINK-18796) FlinkKinesisProducer.backpressureLatch should be volatile

2020-08-07 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17172934#comment-17172934 ] Roman Khachatryan commented on FLINK-18796: --- During the offline discussion, we agreed that

[GitHub] [flink] zentol commented on a change in pull request #13031: [FLINK-18773][runtime] Enables parallel user-code and plugin class loader.

2020-08-07 Thread GitBox
zentol commented on a change in pull request #13031: URL: https://github.com/apache/flink/pull/13031#discussion_r466864583 ## File path: flink-core/src/main/java/org/apache/flink/util/ChildFirstClassLoader.java ## @@ -73,9 +71,7 @@ public ChildFirstClassLoader(

[GitHub] [flink] wuchong commented on a change in pull request #12880: [FLINK-18555][table sql/api] Make TableConfig options can be configur…

2020-08-07 Thread GitBox
wuchong commented on a change in pull request #12880: URL: https://github.com/apache/flink/pull/12880#discussion_r466872581 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/ExecutionConfigOptions.java ## @@ -37,9 +39,24 @@

[jira] [Commented] (FLINK-17183) the 'create table [if not exists]' syntax is not supported

2020-08-07 Thread muzimusi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17172960#comment-17172960 ] muzimusi commented on FLINK-17183: -- Hi [~jark]! This feature is not available in Flink1.11. Should we

[jira] [Commented] (FLINK-17183) the 'create table [if not exists]' syntax is not supported

2020-08-07 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17172968#comment-17172968 ] Leonard Xu commented on FLINK-17183: Hi, [~muzimusi] This issue has implemented in 1.12 

[jira] [Updated] (FLINK-17183) the 'create table [if not exists]' syntax is not supported

2020-08-07 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-17183: --- Fix Version/s: (was: 1.11.0) 1.12.0 > the 'create table [if not exists]'

[jira] [Commented] (FLINK-18840) Support StatementSet with DataStream API

2020-08-07 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17172977#comment-17172977 ] Timo Walther commented on FLINK-18840: -- I could imagine some method like

[GitHub] [flink] AHeise commented on pull request #12962: [FLINK-18694] Add unaligned checkpoint config to web ui

2020-08-07 Thread GitBox
AHeise commented on pull request #12962: URL: https://github.com/apache/flink/pull/12962#issuecomment-670390659 Thank you very much for your contribution. I'm going to try it out locally and do a review then, but it already looks very good.

[GitHub] [flink] rmetzger closed pull request #12240: [FLINK-15792][k8s] Make Flink logs accessible via kubectl logs per default

2020-08-07 Thread GitBox
rmetzger closed pull request #12240: URL: https://github.com/apache/flink/pull/12240 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [flink] JingsongLi commented on a change in pull request #12985: [FLINK-18682][orc][hive] Vector orc reader cannot read Hive 2.0.0 table

2020-08-07 Thread GitBox
JingsongLi commented on a change in pull request #12985: URL: https://github.com/apache/flink/pull/12985#discussion_r466843452 ## File path: flink-formats/flink-orc/src/main/java/org/apache/flink/orc/vector/OrcLegacyTimestampColumnVector.java ## @@ -0,0 +1,168 @@ +/* + *

[jira] [Commented] (FLINK-18681) The jar package version conflict causes the task to continue to increase and grab resources

2020-08-07 Thread wangtaiyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17172926#comment-17172926 ] wangtaiyang commented on FLINK-18681: - This is all the logs. I checked the other logs and only

[GitHub] [flink] rmetzger commented on pull request #13076: [hotfix] Skip some e2e tests on aarch64

2020-08-07 Thread GitBox
rmetzger commented on pull request #13076: URL: https://github.com/apache/flink/pull/13076#issuecomment-670362108 The NPM failures were caused by some outage on NPMs systems. This is an automated message from the Apache Git

[GitHub] [flink] flinkbot edited a comment on pull request #13050: [FLINK-18750][table] SqlValidatorException thrown when select from a …

2020-08-07 Thread GitBox
flinkbot edited a comment on pull request #13050: URL: https://github.com/apache/flink/pull/13050#issuecomment-667904442 ## CI report: * 8559c87345749d7a627fd4ae4d4d58141a53639e Azure:

[GitHub] [flink] flinkbot commented on pull request #13084: [FLINK-18847][docs][python] Add documentation about data types in Python Table API

2020-08-07 Thread GitBox
flinkbot commented on pull request #13084: URL: https://github.com/apache/flink/pull/13084#issuecomment-670378544 ## CI report: * 8e32bc6b48a920108127fed3277a0225ec2b9abd UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #13084: [FLINK-18847][docs][python] Add documentation about data types in Python Table API

2020-08-07 Thread GitBox
flinkbot edited a comment on pull request #13084: URL: https://github.com/apache/flink/pull/13084#issuecomment-670378544 ## CI report: * 8e32bc6b48a920108127fed3277a0225ec2b9abd Azure:

[jira] [Commented] (FLINK-18846) Set a meaningful operator name for the filesystem sink

2020-08-07 Thread zhuqi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17172924#comment-17172924 ] zhuqi commented on FLINK-18846: --- cc [~jark]   If i can take this, pls add me to the contributor list.

[GitHub] [flink] rmetzger commented on pull request #13068: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak in Elasticsearch connector when cluster is down

2020-08-07 Thread GitBox
rmetzger commented on pull request #13068: URL: https://github.com/apache/flink/pull/13068#issuecomment-670354963 Thanks for the backport. Did the commit from master apply without conflicts to the release-1.10 branch? (I'm asking so that don't have to manually compare everything ;) )

[GitHub] [flink] flinkbot edited a comment on pull request #13076: [hotfix] Skip some e2e tests on aarch64

2020-08-07 Thread GitBox
flinkbot edited a comment on pull request #13076: URL: https://github.com/apache/flink/pull/13076#issuecomment-669809007 ## CI report: * 18962c3269adfaa3564009a70cfce0a7adc5cdff Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13050: [FLINK-18750][table] SqlValidatorException thrown when select from a …

2020-08-07 Thread GitBox
flinkbot edited a comment on pull request #13050: URL: https://github.com/apache/flink/pull/13050#issuecomment-667904442 ## CI report: * 8559c87345749d7a627fd4ae4d4d58141a53639e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13071: [FLINK-18751][Coordination] Implement SlotSharingExecutionSlotAllocator

2020-08-07 Thread GitBox
flinkbot edited a comment on pull request #13071: URL: https://github.com/apache/flink/pull/13071#issuecomment-669310861 ## CI report: * 2233727954b8a6272c4a772a03bccc08b5e97720 UNKNOWN * 07fd40233580c1641fda58742e015144d767c2fe UNKNOWN *

[jira] [Updated] (FLINK-18847) Add documentation about data types in Python Table API

2020-08-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18847: --- Labels: pull-request-available (was: ) > Add documentation about data types in Python

[GitHub] [flink] dianfu opened a new pull request #13084: [FLINK-18847][docs][python] Add documentation about data types in Python Table API

2020-08-07 Thread GitBox
dianfu opened a new pull request #13084: URL: https://github.com/apache/flink/pull/13084 ## What is the purpose of the change *This pull request add documentation about data types in Python Table API* ## Brief change log - *Add documentation about data types in

[GitHub] [flink] flinkbot commented on pull request #13084: [FLINK-18847][docs][python] Add documentation about data types in Python Table API

2020-08-07 Thread GitBox
flinkbot commented on pull request #13084: URL: https://github.com/apache/flink/pull/13084#issuecomment-670376080 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 use this comment to track the

[GitHub] [flink] rmetzger commented on pull request #12823: FLINK-18013: Refactor Hadoop utils to a single module

2020-08-07 Thread GitBox
rmetzger commented on pull request #12823: URL: https://github.com/apache/flink/pull/12823#issuecomment-670379348 What's the status of this PR? This is an automated message from the Apache Git Service. To respond to the

[jira] [Commented] (FLINK-18694) Add unaligned checkpoint config to web ui

2020-08-07 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17172976#comment-17172976 ] Arvid Heise commented on FLINK-18694: - Awesome addition. We had a similar (or the same) task planned

[jira] [Commented] (FLINK-13689) Rest High Level Client for Elasticsearch6.x connector leaks threads if no connection could be established

2020-08-07 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17172937#comment-17172937 ] Robert Metzger commented on FLINK-13689: release-1.10:

[jira] [Updated] (FLINK-13689) Rest High Level Client for Elasticsearch6.x connector leaks threads if no connection could be established

2020-08-07 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13689: --- Fix Version/s: 1.10.2 > Rest High Level Client for Elasticsearch6.x connector leaks threads

[GitHub] [flink] rmetzger commented on pull request #13068: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak in Elasticsearch connector when cluster is down

2020-08-07 Thread GitBox
rmetzger commented on pull request #13068: URL: https://github.com/apache/flink/pull/13068#issuecomment-670357300 Okay. In the meantime I checked the changes, everything looks fine. I'll merge this now! Thanks for the backport!

[GitHub] [flink] rmetzger merged pull request #13068: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak in Elasticsearch connector when cluster is down

2020-08-07 Thread GitBox
rmetzger merged pull request #13068: URL: https://github.com/apache/flink/pull/13068 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[jira] [Closed] (FLINK-18838) Support JdbcCatalog in Python Table API

2020-08-07 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-18838. --- Assignee: Dian Fu Resolution: Fixed master: b2cbf1c0017b7587afae730c2275fd0f34123032 > Support

[GitHub] [flink] zentol commented on a change in pull request #13027: [FLINK-16245] Decoupling user classloader from context classloader.

2020-08-07 Thread GitBox
zentol commented on a change in pull request #13027: URL: https://github.com/apache/flink/pull/13027#discussion_r466868396 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSink.java ## @@ -241,12 +242,14 @@ public

[jira] [Created] (FLINK-18847) Add documentation about data types in Python Table API

2020-08-07 Thread Dian Fu (Jira)
Dian Fu created FLINK-18847: --- Summary: Add documentation about data types in Python Table API Key: FLINK-18847 URL: https://issues.apache.org/jira/browse/FLINK-18847 Project: Flink Issue Type:

[GitHub] [flink] zentol commented on pull request #13042: [FLINK-16510] Allow configuring shutdown behavior to avoid JVM freeze

2020-08-07 Thread GitBox
zentol commented on pull request #13042: URL: https://github.com/apache/flink/pull/13042#issuecomment-670374315 @mxm For the future, if you are running into issues building the WebUI, then you can skip it using `-Pskip-webui-build`.

[GitHub] [flink] flinkbot edited a comment on pull request #13071: [FLINK-18751][Coordination] Implement SlotSharingExecutionSlotAllocator

2020-08-07 Thread GitBox
flinkbot edited a comment on pull request #13071: URL: https://github.com/apache/flink/pull/13071#issuecomment-669310861 ## CI report: * 2233727954b8a6272c4a772a03bccc08b5e97720 UNKNOWN * 07fd40233580c1641fda58742e015144d767c2fe UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #12880: [FLINK-18555][table sql/api] Make TableConfig options can be configur…

2020-08-07 Thread GitBox
flinkbot edited a comment on pull request #12880: URL: https://github.com/apache/flink/pull/12880#issuecomment-657437173 ## CI report: * 82edfc5569e7d434ecd56a872b2f56015df3a851 Azure:

[GitHub] [flink] SteNicholas commented on a change in pull request #13017: [FLINK-18258][hive] Implement SHOW PARTITIONS for Hive dialect

2020-08-07 Thread GitBox
SteNicholas commented on a change in pull request #13017: URL: https://github.com/apache/flink/pull/13017#discussion_r466920816 ## File path: flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveDialectITCase.java ## @@ -465,6 +465,49 @@

[jira] [Closed] (FLINK-18806) Taskmanager doesn't start up with error in config

2020-08-07 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-18806. --- Resolution: Duplicate Thanks [~karmagyz], FLINK-18639 does indeed solve this. I'm closing this

[jira] [Assigned] (FLINK-18522) ZKCheckpointIDCounterMultiServersTest.testRecoveredAfterConnectionLoss failed with "Address already in use"

2020-08-07 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-18522: - Assignee: Matthias >

[GitHub] [flink] zhijiangW commented on a change in pull request #12994: [FLINK-18728][network] Make initialCredit of RemoteInputChannel final

2020-08-07 Thread GitBox
zhijiangW commented on a change in pull request #12994: URL: https://github.com/apache/flink/pull/12994#discussion_r466927353 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPool.java ## @@ -161,13 +155,13 @@ public void

[GitHub] [flink] tillrohrmann closed pull request #13080: [BP-1.11][FLINK-16510] Allow configuring shutdown behavior to avoid JVM freeze

2020-08-07 Thread GitBox
tillrohrmann closed pull request #13080: URL: https://github.com/apache/flink/pull/13080 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

[GitHub] [flink] tillrohrmann commented on pull request #13080: [BP-1.11][FLINK-16510] Allow configuring shutdown behavior to avoid JVM freeze

2020-08-07 Thread GitBox
tillrohrmann commented on pull request #13080: URL: https://github.com/apache/flink/pull/13080#issuecomment-670449558 Manually merged via 6782254aadad50d2879a626eb39efeafc93fae13 This is an automated message from the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #12881: [FLINK-18512][kinesis] Introducing RecordPublisher. Refactor ShardConsumer to use PollingRecordPublisher

2020-08-07 Thread GitBox
flinkbot edited a comment on pull request #12881: URL: https://github.com/apache/flink/pull/12881#issuecomment-657437295 ## CI report: * 44aa907f7a0d7457bfd26d5294a0d77ddb4e3c09 Azure:

[jira] [Closed] (FLINK-12011) Add Dockerfile with Debian as base image in Flink distribution

2020-08-07 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-12011. -- Resolution: Not A Problem > Add Dockerfile with Debian as base image in Flink distribution >

[jira] [Commented] (FLINK-10140) Log files are not available via web UI in containerized environment

2020-08-07 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17173083#comment-17173083 ] Robert Metzger commented on FLINK-10140: This is not a problem anymore with the native

[jira] [Closed] (FLINK-10140) Log files are not available via web UI in containerized environment

2020-08-07 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-10140. -- Resolution: Not A Problem > Log files are not available via web UI in containerized

[jira] [Comment Edited] (FLINK-10140) Log files are not available via web UI in containerized environment

2020-08-07 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17173083#comment-17173083 ] Robert Metzger edited comment on FLINK-10140 at 8/7/20, 11:18 AM: -- This

[GitHub] [flink] flinkbot edited a comment on pull request #12880: [FLINK-18555][table sql/api] Make TableConfig options can be configur…

2020-08-07 Thread GitBox
flinkbot edited a comment on pull request #12880: URL: https://github.com/apache/flink/pull/12880#issuecomment-657437173 ## CI report: * 5f9cc66b6457e7a28b137f82fe24bbff14fda84d Azure:

[GitHub] [flink] flinkbot commented on pull request #13085: [FLINK-18849][docs] Improve the code tabs of the Flink documents.

2020-08-07 Thread GitBox
flinkbot commented on pull request #13085: URL: https://github.com/apache/flink/pull/13085#issuecomment-670497782 ## CI report: * cec71d84d3cfb2a69cbae2ed74fd1612ff95f747 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Closed] (FLINK-18522) ZKCheckpointIDCounterMultiServersTest.testRecoveredAfterConnectionLoss failed with "Address already in use"

2020-08-07 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-18522. - Resolution: Won't Fix > ZKCheckpointIDCounterMultiServersTest.testRecoveredAfterConnectionLoss

[jira] [Created] (FLINK-18851) Add checkpoint type to checkpoint history entries in Web UI

2020-08-07 Thread Arvid Heise (Jira)
Arvid Heise created FLINK-18851: --- Summary: Add checkpoint type to checkpoint history entries in Web UI Key: FLINK-18851 URL: https://issues.apache.org/jira/browse/FLINK-18851 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #13085: [FLINK-18849][docs] Improve the code tabs of the Flink documents.

2020-08-07 Thread GitBox
flinkbot edited a comment on pull request #13085: URL: https://github.com/apache/flink/pull/13085#issuecomment-670497782 ## CI report: * cec71d84d3cfb2a69cbae2ed74fd1612ff95f747 Azure:

[jira] [Updated] (FLINK-16419) Avoid to recommit transactions which are known committed successfully to Kafka upon recovery

2020-08-07 Thread Jun Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Qin updated FLINK-16419: Labels: usability (was: ) > Avoid to recommit transactions which are known committed successfully to >

[GitHub] [flink] flinkbot edited a comment on pull request #12988: [FLINK-18678][hive][doc] Update doc about setting hive version

2020-08-07 Thread GitBox
flinkbot edited a comment on pull request #12988: URL: https://github.com/apache/flink/pull/12988#issuecomment-663533121 ## CI report: * 47ecfdd6725845ff0f78050fec2002ca4093d6b4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12994: [FLINK-18728][network] Make initialCredit of RemoteInputChannel final

2020-08-07 Thread GitBox
flinkbot edited a comment on pull request #12994: URL: https://github.com/apache/flink/pull/12994#issuecomment-664206728 ## CI report: * 707c67f554cf59d2ba1e848e05cef0aea1fe7a89 Azure:

[jira] [Commented] (FLINK-18702) Flink elasticsearch connector leaks threads and classloaders thereof

2020-08-07 Thread Jun Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17173144#comment-17173144 ] Jun Qin commented on FLINK-18702: - This has been merged into master. See:

[GitHub] [flink] flinkbot edited a comment on pull request #12988: [FLINK-18678][hive][doc] Update doc about setting hive version

2020-08-07 Thread GitBox
flinkbot edited a comment on pull request #12988: URL: https://github.com/apache/flink/pull/12988#issuecomment-663533121 ## CI report: * 80ca1109553eeff1fe52fb32945ace1fb8524152 Azure:

[jira] [Commented] (FLINK-7289) Memory allocation of RocksDB can be problematic in container environments

2020-08-07 Thread Harsh Singh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17173178#comment-17173178 ] Harsh Singh commented on FLINK-7289: Hi, this doesnt seem to address the issue Vinay pointed out, on

[jira] [Comment Edited] (FLINK-18808) Task-level numRecordsOut metric may be underestimated

2020-08-07 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17173177#comment-17173177 ] Piotr Nowojski edited comment on FLINK-18808 at 8/7/20, 2:37 PM: - +1 to

[jira] [Updated] (FLINK-18849) Improve the code tabs of the Flink documents

2020-08-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18849: --- Labels: pull-request-available (was: ) > Improve the code tabs of the Flink documents >

[GitHub] [flink] WeiZhong94 opened a new pull request #13085: [FLINK-18849][docs] Improve the code tabs of the Flink documents.

2020-08-07 Thread GitBox
WeiZhong94 opened a new pull request #13085: URL: https://github.com/apache/flink/pull/13085 ## What is the purpose of the change *This pull request modifies the `flink.js` to improve the code tabs of the Flink documents.* ## Brief change log - *Split the code tab

[jira] [Created] (FLINK-18850) Add late records dropped metric for row time over windows

2020-08-07 Thread Benchao Li (Jira)
Benchao Li created FLINK-18850: -- Summary: Add late records dropped metric for row time over windows Key: FLINK-18850 URL: https://issues.apache.org/jira/browse/FLINK-18850 Project: Flink Issue

[jira] [Assigned] (FLINK-17503) Make memory configuration logging more user-friendly

2020-08-07 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-17503: - Assignee: Matthias (was: Manish Ghildiyal) > Make memory configuration logging more

[jira] [Comment Edited] (FLINK-17503) Make memory configuration logging more user-friendly

2020-08-07 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17173113#comment-17173113 ] Till Rohrmann edited comment on FLINK-17503 at 8/7/20, 12:58 PM: -

[GitHub] [flink] flinkbot edited a comment on pull request #13071: [FLINK-18751][Coordination] Implement SlotSharingExecutionSlotAllocator

2020-08-07 Thread GitBox
flinkbot edited a comment on pull request #13071: URL: https://github.com/apache/flink/pull/13071#issuecomment-669310861 ## CI report: * 2233727954b8a6272c4a772a03bccc08b5e97720 UNKNOWN * 07fd40233580c1641fda58742e015144d767c2fe UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #13078: [FLINK-18659][hive][orc] Fix streaming write for Hive 1.x Orc table

2020-08-07 Thread GitBox
flinkbot edited a comment on pull request #13078: URL: https://github.com/apache/flink/pull/13078#issuecomment-669935780 ## CI report: * 4209634e8c7709f322e2fd46b5875da9afb3502f Azure:

[jira] [Created] (FLINK-18852) StreamScan should keep the same parallelism as the input

2020-08-07 Thread liupengcheng (Jira)
liupengcheng created FLINK-18852: Summary: StreamScan should keep the same parallelism as the input Key: FLINK-18852 URL: https://issues.apache.org/jira/browse/FLINK-18852 Project: Flink

[jira] [Updated] (FLINK-18852) StreamScan should keep the same parallelism as the input

2020-08-07 Thread liupengcheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liupengcheng updated FLINK-18852: - Description: Currently, the parallelism for StreamTableSourceScan/DataStreamScan is not

[GitHub] [flink] pnowojski commented on a change in pull request #13044: [FLINK-18641][checkpointing] Fix CheckpointCoordinator to work with ExternallyInducedSource

2020-08-07 Thread GitBox
pnowojski commented on a change in pull request #13044: URL: https://github.com/apache/flink/pull/13044#discussion_r466961539 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java ## @@ -530,15 +530,22 @@ private void

[GitHub] [flink] flinkbot edited a comment on pull request #12880: [FLINK-18555][table sql/api] Make TableConfig options can be configur…

2020-08-07 Thread GitBox
flinkbot edited a comment on pull request #12880: URL: https://github.com/apache/flink/pull/12880#issuecomment-657437173 ## CI report: * 1f213639e4e38e9e25506c20d7eff660cadbb6b1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13066: [FLINK-18765][python] Support map() and flat_map() for Python DataStream API.

2020-08-07 Thread GitBox
flinkbot edited a comment on pull request #13066: URL: https://github.com/apache/flink/pull/13066#issuecomment-669097678 ## CI report: * 33e5e101da72c7752adc0d8c95cbaf4527312d49 Azure:

[jira] [Commented] (FLINK-17503) Make memory configuration logging more user-friendly

2020-08-07 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17173113#comment-17173113 ] Till Rohrmann commented on FLINK-17503: --- [~manish.c.ghildi...@gmail.com] [~mapohl] will take this

[GitHub] [flink] flinkbot edited a comment on pull request #12881: [FLINK-18512][kinesis] Introducing RecordPublisher. Refactor ShardConsumer to use PollingRecordPublisher

2020-08-07 Thread GitBox
flinkbot edited a comment on pull request #12881: URL: https://github.com/apache/flink/pull/12881#issuecomment-657437295 ## CI report: * a62d1e33e012b669d56168c198d324f8d83a Azure:

[jira] [Commented] (FLINK-18522) ZKCheckpointIDCounterMultiServersTest.testRecoveredAfterConnectionLoss failed with "Address already in use"

2020-08-07 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17173126#comment-17173126 ] Matthias commented on FLINK-18522: -- ZooKeepers TestServer is implemented in a way that it selects a

[jira] [Created] (FLINK-18853) Supports properties from flink-conf.yaml for SET command in sql client

2020-08-07 Thread godfrey he (Jira)
godfrey he created FLINK-18853: -- Summary: Supports properties from flink-conf.yaml for SET command in sql client Key: FLINK-18853 URL: https://issues.apache.org/jira/browse/FLINK-18853 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #13051: [FLINK-18760][runtime] Redundant task managers should be released when there's no job running in session cluster

2020-08-07 Thread GitBox
flinkbot edited a comment on pull request #13051: URL: https://github.com/apache/flink/pull/13051#issuecomment-667970728 ## CI report: * b387eae159be898230e9b5a410a295f9960dabb1 UNKNOWN * 8234d87e7f9215067cd88ccd848958b5fd652a61 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13031: [FLINK-18773][runtime] Enables parallel user-code and plugin class loader.

2020-08-07 Thread GitBox
flinkbot edited a comment on pull request #13031: URL: https://github.com/apache/flink/pull/13031#issuecomment-666378800 ## CI report: * eda9fa6842aa8a78d0868d9946bd90077d3af3fb Azure:

[GitHub] [flink] pnowojski commented on a change in pull request #13044: [FLINK-18641][checkpointing] Fix CheckpointCoordinator to work with ExternallyInducedSource

2020-08-07 Thread GitBox
pnowojski commented on a change in pull request #13044: URL: https://github.com/apache/flink/pull/13044#discussion_r466961539 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java ## @@ -530,15 +530,22 @@ private void

[GitHub] [flink] pnowojski commented on a change in pull request #13044: [FLINK-18641][checkpointing] Fix CheckpointCoordinator to work with ExternallyInducedSource

2020-08-07 Thread GitBox
pnowojski commented on a change in pull request #13044: URL: https://github.com/apache/flink/pull/13044#discussion_r467068535 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java ## @@ -576,7 +583,22 @@ private void

[GitHub] [flink] flinkbot edited a comment on pull request #13031: [FLINK-18773][runtime] Enables parallel user-code and plugin class loader.

2020-08-07 Thread GitBox
flinkbot edited a comment on pull request #13031: URL: https://github.com/apache/flink/pull/13031#issuecomment-666378800 ## CI report: * eda9fa6842aa8a78d0868d9946bd90077d3af3fb Azure:

[GitHub] [flink] flinkbot commented on pull request #13085: [FLINK-18849][docs] Improve the code tabs of the Flink documents.

2020-08-07 Thread GitBox
flinkbot commented on pull request #13085: URL: https://github.com/apache/flink/pull/13085#issuecomment-670492600 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 use this comment to track the

  1   2   3   >