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

2020-08-06 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 S

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

2020-08-06 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 to

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

2020-08-06 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, please

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

2020-08-06 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 to

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

2020-08-06 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 to

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

2020-08-06 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!

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

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

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

2020-08-06 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 merged pull request #13060: [hotfix][docs] Rephrase the docs about file names in StreamingFileSink

2020-08-06 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 to

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

2020-08-06 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 resp

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

2020-08-06 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 respond

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

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

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

2020-08-06 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 ;) ) ---

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

2020-08-06 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 and

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

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

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

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

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

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

[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-06 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 @@ +/* + * Licen

[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-06 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 @@ +/* + * Licen

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

2020-08-06 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 541bc38b20b7a8

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

2020-08-06 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 to

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

2020-08-06 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 messag

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

2020-08-06 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 >

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

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

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

2020-08-06 Thread Jark Wu (Jira)
Jark Wu created FLINK-18846: --- Summary: Set a meaningful operator name for the filesystem sink Key: FLINK-18846 URL: https://issues.apache.org/jira/browse/FLINK-18846 Project: Flink Issue Type: Impr

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

2020-08-06 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17172911#comment-17172911 ] Jark Wu commented on FLINK-18846: - cc [~lzljs3620320] > Set a meaningful operator name

[jira] [Commented] (FLINK-18196) flink throws `NullPointerException` when executeCheckpointing

2020-08-06 Thread Kai Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17172907#comment-17172907 ] Kai Chen commented on FLINK-18196: -- Another report: [http://apache-flink.147419.n8.nab

[jira] [Updated] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

2020-08-06 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17274: --- Labels: test-stability (was: ) > Maven: Premature end of Content-Length delimited message b

[jira] [Updated] (FLINK-18842) e2e test failed to download "localhost:9999/flink.tgz" in "Wordcount on Docker test"

2020-08-06 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-18842: --- Component/s: Deployment / Docker > e2e test failed to download "localhost:/flink.tgz" in

[jira] [Updated] (FLINK-18842) e2e test failed to download "localhost:9999/flink.tgz" in "Wordcount on Docker test"

2020-08-06 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-18842: --- Labels: test-stability (was: ) > e2e test failed to download "localhost:/flink.tgz" in

[jira] [Updated] (FLINK-18842) e2e test failed to download "localhost:9999/flink.tgz" in "Wordcount on Docker test"

2020-08-06 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-18842: --- Summary: e2e test failed to download "localhost:/flink.tgz" in "Wordcount on Docker test

[jira] [Updated] (FLINK-18333) UnsignedTypeConversionITCase failed caused by MariaDB4j "Asked to waitFor Program"

2020-08-06 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-18333: --- Labels: test-stability (was: ) > UnsignedTypeConversionITCase failed caused by MariaDB4j "A

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

2020-08-06 Thread GitBox
flinkbot edited a comment on pull request #12994: URL: https://github.com/apache/flink/pull/12994#issuecomment-664206728 ## CI report: * 2aab77e658b25b810fcbc29c5977e16cb375c759 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2020-08-06 Thread GitBox
flinkbot edited a comment on pull request #13083: URL: https://github.com/apache/flink/pull/13083#issuecomment-670281607 ## CI report: * 19051add632f730aacb77364b685b9174074458a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-06 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * bce6761325c406591dac1f9ba2d755f5d76a3f78 UNKNOWN * cb4298bf796daf7c9e3ac2842459ea9221f7

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

2020-08-06 Thread GitBox
flinkbot edited a comment on pull request #12994: URL: https://github.com/apache/flink/pull/12994#issuecomment-664206728 ## CI report: * 2efaa69c5791a59239feec7c122ba4fd39462238 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2020-08-06 Thread GitBox
flinkbot edited a comment on pull request #12994: URL: https://github.com/apache/flink/pull/12994#issuecomment-664206728 ## CI report: * 2efaa69c5791a59239feec7c122ba4fd39462238 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-06 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * bce6761325c406591dac1f9ba2d755f5d76a3f78 UNKNOWN * cb4298bf796daf7c9e3ac2842459ea9221f7

[jira] [Commented] (FLINK-18830) JoinCoGroupFunction and FlatJoinCoGroupFunction work incorrectly for outer join when one side of coGroup is empty

2020-08-06 Thread liupengcheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17172797#comment-17172797 ] liupengcheng commented on FLINK-18830: -- First, I think we can create a new function

[jira] [Updated] (FLINK-18844) support maxwell-json for Maxwell binlog collector

2020-08-06 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18844: Affects Version/s: (was: 1.11.1) > support maxwell-json for Maxwell binlog collector > ---

[jira] [Updated] (FLINK-18844) support maxwell-json for Maxwell binlog collector

2020-08-06 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18844: Fix Version/s: 1.12.0 > support maxwell-json for Maxwell binlog collector > --

[jira] [Assigned] (FLINK-18844) support maxwell-json for Maxwell binlog collector

2020-08-06 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-18844: --- Assignee: jinxin > support maxwell-json for Maxwell binlog collector >

[jira] [Updated] (FLINK-18844) support maxwell-json for Maxwell binlog collector

2020-08-06 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18844: Parent: FLINK-18822 Issue Type: Sub-task (was: Improvement) > support maxwell-json for Maxwell bi

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

2020-08-06 Thread GitBox
flinkbot edited a comment on pull request #13083: URL: https://github.com/apache/flink/pull/13083#issuecomment-670281607 ## CI report: * 19051add632f730aacb77364b685b9174074458a Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-06 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * bce6761325c406591dac1f9ba2d755f5d76a3f78 UNKNOWN * cb4298bf796daf7c9e3ac2842459ea9221f7

[GitHub] [flink] Thesharing commented on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-06 Thread GitBox
Thesharing commented on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-670304105 @flinkbot run travis This is an automated message from the Apache Git Service. To respond to the message, ple

[jira] [Created] (FLINK-18845) class not found exception when i use sql client to try mysql as datasource.

2020-08-06 Thread HuiyuZhou (Jira)
HuiyuZhou created FLINK-18845: - Summary: class not found exception when i use sql client to try mysql as datasource. Key: FLINK-18845 URL: https://issues.apache.org/jira/browse/FLINK-18845 Project: Flink

[GitHub] [flink] hequn8128 commented on a change in pull request #13066: [FLINK-18765][python] Support map() and flat_map() for Python DataStream API.

2020-08-06 Thread GitBox
hequn8128 commented on a change in pull request #13066: URL: https://github.com/apache/flink/pull/13066#discussion_r466795433 ## File path: flink-python/pyflink/fn_execution/beam/beam_coder_impl_slow.py ## @@ -186,6 +187,68 @@ def __repr__(self): return 'ArrayCoderImpl

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

2020-08-06 Thread GitBox
zhuzhurk commented on a change in pull request #13071: URL: https://github.com/apache/flink/pull/13071#discussion_r466516013 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/util/DualKeyLinkedMapTest.java ## @@ -16,9 +16,10 @@ * limitations under the Licens

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

2020-08-06 Thread GitBox
flinkbot edited a comment on pull request #13066: URL: https://github.com/apache/flink/pull/13066#issuecomment-669097678 ## CI report: * 4ea614633c68f672acca22af3d912c12cde8974c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] zhuzhurk commented on a change in pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-06 Thread GitBox
zhuzhurk commented on a change in pull request #12917: URL: https://github.com/apache/flink/pull/12917#discussion_r466795801 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolTestBase.java ## @@ -0,0 +1,96 @@ +/* + * Licensed to the

[jira] [Created] (FLINK-18844) support maxwell-json for Maxwell binlog collector

2020-08-06 Thread jinxin (Jira)
jinxin created FLINK-18844: -- Summary: support maxwell-json for Maxwell binlog collector Key: FLINK-18844 URL: https://issues.apache.org/jira/browse/FLINK-18844 Project: Flink Issue Type: Improvement

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

2020-08-06 Thread Zhang Jianguo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhang Jianguo updated FLINK-18843: -- Description: Flink web-ui use Tabs provided by ant-design implements navigations. I found an

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

2020-08-06 Thread Zhang Jianguo (Jira)
Zhang Jianguo created FLINK-18843: - Summary: Flink WEB-UI ISSUE Key: FLINK-18843 URL: https://issues.apache.org/jira/browse/FLINK-18843 Project: Flink Issue Type: Bug Affects Versions: 1.

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

2020-08-06 Thread GitBox
flinkbot edited a comment on pull request #13066: URL: https://github.com/apache/flink/pull/13066#issuecomment-669097678 ## CI report: * 0bc8a1c9388336bf5eecb6b0e53372c7da00f4f7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2020-08-06 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-18796. Resolution: Fixed > FlinkKinesisProducer.backpressureLatch should be volatile > --

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

2020-08-06 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17172778#comment-17172778 ] Zhijiang commented on FLINK-18796: -- Merged in master: 33bdc978a059c50ec55b8f24d40039d13

[GitHub] [flink] zhijiangW merged pull request #13067: [FLINK-18821][network] Report PartitionRequest failures to subsequent…

2020-08-06 Thread GitBox
zhijiangW merged pull request #13067: URL: https://github.com/apache/flink/pull/13067 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 t

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

2020-08-06 Thread GitBox
shuiqiangchen commented on pull request #13066: URL: https://github.com/apache/flink/pull/13066#issuecomment-670286619 @hequn8128 @HuangXingBo Thank you for your comments! I have updated the pr according to your comments, please have a look at it. ---

[GitHub] [flink] zhijiangW merged pull request #13065: [FLINK-18796][kinesis] Make backpressureLatch volatile

2020-08-06 Thread GitBox
zhijiangW merged pull request #13065: URL: https://github.com/apache/flink/pull/13065 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 t

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

2020-08-06 Thread GitBox
flinkbot edited a comment on pull request #13083: URL: https://github.com/apache/flink/pull/13083#issuecomment-670281607 ## CI report: * 19051add632f730aacb77364b685b9174074458a Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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-06 Thread GitBox
flinkbot edited a comment on pull request #13051: URL: https://github.com/apache/flink/pull/13051#issuecomment-667970728 ## CI report: * d116af64b399759a2c30eda5408e8a0660d1c7d9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-06 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * bce6761325c406591dac1f9ba2d755f5d76a3f78 UNKNOWN * cb4298bf796daf7c9e3ac2842459ea9221f7

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

2020-08-06 Thread GitBox
dianfu commented on pull request #13083: URL: https://github.com/apache/flink/pull/13083#issuecomment-670283241 @WeiZhong94 Thanks for the review. Updated the PR. This is an automated message from the Apache Git Service. To r

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

2020-08-06 Thread GitBox
flinkbot commented on pull request #13083: URL: https://github.com/apache/flink/pull/13083#issuecomment-670281607 ## CI report: * 19051add632f730aacb77364b685b9174074458a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[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-06 Thread GitBox
flinkbot edited a comment on pull request #13051: URL: https://github.com/apache/flink/pull/13051#issuecomment-667970728 ## CI report: * 85e3558062b8a70e7fa565b9fab624c5dd13916a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-06 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * bce6761325c406591dac1f9ba2d755f5d76a3f78 UNKNOWN * cb4298bf796daf7c9e3ac2842459ea9221f7

[GitHub] [flink] WeiZhong94 commented on a change in pull request #13083: [FLINK-18838][python] Support JdbcCatalog in Python Table API

2020-08-06 Thread GitBox
WeiZhong94 commented on a change in pull request #13083: URL: https://github.com/apache/flink/pull/13083#discussion_r466777657 ## File path: flink-python/pyflink/table/catalog.py ## @@ -996,3 +1114,16 @@ def __init__(self, catalog_name=None, default_database="default", hive_co

[jira] [Updated] (FLINK-18842) e2e test failed to download "localhost:9999/flink.tgz"

2020-08-06 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18842: Component/s: (was: Tests) Test Infrastructure > e2e test failed to download "localhos

[jira] [Created] (FLINK-18842) e2e test failed to download "localhost:9999/flink.tgz"

2020-08-06 Thread Dian Fu (Jira)
Dian Fu created FLINK-18842: --- Summary: e2e test failed to download "localhost:/flink.tgz" Key: FLINK-18842 URL: https://issues.apache.org/jira/browse/FLINK-18842 Project: Flink Issue Type: Test

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

2020-08-06 Thread GitBox
Myracle commented on pull request #13051: URL: https://github.com/apache/flink/pull/13051#issuecomment-670279387 Thanks, @KarmaGYZ @tillrohrmann. I learn a lot from the discussion . The code is modified referring to the advice. ---

[jira] [Commented] (FLINK-18333) UnsignedTypeConversionITCase failed caused by MariaDB4j "Asked to waitFor Program"

2020-08-06 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17172767#comment-17172767 ] Dian Fu commented on FLINK-18333: - Another instance: https://dev.azure.com/apache-flink

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

2020-08-06 Thread GitBox
flinkbot commented on pull request #13083: URL: https://github.com/apache/flink/pull/13083#issuecomment-670276466 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 pro

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

2020-08-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18838: --- Labels: pull-request-available (was: ) > Support JdbcCatalog in Python Table API >

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

2020-08-06 Thread GitBox
dianfu opened a new pull request #13083: URL: https://github.com/apache/flink/pull/13083 ## What is the purpose of the change *This pull request add support JdbcCatalog in Python Table API. It also add a few static methods used for creating CatalogFunction, CatalogDatabase, Cata

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-06 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * bce6761325c406591dac1f9ba2d755f5d76a3f78 UNKNOWN * cb4298bf796daf7c9e3ac2842459ea9221f7

[GitHub] [flink] Nieal-Yang commented on a change in pull request #11747: [FLINK-10203][Connectors/FileSystem] Support truncate method for old Hadoop versions in HadoopRecoverableFsDataOutputStream

2020-08-06 Thread GitBox
Nieal-Yang commented on a change in pull request #11747: URL: https://github.com/apache/flink/pull/11747#discussion_r466763193 ## File path: flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/truncate/TruncaterFactory.java ## @@ -0,0 +1,39 @@ +/*

[jira] [Commented] (FLINK-16441) Allow users to override flink-conf parameters from SQL CLI environment

2020-08-06 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17172759#comment-17172759 ] Zhu Zhu commented on FLINK-16441: - Thanks for the updates [~jark] > Allow users to over

[GitHub] [flink] Nieal-Yang commented on a change in pull request #11747: [FLINK-10203][Connectors/FileSystem] Support truncate method for old Hadoop versions in HadoopRecoverableFsDataOutputStream

2020-08-06 Thread GitBox
Nieal-Yang commented on a change in pull request #11747: URL: https://github.com/apache/flink/pull/11747#discussion_r466763193 ## File path: flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/truncate/TruncaterFactory.java ## @@ -0,0 +1,39 @@ +/*

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-06 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * bce6761325c406591dac1f9ba2d755f5d76a3f78 UNKNOWN * cb4298bf796daf7c9e3ac2842459ea9221f7

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-06 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * bce6761325c406591dac1f9ba2d755f5d76a3f78 UNKNOWN * cb4298bf796daf7c9e3ac2842459ea9221f7

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-06 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * bce6761325c406591dac1f9ba2d755f5d76a3f78 UNKNOWN * cb4298bf796daf7c9e3ac2842459ea9221f7

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-06 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * bce6761325c406591dac1f9ba2d755f5d76a3f78 UNKNOWN * cb4298bf796daf7c9e3ac2842459ea9221f7

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-06 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * bce6761325c406591dac1f9ba2d755f5d76a3f78 UNKNOWN * cb4298bf796daf7c9e3ac2842459ea9221f7

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-06 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * bce6761325c406591dac1f9ba2d755f5d76a3f78 UNKNOWN * cb4298bf796daf7c9e3ac2842459ea9221f7

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-06 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * bce6761325c406591dac1f9ba2d755f5d76a3f78 UNKNOWN * cb4298bf796daf7c9e3ac2842459ea9221f7

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-06 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * bce6761325c406591dac1f9ba2d755f5d76a3f78 UNKNOWN * cb4298bf796daf7c9e3ac2842459ea9221f7

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-06 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * bce6761325c406591dac1f9ba2d755f5d76a3f78 UNKNOWN * cb4298bf796daf7c9e3ac2842459ea9221f7

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-06 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * bce6761325c406591dac1f9ba2d755f5d76a3f78 UNKNOWN * cb4298bf796daf7c9e3ac2842459ea9221f7

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-06 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * bce6761325c406591dac1f9ba2d755f5d76a3f78 UNKNOWN * cb4298bf796daf7c9e3ac2842459ea9221f7

[GitHub] [flink] flinkbot edited a comment on pull request #13080: [BP-1.11][FLINK-16510] Allow configuring shutdown behavior to avoid JVM freeze

2020-08-06 Thread GitBox
flinkbot edited a comment on pull request #13080: URL: https://github.com/apache/flink/pull/13080#issuecomment-669981929 ## CI report: * ab3e64238a3b76a6d43a5f663e0af84fd6249715 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13082: added code of conduct to project

2020-08-06 Thread GitBox
flinkbot edited a comment on pull request #13082: URL: https://github.com/apache/flink/pull/13082#issuecomment-670088958 ## CI report: * 29f3a987677c7d5ec5967e1cea59f3d624288a36 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #13082: added code of conduct to project

2020-08-06 Thread GitBox
flinkbot commented on pull request #13082: URL: https://github.com/apache/flink/pull/13082#issuecomment-670088958 ## CI report: * 29f3a987677c7d5ec5967e1cea59f3d624288a36 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #13042: [FLINK-16510] Allow configuring shutdown behavior to avoid JVM freeze

2020-08-06 Thread GitBox
flinkbot edited a comment on pull request #13042: URL: https://github.com/apache/flink/pull/13042#issuecomment-667268558 ## CI report: * 0d7596f938ca8c655fef4c011d67e921d3a4b946 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-06 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * bce6761325c406591dac1f9ba2d755f5d76a3f78 UNKNOWN * cb4298bf796daf7c9e3ac2842459ea9221f7

[GitHub] [flink] flinkbot edited a comment on pull request #12985: [FLINK-18682][orc][hive] Vector orc reader cannot read Hive 2.0.0 table

2020-08-06 Thread GitBox
flinkbot edited a comment on pull request #12985: URL: https://github.com/apache/flink/pull/12985#issuecomment-663499515 ## CI report: * 8c2efee79228f39d19301d15a4ff6d733db85cf4 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #13082: added code of conduct to project

2020-08-06 Thread GitBox
flinkbot commented on pull request #13082: URL: https://github.com/apache/flink/pull/13082#issuecomment-670077729 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 pro

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-06 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * bce6761325c406591dac1f9ba2d755f5d76a3f78 UNKNOWN * cb4298bf796daf7c9e3ac2842459ea9221f7

[GitHub] [flink] jivthesh opened a new pull request #13082: added code of conduct to project

2020-08-06 Thread GitBox
jivthesh opened a new pull request #13082: URL: https://github.com/apache/flink/pull/13082

[jira] [Assigned] (FLINK-18779) Support the SupportsFilterPushDown interface for LookupTableSource

2020-08-06 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-18779: --- Assignee: Shengkai Fang > Support the SupportsFilterPushDown interface for LookupTableSource >

  1   2   3   >