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

2020-05-18 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110533#comment-17110533 ] Seth Wiesman commented on FLINK-17506: -- [~david.artiga] That has been resolved. Fixed in Master:

[GitHub] [flink] JingsongLi commented on a change in pull request #12224: [FLINK-17594][filesystem] Support Hadoop path-based part-file writer.

2020-05-18 Thread GitBox
JingsongLi commented on a change in pull request #12224: URL: https://github.com/apache/flink/pull/12224#discussion_r426738686 ## File path: flink-formats/flink-hadoop-bulk/src/main/java/org/apache/flink/formats/hadoop/bulk/committer/HadoopRenameFileCommitter.java ## @@ -0,0

[jira] [Closed] (FLINK-17704) Allow running specific benchmarks from maven directly

2020-05-18 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-17704. --- Resolution: Fixed Fixed via

[GitHub] [flink-statefun] igalshilman commented on a change in pull request #113: [Flink-17644] Add state expiration to the Java SDK

2020-05-18 Thread GitBox
igalshilman commented on a change in pull request #113: URL: https://github.com/apache/flink-statefun/pull/113#discussion_r426786392 ## File path: statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/state/Expiration.java ## @@ -0,0 +1,83 @@ +/* + * Licensed to the Apache

[GitHub] [flink] dawidwys opened a new pull request #12232: [FLINK-15947] Finish moving scala expression DSL to flink-table-api-scala

2020-05-18 Thread GitBox
dawidwys opened a new pull request #12232: URL: https://github.com/apache/flink/pull/12232 ## What is the purpose of the change As per discussion here: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-TABLE-Issue-with-package-structure-in-the-Table-API-td37623.html

[GitHub] [flink] flinkbot commented on pull request #12232: [FLINK-15947] Finish moving scala expression DSL to flink-table-api-scala

2020-05-18 Thread GitBox
flinkbot commented on pull request #12232: URL: https://github.com/apache/flink/pull/12232#issuecomment-630355116 ## CI report: * 5925ef19171dea0dd42cd7f13875b7b05598f4b0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] kl0u edited a comment on pull request #12224: [FLINK-17594][filesystem] Support Hadoop path-based part-file writer.

2020-05-18 Thread GitBox
kl0u edited a comment on pull request #12224: URL: https://github.com/apache/flink/pull/12224#issuecomment-630368825 @gaoyunhaii the changes in the `StreamingFileSink` look good. As long as nothing fails on Azure (we have to wait and see before merging) and given that there was no change

[GitHub] [flink] sjwiesman closed pull request #12041: [FLINK-17506][state-processor-api] SavepointEnvironment should honour 'io.tmp.dirs' property

2020-05-18 Thread GitBox
sjwiesman closed pull request #12041: URL: https://github.com/apache/flink/pull/12041 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] sjwiesman commented on pull request #12041: [FLINK-17506][state-processor-api] SavepointEnvironment should honour 'io.tmp.dirs' property

2020-05-18 Thread GitBox
sjwiesman commented on pull request #12041: URL: https://github.com/apache/flink/pull/12041#issuecomment-630376259 Fixed in Master: 7934fc04ac098e2143cab9459b216725fe1b8be6 release-1.11: ce10080de0e6c35d60147318381c096cf77ec252 release-1.10: 313051c0ffdacb1bca2d26482bd9bc7036bf9fd2

[GitHub] [flink] kl0u closed pull request #12222: [FLINK-17796] Respect user specified classpath for application mode

2020-05-18 Thread GitBox
kl0u closed pull request #1: URL: https://github.com/apache/flink/pull/1 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-statefun] slinkydeveloper commented on a change in pull request #110: [FLINK-17611] Unix domain socket connection between worker and function

2020-05-18 Thread GitBox
slinkydeveloper commented on a change in pull request #110: URL: https://github.com/apache/flink-statefun/pull/110#discussion_r426782069 ## File path: statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/HttpFunctionProvider.java ## @@

[GitHub] [flink] flinkbot commented on pull request #12232: [FLINK-15947] Finish moving scala expression DSL to flink-table-api-scala

2020-05-18 Thread GitBox
flinkbot commented on pull request #12232: URL: https://github.com/apache/flink/pull/12232#issuecomment-630345422 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] flinkbot edited a comment on pull request #12216: [FLINK-17788][scala-shell] scala shell in yarn mode is broken

2020-05-18 Thread GitBox
flinkbot edited a comment on pull request #12216: URL: https://github.com/apache/flink/pull/12216#issuecomment-630047470 ## CI report: * 9b24ab2448e35acd0fabcf226409d37162136391 Azure:

[jira] [Resolved] (FLINK-17781) OperatorCoordinator Context must support calls from thread other than JobMaster Main Thread

2020-05-18 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-17781. -- Resolution: Fixed Fixed in 1.11.0 via   - 3bf6596b99e0d7760398acdfeccf7184d3ddd900  Fixed in

[jira] [Closed] (FLINK-16845) Implement SourceReaderOperator which runs the SourceReader.

2020-05-18 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-16845. > Implement SourceReaderOperator which runs the SourceReader. >

[jira] [Closed] (FLINK-15102) Allow users to construct a DataStream from a new Source API

2020-05-18 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-15102. > Allow users to construct a DataStream from a new Source API >

[jira] [Closed] (FLINK-15131) Add Source API classes

2020-05-18 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-15131. > Add Source API classes > -- > > Key: FLINK-15131 >

[jira] [Closed] (FLINK-17781) OperatorCoordinator Context must support calls from thread other than JobMaster Main Thread

2020-05-18 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-17781. > OperatorCoordinator Context must support calls from thread other than > JobMaster Main Thread >

[jira] [Closed] (FLINK-15101) Add implementation for SourceCoordinator

2020-05-18 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-15101. > Add implementation for SourceCoordinator > > >

[GitHub] [flink-statefun] sjwiesman commented on a change in pull request #113: [Flink-17644] Add state expiration to the Java SDK

2020-05-18 Thread GitBox
sjwiesman commented on a change in pull request #113: URL: https://github.com/apache/flink-statefun/pull/113#discussion_r426813593 ## File path: statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/state/Expiration.java ## @@ -0,0 +1,83 @@ +/* + * Licensed to the Apache

[jira] [Closed] (FLINK-17799) Performance regression in all network benchmarks

2020-05-18 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-17799. -- Resolution: Fixed Merged to 1.11 branch as b834ff6b2f merged to master as a875235389 >

[GitHub] [flink] flinkbot edited a comment on pull request #12232: [FLINK-15947] Finish moving scala expression DSL to flink-table-api-scala

2020-05-18 Thread GitBox
flinkbot edited a comment on pull request #12232: URL: https://github.com/apache/flink/pull/12232#issuecomment-630355116 ## CI report: * 5925ef19171dea0dd42cd7f13875b7b05598f4b0 Azure:

[GitHub] [flink] JingsongLi commented on a change in pull request #12224: [FLINK-17594][filesystem] Support Hadoop path-based part-file writer.

2020-05-18 Thread GitBox
JingsongLi commented on a change in pull request #12224: URL: https://github.com/apache/flink/pull/12224#discussion_r426738686 ## File path: flink-formats/flink-hadoop-bulk/src/main/java/org/apache/flink/formats/hadoop/bulk/committer/HadoopRenameFileCommitter.java ## @@ -0,0

[jira] [Closed] (FLINK-17796) Application mode should respect user specified classpath configuration

2020-05-18 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-17796. -- Resolution: Fixed Merged on master with b591f906685ee1379d791d296bd0b305cc7e9bb7 and on

[GitHub] [flink] GJL closed pull request #12203: [FLINK-17687][tests] Collect TM log files before tearing down Mesos

2020-05-18 Thread GitBox
GJL closed pull request #12203: URL: https://github.com/apache/flink/pull/12203 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 the

[jira] [Closed] (FLINK-17687) Collect TaskManager logs in Mesos Jepsen Tests

2020-05-18 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-17687. Resolution: Fixed 1.11: 656d56e99e3c158c7252db04bc034cce77ad39ba aa2a5709309ef8149607cc6ac696cd990a8aef81

[jira] [Updated] (FLINK-17687) Collect TaskManager logs in Mesos Jepsen Tests

2020-05-18 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-17687: - Description: TM logs are collected in standalone mode and YARN. However, for Mesos tests, TM logs are

[GitHub] [flink] dawidwys commented on pull request #12232: [FLINK-15947] Finish moving scala expression DSL to flink-table-api-scala

2020-05-18 Thread GitBox
dawidwys commented on pull request #12232: URL: https://github.com/apache/flink/pull/12232#issuecomment-630345225 This change would break nearly all users setup. Nevertheless I think it is a very important change that significantly improves usability of the Table API. Let me know

[GitHub] [flink] asfgit closed pull request #12225: [FLINK-17781][coordination] Use Scheduler and MainThreadExecutor in OperatorCoordinator.Context

2020-05-18 Thread GitBox
asfgit closed pull request #12225: URL: https://github.com/apache/flink/pull/12225 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] [Updated] (FLINK-17745) PackagedProgram' extractedTempLibraries and jarfiles may be duplicate

2020-05-18 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17745: --- Affects Version/s: (was: 1.10.0) 1.11.0 > PackagedProgram'

[jira] [Updated] (FLINK-17745) PackagedProgram' extractedTempLibraries and jarfiles may be duplicate

2020-05-18 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17745: --- Issue Type: Improvement (was: Bug) > PackagedProgram' extractedTempLibraries and jarfiles

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

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

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

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

[GitHub] [flink] kl0u opened a new pull request #12233: [FLINK-17745] Remove nested jar handling from PackagedProgram

2020-05-18 Thread GitBox
kl0u opened a new pull request #12233: URL: https://github.com/apache/flink/pull/12233 ## What is the purpose of the change The `PackagesProgram` so far was looking in the user's jar for other jars under a `lib/` directory it was extracting them, copy them to separate files, and

[GitHub] [flink] rmetzger opened a new pull request #12227: [FLINK-17730][CI] Increase 'no output timeout' to 15 minutes

2020-05-18 Thread GitBox
rmetzger opened a new pull request #12227: URL: https://github.com/apache/flink/pull/12227 ## What is the purpose of the change Short history lesson: 1. I introduced `run_mvn`, which broke the travis watchdog (it killed the mvn wrapper script, not maven) 2. we saw a lot of

[jira] [Updated] (FLINK-17730) HadoopS3RecoverableWriterITCase.testRecoverAfterMultiplePersistsStateWithMultiPart times out

2020-05-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17730: --- Labels: pull-request-available test-stability (was: test-stability) >

[GitHub] [flink] flinkbot commented on pull request #12228: [FLINK-17541][table] Support inline structured types

2020-05-18 Thread GitBox
flinkbot commented on pull request #12228: URL: https://github.com/apache/flink/pull/12228#issuecomment-630164761 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

[jira] [Updated] (FLINK-17541) Support inline structured types

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

[GitHub] [flink] twalthr opened a new pull request #12228: [FLINK-17541][table] Support inline structured types

2020-05-18 Thread GitBox
twalthr opened a new pull request #12228: URL: https://github.com/apache/flink/pull/12228 ## What is the purpose of the change This enables inline structured types in the Blink planner. Inline structured types are extracted (e.g. in UDFs) and don't need to be registered in a

[jira] [Commented] (FLINK-17015) Fix NPE from NullAwareMapIterator

2020-05-18 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110286#comment-17110286 ] Yu Li commented on FLINK-17015: --- Thanks for the confirmation [~jark]. Since FLINK-17610 is an improvement

[jira] [Commented] (FLINK-17619) Only set offset commit if group id is configured for Kafka Table source

2020-05-18 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110295#comment-17110295 ] Leonard Xu commented on FLINK-17619: [~jark] I think yes,  the new kafka table source

[jira] [Updated] (FLINK-10615) Cancel with savepoint can fail the job

2020-05-18 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10615: -- Fix Version/s: 1.12.0 > Cancel with savepoint can fail the job >

[jira] [Updated] (FLINK-10615) Cancel with savepoint can fail the job

2020-05-18 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10615: -- Component/s: Runtime / Task > Cancel with savepoint can fail the job >

[jira] [Commented] (FLINK-9133) Improve documentability of REST API

2020-05-18 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110322#comment-17110322 ] Till Rohrmann commented on FLINK-9133: -- Is this issue still relevant [~chesnay]? > Improve

[GitHub] [flink] flinkbot commented on pull request #12231: [FLINK-17799][network] Fix performance regression in the network stack

2020-05-18 Thread GitBox
flinkbot commented on pull request #12231: URL: https://github.com/apache/flink/pull/12231#issuecomment-630207400 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

[jira] [Commented] (FLINK-16931) Large _metadata file lead to JobManager not responding when restart

2020-05-18 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110320#comment-17110320 ] Till Rohrmann commented on FLINK-16931: --- I would propose to move this issue to {{1.12.0}}. Do you

[jira] [Commented] (FLINK-14982) YARN IT Test Case log config is mistakenly disabled

2020-05-18 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110336#comment-17110336 ] Till Rohrmann commented on FLINK-14982: --- What is the state of this issue [~ZhenqiuHuang]? > YARN

[jira] [Updated] (FLINK-14982) YARN IT Test Case log config is mistakenly disabled

2020-05-18 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14982: -- Fix Version/s: 1.11.0 > YARN IT Test Case log config is mistakenly disabled >

[GitHub] [flink] GJL closed pull request #12204: [FLINK-17777][tests] Set HADOOP_CLASSPATH for Mesos TaskManagers

2020-05-18 Thread GitBox
GJL closed pull request #12204: URL: https://github.com/apache/flink/pull/12204 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 the

[GitHub] [flink] flinkbot commented on pull request #12227: [FLINK-17730][CI] Increase 'no output timeout' to 15 minutes

2020-05-18 Thread GitBox
flinkbot commented on pull request #12227: URL: https://github.com/apache/flink/pull/12227#issuecomment-630151071 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

[jira] [Commented] (FLINK-17793) Replace TableSchema with dedicated CatalogSchema

2020-05-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110240#comment-17110240 ] Jark Wu commented on FLINK-17793: - +1 to clean up this interface ASAP. But should a CatalogView has this

[GitHub] [flink] flinkbot commented on pull request #12228: [FLINK-17541][table] Support inline structured types

2020-05-18 Thread GitBox
flinkbot commented on pull request #12228: URL: https://github.com/apache/flink/pull/12228#issuecomment-630171014 ## CI report: * 5c672d3d2f0654b3c5d1a18b20d73804e450382a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] rkhachatryan commented on a change in pull request #12120: [FLINK-17547] Support unaligned checkpoints for records spilled to files

2020-05-18 Thread GitBox
rkhachatryan commented on a change in pull request #12120: URL: https://github.com/apache/flink/pull/12120#discussion_r426612454 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/FileBasedBufferIterator.java ## @@ -85,6 +90,6 @@ private int

[GitHub] [flink] flinkbot edited a comment on pull request #12226: [FLINK-17543][Azure] Add timestamp to log name to allow multiple uploads per module

2020-05-18 Thread GitBox
flinkbot edited a comment on pull request #12226: URL: https://github.com/apache/flink/pull/12226#issuecomment-630160464 ## CI report: * fccf0dd1db9bf8dda47728cd9de6840487551e9e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12227: [FLINK-17730][CI] Increase 'no output timeout' to 15 minutes

2020-05-18 Thread GitBox
flinkbot edited a comment on pull request #12227: URL: https://github.com/apache/flink/pull/12227#issuecomment-630160560 ## CI report: * 09f2ce5209113cccbb7d1ea702a79b86b1182dbe Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12225: [FLINK-17781][coordination] Use Scheduler and MainThreadExecutor in OperatorCoordinator.Context

2020-05-18 Thread GitBox
flinkbot edited a comment on pull request #12225: URL: https://github.com/apache/flink/pull/12225#issuecomment-630123970 ## CI report: * 98f726234e0bce2e0088bed95efd282462dc5fc1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12228: [FLINK-17541][table] Support inline structured types

2020-05-18 Thread GitBox
flinkbot edited a comment on pull request #12228: URL: https://github.com/apache/flink/pull/12228#issuecomment-630171014 ## CI report: * 5c672d3d2f0654b3c5d1a18b20d73804e450382a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12225: [FLINK-17781][coordination] Use Scheduler and MainThreadExecutor in OperatorCoordinator.Context

2020-05-18 Thread GitBox
flinkbot edited a comment on pull request #12225: URL: https://github.com/apache/flink/pull/12225#issuecomment-630123970 ## CI report: * 98f726234e0bce2e0088bed95efd282462dc5fc1 Azure:

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

2020-05-18 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110299#comment-17110299 ] Till Rohrmann commented on FLINK-17464: --- I think a workaround at the moment could be to use

[jira] [Commented] (FLINK-17799) Performance regression in all network benchmarks

2020-05-18 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110297#comment-17110297 ] Piotr Nowojski commented on FLINK-17799: git bisect revealed that this regression is caused by

[GitHub] [flink] flinkbot edited a comment on pull request #12132: [FLINK-17593][Connectors/FileSystem] Support arbitrary recovery mechanism for PartFileWriter

2020-05-18 Thread GitBox
flinkbot edited a comment on pull request #12132: URL: https://github.com/apache/flink/pull/12132#issuecomment-628151415 ## CI report: * 79f3bb064a15bfde312932e603ae2a65e67545fd UNKNOWN * 721b8fc06e4b6feb8c268b629bea0ed112552e54 Azure:

[jira] [Commented] (FLINK-17527) kubernetes-session.sh uses log4j-console.properties

2020-05-18 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110308#comment-17110308 ] Till Rohrmann commented on FLINK-17527: --- Sounds good to me [~fly_in_gis]. I've assigned you to

[jira] [Updated] (FLINK-14632) ExecutionGraphSchedulingTest.testSlotReleasingFailsSchedulingOperation deadlocks

2020-05-18 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14632: -- Fix Version/s: 1.11.0 >

[jira] [Commented] (FLINK-17675) Resolve CVE-2019-11358 from jquery

2020-05-18 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110332#comment-17110332 ] Chesnay Schepler commented on FLINK-17675: -- jQuery is also used in flink-web. > Resolve

[jira] [Commented] (FLINK-10241) Reduce performance/stability impact of latency metrics

2020-05-18 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110331#comment-17110331 ] Till Rohrmann commented on FLINK-10241: --- Do we want to address this problem with Flink {{1.11.0}}

[jira] [Assigned] (FLINK-10694) ZooKeeperHaServices Cleanup

2020-05-18 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-10694: - Assignee: (was: vinoyang) > ZooKeeperHaServices Cleanup >

[jira] [Updated] (FLINK-9133) Improve documentability of REST API

2020-05-18 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9133: Priority: Minor (was: Critical) > Improve documentability of REST API >

[jira] [Commented] (FLINK-9133) Improve documentability of REST API

2020-05-18 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110333#comment-17110333 ] Chesnay Schepler commented on FLINK-9133: - yes; some day I may get around to creating a PR. >

[jira] [Updated] (FLINK-17777) Make Mesos Jepsen Tests pass with Hadoop-free Flink

2020-05-18 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-1: - Fix Version/s: 1.11.0 > Make Mesos Jepsen Tests pass with Hadoop-free Flink >

[jira] [Commented] (FLINK-17793) Replace TableSchema with dedicated CatalogSchema

2020-05-18 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110375#comment-17110375 ] Timo Walther commented on FLINK-17793: -- This would mean that we use two different schemas in the

[GitHub] [flink] flinkbot edited a comment on pull request #12224: [FLINK-17594][filesystem] Support Hadoop path-based part-file writer.

2020-05-18 Thread GitBox
flinkbot edited a comment on pull request #12224: URL: https://github.com/apache/flink/pull/12224#issuecomment-630123879 ## CI report: * 354620f64883486ddf2c02dddf0633b51d0444d9 UNKNOWN * e1a615f3322b72015953856f1316691fd0c77896 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12228: [FLINK-17541][table] Support inline structured types

2020-05-18 Thread GitBox
flinkbot edited a comment on pull request #12228: URL: https://github.com/apache/flink/pull/12228#issuecomment-630171014 ## CI report: * 5c672d3d2f0654b3c5d1a18b20d73804e450382a Azure:

[jira] [Updated] (FLINK-17634) Reject multiple handler registrations under the same URL

2020-05-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17634: --- Labels: pull-request-available (was: ) > Reject multiple handler registrations under the

[GitHub] [flink] flinkbot edited a comment on pull request #12225: [FLINK-17781][coordination] Use Scheduler and MainThreadExecutor in OperatorCoordinator.Context

2020-05-18 Thread GitBox
flinkbot edited a comment on pull request #12225: URL: https://github.com/apache/flink/pull/12225#issuecomment-630123970 ## CI report: * 98f726234e0bce2e0088bed95efd282462dc5fc1 Azure:

[jira] [Closed] (FLINK-17777) Make Mesos Jepsen Tests pass with Hadoop-free Flink

2020-05-18 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-1. Resolution: Fixed 1.11: f46735cb4963af616c0e8538331bed8739a1d353 master:

[jira] [Updated] (FLINK-17800) RocksDB optimizeForPointLookup results in missing time windows

2020-05-18 Thread Yordan Pavlov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yordan Pavlov updated FLINK-17800: -- Description: +My Setup:+ We have been using the _RocksDb_ option of _optimizeForPointLookup_

[jira] [Updated] (FLINK-17800) RocksDB optimizeForPointLookup results in missing time windows

2020-05-18 Thread Yordan Pavlov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yordan Pavlov updated FLINK-17800: -- Description: +My Setup:+ We have been using the _RocksDb_ option of _optimizeForPointLookup_

[jira] [Commented] (FLINK-17676) Is there some way to rollback the .out file of TaskManager

2020-05-18 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110196#comment-17110196 ] Robert Metzger commented on FLINK-17676: Probably not ... but it is somehow the closest

[jira] [Updated] (FLINK-17543) Rerunning failed azure jobs fails when uploading logs

2020-05-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17543: --- Labels: pull-request-available (was: ) > Rerunning failed azure jobs fails when uploading

[GitHub] [flink] rmetzger opened a new pull request #12226: [FLINK-17543][Azure] Add timestamp to log name to allow multiple uploads per module

2020-05-18 Thread GitBox
rmetzger opened a new pull request #12226: URL: https://github.com/apache/flink/pull/12226 ## Brief change log Re-running a failed stage leads to an error message on AZP, because the log artifact exists already. With this change, we are adding a timestamp to the log file name to

[GitHub] [flink] flinkbot edited a comment on pull request #12224: [FLINK-17594][filesystem] Support Hadoop path-based part-file writer.

2020-05-18 Thread GitBox
flinkbot edited a comment on pull request #12224: URL: https://github.com/apache/flink/pull/12224#issuecomment-630123879 ## CI report: * 354620f64883486ddf2c02dddf0633b51d0444d9 UNKNOWN * e1a615f3322b72015953856f1316691fd0c77896 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12075: [FLINK-17004] Document the LIKE clause of CREATE TABLE statement.

2020-05-18 Thread GitBox
flinkbot edited a comment on pull request #12075: URL: https://github.com/apache/flink/pull/12075#issuecomment-626587781 ## CI report: * 5417cb95a7ee2576e1e611b8231a932a9acf4396 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12103: [FLINK-16998][core] Add a changeflag to Row

2020-05-18 Thread GitBox
flinkbot edited a comment on pull request #12103: URL: https://github.com/apache/flink/pull/12103#issuecomment-627456433 ## CI report: * d6bfdf1eb659af9a7c424548b9dd62cbf09cf8c0 Azure:

[GitHub] [flink-statefun] slinkydeveloper commented on a change in pull request #110: [FLINK-17611] Unix domain socket connection between worker and function

2020-05-18 Thread GitBox
slinkydeveloper commented on a change in pull request #110: URL: https://github.com/apache/flink-statefun/pull/110#discussion_r426610978 ## File path: statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/HttpFunctionProvider.java ## @@

[GitHub] [flink] zentol commented on a change in pull request #12227: [FLINK-17730][CI] Increase 'no output timeout' to 15 minutes

2020-05-18 Thread GitBox
zentol commented on a change in pull request #12227: URL: https://github.com/apache/flink/pull/12227#discussion_r426618103 ## File path: tools/azure_controller.sh ## @@ -184,7 +184,7 @@ elif [ $STAGE != "$STAGE_CLEANUP" ]; then fi -TEST="$STAGE"

[jira] [Updated] (FLINK-17504) Update translation of Getting Started / Overview

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

[GitHub] [flink] yangyichao-mango opened a new pull request #12230: [FLINK-17504][docs] Update Chinese translation of Getting Started / O…

2020-05-18 Thread GitBox
yangyichao-mango opened a new pull request #12230: URL: https://github.com/apache/flink/pull/12230 …verview ## What is the purpose of the change *Update Chinese translation of Getting Started / Overview* ## Brief change log *(for example:)* -

[jira] [Commented] (FLINK-17444) StreamingFileSink Azure HadoopRecoverableWriter class missing.

2020-05-18 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110300#comment-17110300 ] Till Rohrmann commented on FLINK-17444: --- [~kkl0u] could link the JIRA issue as related so that we

[GitHub] [flink-statefun] slinkydeveloper commented on a change in pull request #110: [FLINK-17611] Unix domain socket connection between worker and function

2020-05-18 Thread GitBox
slinkydeveloper commented on a change in pull request #110: URL: https://github.com/apache/flink-statefun/pull/110#discussion_r426641782 ## File path: pom.xml ## @@ -170,6 +171,11 @@ under the License.

[GitHub] [flink] yangyichao-mango commented on pull request #12230: [FLINK-17504][docs] Update Chinese translation of Getting Started / O…

2020-05-18 Thread GitBox
yangyichao-mango commented on pull request #12230: URL: https://github.com/apache/flink/pull/12230#issuecomment-630198050 Can you help me to review this PR? @wuchong @klion26 This is an automated message from the Apache

[jira] [Updated] (FLINK-16694) Resuming Externalized Checkpoint end-to-end test failed on travis

2020-05-18 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-16694: -- Fix Version/s: 1.11.0 > Resuming Externalized Checkpoint end-to-end test failed on travis >

[jira] [Updated] (FLINK-17799) Performance regression in all network benchmarks

2020-05-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17799: --- Labels: pull-request-available (was: ) > Performance regression in all network benchmarks

[jira] [Updated] (FLINK-10694) ZooKeeperHaServices Cleanup

2020-05-18 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10694: -- Fix Version/s: (was: 1.12.0) 1.11.0 > ZooKeeperHaServices Cleanup >

[jira] [Commented] (FLINK-17706) Clarify licensing situation for flink-benchmarks

2020-05-18 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110362#comment-17110362 ] Nico Kruber commented on FLINK-17706: - Thanks, just as an update, the following license

[jira] [Commented] (FLINK-17793) Replace TableSchema with dedicated CatalogSchema

2020-05-18 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110191#comment-17110191 ] Timo Walther commented on FLINK-17793: -- [~ykt836] I'm fine with `CatalogTableSchema`, however, it

[GitHub] [flink] flinkbot edited a comment on pull request #12224: [FLINK-17594][filesystem] Support Hadoop path-based part-file writer.

2020-05-18 Thread GitBox
flinkbot edited a comment on pull request #12224: URL: https://github.com/apache/flink/pull/12224#issuecomment-630123879 ## CI report: * 354620f64883486ddf2c02dddf0633b51d0444d9 UNKNOWN * e1a615f3322b72015953856f1316691fd0c77896 UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on pull request #12221: [FLINK-17797][FLINK-17798][hbase][jdbc] Align the behavior between the new and legacy HBase/JDBC table source

2020-05-18 Thread GitBox
flinkbot edited a comment on pull request #12221: URL: https://github.com/apache/flink/pull/12221#issuecomment-630123655 ## CI report: * 129d85d4bcc2b032ff5be1999a8a0277f31a2848 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12199: [FLINK-17774] [table] supports all kinds of changes for select result

2020-05-18 Thread GitBox
flinkbot edited a comment on pull request #12199: URL: https://github.com/apache/flink/pull/12199#issuecomment-629793563 ## CI report: * f11005c6596ecf41efd898ba324374948b2eb8cb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12223: [FLINK-15813][runtime] Set default value of config “jobmanager.execution.failover-strategy” to “region”

2020-05-18 Thread GitBox
flinkbot edited a comment on pull request #12223: URL: https://github.com/apache/flink/pull/12223#issuecomment-630123802 ## CI report: * 1984222ee161599a34d41ba2d8dc6466b4858fab Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12218: [FLINK-16160][table] Fix proctime()/rowtime() doesn't work for TableE…

2020-05-18 Thread GitBox
flinkbot edited a comment on pull request #12218: URL: https://github.com/apache/flink/pull/12218#issuecomment-630087514 ## CI report: * ced394a88ef14eb97b61391aa2fb8b571c6b5977 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/166677325) Bot

<    1   2   3   4   5   6   7   8   9   >