[jira] [Assigned] (FLINK-8573) Print JobID for failed jobs

2018-02-09 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang reassigned FLINK-8573: --- Assignee: mingleizhang > Print JobID for failed jobs > --- > >

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

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16359307#comment-16359307 ] ASF GitHub Bot commented on FLINK-8623: --- GitHub user zhangminglei opened a pull requ

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

2018-02-09 Thread zhangminglei
GitHub user zhangminglei opened a pull request: https://github.com/apache/flink/pull/5449 [FLINK-8623] ConnectionUtilsTest.testReturnLocalHostAddressUsingHeuri… ## What is the purpose of the change Try to fix ConnectionUtilsTest.testReturnLocalHostAddressUsingHeuristics unstab

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

2018-02-09 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16359303#comment-16359303 ] mingleizhang commented on FLINK-8623: - {\{getLocalHost()}} returns the actual IP of on

[jira] [Commented] (FLINK-6469) Configure Memory Sizes with units

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

[GitHub] flink pull request #5448: [FLINK-6469] Configure Memory Sizes with units

2018-02-09 Thread yanghua
GitHub user yanghua opened a pull request: https://github.com/apache/flink/pull/5448 [FLINK-6469] Configure Memory Sizes with units You can merge this pull request into a Git repository by running: $ git pull https://github.com/yanghua/flink FLINK-6469 Alternatively you can r

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

2018-02-09 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16359289#comment-16359289 ] mingleizhang commented on FLINK-8623: - Hi, [~till.rohrmann] The expected address is 12

[jira] [Commented] (FLINK-8360) Implement task-local state recovery

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16359252#comment-16359252 ] ASF GitHub Bot commented on FLINK-8360: --- Github user bowenli86 commented on a diff i

[jira] [Commented] (FLINK-8360) Implement task-local state recovery

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16359255#comment-16359255 ] ASF GitHub Bot commented on FLINK-8360: --- Github user bowenli86 commented on a diff i

[jira] [Commented] (FLINK-8360) Implement task-local state recovery

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16359261#comment-16359261 ] ASF GitHub Bot commented on FLINK-8360: --- Github user bowenli86 commented on a diff i

[jira] [Commented] (FLINK-8360) Implement task-local state recovery

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16359254#comment-16359254 ] ASF GitHub Bot commented on FLINK-8360: --- Github user bowenli86 commented on a diff i

[jira] [Commented] (FLINK-8360) Implement task-local state recovery

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16359256#comment-16359256 ] ASF GitHub Bot commented on FLINK-8360: --- Github user bowenli86 commented on a diff i

[jira] [Commented] (FLINK-8360) Implement task-local state recovery

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16359260#comment-16359260 ] ASF GitHub Bot commented on FLINK-8360: --- Github user bowenli86 commented on a diff i

[jira] [Commented] (FLINK-8360) Implement task-local state recovery

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16359258#comment-16359258 ] ASF GitHub Bot commented on FLINK-8360: --- Github user bowenli86 commented on a diff i

[jira] [Commented] (FLINK-8360) Implement task-local state recovery

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16359250#comment-16359250 ] ASF GitHub Bot commented on FLINK-8360: --- Github user bowenli86 commented on a diff i

[jira] [Commented] (FLINK-8360) Implement task-local state recovery

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16359262#comment-16359262 ] ASF GitHub Bot commented on FLINK-8360: --- Github user bowenli86 commented on a diff i

[jira] [Commented] (FLINK-8360) Implement task-local state recovery

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16359257#comment-16359257 ] ASF GitHub Bot commented on FLINK-8360: --- Github user bowenli86 commented on a diff i

[jira] [Commented] (FLINK-8360) Implement task-local state recovery

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16359253#comment-16359253 ] ASF GitHub Bot commented on FLINK-8360: --- Github user bowenli86 commented on a diff i

[jira] [Commented] (FLINK-8360) Implement task-local state recovery

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16359263#comment-16359263 ] ASF GitHub Bot commented on FLINK-8360: --- Github user bowenli86 commented on a diff i

[jira] [Commented] (FLINK-8360) Implement task-local state recovery

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16359259#comment-16359259 ] ASF GitHub Bot commented on FLINK-8360: --- Github user bowenli86 commented on a diff i

[jira] [Commented] (FLINK-8360) Implement task-local state recovery

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16359251#comment-16359251 ] ASF GitHub Bot commented on FLINK-8360: --- Github user bowenli86 commented on a diff i

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

2018-02-09 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r167356160 --- Diff: docs/ops/state/large_state_tuning.md --- @@ -234,4 +234,97 @@ Compression can be activated through the `ExecutionConfig`: **Notice:** The co

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

2018-02-09 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r167355160 --- Diff: docs/ops/state/large_state_tuning.md --- @@ -234,4 +234,97 @@ Compression can be activated through the `ExecutionConfig`: **Notice:** The co

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

2018-02-09 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r167389639 --- Diff: docs/ops/state/large_state_tuning.md --- @@ -234,4 +234,97 @@ Compression can be activated through the `ExecutionConfig`: **Notice:** The co

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

2018-02-09 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r167357375 --- Diff: docs/ops/state/large_state_tuning.md --- @@ -234,4 +234,97 @@ Compression can be activated through the `ExecutionConfig`: **Notice:** The co

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

2018-02-09 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r167356732 --- Diff: docs/ops/state/large_state_tuning.md --- @@ -234,4 +234,97 @@ Compression can be activated through the `ExecutionConfig`: **Notice:** The co

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

2018-02-09 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r167354757 --- Diff: docs/ops/state/large_state_tuning.md --- @@ -234,4 +234,97 @@ Compression can be activated through the `ExecutionConfig`: **Notice:** The co

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

2018-02-09 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r167357486 --- Diff: docs/ops/state/large_state_tuning.md --- @@ -234,4 +234,97 @@ Compression can be activated through the `ExecutionConfig`: **Notice:** The co

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

2018-02-09 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r167356422 --- Diff: docs/ops/state/large_state_tuning.md --- @@ -234,4 +234,97 @@ Compression can be activated through the `ExecutionConfig`: **Notice:** The co

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

2018-02-09 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r167389638 --- Diff: docs/ops/state/large_state_tuning.md --- @@ -234,4 +234,97 @@ Compression can be activated through the `ExecutionConfig`: **Notice:** The co

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

2018-02-09 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r167354956 --- Diff: docs/ops/state/large_state_tuning.md --- @@ -234,4 +234,97 @@ Compression can be activated through the `ExecutionConfig`: **Notice:** The co

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

2018-02-09 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r167355583 --- Diff: docs/ops/state/large_state_tuning.md --- @@ -234,4 +234,97 @@ Compression can be activated through the `ExecutionConfig`: **Notice:** The co

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

2018-02-09 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r167356561 --- Diff: docs/ops/state/large_state_tuning.md --- @@ -234,4 +234,97 @@ Compression can be activated through the `ExecutionConfig`: **Notice:** The co

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

2018-02-09 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r167357164 --- Diff: docs/ops/state/large_state_tuning.md --- @@ -234,4 +234,97 @@ Compression can be activated through the `ExecutionConfig`: **Notice:** The co

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

2018-02-09 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r167357036 --- Diff: docs/ops/state/large_state_tuning.md --- @@ -234,4 +234,97 @@ Compression can be activated through the `ExecutionConfig`: **Notice:** The co

[jira] [Commented] (FLINK-8577) Implement proctime DataStream to Table upsert conversion.

2018-02-09 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16359247#comment-16359247 ] Hequn Cheng commented on FLINK-8577: Hi, [~fhueske] [~twalthr] Agree, I also prefer o

[jira] [Commented] (FLINK-8423) OperatorChain#pushToOperator catch block may fail with NPE

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16359213#comment-16359213 ] ASF GitHub Bot commented on FLINK-8423: --- GitHub user zhangminglei opened a pull requ

[GitHub] flink pull request #5447: [FLINK-8423] OperatorChain#pushToOperator catch bl...

2018-02-09 Thread zhangminglei
GitHub user zhangminglei opened a pull request: https://github.com/apache/flink/pull/5447 [FLINK-8423] OperatorChain#pushToOperator catch block may fail with NPE ## What is the purpose of the change Fix the NPE when outputTag is null. ## Brief change log Add whe

[jira] [Commented] (FLINK-8423) OperatorChain#pushToOperator catch block may fail with NPE

2018-02-09 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16359208#comment-16359208 ] mingleizhang commented on FLINK-8423: - Hi, [~Zentol] Does this NPE will make the jvm d

[jira] [Commented] (FLINK-8617) Fix code generation bug while accessing Map type

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16359198#comment-16359198 ] ASF GitHub Bot commented on FLINK-8617: --- Github user Xpray commented on the issue:

[GitHub] flink issue #5438: [FLINK-8617][TableAPI & SQL] Fix code generation bug whil...

2018-02-09 Thread Xpray
Github user Xpray commented on the issue: https://github.com/apache/flink/pull/5438 @twalthr the PR has been updated, please have a look. ---

[jira] [Commented] (FLINK-8629) Allow JobMaster to rescale jobs

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16358897#comment-16358897 ] ASF GitHub Bot commented on FLINK-8629: --- GitHub user tillrohrmann opened a pull requ

[GitHub] flink pull request #5446: [FLINK-8629] [flip6] Allow JobMaster to rescale jo...

2018-02-09 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5446 [FLINK-8629] [flip6] Allow JobMaster to rescale jobs ## What is the purpose of the change This commit adds the functionality to rescale a job or parts of it to the JobMaster. In ord

[jira] [Created] (FLINK-8629) Allow JobMaster to rescale jobs

2018-02-09 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-8629: Summary: Allow JobMaster to rescale jobs Key: FLINK-8629 URL: https://issues.apache.org/jira/browse/FLINK-8629 Project: Flink Issue Type: New Feature

[jira] [Updated] (FLINK-8628) BucketingSink does not work with S3

2018-02-09 Thread dejan miljkovic (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dejan miljkovic updated FLINK-8628: --- Description: BucketingSink does not work wit S3. Followed instructions provided on  [https://

[jira] [Created] (FLINK-8628) BucketingSink does not work wit S3

2018-02-09 Thread dejan miljkovic (JIRA)
dejan miljkovic created FLINK-8628: -- Summary: BucketingSink does not work wit S3 Key: FLINK-8628 URL: https://issues.apache.org/jira/browse/FLINK-8628 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-8627) Introduce SUSPENDING state

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16358780#comment-16358780 ] ASF GitHub Bot commented on FLINK-8627: --- GitHub user tillrohrmann opened a pull requ

[GitHub] flink pull request #5445: [FLINK-8627] Introduce new JobStatus#SUSPENDING

2018-02-09 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5445 [FLINK-8627] Introduce new JobStatus#SUSPENDING ## What is the purpose of the change The new JobStatus#SUSPENDING says that an ExecutionGraph has been suspended but its clean up ha

[jira] [Created] (FLINK-8627) Introduce SUSPENDING state

2018-02-09 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-8627: Summary: Introduce SUSPENDING state Key: FLINK-8627 URL: https://issues.apache.org/jira/browse/FLINK-8627 Project: Flink Issue Type: Improvement Co

[jira] [Closed] (FLINK-8571) Provide an enhanced KeyedStream implementation to use ForwardPartitioner

2018-02-09 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8571. - Resolution: Fixed Fix Version/s: 1.4.1 1.5.0 Merged in 91eea376ee. Merg

[GitHub] flink pull request #5424: FLINK-8571] [DataStream] Introduce utility functio...

2018-02-09 Thread StefanRRichter
Github user StefanRRichter closed the pull request at: https://github.com/apache/flink/pull/5424 ---

[jira] [Commented] (FLINK-8571) Provide an enhanced KeyedStream implementation to use ForwardPartitioner

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16358730#comment-16358730 ] ASF GitHub Bot commented on FLINK-8571: --- Github user StefanRRichter closed the pull

[jira] [Commented] (FLINK-8456) Add Scala API for Connected Streams with Broadcast State.

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

[jira] [Closed] (FLINK-8456) Add Scala API for Connected Streams with Broadcast State.

2018-02-09 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-8456. - Resolution: Fixed Merged on master at 9628dc8917b2f69bb04119c1d41932076632de01 > Add Scala API fo

[GitHub] flink pull request #5425: [FLINK-8456] Add Scala API for Connected Streams w...

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

[jira] [Closed] (FLINK-8597) Add examples for Connected Streams with Broadcast State.

2018-02-09 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-8597. - Resolution: Fixed Merged on master at dea4172604126fc40fc8fbf7f83a632733bd0dfb > Add examples for

[jira] [Commented] (FLINK-8571) Provide an enhanced KeyedStream implementation to use ForwardPartitioner

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16358699#comment-16358699 ] ASF GitHub Bot commented on FLINK-8571: --- Github user StefanRRichter commented on the

[GitHub] flink issue #5424: FLINK-8571] [DataStream] Introduce utility function that ...

2018-02-09 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/5424 Thanks for the review @aljoscha. Will merge. ---

[GitHub] flink issue #5048: [Flink-7871] [flip6] SlotPool should release unused slots...

2018-02-09 Thread ifndef-SleePy
Github user ifndef-SleePy commented on the issue: https://github.com/apache/flink/pull/5048 Hi @tillrohrmann , I just updated the PR, sorry for delaying so long. ---

[jira] [Commented] (FLINK-8571) Provide an enhanced KeyedStream implementation to use ForwardPartitioner

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16358641#comment-16358641 ] ASF GitHub Bot commented on FLINK-8571: --- Github user StefanRRichter closed the pull

[GitHub] flink pull request #5439: [FLINK-8571] [DataStream] [Backport] Introduce uti...

2018-02-09 Thread StefanRRichter
Github user StefanRRichter closed the pull request at: https://github.com/apache/flink/pull/5439 ---

[GitHub] flink issue #5439: [FLINK-8571] [DataStream] [Backport] Introduce utility fu...

2018-02-09 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/5439 Thanks for the reviews! Will merge. ---

[jira] [Commented] (FLINK-8571) Provide an enhanced KeyedStream implementation to use ForwardPartitioner

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16358624#comment-16358624 ] ASF GitHub Bot commented on FLINK-8571: --- Github user StefanRRichter commented on the

[jira] [Commented] (FLINK-8626) Introduce BackPressureStatsTracker interface

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16358589#comment-16358589 ] ASF GitHub Bot commented on FLINK-8626: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-8626) Introduce BackPressureStatsTracker interface

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16358588#comment-16358588 ] ASF GitHub Bot commented on FLINK-8626: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #5443: [FLINK-8626] Introduce BackPressureStatsTracker in...

2018-02-09 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5443#discussion_r167267838 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/WebRuntimeMonitor.java --- @@ -143,7 +143,7 @@ private final Stac

[GitHub] flink pull request #5443: [FLINK-8626] Introduce BackPressureStatsTracker in...

2018-02-09 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5443#discussion_r167268048 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/backpressure/VoidBackPressureStatsTracker.java --- @@ -0,0 +1,36 @@ +/

[jira] [Commented] (FLINK-8456) Add Scala API for Connected Streams with Broadcast State.

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16358582#comment-16358582 ] ASF GitHub Bot commented on FLINK-8456: --- Github user aljoscha commented on the issue

[GitHub] flink issue #5425: [FLINK-8456] Add Scala API for Connected Streams with Bro...

2018-02-09 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5425 I think this looks good now. ---

[jira] [Commented] (FLINK-8571) Provide an enhanced KeyedStream implementation to use ForwardPartitioner

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16358559#comment-16358559 ] ASF GitHub Bot commented on FLINK-8571: --- Github user tzulitai commented on the issue

[GitHub] flink issue #5439: [FLINK-8571] [DataStream] [Backport] Introduce utility fu...

2018-02-09 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5439 LGTM once Travis is green. We should also remove the redundant mention of FLINK-8571 in `ReinterpretAsKeyedStreamITCase` while merging. ---

[jira] [Commented] (FLINK-8546) Respect savepoint settings and recover from latest checkpoint in Flip-6

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16358518#comment-16358518 ] ASF GitHub Bot commented on FLINK-8546: --- GitHub user tillrohrmann opened a pull requ

[GitHub] flink pull request #5444: [FLINK-8546] [flip6] Respect savepoints and restor...

2018-02-09 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5444 [FLINK-8546] [flip6] Respect savepoints and restore from latest checkpoints ## What is the purpose of the change Let the JobMaster respect checkpoints and savepoints. The JobMaster will

[jira] [Commented] (FLINK-8573) Print JobID for failed jobs

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16358511#comment-16358511 ] ASF GitHub Bot commented on FLINK-8573: --- Github user zhangminglei commented on the i

[GitHub] flink issue #5421: [FLINK-8573] [client] Add more information for printing J...

2018-02-09 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/5421 The CI error does not relevant to this PR. ```BackPressureStatsTrackerITCase``` test failed. ---

[jira] [Commented] (FLINK-8626) Introduce BackPressureStatsTracker interface

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16358509#comment-16358509 ] ASF GitHub Bot commented on FLINK-8626: --- GitHub user tillrohrmann opened a pull requ

[GitHub] flink pull request #5443: [FLINK-8626] Introduce BackPressureStatsTracker in...

2018-02-09 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5443 [FLINK-8626] Introduce BackPressureStatsTracker interface ## What is the purpose of the change Renames BackPressureStatsTracker into BackPressureStatsTrackerImpl and introduce a Ba

[jira] [Created] (FLINK-8626) Introduce BackPressureStatsTracker interface

2018-02-09 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-8626: Summary: Introduce BackPressureStatsTracker interface Key: FLINK-8626 URL: https://issues.apache.org/jira/browse/FLINK-8626 Project: Flink Issue Type: Improv

[jira] [Commented] (FLINK-7713) Port JarUploadHandler to new REST endpoint

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16358506#comment-16358506 ] ASF GitHub Bot commented on FLINK-7713: --- Github user GJL commented on a diff in the

[GitHub] flink pull request #5442: [FLINK-7713][flip6] Implement JarUploadHandler

2018-02-09 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5442#discussion_r167250379 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/ng/JarUploadHandler.java --- @@ -0,0 +1,103 @@ +/* + * Licensed t

[jira] [Commented] (FLINK-7713) Port JarUploadHandler to new REST endpoint

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16358504#comment-16358504 ] ASF GitHub Bot commented on FLINK-7713: --- Github user GJL commented on a diff in the

[GitHub] flink pull request #5442: [FLINK-7713][flip6] Implement JarUploadHandler

2018-02-09 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5442#discussion_r167249950 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorUtils.java --- @@ -207,6 +215,53 @@ public static WebMonitor startWebRuntime

[jira] [Commented] (FLINK-7713) Port JarUploadHandler to new REST endpoint

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16358503#comment-16358503 ] ASF GitHub Bot commented on FLINK-7713: --- Github user GJL commented on a diff in the

[GitHub] flink pull request #5442: [FLINK-7713][flip6] Implement JarUploadHandler

2018-02-09 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5442#discussion_r167249729 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorUtils.java --- @@ -207,6 +215,53 @@ public static WebMonitor startWebRuntime

[jira] [Commented] (FLINK-7713) Port JarUploadHandler to new REST endpoint

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16358499#comment-16358499 ] ASF GitHub Bot commented on FLINK-7713: --- Github user GJL commented on a diff in the

[jira] [Commented] (FLINK-7713) Port JarUploadHandler to new REST endpoint

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16358500#comment-16358500 ] ASF GitHub Bot commented on FLINK-7713: --- Github user GJL commented on a diff in the

[GitHub] flink pull request #5442: [FLINK-7713][flip6] Implement JarUploadHandler

2018-02-09 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5442#discussion_r167249371 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/ng/JarUploadResponseBody.java --- @@ -0,0 +1,58 @@ +/* + * Licens

[GitHub] flink pull request #5442: [FLINK-7713][flip6] Implement JarUploadHandler

2018-02-09 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5442#discussion_r167249285 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/ng/JarUploadHandler.java --- @@ -0,0 +1,103 @@ +/* + * Licensed t

[jira] [Commented] (FLINK-7713) Port JarUploadHandler to new REST endpoint

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

[GitHub] flink pull request #5442: [FLINK-7713][flip6] Implement JarUploadHandler

2018-02-09 Thread GJL
GitHub user GJL opened a pull request: https://github.com/apache/flink/pull/5442 [FLINK-7713][flip6] Implement JarUploadHandler ## What is the purpose of the change *Allow uploading jars through HTTP to enable job submissions from the web ui.* cc: @tillrohrmann

[jira] [Commented] (FLINK-8538) Add a Kafka table source factory with JSON format support

2018-02-09 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16358494#comment-16358494 ] Xingcan Cui commented on FLINK-8538: Thanks for the comments [~twalthr] and [~fhueske]

[jira] [Updated] (FLINK-8625) Move OutputFlusher thread to Netty scheduled executor

2018-02-09 Thread Ken Krugler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ken Krugler updated FLINK-8625: --- Summary: Move OutputFlusher thread to Netty scheduled executor (was: Move OutputFlasherThread to Nett

[jira] [Commented] (FLINK-8607) Add a basic embedded SQL CLI client

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

[GitHub] flink pull request #5441: [FLINK-8607] [table] Add a basic embedded SQL CLI ...

2018-02-09 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/5441 [FLINK-8607] [table] Add a basic embedded SQL CLI client ## What is the purpose of the change This PR implements the first part of the implementation plan described in FLIP-24. ```

[jira] [Commented] (FLINK-8617) Fix code generation bug while accessing Map type

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16358470#comment-16358470 ] ASF GitHub Bot commented on FLINK-8617: --- Github user Xpray commented on the issue:

[GitHub] flink issue #5438: [FLINK-8617][TableAPI & SQL] Fix code generation bug whil...

2018-02-09 Thread Xpray
Github user Xpray commented on the issue: https://github.com/apache/flink/pull/5438 I've removed the ITCase and add some tests to ```org.apache.flink.table.expressions.MapTypeTest ``` ---

[jira] [Commented] (FLINK-8571) Provide an enhanced KeyedStream implementation to use ForwardPartitioner

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16358451#comment-16358451 ] ASF GitHub Bot commented on FLINK-8571: --- Github user StefanRRichter commented on the

[GitHub] flink issue #5439: [FLINK-8571] [DataStream] [Backport] Introduce utility fu...

2018-02-09 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/5439 Added the test. ---

[jira] [Commented] (FLINK-6428) Add support DISTINCT in dataStream SQL

2018-02-09 Thread Lynch Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16358399#comment-16358399 ] Lynch Lee commented on FLINK-6428: -- OK。 [~fhueske], Thanks your explaination . I got it c

[jira] [Commented] (FLINK-8456) Add Scala API for Connected Streams with Broadcast State.

2018-02-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16358384#comment-16358384 ] ASF GitHub Bot commented on FLINK-8456: --- Github user kl0u commented on the issue:

  1   2   >