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

2018-03-02 Thread Stephan Ewen (JIRA)
[ 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-8824) In Kafka Consumers, replace 'getCanonicalName()' with 'getClassName()'

2018-03-02 Thread Stephan Ewen (JIRA)
[ 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-8829) Flink in EMR(YARN) is down due to Akka communication issue

2018-03-02 Thread Stephan Ewen (JIRA)
[ 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] [Updated] (FLINK-8835) Fix TaskManager config keys

2018-03-02 Thread Stephan Ewen (JIRA)
[ 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] [Commented] (FLINK-8836) Duplicating a KryoSerializer does not duplicate registered default serializers

2018-03-02 Thread Stephan Ewen (JIRA)
[ 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] [Updated] (FLINK-8835) Fix TaskManager config keys

2018-03-02 Thread Stephan Ewen (JIRA)
[ 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-8837) Move DataStreamUtils to package 'experimental'.

2018-03-02 Thread Stephan Ewen (JIRA)
[ 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-8402) HadoopS3FileSystemITCase.testDirectoryListing fails on Travis

2018-03-02 Thread ASF GitHub Bot (JIRA)
[ 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 #5624: [FLINK-8402][s3][tests] fix hadoop/presto S3 IT ca...

2018-03-02 Thread NicoK
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] [Updated] (FLINK-8686) Improve basic embedded SQL client

2018-03-02 Thread Timo Walther (JIRA)
[ 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...

2018-03-02 Thread GJL
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-8834) Job fails to restart due to some tasks stuck in cancelling state

2018-03-02 Thread Stephan Ewen (JIRA)
[ 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-8459) Implement cancelWithSavepoint in RestClusterClient

2018-03-02 Thread ASF GitHub Bot (JIRA)
[ 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] [Commented] (FLINK-8402) HadoopS3FileSystemITCase.testDirectoryListing fails on Travis

2018-03-02 Thread Nico Kruber (JIRA)
[ 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

2018-03-02 Thread Nico Kruber (JIRA)
[ 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] [Created] (FLINK-8841) Duplicate MapSerializer and HashMapSerializer.

2018-03-02 Thread Kostas Kloudas (JIRA)
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-8769) Quickstart job execution in IDE logs contain several exceptions

2018-03-02 Thread ASF GitHub Bot (JIRA)
[ 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:

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

2018-03-02 Thread ASF GitHub Bot (JIRA)
[ 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 #5623: [FLINK-8807] Fix ZookeeperCompleted checkpoint sto...

2018-03-02 Thread aljoscha
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

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

2018-03-02 Thread GJL
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

2018-03-02 Thread Timo Walther (JIRA)
[ 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] [Commented] (FLINK-8807) ZookeeperCompleted checkpoint store can get stuck in infinite loop

2018-03-02 Thread ASF GitHub Bot (JIRA)
[ 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-8834) Job fails to restart due to some tasks stuck in cancelling state

2018-03-02 Thread Daniel Harper (JIRA)
[ 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 #5625: [FLINK-8826] [flip6] Start Yarn TaskExecutor with ...

2018-03-02 Thread tillrohrmann
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] [Commented] (FLINK-8826) In Flip6 mode, when starting yarn cluster, configured taskmanager.heap.mb is ignored

2018-03-02 Thread ASF GitHub Bot (JIRA)
[ 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:

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

2018-03-02 Thread Till Rohrmann (JIRA)
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-8828) Add collect method to DataStream / DataSet scala api

2018-03-02 Thread ASF GitHub Bot (JIRA)
[ 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...

2018-03-02 Thread bowenli86
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

2018-03-02 Thread Till Rohrmann (JIRA)
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

2018-03-02 Thread ASF GitHub Bot (JIRA)
[ 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

2018-03-02 Thread tillrohrmann
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] [Commented] (FLINK-8623) ConnectionUtilsTest.testReturnLocalHostAddressUsingHeuristics unstable on Travis

2018-03-02 Thread ASF GitHub Bot (JIRA)
[ 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...

2018-03-02 Thread zhangminglei
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

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

2018-03-02 Thread ASF GitHub Bot (JIRA)
[ 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

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

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

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

2018-03-02 Thread ASF GitHub Bot (JIRA)
[ 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:

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

2018-03-02 Thread ASF GitHub Bot (JIRA)
[ 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:

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

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

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

2018-03-02 Thread buptljy
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 issue #5628: [FLINK-6895][table]Add STR_TO_DATE supported in SQL

2018-03-02 Thread buptljy
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

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

2018-03-02 Thread ASF GitHub Bot (JIRA)
[ 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:

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

2018-03-02 Thread ASF GitHub Bot (JIRA)
[ 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-8837) Move DataStreamUtils to package 'experimental'.

2018-03-02 Thread Chesnay Schepler (JIRA)
[ 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

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

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

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

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

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

2018-03-02 Thread ASF GitHub Bot (JIRA)
[ 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

2018-03-02 Thread ASF GitHub Bot (JIRA)
[ 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:

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

2018-03-02 Thread Till Rohrmann (JIRA)
[ 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

2018-03-02 Thread Till Rohrmann (JIRA)
[ 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] [Closed] (FLINK-8840) Pull out YarnClient initialization out of AbstractYarnClusterDescriptor

2018-03-02 Thread Till Rohrmann (JIRA)
[ 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: 

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

2018-03-02 Thread zhangminglei
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] [Commented] (FLINK-8799) Make AbstractYarnClusterDescriptor immutable

2018-03-02 Thread ASF GitHub Bot (JIRA)
[ 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

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

2018-03-02 Thread Bowen Li (JIRA)
[ 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] [Assigned] (FLINK-8585) Efficiently handle read-only and non array ByteBuffers in DataInputDeserializer

2018-03-02 Thread Bowen Li (JIRA)
[ 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

2018-03-02 Thread Jelmer Kuperus (JIRA)
[ 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] [Created] (FLINK-8844) Export job jar file name or job version property via REST API

2018-03-02 Thread Elias Levy (JIRA)
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

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

2018-03-02 Thread webmakersteve
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] [Comment Edited] (FLINK-8467) Restoring job that does not use checkpointing from savepoint breaks

2018-03-02 Thread Jelmer Kuperus (JIRA)
[ 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] [Comment Edited] (FLINK-8467) Restoring job that does not use checkpointing from savepoint breaks

2018-03-02 Thread Jelmer Kuperus (JIRA)
[ 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] [Closed] (FLINK-8842) Change default REST port to 8081

2018-03-02 Thread Till Rohrmann (JIRA)
[ 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] [Commented] (FLINK-8842) Change default REST port to 8081

2018-03-02 Thread ASF GitHub Bot (JIRA)
[ 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

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

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

2018-03-02 Thread Jelmer Kuperus (JIRA)
[ 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] [Commented] (FLINK-8467) Restoring job that does not use checkpointing from savepoint breaks

2018-03-02 Thread Jelmer Kuperus (JIRA)
[ 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

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

2018-03-02 Thread Jelmer Kuperus (JIRA)
[ 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

2018-03-02 Thread Jelmer Kuperus (JIRA)
[ 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

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

2018-03-02 Thread zhangminglei
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

2018-03-02 Thread ASF GitHub Bot (JIRA)
[ 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 ...

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

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

2018-03-02 Thread ASF GitHub Bot (JIRA)
[ 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...

2018-03-02 Thread yanghua
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. ---

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

2018-03-02 Thread Xpray
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

2018-03-02 Thread ASF GitHub Bot (JIRA)
[ 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

2018-03-02 Thread ASF GitHub Bot (JIRA)
[ 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...

2018-03-02 Thread hequn8128
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] [Resolved] (FLINK-8821) Fix non-terminating decimal error

2018-03-02 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-8821. - Resolution: Fixed Fix Version/s: 1.6.0 1.5.0 Fixed in 1.6.0:

[jira] [Commented] (FLINK-8821) Fix non-terminating decimal error

2018-03-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383351#comment-16383351 ] ASF GitHub Bot commented on FLINK-8821: --- Github user asfgit closed the pull request at:

[jira] [Updated] (FLINK-8833) Create a SQL Client JSON format fat-jar

2018-03-02 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-8833: Summary: Create a SQL Client JSON format fat-jar (was: Create SQL Client JSON format fat-jar) >

[jira] [Assigned] (FLINK-7282) Credit-based Network Flow Control

2018-03-02 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang reassigned FLINK-7282: --- Assignee: zhijiang > Credit-based Network Flow Control > - > >

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

2018-03-02 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-8799: Issue Type: Improvement (was: Bug) > Make AbstractYarnClusterDescriptor immutable >

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

2018-03-02 Thread yanghua
GitHub user yanghua opened a pull request: https://github.com/apache/flink/pull/5617 [FLINK-8799][YARN] Make AbstractYarnClusterDescriptor immutable ## What is the purpose of the change *This pull request Make AbstractYarnClusterDescriptor immutable* ## Brief

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

2018-03-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383393#comment-16383393 ] ASF GitHub Bot commented on FLINK-8799: --- GitHub user yanghua opened a pull request:

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

2018-03-02 Thread Daniel Harper (JIRA)
Daniel Harper created FLINK-8834: Summary: Job fails to restart due to some tasks stuck in cancelling state Key: FLINK-8834 URL: https://issues.apache.org/jira/browse/FLINK-8834 Project: Flink

[GitHub] flink pull request #5608: [FLINK-8821][TableAPI && SQL] Fix non-terminating ...

2018-03-02 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5608 ---

[jira] [Comment Edited] (FLINK-8794) When using BucketingSink, it happens that one of the files is always in the [.in-progress] state

2018-03-02 Thread yanxiaobin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383356#comment-16383356 ] yanxiaobin edited comment on FLINK-8794 at 3/2/18 8:40 AM: --- hi, [~pnowojski]

[jira] [Created] (FLINK-8832) Create a SQL Client Kafka fat-jar

2018-03-02 Thread Timo Walther (JIRA)
Timo Walther created FLINK-8832: --- Summary: Create a SQL Client Kafka fat-jar Key: FLINK-8832 URL: https://issues.apache.org/jira/browse/FLINK-8832 Project: Flink Issue Type: Sub-task

[GitHub] flink pull request #5616: [FLINK-8828] [stream, dataset, scala] Introduce co...

2018-03-02 Thread jelmerk
GitHub user jelmerk opened a pull request: https://github.com/apache/flink/pull/5616 [FLINK-8828] [stream, dataset, scala] Introduce collect method ## What is the purpose of the change A collect function is a method that takes a Partial Function as its parameter and

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

2018-03-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383391#comment-16383391 ] ASF GitHub Bot commented on FLINK-8828: --- GitHub user jelmerk opened a pull request:

[jira] [Assigned] (FLINK-8830) YarnResourceManager throws NullPointerException

2018-03-02 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-8830: --- Assignee: vinoyang > YarnResourceManager throws NullPointerException >

[jira] [Commented] (FLINK-8794) When using BucketingSink, it happens that one of the files is always in the [.in-progress] state

2018-03-02 Thread yanxiaobin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383356#comment-16383356 ] yanxiaobin commented on FLINK-8794: --- hi, [~pnowojski] ! Thank you for your suggestion! The downstream

[jira] [Created] (FLINK-8831) Create SQL Client dependencies

2018-03-02 Thread Timo Walther (JIRA)
Timo Walther created FLINK-8831: --- Summary: Create SQL Client dependencies Key: FLINK-8831 URL: https://issues.apache.org/jira/browse/FLINK-8831 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-8833) Create SQL Client JSON format fat-jar

2018-03-02 Thread Timo Walther (JIRA)
Timo Walther created FLINK-8833: --- Summary: Create SQL Client JSON format fat-jar Key: FLINK-8833 URL: https://issues.apache.org/jira/browse/FLINK-8833 Project: Flink Issue Type: Sub-task

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

2018-03-02 Thread Daniel Harper (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Harper updated FLINK-8834: - Description: Our job threw an exception overnight, causing the job to commence attempting a

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

2018-03-02 Thread Daniel Harper (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Harper updated FLINK-8834: - Environment: AWS EMR 5.12 Flink 1.4.0 Beam 2.3.0 was: EMR 5.12 Flink 1.4.0 Beam 2.3.0 >

[jira] [Created] (FLINK-8830) YarnResourceManager throws NullPointerException

2018-03-02 Thread Piotr Nowojski (JIRA)
Piotr Nowojski created FLINK-8830: - Summary: YarnResourceManager throws NullPointerException Key: FLINK-8830 URL: https://issues.apache.org/jira/browse/FLINK-8830 Project: Flink Issue Type:

[jira] [Closed] (FLINK-8806) Failure in UnionInputGate getNextBufferOrEvent()

2018-03-02 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-8806. -- Resolution: Duplicate > Failure in UnionInputGate getNextBufferOrEvent() >

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

2018-03-02 Thread NicoK
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] [Commented] (FLINK-8623) ConnectionUtilsTest.testReturnLocalHostAddressUsingHeuristics unstable on Travis

2018-03-02 Thread ASF GitHub Bot (JIRA)
[ 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:

[jira] [Comment Edited] (FLINK-8830) YarnResourceManager throws NullPointerException

2018-03-02 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383435#comment-16383435 ] Till Rohrmann edited comment on FLINK-8830 at 3/2/18 10:39 AM: --- Looks like a

[jira] [Commented] (FLINK-8811) Add MiniClusterClient to allow fast MiniCluster operations

2018-03-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383436#comment-16383436 ] ASF GitHub Bot commented on FLINK-8811: --- Github user tillrohrmann commented on a diff in the pull

  1   2   >