[jira] [Commented] (FLINK-17464) Stanalone HA Cluster crash with non-recoverable cluster state - need to wipe cluster to recover service

2020-05-04 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099576#comment-17099576 ] Till Rohrmann commented on FLINK-17464: --- No I don't think that this is an architec

[GitHub] [flink] twalthr commented on a change in pull request #11959: [FLINK-16997][table-common] Add new factory interfaces and discovery utilities

2020-05-04 Thread GitBox
twalthr commented on a change in pull request #11959: URL: https://github.com/apache/flink/pull/11959#discussion_r419893421 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/format/Format.java ## @@ -0,0 +1,57 @@ +/* + * Licensed to th

[jira] [Commented] (FLINK-16947) ArtifactResolutionException: Could not transfer artifact. Entry [...] has not been leased from this pool

2020-05-04 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099571#comment-17099571 ] Robert Metzger commented on FLINK-16947: We are getting an exception relating to

[GitHub] [flink] twalthr commented on a change in pull request #11959: [FLINK-16997][table-common] Add new factory interfaces and discovery utilities

2020-05-04 Thread GitBox
twalthr commented on a change in pull request #11959: URL: https://github.com/apache/flink/pull/11959#discussion_r419892167 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/CatalogBaseTable.java ## @@ -28,13 +29,24 @@ * key-value pair

[jira] [Closed] (FLINK-17489) Support any kind of array in StringUtils.arrayAwareToString()

2020-05-04 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-17489. Fix Version/s: 1.11.0 Resolution: Fixed Fixed in 1.11.0: 7b2f000da12d719752444544c37933e53b

[jira] [Created] (FLINK-17511) "RocksDB Memory Management end-to-end test" fails with "Current block cache usage 202123272 larger than expected memory limit 200000000"

2020-05-04 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-17511: -- Summary: "RocksDB Memory Management end-to-end test" fails with "Current block cache usage 202123272 larger than expected memory limit 2" Key: FLINK-17511 URL: https:

[jira] [Updated] (FLINK-17511) "RocksDB Memory Management end-to-end test" fails with "Current block cache usage 202123272 larger than expected memory limit 200000000"

2020-05-04 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17511: --- Affects Version/s: (was: 1.11.0) 1.10.0 > "RocksDB Memory Managem

[GitHub] [flink] twalthr commented on a change in pull request #11969: [FLINK-17489][core] Support any kind of array in StringUtils.arrayAwareToString()

2020-05-04 Thread GitBox
twalthr commented on a change in pull request #11969: URL: https://github.com/apache/flink/pull/11969#discussion_r419884235 ## File path: flink-core/src/test/java/org/apache/flink/util/StringUtilsTest.java ## @@ -39,21 +40,26 @@ public void testControlCharacters() { }

[jira] [Commented] (FLINK-16947) ArtifactResolutionException: Could not transfer artifact. Entry [...] has not been leased from this pool

2020-05-04 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099553#comment-17099553 ] Robert Metzger commented on FLINK-16947: https://dev.azure.com/apache-flink/apac

[jira] [Comment Edited] (FLINK-16947) ArtifactResolutionException: Could not transfer artifact. Entry [...] has not been leased from this pool

2020-05-04 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099553#comment-17099553 ] Robert Metzger edited comment on FLINK-16947 at 5/5/20, 6:10 AM: -

[jira] [Commented] (FLINK-17510) StreamingKafkaITCase. testKafka timeouts on downloading Kafka

2020-05-04 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099551#comment-17099551 ] Robert Metzger commented on FLINK-17510: Most likely, the network throttling of

[jira] [Commented] (FLINK-17497) Quickstarts Java nightly end-to-end test fails with "class file has wrong version 55.0, should be 52.0"

2020-05-04 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099552#comment-17099552 ] Robert Metzger commented on FLINK-17497: https://dev.azure.com/apache-flink/apac

[jira] [Created] (FLINK-17510) StreamingKafkaITCase. testKafka timeouts on downloading Kafka

2020-05-04 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-17510: -- Summary: StreamingKafkaITCase. testKafka timeouts on downloading Kafka Key: FLINK-17510 URL: https://issues.apache.org/jira/browse/FLINK-17510 Project: Flink

[jira] [Updated] (FLINK-17506) SavepointEnvironment does not honour 'io.tmp.dirs' property

2020-05-04 Thread David Artiga (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Artiga updated FLINK-17506: - Description: {{SavepointEnvironment}} [creates an IOManagerAsync|https://github.com/apache/flink

[GitHub] [flink] flinkbot edited a comment on pull request #11985: [FLINK-16989][table] Support ScanTableSource in blink planner

2020-05-04 Thread GitBox
flinkbot edited a comment on pull request #11985: URL: https://github.com/apache/flink/pull/11985#issuecomment-623545781 ## CI report: * 945427a9cf24c43097883cc9fccbac2983ab8bac Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #11985: [FLINK-16989][table] Support ScanTableSource in blink planner

2020-05-04 Thread GitBox
flinkbot edited a comment on pull request #11985: URL: https://github.com/apache/flink/pull/11985#issuecomment-623545781 ## CI report: * de26ba11042772d77be2416fd6c829d80c9c66b7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #11985: [FLINK-16989][table] Support ScanTableSource in blink planner

2020-05-04 Thread GitBox
flinkbot edited a comment on pull request #11985: URL: https://github.com/apache/flink/pull/11985#issuecomment-623545781 ## CI report: * de26ba11042772d77be2416fd6c829d80c9c66b7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] RocMarshal commented on pull request #11979: [FLINK-17291][docs] Translate 'docs/training/event_driven.zh.md' to C…

2020-05-04 Thread GitBox
RocMarshal commented on pull request #11979: URL: https://github.com/apache/flink/pull/11979#issuecomment-623845807 Hi, @wuchong . I have completed the translation of this page and made corresponding improvements according to the suggestions of community members. If you have free time, wou

[jira] [Comment Edited] (FLINK-17291) Translate training lesson on event-driven applications to chinese

2020-05-04 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099479#comment-17099479 ] RocMarshal edited comment on FLINK-17291 at 5/5/20, 3:29 AM: -

[jira] [Comment Edited] (FLINK-17291) Translate training lesson on event-driven applications to chinese

2020-05-04 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099479#comment-17099479 ] RocMarshal edited comment on FLINK-17291 at 5/5/20, 1:46 AM: -

[jira] [Commented] (FLINK-17291) Translate training lesson on event-driven applications to chinese

2020-05-04 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099479#comment-17099479 ] RocMarshal commented on FLINK-17291: Hi,[~alpinegizmo]. I have completed the transl

[GitHub] [flink] flinkbot edited a comment on pull request #11952: [FLINK-16638][runtime][checkpointing] Flink checkStateMappingCompleteness doesn't include UserDefinedOperatorIDs

2020-05-04 Thread GitBox
flinkbot edited a comment on pull request #11952: URL: https://github.com/apache/flink/pull/11952#issuecomment-621589853 ## CI report: * 5a2f6e8bd534d439b30e10b41a17821a3ea93590 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] RocMarshal commented on pull request #11979: [FLINK-17291][docs] Translate 'docs/training/event_driven.zh.md' to C…

2020-05-04 Thread GitBox
RocMarshal commented on pull request #11979: URL: https://github.com/apache/flink/pull/11979#issuecomment-623785660 Hi, @XBaith ,I have updated the document according to your suggestions. Obviously, it is very helpful for the translation of the document. Thank you very much for your help.

[GitHub] [flink] RocMarshal commented on pull request #11979: [FLINK-17291][docs] Translate 'docs/training/event_driven.zh.md' to C…

2020-05-04 Thread GitBox
RocMarshal commented on pull request #11979: URL: https://github.com/apache/flink/pull/11979#issuecomment-623783106 @flinkbot run travis This is an automated message from the Apache Git Service. To respond to the message, ple

[GitHub] [flink] caozhen1937 commented on pull request #11978: [FLINK-16086][chinese-translation]Translate "Temporal Tables" page of "Streaming Concepts" into Chinese

2020-05-04 Thread GitBox
caozhen1937 commented on pull request #11978: URL: https://github.com/apache/flink/pull/11978#issuecomment-623782234 Hi @wuchong , if you have free time , please review it, thank you This is an automated message from the Apac

[GitHub] [flink] flinkbot edited a comment on pull request #11986: [FLINK-17361] [jdbc] Added custom query on JDBC tables

2020-05-04 Thread GitBox
flinkbot edited a comment on pull request #11986: URL: https://github.com/apache/flink/pull/11986#issuecomment-623579672 ## CI report: * 1597769183be673722456fb55e296d38d0fad837 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Assigned] (FLINK-17506) SavepointEnvironment does not honour 'io.tmp.dirs' property

2020-05-04 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman reassigned FLINK-17506: Assignee: Seth Wiesman > SavepointEnvironment does not honour 'io.tmp.dirs' property > --

[GitHub] [flink] flinkbot edited a comment on pull request #11952: [FLINK-16638][runtime][checkpointing] Flink checkStateMappingCompleteness doesn't include UserDefinedOperatorIDs

2020-05-04 Thread GitBox
flinkbot edited a comment on pull request #11952: URL: https://github.com/apache/flink/pull/11952#issuecomment-621589853 ## CI report: * 2113227fdc0076eb9e2f72ae7883c2d5d245cbab Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #11952: [FLINK-16638][runtime][checkpointing] Flink checkStateMappingCompleteness doesn't include UserDefinedOperatorIDs

2020-05-04 Thread GitBox
flinkbot edited a comment on pull request #11952: URL: https://github.com/apache/flink/pull/11952#issuecomment-621589853 ## CI report: * 2113227fdc0076eb9e2f72ae7883c2d5d245cbab Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Assigned] (FLINK-17465) Update Chinese user documentation for job manager memory model

2020-05-04 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-17465: --- Assignee: Xintong Song > Update Chinese user documentation for job manager memory m

[jira] [Created] (FLINK-17509) Support OracleDialect

2020-05-04 Thread Flavio Pompermaier (Jira)
Flavio Pompermaier created FLINK-17509: -- Summary: Support OracleDialect Key: FLINK-17509 URL: https://issues.apache.org/jira/browse/FLINK-17509 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17508) Develop OracleCatalog

2020-05-04 Thread Flavio Pompermaier (Jira)
Flavio Pompermaier created FLINK-17508: -- Summary: Develop OracleCatalog Key: FLINK-17508 URL: https://issues.apache.org/jira/browse/FLINK-17508 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17507) Training figure program_dataflow.svg should use preferred parts of the API

2020-05-04 Thread David Anderson (Jira)
David Anderson created FLINK-17507: -- Summary: Training figure program_dataflow.svg should use preferred parts of the API Key: FLINK-17507 URL: https://issues.apache.org/jira/browse/FLINK-17507 Projec

[jira] [Updated] (FLINK-17507) Training figure program_dataflow.svg should use preferred parts of the API

2020-05-04 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-17507: --- Description: It would be better if fig/program_dataflow.svg used a {{ProcessWindowFunction}

[GitHub] [flink] flinkbot edited a comment on pull request #11986: [FLINK-17361] [jdbc] Added custom query on JDBC tables

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

[GitHub] [flink] rkhachatryan commented on pull request #11952: [FLINK-16638][runtime][checkpointing] Flink checkStateMappingCompleteness doesn't include UserDefinedOperatorIDs

2020-05-04 Thread GitBox
rkhachatryan commented on pull request #11952: URL: https://github.com/apache/flink/pull/11952#issuecomment-623702887 @edu05 can you please squash the commits and rebase to the latest master (Azure build still fails)? This i

[GitHub] [flink] flinkbot edited a comment on pull request #11986: [FLINK-17361] [jdbc] Added custom query on JDBC tables

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

[GitHub] [flink] fpompermaier commented on pull request #11900: [FLINK-17284][jdbc][postgres] Support serial fields

2020-05-04 Thread GitBox
fpompermaier commented on pull request #11900: URL: https://github.com/apache/flink/pull/11900#issuecomment-623697631 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, pl

[GitHub] [flink] fpompermaier removed a comment on pull request #11900: [FLINK-17284][jdbc][postgres] Support serial fields

2020-05-04 Thread GitBox
fpompermaier removed a comment on pull request #11900: URL: https://github.com/apache/flink/pull/11900#issuecomment-623697329 @flinkbot run travis @flinkbot run azure This is an automated message from the Apache Git Se

[GitHub] [flink] fpompermaier removed a comment on pull request #11900: [FLINK-17284][jdbc][postgres] Support serial fields

2020-05-04 Thread GitBox
fpompermaier removed a comment on pull request #11900: URL: https://github.com/apache/flink/pull/11900#issuecomment-623310522 @flinkbot run travis @flinkbot run azure This is an automated message from the Apache Git Servic

[GitHub] [flink] fpompermaier commented on pull request #11900: [FLINK-17284][jdbc][postgres] Support serial fields

2020-05-04 Thread GitBox
fpompermaier commented on pull request #11900: URL: https://github.com/apache/flink/pull/11900#issuecomment-623697329 @flinkbot run travis @flinkbot run azure This is an automated message from the Apache Git Service. T

[GitHub] [flink] zentol commented on a change in pull request #11983: [FLINK-11086] Replace flink-shaded-hadoop dependencies; add Hadoop 3 test profile

2020-05-04 Thread GitBox
zentol commented on a change in pull request #11983: URL: https://github.com/apache/flink/pull/11983#discussion_r419698801 ## File path: flink-dist/pom.xml ## @@ -137,8 +137,8 @@ under the License. ${project.version}

[GitHub] [flink] rmetzger commented on a change in pull request #11983: [FLINK-11086] Replace flink-shaded-hadoop dependencies; add Hadoop 3 test profile

2020-05-04 Thread GitBox
rmetzger commented on a change in pull request #11983: URL: https://github.com/apache/flink/pull/11983#discussion_r419675846 ## File path: flink-dist/pom.xml ## @@ -137,8 +137,8 @@ under the License. ${project.version}

[GitHub] [flink] flinkbot edited a comment on pull request #11988: [FLINK-17244][docs] Update the Getting Started page

2020-05-04 Thread GitBox
flinkbot edited a comment on pull request #11988: URL: https://github.com/apache/flink/pull/11988#issuecomment-623640141 ## CI report: * cc4fa4fe94ef8a6ff97a2a9b7bb752302224c5c4 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-17464) Stanalone HA Cluster crash with non-recoverable cluster state - need to wipe cluster to recover service

2020-05-04 Thread John Lonergan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099232#comment-17099232 ] John Lonergan commented on FLINK-17464: --- Yep think failing the job is the lesser e

[GitHub] [flink] flinkbot commented on pull request #11988: [FLINK-17244][docs] Update the Getting Started page

2020-05-04 Thread GitBox
flinkbot commented on pull request #11988: URL: https://github.com/apache/flink/pull/11988#issuecomment-623622490 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-17244) Update Getting Started / Overview: training and python

2020-05-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17244: --- Labels: pull-request-available (was: ) > Update Getting Started / Overview: training and py

[jira] [Commented] (FLINK-17500) Deploy JobGraph from file in StandaloneClusterEntrypoint

2020-05-04 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099208#comment-17099208 ] Kostas Kloudas commented on FLINK-17500: [~uce] and [~trohrmann] with the introd

[GitHub] [flink] zentol commented on a change in pull request #11983: [FLINK-11086] Replace flink-shaded-hadoop dependencies; add Hadoop 3 test profile

2020-05-04 Thread GitBox
zentol commented on a change in pull request #11983: URL: https://github.com/apache/flink/pull/11983#discussion_r419630074 ## File path: flink-dist/pom.xml ## @@ -137,8 +137,8 @@ under the License. ${project.version}

[GitHub] [flink] flinkbot commented on pull request #11987: [hotfix] Show hostname in failure error message

2020-05-04 Thread GitBox
flinkbot commented on pull request #11987: URL: https://github.com/apache/flink/pull/11987#issuecomment-623621331 ## CI report: * db7481419288348aebf6a09127410424ff517b01 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] alpinegizmo opened a new pull request #11988: [FLINK-17244][docs] Update the Getting Started page

2020-05-04 Thread GitBox
alpinegizmo opened a new pull request #11988: URL: https://github.com/apache/flink/pull/11988 ## What is the purpose of the change * Generally improve the content of this page * Add the Python Table API code walkthrough * Add the Hands-on Training ## Translation *

[GitHub] [flink] flinkbot commented on pull request #11987: [hotfix] Show hostname in failure error message

2020-05-04 Thread GitBox
flinkbot commented on pull request #11987: URL: https://github.com/apache/flink/pull/11987#issuecomment-623611390 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 #11986: [FLINK-17361] [jdbc] Added custom query on JDBC tables

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

[GitHub] [flink] qqibrow opened a new pull request #11987: [hotfix] Show hostname in failure error message

2020-05-04 Thread GitBox
qqibrow opened a new pull request #11987: URL: https://github.com/apache/flink/pull/11987 Adding hostname in error message could help us detect host issue. The new error message would be like: ``` 2019-12-07 05:04:43,264 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph

[jira] [Updated] (FLINK-17313) Validation error when insert decimal/varchar with precision into sink using TypeInformation of row

2020-05-04 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-17313: - Fix Version/s: 1.11.0 > Validation error when insert decimal/varchar with precision into

[GitHub] [flink] flinkbot edited a comment on pull request #11986: [FLINK-17361] [jdbc] Added custom query on JDBC tables

2020-05-04 Thread GitBox
flinkbot edited a comment on pull request #11986: URL: https://github.com/apache/flink/pull/11986#issuecomment-623579672 ## CI report: * 4cc9434270958dcbdf322483531c97c108c4a2e8 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-17506) SavepointEnvironment does not honour 'io.tmp.dirs' property

2020-05-04 Thread David Artiga (Jira)
David Artiga created FLINK-17506: Summary: SavepointEnvironment does not honour 'io.tmp.dirs' property Key: FLINK-17506 URL: https://issues.apache.org/jira/browse/FLINK-17506 Project: Flink

[GitHub] [flink] flinkbot commented on pull request #11986: [FLINK-17361] [jdbc] Added custom query on JDBC tables

2020-05-04 Thread GitBox
flinkbot commented on pull request #11986: URL: https://github.com/apache/flink/pull/11986#issuecomment-623579672 ## CI report: * 4cc9434270958dcbdf322483531c97c108c4a2e8 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #11986: [FLINK-17361] [jdbc] Added custom query on JDBC tables

2020-05-04 Thread GitBox
flinkbot commented on pull request #11986: URL: https://github.com/apache/flink/pull/11986#issuecomment-623574742 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] [Commented] (FLINK-17361) Support creating of a JDBC table using a custom query

2020-05-04 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099106#comment-17099106 ] Flavio Pompermaier commented on FLINK-17361: As I commented in the PR I name

[jira] [Updated] (FLINK-17361) Support creating of a JDBC table using a custom query

2020-05-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17361: --- Labels: pull-request-available (was: ) > Support creating of a JDBC table using a custom qu

[GitHub] [flink] fpompermaier opened a new pull request #11986: [FLINK-17361] [jdbc] Added custom query on JDBC tables

2020-05-04 Thread GitBox
fpompermaier opened a new pull request #11986: URL: https://github.com/apache/flink/pull/11986 ## What is the purpose of the change Enable users to create a JDBC source table using a custom query / prepared statement. ## Brief change log - Managed 'connector

[GitHub] [flink] flinkbot edited a comment on pull request #11985: [FLINK-16989][table] Support ScanTableSource in blink planner

2020-05-04 Thread GitBox
flinkbot edited a comment on pull request #11985: URL: https://github.com/apache/flink/pull/11985#issuecomment-623545781 ## CI report: * de26ba11042772d77be2416fd6c829d80c9c66b7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #11854: [FLINK-17407] Introduce external resource framework

2020-05-04 Thread GitBox
flinkbot edited a comment on pull request #11854: URL: https://github.com/apache/flink/pull/11854#issuecomment-617586491 ## CI report: * bddb0e274da11bbe99d15c6e0bb55e8d8c0e658a UNKNOWN * dc7a9c5c7d1fac82518815b9277809dfb82ddaac UNKNOWN * 2238559b0e2245e77204e7c7d0ef34c7a97e

[GitHub] [flink] walterddr commented on pull request #11936: [FLINK-17386][Security][hotfix] fix LinkageError not captured

2020-05-04 Thread GitBox
walterddr commented on pull request #11936: URL: https://github.com/apache/flink/pull/11936#issuecomment-623568748 @aljoscha could you take another look? This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] pnowojski commented on a change in pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

2020-05-04 Thread GitBox
pnowojski commented on a change in pull request #11687: URL: https://github.com/apache/flink/pull/11687#discussion_r419564857 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java ## @@ -731,33 +726,29 @@ p

[GitHub] [flink] flinkbot edited a comment on pull request #11985: [FLINK-16989][table] Support ScanTableSource in blink planner

2020-05-04 Thread GitBox
flinkbot edited a comment on pull request #11985: URL: https://github.com/apache/flink/pull/11985#issuecomment-623545781 ## CI report: * de26ba11042772d77be2416fd6c829d80c9c66b7 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation.

2020-05-04 Thread GitBox
flinkbot edited a comment on pull request #11554: URL: https://github.com/apache/flink/pull/11554#issuecomment-605459909 ## CI report: * 14e9fe3bfdeeae480047848801243f9fbed03cb4 UNKNOWN * a11dbc2d6b25ff16ef3cff4ecc751538d6867e68 UNKNOWN * 5b241a0386f6ae029759e076afef6b155b10

[GitHub] [flink] edu05 commented on pull request #11952: [FLINK-16638][runtime][checkpointing] Flink checkStateMappingCompleteness doesn't include UserDefinedOperatorIDs

2020-05-04 Thread GitBox
edu05 commented on pull request #11952: URL: https://github.com/apache/flink/pull/11952#issuecomment-623554001 @rkhachatryan Are there any outstanding issues? This is an automated message from the Apache Git Service. To respo

[GitHub] [flink] flinkbot edited a comment on pull request #11979: [FLINK-17291][docs] Translate 'docs/training/event_driven.zh.md' to C…

2020-05-04 Thread GitBox
flinkbot edited a comment on pull request #11979: URL: https://github.com/apache/flink/pull/11979#issuecomment-623137252 ## CI report: * 51f00c041b126b54616f191f669750e819c733db Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #11985: [FLINK-16989][table] Support ScanTableSource in blink planner

2020-05-04 Thread GitBox
flinkbot commented on pull request #11985: URL: https://github.com/apache/flink/pull/11985#issuecomment-623545781 ## CI report: * de26ba11042772d77be2416fd6c829d80c9c66b7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation.

2020-05-04 Thread GitBox
flinkbot edited a comment on pull request #11554: URL: https://github.com/apache/flink/pull/11554#issuecomment-605459909 ## CI report: * 14e9fe3bfdeeae480047848801243f9fbed03cb4 UNKNOWN * a11dbc2d6b25ff16ef3cff4ecc751538d6867e68 UNKNOWN * 5b241a0386f6ae029759e076afef6b155b10

[GitHub] [flink] zhijiangW commented on pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

2020-05-04 Thread GitBox
zhijiangW commented on pull request #11687: URL: https://github.com/apache/flink/pull/11687#issuecomment-623538520 Thanks for the further reviews @pnowojski ! > I'm still not sure if this is the right approach. It's better compared to the original proposal, at a cost of much more ad

[GitHub] [flink] flinkbot commented on pull request #11985: [FLINK-16989][table] Support ScanTableSource in blink planner

2020-05-04 Thread GitBox
flinkbot commented on pull request #11985: URL: https://github.com/apache/flink/pull/11985#issuecomment-623535573 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] [Commented] (FLINK-17327) Kafka unavailability could cause Flink TM shutdown

2020-05-04 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099045#comment-17099045 ] Aljoscha Krettek commented on FLINK-17327: -- I believe that {{TransactionalReque

[GitHub] [flink] flinkbot edited a comment on pull request #11979: [FLINK-17291][docs] Translate 'docs/training/event_driven.zh.md' to C…

2020-05-04 Thread GitBox
flinkbot edited a comment on pull request #11979: URL: https://github.com/apache/flink/pull/11979#issuecomment-623137252 ## CI report: * 51f00c041b126b54616f191f669750e819c733db Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] zhijiangW commented on a change in pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

2020-05-04 Thread GitBox
zhijiangW commented on a change in pull request #11687: URL: https://github.com/apache/flink/pull/11687#discussion_r419522975 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/reader/AbstractRecordReader.java ## @@ -63,6 +63,8 @@ protected Abstr

[jira] [Updated] (FLINK-16989) Support ScanTableSource in planner

2020-05-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16989: --- Labels: pull-request-available (was: ) > Support ScanTableSource in planner > -

[GitHub] [flink] zhijiangW commented on a change in pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

2020-05-04 Thread GitBox
zhijiangW commented on a change in pull request #11687: URL: https://github.com/apache/flink/pull/11687#discussion_r419521815 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/LocalInputChannel.java ## @@ -97,6 +100,18 @@ public L

[GitHub] [flink] wuchong opened a new pull request #11985: [FLINK-16989][table] Support ScanTableSource in blink planner

2020-05-04 Thread GitBox
wuchong opened a new pull request #11985: URL: https://github.com/apache/flink/pull/11985 ## What is the purpose of the change Support the `ScanTableSource` interface in planner. We don't support change mode `[I, UA, D]` (`UPDATE_AFTER` without `UPDATE_BEFORE`) in first versi

[GitHub] [flink] zhijiangW commented on a change in pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

2020-05-04 Thread GitBox
zhijiangW commented on a change in pull request #11687: URL: https://github.com/apache/flink/pull/11687#discussion_r419521605 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java ## @@ -371,7 +373,14 @@ boolea

[GitHub] [flink] zhijiangW commented on a change in pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

2020-05-04 Thread GitBox
zhijiangW commented on a change in pull request #11687: URL: https://github.com/apache/flink/pull/11687#discussion_r419520547 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java ## @@ -105,12 +98,15 @@ public

[jira] [Commented] (FLINK-16947) ArtifactResolutionException: Could not transfer artifact. Entry [...] has not been leased from this pool

2020-05-04 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099035#comment-17099035 ] Robert Metzger commented on FLINK-16947: MSFT hosted: https://dev.azure.com/rme

[GitHub] [flink] rmetzger commented on pull request #11983: [FLINK-11086] Replace flink-shaded-hadoop dependencies; add Hadoop 3 test profile

2020-05-04 Thread GitBox
rmetzger commented on pull request #11983: URL: https://github.com/apache/flink/pull/11983#issuecomment-623529249 The YARN failure on Azure is a known YARN issue: https://issues.apache.org/jira/browse/FLINK-15534 This is an

[GitHub] [flink] flinkbot edited a comment on pull request #11854: [FLINK-17407] Introduce external resource framework

2020-05-04 Thread GitBox
flinkbot edited a comment on pull request #11854: URL: https://github.com/apache/flink/pull/11854#issuecomment-617586491 ## CI report: * bddb0e274da11bbe99d15c6e0bb55e8d8c0e658a UNKNOWN * dc7a9c5c7d1fac82518815b9277809dfb82ddaac UNKNOWN * 2238559b0e2245e77204e7c7d0ef34c7a97e

[GitHub] [flink] flinkbot edited a comment on pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation.

2020-05-04 Thread GitBox
flinkbot edited a comment on pull request #11554: URL: https://github.com/apache/flink/pull/11554#issuecomment-605459909 ## CI report: * 14e9fe3bfdeeae480047848801243f9fbed03cb4 UNKNOWN * a11dbc2d6b25ff16ef3cff4ecc751538d6867e68 UNKNOWN * 360f3e0be00e518c2f268f26aab06d6f2776

[GitHub] [flink] zhijiangW commented on a change in pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

2020-05-04 Thread GitBox
zhijiangW commented on a change in pull request #11687: URL: https://github.com/apache/flink/pull/11687#discussion_r419513791 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/LocalInputChannel.java ## @@ -168,6 +175,12 @@ public

[jira] [Commented] (FLINK-16947) ArtifactResolutionException: Could not transfer artifact. Entry [...] has not been leased from this pool

2020-05-04 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099029#comment-17099029 ] Robert Metzger commented on FLINK-16947: https://dev.azure.com/apache-flink/apac

[GitHub] [flink] rmetzger commented on pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation.

2020-05-04 Thread GitBox
rmetzger commented on pull request #11554: URL: https://github.com/apache/flink/pull/11554#issuecomment-623522364 The bot needs quite some time to update. I notified Chesnay already to look into it. This is an automated mess

[GitHub] [flink] zhijiangW commented on a change in pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

2020-05-04 Thread GitBox
zhijiangW commented on a change in pull request #11687: URL: https://github.com/apache/flink/pull/11687#discussion_r419508820 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/LocalInputChannel.java ## @@ -168,6 +175,12 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #11979: [FLINK-17291][docs] Translate 'docs/training/event_driven.zh.md' to C…

2020-05-04 Thread GitBox
flinkbot edited a comment on pull request #11979: URL: https://github.com/apache/flink/pull/11979#issuecomment-623137252 ## CI report: * 51f00c041b126b54616f191f669750e819c733db Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] zhijiangW commented on a change in pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

2020-05-04 Thread GitBox
zhijiangW commented on a change in pull request #11687: URL: https://github.com/apache/flink/pull/11687#discussion_r419502301 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/LocalInputChannel.java ## @@ -87,10 +90,14 @@ public L

[GitHub] [flink] becketqin commented on pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation.

2020-05-04 Thread GitBox
becketqin commented on pull request #11554: URL: https://github.com/apache/flink/pull/11554#issuecomment-623516373 @rmetzger Thanks for the help. I just tried to do a rebase as well as an empty commit. But it seems the CI test was still not triggered.

[GitHub] [flink] flinkbot edited a comment on pull request #11854: [FLINK-17407] Introduce external resource framework

2020-05-04 Thread GitBox
flinkbot edited a comment on pull request #11854: URL: https://github.com/apache/flink/pull/11854#issuecomment-617586491 ## CI report: * bddb0e274da11bbe99d15c6e0bb55e8d8c0e658a UNKNOWN * dc7a9c5c7d1fac82518815b9277809dfb82ddaac UNKNOWN * 2238559b0e2245e77204e7c7d0ef34c7a97e

[jira] [Resolved] (FLINK-17499) LazyTimerService used to register timers via State Processing API incorrectly mixes event time timers with processing time timers

2020-05-04 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman resolved FLINK-17499. -- Resolution: Fixed > LazyTimerService used to register timers via State Processing API incorrec

[jira] [Commented] (FLINK-17499) LazyTimerService used to register timers via State Processing API incorrectly mixes event time timers with processing time timers

2020-05-04 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099011#comment-17099011 ] Seth Wiesman commented on FLINK-17499: -- Fixed in master: d6439c8d0e7792961635e3e429

[jira] [Updated] (FLINK-17499) LazyTimerService used to register timers via State Processing API incorrectly mixes event time timers with processing time timers

2020-05-04 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-17499: - Affects Version/s: (was: 1.10.0) 1.10.2 > LazyTimerService used to re

[jira] [Commented] (FLINK-17453) KyroSerializer throws IndexOutOfBoundsException type java.util.PriorityQueue

2020-05-04 Thread Jiayi Liao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099007#comment-17099007 ] Jiayi Liao commented on FLINK-17453: [~aljoscha] It's {{HashMap}}. I've attached the

[jira] [Updated] (FLINK-17453) KyroSerializer throws IndexOutOfBoundsException type java.util.PriorityQueue

2020-05-04 Thread Jiayi Liao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi Liao updated FLINK-17453: --- Attachment: udaf > KyroSerializer throws IndexOutOfBoundsException type java.util.PriorityQueue > --

[GitHub] [flink] zhijiangW commented on a change in pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

2020-05-04 Thread GitBox
zhijiangW commented on a change in pull request #11687: URL: https://github.com/apache/flink/pull/11687#discussion_r419494982 ## File path: flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/BackPressureITCase.java ## @@ -94,7 +94,7 @@ private static Configurati

  1   2   3   >