[jira] [Commented] (FLINK-10555) Port AkkaSslITCase to new code base

2018-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16679224#comment-16679224 ] ASF GitHub Bot commented on FLINK-10555: TisonKun commented on issue #6849: [FLI

[jira] [Commented] (FLINK-9875) Add concurrent creation of execution job vertex

2018-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16679221#comment-16679221 ] ASF GitHub Bot commented on FLINK-9875: --- TisonKun closed pull request #6353: [FLINK

[jira] [Commented] (FLINK-9875) Add concurrent creation of execution job vertex

2018-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16679220#comment-16679220 ] ASF GitHub Bot commented on FLINK-9875: --- TisonKun commented on issue #6353: [FLINK-

[jira] [Commented] (FLINK-10706) Update the Flink Dashboard and its components

2018-11-07 Thread Yadong Xie (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16679189#comment-16679189 ] Yadong Xie commented on FLINK-10706: [~Zentol] [~wolli] thank you! I will start my

[jira] [Commented] (FLINK-9002) Add operators with input type that goes through Avro serialization (with schema/generic)

2018-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16679345#comment-16679345 ] ASF GitHub Bot commented on FLINK-9002: --- tzulitai commented on issue #7041: [FLINK-

[jira] [Commented] (FLINK-10815) Rethink the rescale operation, can we do it async

2018-11-07 Thread Shimin Yang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16679185#comment-16679185 ] Shimin Yang commented on FLINK-10815: - Thanks [~dawidwys]. I will close this issue.

[jira] [Commented] (FLINK-9002) Add operators with input type that goes through Avro serialization (with schema/generic)

2018-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16679342#comment-16679342 ] ASF GitHub Bot commented on FLINK-9002: --- tzulitai commented on a change in pull req

[jira] [Closed] (FLINK-10815) Rethink the rescale operation, can we do it async

2018-11-07 Thread Shimin Yang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang closed FLINK-10815. --- Resolution: Workaround > Rethink the rescale operation, can we do it async > ---

[GitHub] tzulitai commented on issue #7041: [FLINK-9002] [e2e] Add operators with input type that goes through Avro serialization

2018-11-07 Thread GitBox
tzulitai commented on issue #7041: [FLINK-9002] [e2e] Add operators with input type that goes through Avro serialization URL: https://github.com/apache/flink/pull/7041#issuecomment-436888088 @zentol Thanks, will remember to fix the typo when merging. @dawidwys I addressed your commen

[GitHub] tzulitai commented on a change in pull request #7041: [FLINK-9002] [e2e] Add operators with input type that goes through Avro serialization

2018-11-07 Thread GitBox
tzulitai commented on a change in pull request #7041: [FLINK-9002] [e2e] Add operators with input type that goes through Avro serialization URL: https://github.com/apache/flink/pull/7041#discussion_r231775682 ## File path: flink-end-to-end-tests/flink-datastream-allround-test/src/m

[GitHub] tzulitai commented on a change in pull request #7041: [FLINK-9002] [e2e] Add operators with input type that goes through Avro serialization

2018-11-07 Thread GitBox
tzulitai commented on a change in pull request #7041: [FLINK-9002] [e2e] Add operators with input type that goes through Avro serialization URL: https://github.com/apache/flink/pull/7041#discussion_r231775701 ## File path: flink-end-to-end-tests/flink-datastream-allround-test/src/m

[GitHub] zhijiangW opened a new pull request #7051: [FLINK-10820][network] Simplify the RebalancePartitioner implementation

2018-11-07 Thread GitBox
zhijiangW opened a new pull request #7051: [FLINK-10820][network] Simplify the RebalancePartitioner implementation URL: https://github.com/apache/flink/pull/7051 ## What is the purpose of the change *The current `RebalancePartitioner` implementations seems a little hacky for selecti

[GitHub] asfgit closed pull request #6949: [FLINK-10676][table] Add 'as' method for OverWindowWithOrderBy

2018-11-07 Thread GitBox
asfgit closed pull request #6949: [FLINK-10676][table] Add 'as' method for OverWindowWithOrderBy URL: https://github.com/apache/flink/pull/6949 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As t

[GitHub] sunjincheng121 commented on issue #6949: [FLINK-10676][table] Add 'as' method for OverWindowWithOrderBy

2018-11-07 Thread GitBox
sunjincheng121 commented on issue #6949: [FLINK-10676][table] Add 'as' method for OverWindowWithOrderBy URL: https://github.com/apache/flink/pull/6949#issuecomment-436862717 After the rerun, the error disappeared. no specific reasons are found, so created a JIRA. [FLINK-10819](https://iss

[GitHub] TisonKun commented on issue #6946: [FLINK-10700] [cluster managerment] Remove LegacyStandaloneClusterDes…

2018-11-07 Thread GitBox
TisonKun commented on issue #6946: [FLINK-10700] [cluster managerment] Remove LegacyStandaloneClusterDes… URL: https://github.com/apache/flink/pull/6946#issuecomment-436856580 cc @StefanRRichter @GJL This is an automated mes

[GitHub] TisonKun commented on issue #6872: [FLINK-10436] Add ConfigOption#withFallbackKeys

2018-11-07 Thread GitBox
TisonKun commented on issue #6872: [FLINK-10436] Add ConfigOption#withFallbackKeys URL: https://github.com/apache/flink/pull/6872#issuecomment-436856289 ping @tillrohrmann as we have cut the release branch. This is an automat

[GitHub] TisonKun commented on issue #6849: [FLINK-10555] [test] Port AkkaSslITCase to new code base

2018-11-07 Thread GitBox
TisonKun commented on issue #6849: [FLINK-10555] [test] Port AkkaSslITCase to new code base URL: https://github.com/apache/flink/pull/6849#issuecomment-436855977 re-push for resolving conflict. This is an automated message fr

[GitHub] TisonKun closed pull request #6353: [FLINK-9875][runtime] Add concurrent creation of execution job vertex

2018-11-07 Thread GitBox
TisonKun closed pull request #6353: [FLINK-9875][runtime] Add concurrent creation of execution job vertex URL: https://github.com/apache/flink/pull/6353 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenan

[GitHub] TisonKun commented on issue #6353: [FLINK-9875][runtime] Add concurrent creation of execution job vertex

2018-11-07 Thread GitBox
TisonKun commented on issue #6353: [FLINK-9875][runtime] Add concurrent creation of execution job vertex URL: https://github.com/apache/flink/pull/6353#issuecomment-436855410 close as no consensus, further discussion happened as described above.

[GitHub] TisonKun closed pull request #6345: [FLINK-9869][runtime] Send PartitionInfo in batch to Improve perfornance

2018-11-07 Thread GitBox
TisonKun closed pull request #6345: [FLINK-9869][runtime] Send PartitionInfo in batch to Improve perfornance URL: https://github.com/apache/flink/pull/6345 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of prove

[GitHub] TisonKun commented on issue #6345: [FLINK-9869][runtime] Send PartitionInfo in batch to Improve perfornance

2018-11-07 Thread GitBox
TisonKun commented on issue #6345: [FLINK-9869][runtime] Send PartitionInfo in batch to Improve perfornance URL: https://github.com/apache/flink/pull/6345#issuecomment-436854489 close for no longer interest This is an automat

[GitHub] TisonKun opened a new pull request #7050: [hotfix] Follow up FLINK-6046 to clean unused variable

2018-11-07 Thread GitBox
TisonKun opened a new pull request #7050: [hotfix] Follow up FLINK-6046 to clean unused variable URL: https://github.com/apache/flink/pull/7050 ## What is the purpose of the change After FLINK-6046 5ff07e63d1e9a98959e5edf6687b847d23d5 resolved, we replaced `serializedTaskInforma

[GitHub] sunjincheng121 commented on issue #6949: [FLINK-10676][table] Add 'as' method for OverWindowWithOrderBy

2018-11-07 Thread GitBox
sunjincheng121 commented on issue #6949: [FLINK-10676][table] Add 'as' method for OverWindowWithOrderBy URL: https://github.com/apache/flink/pull/6949#issuecomment-436838520 CI find `JobManagerHAProcessFailureRecoveryITCase.testDispatcherProcessFailure:331 » IllegalArgument` test fail whi

[jira] [Updated] (FLINK-10817) Upgrade presto dependency to support path-style access

2018-11-07 Thread Adam Lamar (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Adam Lamar updated FLINK-10817: --- Description: In order to use any given non-AWS s3 implementation backed by the presto s3 filesystem

[jira] [Created] (FLINK-10817) Upgrade presto dependency to support path-style access

2018-11-07 Thread Adam Lamar (JIRA)
Adam Lamar created FLINK-10817: -- Summary: Upgrade presto dependency to support path-style access Key: FLINK-10817 URL: https://issues.apache.org/jira/browse/FLINK-10817 Project: Flink Issue Type

[jira] [Closed] (FLINK-10682) EOFException occurs during deserialization of Avro class

2018-11-07 Thread Ben La Monica (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ben La Monica closed FLINK-10682. - Resolution: Resolved Fix Version/s: 1.5.5 [~till.rohrmann] that did the trick! It no long

[jira] [Commented] (FLINK-10816) Fix LockableTypeSerializer.duplicate()

2018-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16678568#comment-16678568 ] ASF GitHub Bot commented on FLINK-10816: zentol commented on a change in pull re

[GitHub] zentol commented on issue #7041: [FLINK-9002] [e2e] Add operators with input type that goes through Avro serialization

2018-11-07 Thread GitBox
zentol commented on issue #7041: [FLINK-9002] [e2e] Add operators with input type that goes through Avro serialization URL: https://github.com/apache/flink/pull/7041#issuecomment-436715885 There's a typo in the commit message: `tyoe`-> `type` ---

[jira] [Commented] (FLINK-9002) Add operators with input type that goes through Avro serialization (with schema/generic)

2018-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16678574#comment-16678574 ] ASF GitHub Bot commented on FLINK-9002: --- zentol commented on issue #7041: [FLINK-90

[jira] [Commented] (FLINK-10803) Add documentation about S3 support by the StreamingFileSink

2018-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16678571#comment-16678571 ] ASF GitHub Bot commented on FLINK-10803: zentol commented on a change in pull re

[GitHub] zentol commented on a change in pull request #7046: [FLINK-10803] Update the documentation to include changes to the S3 connector.

2018-11-07 Thread GitBox
zentol commented on a change in pull request #7046: [FLINK-10803] Update the documentation to include changes to the S3 connector. URL: https://github.com/apache/flink/pull/7046#discussion_r231609764 ## File path: docs/dev/connectors/streamfile_sink.md ## @@ -24,16 +24,24

[jira] [Commented] (FLINK-10816) Fix LockableTypeSerializer.duplicate()

2018-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16678557#comment-16678557 ] ASF GitHub Bot commented on FLINK-10816: zentol commented on a change in pull re

[jira] [Commented] (FLINK-10816) Fix LockableTypeSerializer.duplicate()

2018-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16678567#comment-16678567 ] ASF GitHub Bot commented on FLINK-10816: zentol commented on a change in pull re

[GitHub] zentol commented on a change in pull request #7049: [FLINK-10816][cep] Fix LockableTypeSerializer.duplicate() to consider…

2018-11-07 Thread GitBox
zentol commented on a change in pull request #7049: [FLINK-10816][cep] Fix LockableTypeSerializer.duplicate() to consider… URL: https://github.com/apache/flink/pull/7049#discussion_r231609118 ## File path: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffe

[GitHub] zentol commented on a change in pull request #7049: [FLINK-10816][cep] Fix LockableTypeSerializer.duplicate() to consider…

2018-11-07 Thread GitBox
zentol commented on a change in pull request #7049: [FLINK-10816][cep] Fix LockableTypeSerializer.duplicate() to consider… URL: https://github.com/apache/flink/pull/7049#discussion_r231608543 ## File path: flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/sharedbuffe

[GitHub] TisonKun closed pull request #6947: [hotfix] [tests] refactor YARNSessionCapacitySchedulerITCase

2018-11-07 Thread GitBox
TisonKun closed pull request #6947: [hotfix] [tests] refactor YARNSessionCapacitySchedulerITCase URL: https://github.com/apache/flink/pull/6947 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As t

[GitHub] zentol commented on a change in pull request #7049: [FLINK-10816][cep] Fix LockableTypeSerializer.duplicate() to consider…

2018-11-07 Thread GitBox
zentol commented on a change in pull request #7049: [FLINK-10816][cep] Fix LockableTypeSerializer.duplicate() to consider… URL: https://github.com/apache/flink/pull/7049#discussion_r231607022 ## File path: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffe

[jira] [Commented] (FLINK-10816) Fix LockableTypeSerializer.duplicate()

2018-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16678517#comment-16678517 ] ASF GitHub Bot commented on FLINK-10816: StefanRRichter opened a new pull reques

[jira] [Updated] (FLINK-10816) Fix LockableTypeSerializer.duplicate()

2018-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10816: --- Labels: pull-request-available (was: ) > Fix LockableTypeSerializer.duplicate() >

[GitHub] StefanRRichter opened a new pull request #7049: [FLINK-10816][cep] Fix LockableTypeSerializer.duplicate() to consider…

2018-11-07 Thread GitBox
StefanRRichter opened a new pull request #7049: [FLINK-10816][cep] Fix LockableTypeSerializer.duplicate() to consider… URL: https://github.com/apache/flink/pull/7049 … deep duplication of element serializer ## What is the purpose of the change `LockableTypeSerializer.duplicate

[GitHub] zentol commented on a change in pull request #7045: [hotfix] Update nightly master cron jobs

2018-11-07 Thread GitBox
zentol commented on a change in pull request #7045: [hotfix] Update nightly master cron jobs URL: https://github.com/apache/flink/pull/7045#discussion_r231588464 ## File path: splits/split_kubernetes_e2e.sh ## @@ -44,7 +44,6 @@ echo "Flink distribution directory: $FLINK_DI

[GitHub] zentol commented on a change in pull request #7045: [hotfix] Update nightly master cron jobs

2018-11-07 Thread GitBox
zentol commented on a change in pull request #7045: [hotfix] Update nightly master cron jobs URL: https://github.com/apache/flink/pull/7045#discussion_r231588464 ## File path: splits/split_kubernetes_e2e.sh ## @@ -44,7 +44,6 @@ echo "Flink distribution directory: $FLINK_DI

[GitHub] zentol commented on a change in pull request #7045: [hotfix] Update nightly master cron jobs

2018-11-07 Thread GitBox
zentol commented on a change in pull request #7045: [hotfix] Update nightly master cron jobs URL: https://github.com/apache/flink/pull/7045#discussion_r231588225 ## File path: splits/split_misc.sh ## @@ -43,12 +43,16 @@ echo "Flink distribution directory: $FLINK_DIR" #

[jira] [Created] (FLINK-10816) Fix LockableTypeSerializer.duplicate()

2018-11-07 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-10816: -- Summary: Fix LockableTypeSerializer.duplicate() Key: FLINK-10816 URL: https://issues.apache.org/jira/browse/FLINK-10816 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-10815) Rethink the rescale operation, can we do it async

2018-11-07 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16678468#comment-16678468 ] Dawid Wysakowicz commented on FLINK-10815: -- I think the correct way to proceed

[jira] [Commented] (FLINK-10676) Add 'as' method for OverWindowWithOrderBy in Java API

2018-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16678462#comment-16678462 ] ASF GitHub Bot commented on FLINK-10676: sunjincheng121 edited a comment on issu

[GitHub] sunjincheng121 edited a comment on issue #6949: [FLINK-10676][table] Add 'as' method for OverWindowWithOrderBy

2018-11-07 Thread GitBox
sunjincheng121 edited a comment on issue #6949: [FLINK-10676][table] Add 'as' method for OverWindowWithOrderBy URL: https://github.com/apache/flink/pull/6949#issuecomment-436683222 @hequn8128 Thanks for the updated! +1 to merged. Thanks, Jincheng --

[GitHub] sunjincheng121 commented on issue #6949: [FLINK-10676][table] Add 'as' method for OverWindowWithOrderBy

2018-11-07 Thread GitBox
sunjincheng121 commented on issue #6949: [FLINK-10676][table] Add 'as' method for OverWindowWithOrderBy URL: https://github.com/apache/flink/pull/6949#issuecomment-436683222 @hequn8128 Thanks for the updated! + 1 to merged. Thanks, Jincheng

[jira] [Commented] (FLINK-10676) Add 'as' method for OverWindowWithOrderBy in Java API

2018-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16678461#comment-16678461 ] ASF GitHub Bot commented on FLINK-10676: sunjincheng121 commented on issue #6949

[jira] [Comment Edited] (FLINK-10815) Rethink the rescale operation, can we do it async

2018-11-07 Thread Shimin Yang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16678456#comment-16678456 ] Shimin Yang edited comment on FLINK-10815 at 11/7/18 4:19 PM:

[jira] [Assigned] (FLINK-10809) Using DataStreamUtils.reinterpretAsKeyedStream produces corrupted keyed state after restore

2018-11-07 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-10809: -- Assignee: Stefan Richter > Using DataStreamUtils.reinterpretAsKeyedStream produces co

[jira] [Commented] (FLINK-10815) Rethink the rescale operation, can we do it async

2018-11-07 Thread Shimin Yang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16678456#comment-16678456 ] Shimin Yang commented on FLINK-10815: - [~till.rohrmann], I would like to hear your o

[jira] [Updated] (FLINK-10809) Using DataStreamUtils.reinterpretAsKeyedStream produces corrupted keyed state after restore

2018-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10809: --- Labels: pull-request-available (was: ) > Using DataStreamUtils.reinterpretAsKeyedStream pro

[jira] [Commented] (FLINK-10809) Using DataStreamUtils.reinterpretAsKeyedStream produces corrupted keyed state after restore

2018-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16678454#comment-16678454 ] ASF GitHub Bot commented on FLINK-10809: StefanRRichter opened a new pull reques

[GitHub] StefanRRichter opened a new pull request #7048: [FLINK-10809][state] Include keyed state that is not from head operat…

2018-11-07 Thread GitBox
StefanRRichter opened a new pull request #7048: [FLINK-10809][state] Include keyed state that is not from head operat… URL: https://github.com/apache/flink/pull/7048 …ors in state assignment ## What is the purpose of the change This PR includes keyed state that was not from a

[jira] [Commented] (FLINK-10676) Add 'as' method for OverWindowWithOrderBy in Java API

2018-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16678451#comment-16678451 ] ASF GitHub Bot commented on FLINK-10676: hequn8128 commented on issue #6949: [FL

[GitHub] hequn8128 commented on issue #6949: [FLINK-10676][table] Add 'as' method for OverWindowWithOrderBy

2018-11-07 Thread GitBox
hequn8128 commented on issue #6949: [FLINK-10676][table] Add 'as' method for OverWindowWithOrderBy URL: https://github.com/apache/flink/pull/6949#issuecomment-436680634 Hi @sunjincheng121 , thanks a lot for your view. I think all of the suggestions are good! I have addressed the comments a

[jira] [Created] (FLINK-10815) Rethink the rescale operation, can we do it async

2018-11-07 Thread Shimin Yang (JIRA)
Shimin Yang created FLINK-10815: --- Summary: Rethink the rescale operation, can we do it async Key: FLINK-10815 URL: https://issues.apache.org/jira/browse/FLINK-10815 Project: Flink Issue Type: I

[GitHub] kl0u commented on issue #7047: [FLINK-10522] Check if RecoverableWriter supportsResume() and act accordingly.

2018-11-07 Thread GitBox
kl0u commented on issue #7047: [FLINK-10522] Check if RecoverableWriter supportsResume() and act accordingly. URL: https://github.com/apache/flink/pull/7047#issuecomment-436675707 R @azagrebin This is an automated message fr

[jira] [Commented] (FLINK-10522) Check if RecoverableWriter supportsResume and act accordingly.

2018-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16678437#comment-16678437 ] ASF GitHub Bot commented on FLINK-10522: kl0u commented on issue #7047: [FLINK-1

[jira] [Commented] (FLINK-10522) Check if RecoverableWriter supportsResume and act accordingly.

2018-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16678420#comment-16678420 ] ASF GitHub Bot commented on FLINK-10522: kl0u opened a new pull request #7047: [

[jira] [Updated] (FLINK-10522) Check if RecoverableWriter supportsResume and act accordingly.

2018-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10522: --- Labels: pull-request-available (was: ) > Check if RecoverableWriter supportsResume and act

[GitHub] kl0u opened a new pull request #7047: [FLINK-10522] Check if RecoverableWriter supportsResume() and act accordingly.

2018-11-07 Thread GitBox
kl0u opened a new pull request #7047: [FLINK-10522] Check if RecoverableWriter supportsResume() and act accordingly. URL: https://github.com/apache/flink/pull/7047 ## What is the purpose of the change So far, the `StreamingFileSink` was always resuming when recovering from a checkpo

[jira] [Commented] (FLINK-10803) Add documentation about S3 support by the StreamingFileSink

2018-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16678409#comment-16678409 ] ASF GitHub Bot commented on FLINK-10803: kl0u commented on issue #7046: [FLINK-1

[jira] [Reopened] (FLINK-10361) Elasticsearch (v6.3.1) sink end-to-end test instable

2018-11-07 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reopened FLINK-10361: -- Assignee: (was: Biao Liu) Apparently, this issue is not fixed entirely. I got the same e

[GitHub] kl0u commented on issue #7046: [FLINK-10803] Update the documentation to include changes to the S3 connector.

2018-11-07 Thread GitBox
kl0u commented on issue #7046: [FLINK-10803] Update the documentation to include changes to the S3 connector. URL: https://github.com/apache/flink/pull/7046#issuecomment-436667078 R @GJL , @twalthr , @aljoscha This is an aut

[jira] [Commented] (FLINK-10803) Add documentation about S3 support by the StreamingFileSink

2018-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16678406#comment-16678406 ] ASF GitHub Bot commented on FLINK-10803: kl0u opened a new pull request #7046: [

[jira] [Updated] (FLINK-10803) Add documentation about S3 support by the StreamingFileSink

2018-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10803: --- Labels: pull-request-available (was: ) > Add documentation about S3 support by the Streamin

[GitHub] kl0u opened a new pull request #7046: [FLINK-10803] Update the documentation to include changes to the S3 connector.

2018-11-07 Thread GitBox
kl0u opened a new pull request #7046: [FLINK-10803] Update the documentation to include changes to the S3 connector. URL: https://github.com/apache/flink/pull/7046 This PR simply documents already introduced changes. To build the docs and verify the change go to the `FLINK_DIR/docs/`

[jira] [Commented] (FLINK-10676) Add 'as' method for OverWindowWithOrderBy in Java API

2018-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16678405#comment-16678405 ] ASF GitHub Bot commented on FLINK-10676: hequn8128 commented on a change in pull

[GitHub] hequn8128 commented on a change in pull request #6949: [FLINK-10676][table] Add 'as' method for OverWindowWithOrderBy

2018-11-07 Thread GitBox
hequn8128 commented on a change in pull request #6949: [FLINK-10676][table] Add 'as' method for OverWindowWithOrderBy URL: https://github.com/apache/flink/pull/6949#discussion_r231555804 ## File path: docs/dev/table/tableApi.md ## @@ -1571,13 +1571,15 @@ The `OverWindow` d

[GitHub] twalthr opened a new pull request #7045: [hotfix] Update nightly master cron jobs

2018-11-07 Thread GitBox
twalthr opened a new pull request #7045: [hotfix] Update nightly master cron jobs URL: https://github.com/apache/flink/pull/7045 ## What is the purpose of the change This PR updates the nightly master cron jobs to be in sync with the available end-to-end tests. ## Brief chang

[jira] [Commented] (FLINK-10676) Add 'as' method for OverWindowWithOrderBy in Java API

2018-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16678374#comment-16678374 ] ASF GitHub Bot commented on FLINK-10676: sunjincheng121 commented on a change in

[jira] [Commented] (FLINK-10676) Add 'as' method for OverWindowWithOrderBy in Java API

2018-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16678376#comment-16678376 ] ASF GitHub Bot commented on FLINK-10676: sunjincheng121 commented on a change in

[jira] [Commented] (FLINK-10676) Add 'as' method for OverWindowWithOrderBy in Java API

2018-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16678375#comment-16678375 ] ASF GitHub Bot commented on FLINK-10676: sunjincheng121 commented on a change in

[GitHub] sunjincheng121 commented on a change in pull request #6949: [FLINK-10676][table] Add 'as' method for OverWindowWithOrderBy

2018-11-07 Thread GitBox
sunjincheng121 commented on a change in pull request #6949: [FLINK-10676][table] Add 'as' method for OverWindowWithOrderBy URL: https://github.com/apache/flink/pull/6949#discussion_r231493947 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/java/w

[GitHub] sunjincheng121 commented on a change in pull request #6949: [FLINK-10676][table] Add 'as' method for OverWindowWithOrderBy

2018-11-07 Thread GitBox
sunjincheng121 commented on a change in pull request #6949: [FLINK-10676][table] Add 'as' method for OverWindowWithOrderBy URL: https://github.com/apache/flink/pull/6949#discussion_r231500755 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/scala/

[GitHub] sunjincheng121 commented on a change in pull request #6949: [FLINK-10676][table] Add 'as' method for OverWindowWithOrderBy

2018-11-07 Thread GitBox
sunjincheng121 commented on a change in pull request #6949: [FLINK-10676][table] Add 'as' method for OverWindowWithOrderBy URL: https://github.com/apache/flink/pull/6949#discussion_r231500525 ## File path: docs/dev/table/tableApi.md ## @@ -1571,13 +1571,15 @@ The `OverWind

[jira] [Updated] (FLINK-10213) Task managers cache a negative DNS lookup of the blob server indefinitely

2018-11-07 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun updated FLINK-10213: - Fix Version/s: 1.8.0 > Task managers cache a negative DNS lookup of the blob server indefinitely > -

[jira] [Updated] (FLINK-10812) javadoc-plugin fails for flink-e2e-test-utils

2018-11-07 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-10812: - Summary: javadoc-plugin fails for flink-e2e-test-utils (was: Snapshot deployment broken

[jira] [Commented] (FLINK-10813) Automatically seach for missing scala suffixes

2018-11-07 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16678352#comment-16678352 ] Chesnay Schepler commented on FLINK-10813: -- Not as simple unfortunately. Basica

[jira] [Assigned] (FLINK-10803) Add documentation about S3 support by the StreamingFileSink

2018-11-07 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-10803: -- Assignee: Kostas Kloudas > Add documentation about S3 support by the StreamingFileSin

[jira] [Closed] (FLINK-10812) javadoc-plugin fails for flink-e2e-test-utils

2018-11-07 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-10812. Resolution: Fixed > javadoc-plugin fails for flink-e2e-test-utils > --

[jira] [Closed] (FLINK-10812) Snapshot deployment broken for master

2018-11-07 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-10812. Resolution: Fixed master: 3abf676911ab782ed7dcfcb4f7c3b4bf06a6b2e4 1.7: ef4394188988568f80

[jira] [Reopened] (FLINK-10812) Snapshot deployment broken for master

2018-11-07 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-10812: -- > Snapshot deployment broken for master > - > >

[jira] [Assigned] (FLINK-10625) Add MATCH_RECOGNIZE documentation

2018-11-07 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-10625: Assignee: Dawid Wysakowicz > Add MATCH_RECOGNIZE documentation >

[jira] [Assigned] (FLINK-10814) Kafka examples modules need scala suffix

2018-11-07 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-10814: Assignee: (was: Chesnay Schepler) > Kafka examples modules need scala suffix

[jira] [Commented] (FLINK-10419) ClassNotFoundException while deserializing user exceptions from checkpointing

2018-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16678327#comment-16678327 ] ASF GitHub Bot commented on FLINK-10419: NicoK commented on issue #7033: [FLINK-

[jira] [Comment Edited] (FLINK-10674) DistinctAccumulator.remove lead to NPE

2018-11-07 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16678335#comment-16678335 ] Timo Walther edited comment on FLINK-10674 at 11/7/18 2:55 PM: ---

[jira] [Resolved] (FLINK-10797) "IntelliJ Setup" link is broken in Readme.md

2018-11-07 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun resolved FLINK-10797. -- Resolution: Fixed master(1.8-SNAPSHOT) at https://github.com/apache/flink/commit/1a0a005eea2247ce2628

[jira] [Created] (FLINK-10814) Kafka examples modules need scala suffix

2018-11-07 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-10814: Summary: Kafka examples modules need scala suffix Key: FLINK-10814 URL: https://issues.apache.org/jira/browse/FLINK-10814 Project: Flink Issue Type:

[jira] [Commented] (FLINK-10674) DistinctAccumulator.remove lead to NPE

2018-11-07 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16678335#comment-16678335 ] Timo Walther commented on FLINK-10674: -- [~winipanda] have you started working on th

[jira] [Commented] (FLINK-10812) Snapshot deployment broken for master

2018-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16678330#comment-16678330 ] ASF GitHub Bot commented on FLINK-10812: zentol closed pull request #7044: [FLIN

[jira] [Assigned] (FLINK-10419) ClassNotFoundException while deserializing user exceptions from checkpointing

2018-11-07 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reassigned FLINK-10419: --- Assignee: (was: Nico Kruber) > ClassNotFoundException while deserializing user exceptio

[GitHub] zentol closed pull request #7044: [FLINK-10812][build] Skip javadoc plugin for e2e-test-utils

2018-11-07 Thread GitBox
zentol closed pull request #7044: [FLINK-10812][build] Skip javadoc plugin for e2e-test-utils URL: https://github.com/apache/flink/pull/7044 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this

[jira] [Commented] (FLINK-10419) ClassNotFoundException while deserializing user exceptions from checkpointing

2018-11-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16678328#comment-16678328 ] ASF GitHub Bot commented on FLINK-10419: NicoK closed pull request #7033: [FLINK

[GitHub] NicoK commented on issue #7033: [FLINK-10419][checkpoint] fix ClassNotFoundException while deserializing user exceptions

2018-11-07 Thread GitBox
NicoK commented on issue #7033: [FLINK-10419][checkpoint] fix ClassNotFoundException while deserializing user exceptions URL: https://github.com/apache/flink/pull/7033#issuecomment-436647987 True, this only helps with the old non-Flip6 code. I guess, the `declineCheckpoint()` RPC method sh

[GitHub] NicoK closed pull request #7033: [FLINK-10419][checkpoint] fix ClassNotFoundException while deserializing user exceptions

2018-11-07 Thread GitBox
NicoK closed pull request #7033: [FLINK-10419][checkpoint] fix ClassNotFoundException while deserializing user exceptions URL: https://github.com/apache/flink/pull/7033 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the

[jira] [Closed] (FLINK-10750) SocketClientSinkTest.testRetry fails on Travis

2018-11-07 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-10750. - Resolution: Fixed Fix Version/s: 1.6.3 1.5.6 Fixed via master: dfe7be7

[jira] [Commented] (FLINK-10682) EOFException occurs during deserialization of Avro class

2018-11-07 Thread Ben La Monica (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16678306#comment-16678306 ] Ben La Monica commented on FLINK-10682: --- Thank you, I'll give it a try. > EOFExce

  1   2   3   >