[jira] [Commented] (FLINK-8799) Make AbstractYarnClusterDescriptor immutable

[ https://issues.apache.org/jira/browse/FLINK-8799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16384539#comment-16384539 ] ASF GitHub Bot commented on FLINK-8799: --- Github user zhangminglei commented on a diff in the pull

[GitHub] flink pull request #5617: [FLINK-8799][YARN] Make AbstractYarnClusterDescrip...

Github user zhangminglei commented on a diff in the pull request: https://github.com/apache/flink/pull/5617#discussion_r172009559 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java --- @@ -476,14 +379,12 @@ protected Configuration

[jira] [Closed] (FLINK-8840) Pull out YarnClient initialization out of AbstractYarnClusterDescriptor

[ https://issues.apache.org/jira/browse/FLINK-8840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8840. Resolution: Fixed Fixed via  1.6.0: 193386bcd5d0e2003a831138d6282af1880e1ab8 1.5.0: 

[jira] [Resolved] (FLINK-8826) In Flip6 mode, when starting yarn cluster, configured taskmanager.heap.mb is ignored

[ https://issues.apache.org/jira/browse/FLINK-8826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-8826. -- Resolution: Fixed Fix Version/s: 1.6.0 1.5.0 Fixed via 1.6.0: 

[jira] [Resolved] (FLINK-8459) Implement cancelWithSavepoint in RestClusterClient

[ https://issues.apache.org/jira/browse/FLINK-8459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-8459. -- Resolution: Fixed Fix Version/s: 1.6.0 Fixed via 1.6.0: 

[jira] [Commented] (FLINK-8826) In Flip6 mode, when starting yarn cluster, configured taskmanager.heap.mb is ignored

[ https://issues.apache.org/jira/browse/FLINK-8826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16384535#comment-16384535 ] ASF GitHub Bot commented on FLINK-8826: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-8459) Implement cancelWithSavepoint in RestClusterClient

[ https://issues.apache.org/jira/browse/FLINK-8459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16384536#comment-16384536 ] ASF GitHub Bot commented on FLINK-8459: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #5622: [FLINK-8459][flip6] Implement RestClusterClient.ca...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5622 ---

[GitHub] flink pull request #5625: [FLINK-8826] [flip6] Start Yarn TaskExecutor with ...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5625 ---

[jira] [Commented] (FLINK-8837) Move DataStreamUtils to package 'experimental'.

[ https://issues.apache.org/jira/browse/FLINK-8837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16384533#comment-16384533 ] Chesnay Schepler commented on FLINK-8837: - I'd be in favor of adding an annotation as there should

[jira] [Commented] (FLINK-6895) Add STR_TO_DATE supported in SQL

[ https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16384529#comment-16384529 ] ASF GitHub Bot commented on FLINK-6895: --- Github user buptljy commented on the issue:

[jira] [Commented] (FLINK-6895) Add STR_TO_DATE supported in SQL

[ https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16384528#comment-16384528 ] ASF GitHub Bot commented on FLINK-6895: --- GitHub user buptljy opened a pull request:

[GitHub] flink issue #5628: [FLINK-6895][table]Add STR_TO_DATE supported in SQL

Github user buptljy commented on the issue: https://github.com/apache/flink/pull/5628 Actually I am not sure if it is appropriate to return "string" because it should be the inverse of the "DATE_FORMAT()". However, If I return DATE/TIME/DATETIME as the jira issue described, the type

[GitHub] flink pull request #5628: [FLINK-6895][table]Add STR_TO_DATE supported in SQ...

GitHub user buptljy opened a pull request: https://github.com/apache/flink/pull/5628 [FLINK-6895][table]Add STR_TO_DATE supported in SQL ## What is the purpose of the change Add STR_TO_DATE Function supported in SQL ## Brief change log * STR_TO_DATE(str string, format

[GitHub] flink pull request #5618: [FLINK-6895][table]Add STR_TO_DATE supported in SQ...

Github user buptljy closed the pull request at: https://github.com/apache/flink/pull/5618 ---

[jira] [Commented] (FLINK-6895) Add STR_TO_DATE supported in SQL

[ https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16384527#comment-16384527 ] ASF GitHub Bot commented on FLINK-6895: --- Github user buptljy closed the pull request at:

[jira] [Commented] (FLINK-8799) Make AbstractYarnClusterDescriptor immutable

[ https://issues.apache.org/jira/browse/FLINK-8799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16384526#comment-16384526 ] ASF GitHub Bot commented on FLINK-8799: --- Github user yanghua commented on the issue:

[GitHub] flink issue #5617: [FLINK-8799][YARN] Make AbstractYarnClusterDescriptor imm...

Github user yanghua commented on the issue: https://github.com/apache/flink/pull/5617 @tillrohrmann could you please review this PR? Thanks. ---

[GitHub] flink issue #5613: [FLINK-8274] [table] Split generated methods for preventi...

Github user Xpray commented on the issue: https://github.com/apache/flink/pull/5613 @twalthr yes that your PR have solved the urgent ones. I have cases with huge unboxing code but we can still split it in this way. As for large section codes of one field we may have to make the

[jira] [Commented] (FLINK-8274) Fix Java 64K method compiling limitation for CommonCalc

[ https://issues.apache.org/jira/browse/FLINK-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16384460#comment-16384460 ] ASF GitHub Bot commented on FLINK-8274: --- Github user hequn8128 commented on the issue:

[jira] [Commented] (FLINK-8274) Fix Java 64K method compiling limitation for CommonCalc

[ https://issues.apache.org/jira/browse/FLINK-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16384461#comment-16384461 ] ASF GitHub Bot commented on FLINK-8274: --- Github user Xpray commented on the issue:

[GitHub] flink issue #5613: [FLINK-8274] [table] Split generated methods for preventi...

Github user hequn8128 commented on the issue: https://github.com/apache/flink/pull/5613 Hi @twalthr Current implementation will reach the limits if a field becomes too large. This can be reproduced by creating a filed produced by concat_ws(). see

[jira] [Commented] (FLINK-8623) ConnectionUtilsTest.testReturnLocalHostAddressUsingHeuristics unstable on Travis

[ https://issues.apache.org/jira/browse/FLINK-8623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16384451#comment-16384451 ] ASF GitHub Bot commented on FLINK-8623: --- Github user zhangminglei commented on a diff in the pull

[jira] [Commented] (FLINK-8623) ConnectionUtilsTest.testReturnLocalHostAddressUsingHeuristics unstable on Travis

[ https://issues.apache.org/jira/browse/FLINK-8623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16384450#comment-16384450 ] ASF GitHub Bot commented on FLINK-8623: --- Github user zhangminglei commented on a diff in the pull

[GitHub] flink pull request #5449: [FLINK-8623] ConnectionUtilsTest.testReturnLocalHo...

Github user zhangminglei commented on a diff in the pull request: https://github.com/apache/flink/pull/5449#discussion_r172004051 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/net/ConnectionUtilsTest.java --- @@ -61,7 +61,7 @@ public void

[GitHub] flink pull request #5449: [FLINK-8623] ConnectionUtilsTest.testReturnLocalHo...

Github user zhangminglei commented on a diff in the pull request: https://github.com/apache/flink/pull/5449#discussion_r172004016 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/net/ConnectionUtilsTest.java --- @@ -61,7 +61,7 @@ public void

[jira] [Commented] (FLINK-8459) Implement cancelWithSavepoint in RestClusterClient

[ https://issues.apache.org/jira/browse/FLINK-8459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1638#comment-1638 ] ASF GitHub Bot commented on FLINK-8459: --- Github user yanghua commented on the issue:

[GitHub] flink pull request #5565: [FLINK-8459][flip6] Implement cancelWithSavepoint ...

Github user yanghua closed the pull request at: https://github.com/apache/flink/pull/5565 ---

[jira] [Commented] (FLINK-8459) Implement cancelWithSavepoint in RestClusterClient

[ https://issues.apache.org/jira/browse/FLINK-8459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16384445#comment-16384445 ] ASF GitHub Bot commented on FLINK-8459: --- Github user yanghua closed the pull request at:

[GitHub] flink issue #5565: [FLINK-8459][flip6] Implement cancelWithSavepoint in Rest...

Github user yanghua commented on the issue: https://github.com/apache/flink/pull/5565 @GJL OK, That's all right. Now I close this PR. ---

[jira] [Commented] (FLINK-8842) Change default REST port to 8081

[ https://issues.apache.org/jira/browse/FLINK-8842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16384272#comment-16384272 ] ASF GitHub Bot commented on FLINK-8842: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #5626: [FLINK-8842] Change the Rest default port to 8081

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5626 ---

[jira] [Closed] (FLINK-8842) Change default REST port to 8081

[ https://issues.apache.org/jira/browse/FLINK-8842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8842. Resolution: Fixed Fixed via 1.6.0: 2d3c5d597359f51f310f9eeb994c55f516eb1a30 1.5.0: 

[jira] [Comment Edited] (FLINK-8467) Restoring job that does not use checkpointing from savepoint breaks

[ https://issues.apache.org/jira/browse/FLINK-8467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16384252#comment-16384252 ] Jelmer Kuperus edited comment on FLINK-8467 at 3/2/18 10:44 PM: Sorry for

[jira] [Comment Edited] (FLINK-8467) Restoring job that does not use checkpointing from savepoint breaks

[ https://issues.apache.org/jira/browse/FLINK-8467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16384252#comment-16384252 ] Jelmer Kuperus edited comment on FLINK-8467 at 3/2/18 10:38 PM: Sorry for

[jira] [Comment Edited] (FLINK-8467) Restoring job that does not use checkpointing from savepoint breaks

[ https://issues.apache.org/jira/browse/FLINK-8467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16384252#comment-16384252 ] Jelmer Kuperus edited comment on FLINK-8467 at 3/2/18 10:37 PM: Sorry for

[jira] [Comment Edited] (FLINK-8467) Restoring job that does not use checkpointing from savepoint breaks

[ https://issues.apache.org/jira/browse/FLINK-8467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16384252#comment-16384252 ] Jelmer Kuperus edited comment on FLINK-8467 at 3/2/18 10:36 PM: Sorry for

[jira] [Comment Edited] (FLINK-8467) Restoring job that does not use checkpointing from savepoint breaks

[ https://issues.apache.org/jira/browse/FLINK-8467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16384252#comment-16384252 ] Jelmer Kuperus edited comment on FLINK-8467 at 3/2/18 10:35 PM: Sorry for

[jira] [Assigned] (FLINK-8585) Efficiently handle read-only and non array ByteBuffers in DataInputDeserializer

[ https://issues.apache.org/jira/browse/FLINK-8585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-8585: --- Assignee: Bowen Li > Efficiently handle read-only and non array ByteBuffers in >

[jira] [Comment Edited] (FLINK-8467) Restoring job that does not use checkpointing from savepoint breaks

[ https://issues.apache.org/jira/browse/FLINK-8467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16384252#comment-16384252 ] Jelmer Kuperus edited comment on FLINK-8467 at 3/2/18 10:28 PM: Sorry for

[jira] [Commented] (FLINK-8467) Restoring job that does not use checkpointing from savepoint breaks

[ https://issues.apache.org/jira/browse/FLINK-8467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16384252#comment-16384252 ] Jelmer Kuperus commented on FLINK-8467: --- Sorry for the late response. I just realized that

[GitHub] flink pull request #5627: [doc] Remove missed CheckpointedRestoring

GitHub user webmakersteve opened a pull request: https://github.com/apache/flink/pull/5627 [doc] Remove missed CheckpointedRestoring ## What is the purpose of the change Pull request fixes one missed CheckpointedRestoring interface which was removed in Flink 1.4

[jira] [Created] (FLINK-8844) Export job jar file name or job version property via REST API

Elias Levy created FLINK-8844: - Summary: Export job jar file name or job version property via REST API Key: FLINK-8844 URL: https://issues.apache.org/jira/browse/FLINK-8844 Project: Flink Issue

[jira] [Closed] (FLINK-7671) testBlobServerCleanupCancelledJob in JobManagerCleanupITCase failed in build

[ https://issues.apache.org/jira/browse/FLINK-7671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-7671. --- Resolution: Invalid > testBlobServerCleanupCancelledJob in JobManagerCleanupITCase failed in build >

[jira] [Commented] (FLINK-8828) Add collect method to DataStream / DataSet scala api

[ https://issues.apache.org/jira/browse/FLINK-8828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16384046#comment-16384046 ] ASF GitHub Bot commented on FLINK-8828: --- Github user bowenli86 commented on the issue:

[GitHub] flink issue #5616: [FLINK-8828] [stream, dataset, scala] Introduce collect m...

Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/5616 need to add to java API as well ---

[jira] [Created] (FLINK-8843) Decouple bind REST address from advertised address

Till Rohrmann created FLINK-8843: Summary: Decouple bind REST address from advertised address Key: FLINK-8843 URL: https://issues.apache.org/jira/browse/FLINK-8843 Project: Flink Issue Type:

[jira] [Commented] (FLINK-8842) Change default REST port to 8081

[ https://issues.apache.org/jira/browse/FLINK-8842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16384022#comment-16384022 ] ASF GitHub Bot commented on FLINK-8842: --- GitHub user tillrohrmann opened a pull request:

[GitHub] flink pull request #5626: [FLINK-8842] Change the Rest default port to 8081

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5626 [FLINK-8842] Change the Rest default port to 8081 ## What is the purpose of the change Change the default REST port to `8081`. ## Verifying this change Tested

[jira] [Created] (FLINK-8842) Change default REST port to 8081

Till Rohrmann created FLINK-8842: Summary: Change default REST port to 8081 Key: FLINK-8842 URL: https://issues.apache.org/jira/browse/FLINK-8842 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-8826) In Flip6 mode, when starting yarn cluster, configured taskmanager.heap.mb is ignored

[ https://issues.apache.org/jira/browse/FLINK-8826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16384000#comment-16384000 ] ASF GitHub Bot commented on FLINK-8826: --- GitHub user tillrohrmann opened a pull request:

[GitHub] flink pull request #5625: [FLINK-8826] [flip6] Start Yarn TaskExecutor with ...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5625 [FLINK-8826] [flip6] Start Yarn TaskExecutor with proper slots and memory ## What is the purpose of the change Read the default TaskManager memory and number of slots from the

[jira] [Created] (FLINK-8841) Duplicate MapSerializer and HashMapSerializer.

Kostas Kloudas created FLINK-8841: - Summary: Duplicate MapSerializer and HashMapSerializer. Key: FLINK-8841 URL: https://issues.apache.org/jira/browse/FLINK-8841 Project: Flink Issue Type:

[jira] [Commented] (FLINK-8834) Job fails to restart due to some tasks stuck in cancelling state

[ https://issues.apache.org/jira/browse/FLINK-8834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383826#comment-16383826 ] Daniel Harper commented on FLINK-8834: -- I can only see 2 log lines, one line for each task that

[GitHub] flink pull request #5624: [FLINK-8402][s3][tests] fix hadoop/presto S3 IT ca...

GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/5624 [FLINK-8402][s3][tests] fix hadoop/presto S3 IT cases for eventually-consistent operations ## What is the purpose of the change `HadoopS3FileSystemITCase` and `PrestoS3FileSystemITCase` rely

[jira] [Commented] (FLINK-8402) HadoopS3FileSystemITCase.testDirectoryListing fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-8402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383822#comment-16383822 ] ASF GitHub Bot commented on FLINK-8402: --- GitHub user NicoK opened a pull request:

[GitHub] flink pull request #5623: [FLINK-8807] Fix ZookeeperCompleted checkpoint sto...

GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/5623 [FLINK-8807] Fix ZookeeperCompleted checkpoint store can get stuck in infinite loop Before, CompletedCheckpoint did not have proper equals()/hashCode(), which meant that the fixpoint condition

[jira] [Commented] (FLINK-8807) ZookeeperCompleted checkpoint store can get stuck in infinite loop

[ https://issues.apache.org/jira/browse/FLINK-8807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383803#comment-16383803 ] ASF GitHub Bot commented on FLINK-8807: --- GitHub user aljoscha opened a pull request:

[jira] [Commented] (FLINK-8402) HadoopS3FileSystemITCase.testDirectoryListing fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-8402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383800#comment-16383800 ] Nico Kruber commented on FLINK-8402: We obviously need to take more care of [S3's consistency

[jira] [Assigned] (FLINK-8402) HadoopS3FileSystemITCase.testDirectoryListing fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-8402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reassigned FLINK-8402: -- Assignee: Nico Kruber > HadoopS3FileSystemITCase.testDirectoryListing fails on Travis >

[jira] [Commented] (FLINK-8834) Job fails to restart due to some tasks stuck in cancelling state

[ https://issues.apache.org/jira/browse/FLINK-8834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383791#comment-16383791 ] Stephan Ewen commented on FLINK-8834: - Can you check how often you see the line "Task '...' did not

[jira] [Commented] (FLINK-8829) Flink in EMR(YARN) is down due to Akka communication issue

[ https://issues.apache.org/jira/browse/FLINK-8829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383785#comment-16383785 ] Stephan Ewen commented on FLINK-8829: - One reason why this could happen that we saw in the past is

[jira] [Commented] (FLINK-8837) Move DataStreamUtils to package 'experimental'.

[ https://issues.apache.org/jira/browse/FLINK-8837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383772#comment-16383772 ] Stephan Ewen commented on FLINK-8837: - I see the issue with package private methods. Originally, the

[jira] [Commented] (FLINK-8824) In Kafka Consumers, replace 'getCanonicalName()' with 'getClassName()'

[ https://issues.apache.org/jira/browse/FLINK-8824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383765#comment-16383765 ] Stephan Ewen commented on FLINK-8824: - You are right, nested classes are the problematic case. Arrays

[jira] [Commented] (FLINK-8459) Implement cancelWithSavepoint in RestClusterClient

[ https://issues.apache.org/jira/browse/FLINK-8459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383760#comment-16383760 ] ASF GitHub Bot commented on FLINK-8459: --- Github user GJL commented on a diff in the pull request:

[GitHub] flink pull request #5622: [FLINK-8459][flip6] Implement RestClusterClient.ca...

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5622#discussion_r171888774 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/savepoints/SavepointTriggerRequestBody.java --- @@ -36,15 +36,26 @@

[jira] [Commented] (FLINK-8459) Implement cancelWithSavepoint in RestClusterClient

[ https://issues.apache.org/jira/browse/FLINK-8459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383745#comment-16383745 ] ASF GitHub Bot commented on FLINK-8459: --- Github user GJL commented on a diff in the pull request:

[jira] [Updated] (FLINK-8835) Fix TaskManager config keys

[ https://issues.apache.org/jira/browse/FLINK-8835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-8835: Description: Many new config keys in the TaskManager don't follow the proper naming scheme. We

[jira] [Updated] (FLINK-8686) Improve basic embedded SQL client

[ https://issues.apache.org/jira/browse/FLINK-8686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-8686: Description: This issue describes follow-up issues that should be fixes in order to make the SQL

[GitHub] flink pull request #5622: [FLINK-8459][flip6] Implement RestClusterClient.ca...

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5622#discussion_r171886987 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/savepoints/SavepointTriggerRequestBody.java --- @@ -36,15 +36,26 @@

[jira] [Updated] (FLINK-8686) Improve basic embedded SQL client

[ https://issues.apache.org/jira/browse/FLINK-8686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-8686: Description: This issue describes follow-up issues that should be fixes in order to make the SQL

[jira] [Updated] (FLINK-8835) Fix TaskManager config keys

[ https://issues.apache.org/jira/browse/FLINK-8835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-8835: Labels: easy-fix (was: ) > Fix TaskManager config keys > --- > >

[jira] [Commented] (FLINK-8836) Duplicating a KryoSerializer does not duplicate registered default serializers

[ https://issues.apache.org/jira/browse/FLINK-8836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383737#comment-16383737 ] Stephan Ewen commented on FLINK-8836: - I would actually not classify this as critical but rather minor

[jira] [Commented] (FLINK-8836) Duplicating a KryoSerializer does not duplicate registered default serializers

[ https://issues.apache.org/jira/browse/FLINK-8836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383734#comment-16383734 ] Stephan Ewen commented on FLINK-8836: - I see. We can check what Kryo's philosophy on serializers is,

[jira] [Commented] (FLINK-8769) Quickstart job execution in IDE logs contain several exceptions

[ https://issues.apache.org/jira/browse/FLINK-8769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383717#comment-16383717 ] ASF GitHub Bot commented on FLINK-8769: --- Github user GJL commented on a diff in the pull request:

[GitHub] flink pull request #5611: [FLINK-8769][flip6] do not print error causing exc...

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5611#discussion_r171883413 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DispatcherRestEndpoint.java --- @@ -120,7 +120,12 @@ public DispatcherRestEndpoint(

[jira] [Updated] (FLINK-8686) Improve basic embedded SQL client

[ https://issues.apache.org/jira/browse/FLINK-8686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-8686: Priority: Blocker (was: Major) > Improve basic embedded SQL client >

[jira] [Updated] (FLINK-8686) Improve basic embedded SQL client

[ https://issues.apache.org/jira/browse/FLINK-8686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-8686: Fix Version/s: 1.5.0 > Improve basic embedded SQL client > -- > >

[jira] [Commented] (FLINK-8623) ConnectionUtilsTest.testReturnLocalHostAddressUsingHeuristics unstable on Travis

[ https://issues.apache.org/jira/browse/FLINK-8623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383644#comment-16383644 ] ASF GitHub Bot commented on FLINK-8623: --- Github user NicoK commented on a diff in the pull request:

[GitHub] flink pull request #5449: [FLINK-8623] ConnectionUtilsTest.testReturnLocalHo...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/5449#discussion_r171858504 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/net/ConnectionUtilsTest.java --- @@ -61,7 +61,7 @@ public void

[jira] [Created] (FLINK-8840) Pull out YarnClient initialization out of AbstractYarnClusterDescriptor

Till Rohrmann created FLINK-8840: Summary: Pull out YarnClient initialization out of AbstractYarnClusterDescriptor Key: FLINK-8840 URL: https://issues.apache.org/jira/browse/FLINK-8840 Project: Flink

[GitHub] flink issue #5613: [FLINK-8274] [table] Split generated methods for preventi...

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/5613 @Xpray yes that might be necessary as well. I think this code does not solve all problems but the most urgent ones. It still fails if expressions in a field become too large or the unboxing. Or even

[jira] [Commented] (FLINK-8274) Fix Java 64K method compiling limitation for CommonCalc

[ https://issues.apache.org/jira/browse/FLINK-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383631#comment-16383631 ] ASF GitHub Bot commented on FLINK-8274: --- Github user twalthr commented on the issue:

[jira] [Commented] (FLINK-8459) Implement cancelWithSavepoint in RestClusterClient

[ https://issues.apache.org/jira/browse/FLINK-8459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383628#comment-16383628 ] ASF GitHub Bot commented on FLINK-8459: --- Github user GJL commented on the issue:

[GitHub] flink issue #5565: [FLINK-8459][flip6] Implement cancelWithSavepoint in Rest...

Github user GJL commented on the issue: https://github.com/apache/flink/pull/5565 @yanghua Thanks for your contribution but I am afraid to tell you that we have changed our mind and decided that it is better not to allow checkpoints between the savepoint and job cancelation.

[jira] [Commented] (FLINK-8459) Implement cancelWithSavepoint in RestClusterClient

[ https://issues.apache.org/jira/browse/FLINK-8459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383624#comment-16383624 ] ASF GitHub Bot commented on FLINK-8459: --- Github user GJL commented on a diff in the pull request:

[GitHub] flink pull request #5622: [FLINK-8459][flip6] Implement RestClusterClient.ca...

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5622#discussion_r171858873 --- Diff: flink-tests/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterTriggerSavepointIT.java --- @@ -0,0 +1,219 @@ +/* + * Licensed to the

[GitHub] flink pull request #5622: [FLINK-8459][flip6] Implement RestClusterClient.ca...

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5622#discussion_r171858593 --- Diff: flink-tests/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterTriggerSavepointIT.java --- @@ -0,0 +1,219 @@ +/* + * Licensed to the

[GitHub] flink pull request #5622: [FLINK-8459][flip6] Implement RestClusterClient.ca...

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5622#discussion_r171858662 --- Diff: flink-tests/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterTriggerSavepointIT.java --- @@ -0,0 +1,219 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-8459) Implement cancelWithSavepoint in RestClusterClient

[ https://issues.apache.org/jira/browse/FLINK-8459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383622#comment-16383622 ] ASF GitHub Bot commented on FLINK-8459: --- Github user GJL commented on a diff in the pull request:

[jira] [Commented] (FLINK-8459) Implement cancelWithSavepoint in RestClusterClient

[ https://issues.apache.org/jira/browse/FLINK-8459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383623#comment-16383623 ] ASF GitHub Bot commented on FLINK-8459: --- Github user GJL commented on a diff in the pull request:

[jira] [Commented] (FLINK-8459) Implement cancelWithSavepoint in RestClusterClient

[ https://issues.apache.org/jira/browse/FLINK-8459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383619#comment-16383619 ] ASF GitHub Bot commented on FLINK-8459: --- Github user GJL commented on a diff in the pull request:

[jira] [Commented] (FLINK-8459) Implement cancelWithSavepoint in RestClusterClient

[ https://issues.apache.org/jira/browse/FLINK-8459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383618#comment-16383618 ] ASF GitHub Bot commented on FLINK-8459: --- Github user GJL commented on a diff in the pull request:

[GitHub] flink pull request #5622: [FLINK-8459][flip6] Implement RestClusterClient.ca...

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5622#discussion_r171858158 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/rest/messages/job/savepoints/SavepointTriggerRequestBodyTest.java --- @@ -34,8 +34,8 @@

[GitHub] flink pull request #5622: [FLINK-8459][flip6] Implement RestClusterClient.ca...

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5622#discussion_r171857970 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java --- @@ -971,14 +971,44 @@ public void

[jira] [Commented] (FLINK-8459) Implement cancelWithSavepoint in RestClusterClient

[ https://issues.apache.org/jira/browse/FLINK-8459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383616#comment-16383616 ] ASF GitHub Bot commented on FLINK-8459: --- Github user GJL commented on a diff in the pull request:

[GitHub] flink pull request #5622: [FLINK-8459][flip6] Implement RestClusterClient.ca...

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5622#discussion_r171857517 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java --- @@ -971,14 +971,44 @@ public void

[jira] [Commented] (FLINK-8459) Implement cancelWithSavepoint in RestClusterClient

[ https://issues.apache.org/jira/browse/FLINK-8459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383612#comment-16383612 ] ASF GitHub Bot commented on FLINK-8459: --- Github user GJL commented on a diff in the pull request:

[GitHub] flink pull request #5622: [FLINK-8459][flip6] Implement RestClusterClient.ca...

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5622#discussion_r171857387 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java --- @@ -971,14 +971,44 @@ public void

[jira] [Commented] (FLINK-8459) Implement cancelWithSavepoint in RestClusterClient

[ https://issues.apache.org/jira/browse/FLINK-8459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383610#comment-16383610 ] ASF GitHub Bot commented on FLINK-8459: --- GitHub user GJL opened a pull request:

  1   2   >