[jira] [Commented] (FLINK-11162) Provide a rest API to list all logical operators

2018-12-13 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16721022#comment-16721022 ] vinoyang commented on FLINK-11162: -- We need to get the correspondence between the logical operator id

[GitHub] klion26 commented on issue #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS

2018-12-13 Thread GitBox
klion26 commented on issue #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS URL: https://github.com/apache/flink/pull/6777#issuecomment-447240579 thank you @azagrebin .I've just addressed the comments.

[GitHub] TisonKun commented on issue #4376: [FLINK-6521] Add per job cleanup methods to HighAvailabilityServices

2018-12-13 Thread GitBox
TisonKun commented on issue #4376: [FLINK-6521] Add per job cleanup methods to HighAvailabilityServices URL: https://github.com/apache/flink/pull/4376#issuecomment-447238896 @tillrohrmann @zjureel I think the functionality is implemented occasionally by #6587

[jira] [Comment Edited] (FLINK-6625) Flink removes HA job data when reaching JobStatus.FAILED

2018-12-13 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16721001#comment-16721001 ] TisonKun edited comment on FLINK-6625 at 12/14/18 7:04 AM: --- Does it mean when

[jira] [Commented] (FLINK-6625) Flink removes HA job data when reaching JobStatus.FAILED

2018-12-13 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16721001#comment-16721001 ] TisonKun commented on FLINK-6625: - Does it mean when job finished with FAILED, the clean-up job would be

[GitHub] zhuzhurk commented on a change in pull request #7255: [FLINK-10945] Use InputDependencyConstraint to avoid resource dead…

2018-12-13 Thread GitBox
zhuzhurk commented on a change in pull request #7255: [FLINK-10945] Use InputDependencyConstraint to avoid resource dead… URL: https://github.com/apache/flink/pull/7255#discussion_r241657101 ## File path:

[GitHub] klion26 commented on issue #7171: FLINK-10918 Fix error while checkpointing on window keyed state rock …

2018-12-13 Thread GitBox
klion26 commented on issue #7171: FLINK-10918 Fix error while checkpointing on window keyed state rock … URL: https://github.com/apache/flink/pull/7171#issuecomment-447228246 @imamitsehgal thank you for your contribution. Could you please add a test to verify this? (Before the patch has

[GitHub] zhuzhurk commented on a change in pull request #7255: [FLINK-10945] Use InputDependencyConstraint to avoid resource dead…

2018-12-13 Thread GitBox
zhuzhurk commented on a change in pull request #7255: [FLINK-10945] Use InputDependencyConstraint to avoid resource dead… URL: https://github.com/apache/flink/pull/7255#discussion_r241652922 ## File path:

[GitHub] zhuzhurk commented on a change in pull request #7255: [FLINK-10945] Use InputDependencyConstraint to avoid resource dead…

2018-12-13 Thread GitBox
zhuzhurk commented on a change in pull request #7255: [FLINK-10945] Use InputDependencyConstraint to avoid resource dead… URL: https://github.com/apache/flink/pull/7255#discussion_r241652553 ## File path:

[GitHub] zhuzhurk commented on a change in pull request #7255: [FLINK-10945] Use InputDependencyConstraint to avoid resource dead…

2018-12-13 Thread GitBox
zhuzhurk commented on a change in pull request #7255: [FLINK-10945] Use InputDependencyConstraint to avoid resource dead… URL: https://github.com/apache/flink/pull/7255#discussion_r241652478 ## File path:

[GitHub] zhuzhurk commented on a change in pull request #7255: [FLINK-10945] Use InputDependencyConstraint to avoid resource dead…

2018-12-13 Thread GitBox
zhuzhurk commented on a change in pull request #7255: [FLINK-10945] Use InputDependencyConstraint to avoid resource dead… URL: https://github.com/apache/flink/pull/7255#discussion_r241652506 ## File path:

[jira] [Updated] (FLINK-11078) Capability to define the numerical range for running TaskExecutors

2018-12-13 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun updated FLINK-11078: - Description: In pre-FLIP-6 context, we start a yarn session with fixed number of running

[jira] [Updated] (FLINK-11078) Capability to define the numerical range for running TaskExecutors

2018-12-13 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun updated FLINK-11078: - Description: In pre-FLIP-6 context, we start a yarn session with fixed number of running

[jira] [Assigned] (FLINK-9462) Disentangle flink-json and flink-table

2018-12-13 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9462: --- Assignee: vinoyang > Disentangle flink-json and flink-table >

[GitHub] klion26 commented on issue #7301: [FLINK-11160][Kafka Connector]

2018-12-13 Thread GitBox
klion26 commented on issue #7301: [FLINK-11160][Kafka Connector] URL: https://github.com/apache/flink/pull/7301#issuecomment-447223998 @Zhen-hao thank you for your contribution. Maybe you could execute `mvn clean validate -Denforcer.skip -T 1C` locally to find the format error.

[jira] [Assigned] (FLINK-9462) Disentangle flink-json and flink-table

2018-12-13 Thread boshu Zheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-9462: -- Assignee: (was: boshu Zheng) > Disentangle flink-json and flink-table >

[GitHub] KarmaGYZ opened a new pull request #7307: [hotfix][docs] Imporve the correctness in Detecting Patterns doc

2018-12-13 Thread GitBox
KarmaGYZ opened a new pull request #7307: [hotfix][docs] Imporve the correctness in Detecting Patterns doc URL: https://github.com/apache/flink/pull/7307 ## What is the purpose of the change This pr is to fix type, incorrect type and the result of example in **Detecting Patterns in

[jira] [Commented] (FLINK-10558) Port YARNHighAvailabilityITCase and YARNSessionCapacitySchedulerITCase to new code base

2018-12-13 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16720922#comment-16720922 ] TisonKun commented on FLINK-10558: -- {{YARNSessionCapacitySchedulerITCase#testClientStartup}} can be

[GitHub] TisonKun edited a comment on issue #7303: [FLINK-10569] [tests] Get rid of Scheduler and Instance from valid tests

2018-12-13 Thread GitBox
TisonKun edited a comment on issue #7303: [FLINK-10569] [tests] Get rid of Scheduler and Instance from valid tests URL: https://github.com/apache/flink/pull/7303#issuecomment-447211074 >03:14:22.321 [ERROR] Tests run: 10, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 3.189 s <<<

[jira] [Created] (FLINK-11163) RestClusterClientTest#testSendIsNotRetriableIfHttpNotFound with BindException

2018-12-13 Thread TisonKun (JIRA)
TisonKun created FLINK-11163: Summary: RestClusterClientTest#testSendIsNotRetriableIfHttpNotFound with BindException Key: FLINK-11163 URL: https://issues.apache.org/jira/browse/FLINK-11163 Project: Flink

[GitHub] TisonKun commented on issue #7303: [FLINK-10569] [tests] Get rid of Scheduler and Instance from valid tests

2018-12-13 Thread GitBox
TisonKun commented on issue #7303: [FLINK-10569] [tests] Get rid of Scheduler and Instance from valid tests URL: https://github.com/apache/flink/pull/7303#issuecomment-447211074 >03:14:22.321 [ERROR] Tests run: 10, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 3.189 s <<< FAILURE! -

[GitHub] Myasuka commented on issue #7281: [FLINK-11107][state] Avoid memory stateBackend to create arbitrary folders under HA path when no checkpoint path configured

2018-12-13 Thread GitBox
Myasuka commented on issue #7281: [FLINK-11107][state] Avoid memory stateBackend to create arbitrary folders under HA path when no checkpoint path configured URL: https://github.com/apache/flink/pull/7281#issuecomment-447208854 @klion26 Hmm, I think it's not the same thing, even you could

[GitHub] maqingxiang opened a new pull request #7306: [hotfix][docs][udfs.md]fix the example of scalar function in udfs.md

2018-12-13 Thread GitBox
maqingxiang opened a new pull request #7306: [hotfix][docs][udfs.md]fix the example of scalar function in udfs.md URL: https://github.com/apache/flink/pull/7306 This is an automated message from the Apache Git Service. To

[jira] [Updated] (FLINK-11135) Reduce priority of the deprecated Hadoop specific Flink conf options

2018-12-13 Thread Paul Lin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-11135: - Component/s: YARN > Reduce priority of the deprecated Hadoop specific Flink conf options >

[GitHub] klion26 commented on a change in pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS

2018-12-13 Thread GitBox
klion26 commented on a change in pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS URL: https://github.com/apache/flink/pull/6777#discussion_r241639512 ## File path:

[GitHub] zjffdu commented on issue #7305: [FLINK-11161]Unable to import java packages in scala-shell

2018-12-13 Thread GitBox
zjffdu commented on issue #7305: [FLINK-11161]Unable to import java packages in scala-shell URL: https://github.com/apache/flink/pull/7305#issuecomment-447203754 Thanks @shuiqiangchen Could you add unit test ? This is an

[GitHub] shuiqiangchen opened a new pull request #7305: [FLINK-11161]Unable to import java packages in scala-shell

2018-12-13 Thread GitBox
shuiqiangchen opened a new pull request #7305: [FLINK-11161]Unable to import java packages in scala-shell URL: https://github.com/apache/flink/pull/7305 ## What is the purpose of the change To solve the problem of unable to import java packages in scala-shell. There is no

[GitHub] zhuzhurk commented on a change in pull request #7255: [FLINK-10945] Use InputDependencyConstraint to avoid resource dead…

2018-12-13 Thread GitBox
zhuzhurk commented on a change in pull request #7255: [FLINK-10945] Use InputDependencyConstraint to avoid resource dead… URL: https://github.com/apache/flink/pull/7255#discussion_r241636524 ## File path:

[GitHub] zhuzhurk commented on a change in pull request #7255: [FLINK-10945] Use InputDependencyConstraint to avoid resource dead…

2018-12-13 Thread GitBox
zhuzhurk commented on a change in pull request #7255: [FLINK-10945] Use InputDependencyConstraint to avoid resource dead… URL: https://github.com/apache/flink/pull/7255#discussion_r241636524 ## File path:

[jira] [Commented] (FLINK-10848) Flink's Yarn ResourceManager can allocate too many excess containers

2018-12-13 Thread Fan Xinpu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16720880#comment-16720880 ] Fan Xinpu commented on FLINK-10848: --- Shuyi, is there a posibility that the ContainerRequest be removed

[jira] [Commented] (FLINK-11162) Provide a rest API to list all logical operators

2018-12-13 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16720873#comment-16720873 ] vinoyang commented on FLINK-11162: -- I think this interface is necessary, we can get it from

[jira] [Closed] (FLINK-10601) Make user home dir consistent with Flink default filesystem

2018-12-13 Thread Paul Lin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin closed FLINK-10601. Resolution: Won't Fix > Make user home dir consistent with Flink default filesystem >

[jira] [Created] (FLINK-11162) Provide a rest API to list all logical operators

2018-12-13 Thread vinoyang (JIRA)
vinoyang created FLINK-11162: Summary: Provide a rest API to list all logical operators Key: FLINK-11162 URL: https://issues.apache.org/jira/browse/FLINK-11162 Project: Flink Issue Type: New

[GitHub] shuiqiangchen closed pull request #7304: [FLINK-11161]Unable to import java packages in scala-shell

2018-12-13 Thread GitBox
shuiqiangchen closed pull request #7304: [FLINK-11161]Unable to import java packages in scala-shell URL: https://github.com/apache/flink/pull/7304 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:

[GitHub] sunjincheng121 commented on issue #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction

2018-12-13 Thread GitBox
sunjincheng121 commented on issue #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction URL: https://github.com/apache/flink/pull/7253#issuecomment-447199240 Thanks for the update and feedback @dianfu This PR is

[GitHub] dianfu commented on a change in pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction

2018-12-13 Thread GitBox
dianfu commented on a change in pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction URL: https://github.com/apache/flink/pull/7253#discussion_r241632861 ## File path:

[jira] [Updated] (FLINK-11161) Unable to import java packages in scala-shell

2018-12-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11161: --- Labels: pull-request-available (was: ) > Unable to import java packages in scala-shell >

[GitHub] shuiqiangchen opened a new pull request #7304: [FLINK-11161]Unable to import java packages in scala-shell

2018-12-13 Thread GitBox
shuiqiangchen opened a new pull request #7304: [FLINK-11161]Unable to import java packages in scala-shell URL: https://github.com/apache/flink/pull/7304 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server,

[GitHub] sunjincheng121 commented on a change in pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction

2018-12-13 Thread GitBox
sunjincheng121 commented on a change in pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction URL: https://github.com/apache/flink/pull/7253#discussion_r241629469 ## File path:

[jira] [Commented] (FLINK-11120) The bug of timestampadd handles time

2018-12-13 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16720843#comment-16720843 ] Hequn Cheng commented on FLINK-11120: - [~x1q1j1] Hi, thanks for reporting the problem. Could you add

[GitHub] zzchun commented on a change in pull request #7291: [hotfix] [docs] Display Connectors and Formats tables, and fix typo in documentation

2018-12-13 Thread GitBox
zzchun commented on a change in pull request #7291: [hotfix] [docs] Display Connectors and Formats tables, and fix typo in documentation URL: https://github.com/apache/flink/pull/7291#discussion_r241627373 ## File path: docs/dev/table/connect.md ## @@ -58,11 +56,7 @@ The

[GitHub] dianfu commented on issue #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction

2018-12-13 Thread GitBox
dianfu commented on issue #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction URL: https://github.com/apache/flink/pull/7253#issuecomment-447190027 @sunjincheng121 Thanks a lot for your review, appreciate! Updated

[GitHub] dianfu commented on a change in pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction

2018-12-13 Thread GitBox
dianfu commented on a change in pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction URL: https://github.com/apache/flink/pull/7253#discussion_r241626349 ## File path:

[jira] [Commented] (FLINK-11139) stream non window join support state ttl

2018-12-13 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16720833#comment-16720833 ] Hequn Cheng commented on FLINK-11139: - [~zhaoshijie] Do you mean you have already switched to state

[jira] [Assigned] (FLINK-11157) Web UI should show timestamps relative to server time zone

2018-12-13 Thread leesf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] leesf reassigned FLINK-11157: - Assignee: leesf > Web UI should show timestamps relative to server time zone >

[jira] [Assigned] (FLINK-11161) Unable to import java packages in scala-shell

2018-12-13 Thread shuiqiangchen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shuiqiangchen reassigned FLINK-11161: - Assignee: shuiqiangchen > Unable to import java packages in scala-shell >

[jira] [Updated] (FLINK-11161) Unable to import java packages in scala-shell

2018-12-13 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-11161: --- Attachment: (was: image-2018-12-14-09-56-18-275.png) > Unable to import java packages in

[jira] [Updated] (FLINK-11161) Unable to import java packages in scala-shell

2018-12-13 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-11161: --- Attachment: (was: image-2018-12-14-09-55-29-523.png) > Unable to import java packages in

[jira] [Created] (FLINK-11161) Unable to import java packages in scala-shell

2018-12-13 Thread Jeff Zhang (JIRA)
Jeff Zhang created FLINK-11161: -- Summary: Unable to import java packages in scala-shell Key: FLINK-11161 URL: https://issues.apache.org/jira/browse/FLINK-11161 Project: Flink Issue Type:

[GitHub] dianfu commented on issue #7286: [FLINK-8739] [table] Optimize DISTINCT aggregates to use the same distinct accumulator if possible

2018-12-13 Thread GitBox
dianfu commented on issue #7286: [FLINK-8739] [table] Optimize DISTINCT aggregates to use the same distinct accumulator if possible URL: https://github.com/apache/flink/pull/7286#issuecomment-447186443 @walterddr Thanks a lot for your comments, very appreciated! Yes, you are right that

[GitHub] link3280 opened a new pull request #7294: [FLINK-11126][YARN][security] Filter out AMRMToken in the TaskManager credentials

2018-12-13 Thread GitBox
link3280 opened a new pull request #7294: [FLINK-11126][YARN][security] Filter out AMRMToken in the TaskManager credentials URL: https://github.com/apache/flink/pull/7294 ## What is the purpose of the change Currently, Flink JobManager propagates its storage tokens to TaskManager to

[GitHub] link3280 commented on issue #7294: [FLINK-11126][YARN][security] Filter out AMRMToken in the TaskManager credentials

2018-12-13 Thread GitBox
link3280 commented on issue #7294: [FLINK-11126][YARN][security] Filter out AMRMToken in the TaskManager credentials URL: https://github.com/apache/flink/pull/7294#issuecomment-447184156 The build failed with some network issues. I'll close and reopen the PR to trigger a rebuild.

[GitHub] link3280 closed pull request #7294: [FLINK-11126][YARN][security] Filter out AMRMToken in the TaskManager credentials

2018-12-13 Thread GitBox
link3280 closed pull request #7294: [FLINK-11126][YARN][security] Filter out AMRMToken in the TaskManager credentials URL: https://github.com/apache/flink/pull/7294 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the

[jira] [Assigned] (FLINK-11158) Do not show empty page for unknown jobs

2018-12-13 Thread leesf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] leesf reassigned FLINK-11158: - Assignee: leesf > Do not show empty page for unknown jobs > --- >

[jira] [Assigned] (FLINK-11159) Allow configuration whether to fall back to savepoints for restore

2018-12-13 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-11159: Assignee: vinoyang > Allow configuration whether to fall back to savepoints for restore >

[jira] [Assigned] (FLINK-11154) Upgrade Netty to 4.1.32

2018-12-13 Thread leesf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] leesf reassigned FLINK-11154: - Assignee: leesf > Upgrade Netty to 4.1.32 > --- > > Key:

[GitHub] sunjincheng121 commented on a change in pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction

2018-12-13 Thread GitBox
sunjincheng121 commented on a change in pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction URL: https://github.com/apache/flink/pull/7253#discussion_r241598951 ## File path:

[GitHub] sunjincheng121 commented on a change in pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction

2018-12-13 Thread GitBox
sunjincheng121 commented on a change in pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction URL: https://github.com/apache/flink/pull/7253#discussion_r241612651 ## File path:

[GitHub] sunjincheng121 commented on a change in pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction

2018-12-13 Thread GitBox
sunjincheng121 commented on a change in pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction URL: https://github.com/apache/flink/pull/7253#discussion_r241612651 ## File path:

[GitHub] klion26 commented on a change in pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS

2018-12-13 Thread GitBox
klion26 commented on a change in pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS URL: https://github.com/apache/flink/pull/6777#discussion_r241610539 ## File path:

[jira] [Updated] (FLINK-10569) Clean up uses of Scheduler and Instance in valid tests

2018-12-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10569: --- Labels: pull-request-available (was: ) > Clean up uses of Scheduler and Instance in valid

[GitHub] TisonKun opened a new pull request #7303: [FLINK-10569] [tests] Get rid of Scheduler and Instance from valid tests

2018-12-13 Thread GitBox
TisonKun opened a new pull request #7303: [FLINK-10569] [tests] Get rid of Scheduler and Instance from valid tests URL: https://github.com/apache/flink/pull/7303 ## What is the purpose of the change Legacy class `Scheduler` and `Instance` are still used in some valid tests like

[jira] [Updated] (FLINK-11156) ZooKeeperCompletedCheckpointStoreMockitoTest fails with IncompatibleClassChangeError

2018-12-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11156: --- Labels: pull-request-available (was: ) > ZooKeeperCompletedCheckpointStoreMockitoTest

[GitHub] TisonKun opened a new pull request #7302: [FLINK-11156] [tests] Reconcile powermock with JDK 9

2018-12-13 Thread GitBox
TisonKun opened a new pull request #7302: [FLINK-11156] [tests] Reconcile powermock with JDK 9 URL: https://github.com/apache/flink/pull/7302 …Test ## What is the purpose of the change The issue is caused because powermock hasn't fully supported JDK 9+ yet. Specifically,

[jira] [Commented] (FLINK-11127) Make metrics query service establish connection to JobManager

2018-12-13 Thread Sergei Poganshev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16720579#comment-16720579 ] Sergei Poganshev commented on FLINK-11127: -- Yes, the workaround works. > Make metrics query

[jira] [Resolved] (FLINK-11145) Fix Hadoop version handling in binary release script

2018-12-13 Thread Thomas Weise (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-11145. -- Resolution: Fixed Fix Version/s: 1.7.2 1.8.0 > Fix Hadoop version

[jira] [Updated] (FLINK-11145) Fix Hadoop version handling in binary release script

2018-12-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11145: --- Labels: pull-request-available (was: ) > Fix Hadoop version handling in binary release

[GitHub] tweise closed pull request #7278: [FLINK-11145] Allow for override of HADOOP_VERSION for single variant binary release build

2018-12-13 Thread GitBox
tweise closed pull request #7278: [FLINK-11145] Allow for override of HADOOP_VERSION for single variant binary release build URL: https://github.com/apache/flink/pull/7278 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for

[jira] [Updated] (FLINK-11023) Update LICENSE and NOTICE files for flink-connectors

2018-12-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11023: - Fix Version/s: (was: 1.5.6) > Update LICENSE and NOTICE files for flink-connectors

[jira] [Closed] (FLINK-11152) ClosureCleanerTest fails with IllegalStateException

2018-12-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-11152. Resolution: Fixed master: d29848d9ae338acd30b587516e0f916d10756432 > ClosureCleanerTest

[GitHub] Zhen-hao commented on issue #7301: [FLINK-11160][Kafka Connector]

2018-12-13 Thread GitBox
Zhen-hao commented on issue #7301: [FLINK-11160][Kafka Connector] URL: https://github.com/apache/flink/pull/7301#issuecomment-447074808 it seems there were some formatting errors. can someone tell me how to get the format correct?

[GitHub] zentol closed pull request #7299: [FLINK-11152][flink-java] Use asm 6 in ClosureCleaner

2018-12-13 Thread GitBox
zentol closed pull request #7299: [FLINK-11152][flink-java] Use asm 6 in ClosureCleaner URL: https://github.com/apache/flink/pull/7299 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 is a

[GitHub] Zhen-hao opened a new pull request #7301: [FLINK-11160][Kafka Connector]

2018-12-13 Thread GitBox
Zhen-hao opened a new pull request #7301: [FLINK-11160][Kafka Connector] URL: https://github.com/apache/flink/pull/7301 Summary: raised the confluent version to 4.1, added serialization schemas for confluent and added dependencies Note: when I run `mvn clean verify` locally I get

[jira] [Created] (FLINK-11160) Confluent Avro Serialization Schema

2018-12-13 Thread Zhenhao Li (JIRA)
Zhenhao Li created FLINK-11160: -- Summary: Confluent Avro Serialization Schema Key: FLINK-11160 URL: https://issues.apache.org/jira/browse/FLINK-11160 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-11156) ZooKeeperCompletedCheckpointStoreMockitoTest fails with IncompatibleClassChangeError

2018-12-13 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16720409#comment-16720409 ] Gary Yao commented on FLINK-11156: -- [~Tison] We have a [java9 build

[jira] [Created] (FLINK-11159) Allow configuration whether to fall back to savepoints for restore

2018-12-13 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-11159: --- Summary: Allow configuration whether to fall back to savepoints for restore Key: FLINK-11159 URL: https://issues.apache.org/jira/browse/FLINK-11159 Project: Flink

[jira] [Commented] (FLINK-11156) ZooKeeperCompletedCheckpointStoreMockitoTest fails with IncompatibleClassChangeError

2018-12-13 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16720395#comment-16720395 ] TisonKun commented on FLINK-11156: -- I guess it is an issue about mockito/powermock on JDK 9+? >

[GitHub] leesf commented on issue #5376: [FLINK-6214] WindowAssigners do not allow negative offsets

2018-12-13 Thread GitBox
leesf commented on issue #5376: [FLINK-6214] WindowAssigners do not allow negative offsets URL: https://github.com/apache/flink/pull/5376#issuecomment-447040177 Or can we directly remove the constraint of offset less than 0 in TumblingEventTimeWindows constructor?

[jira] [Assigned] (FLINK-6214) WindowAssigners do not allow negative offsets

2018-12-13 Thread leesf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] leesf reassigned FLINK-6214: Assignee: leesf > WindowAssigners do not allow negative offsets >

[jira] [Assigned] (FLINK-11156) ZooKeeperCompletedCheckpointStoreMockitoTest fails with IncompatibleClassChangeError

2018-12-13 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun reassigned FLINK-11156: Assignee: TisonKun > ZooKeeperCompletedCheckpointStoreMockitoTest fails with >

[GitHub] walterddr commented on issue #7286: [FLINK-8739] [table] Optimize DISTINCT aggregates to use the same distinct accumulator if possible

2018-12-13 Thread GitBox
walterddr commented on issue #7286: [FLINK-8739] [table] Optimize DISTINCT aggregates to use the same distinct accumulator if possible URL: https://github.com/apache/flink/pull/7286#issuecomment-447032756 Thanks for the contribution @dianfu. I haven't taken a deep look yet but seems like

[jira] [Comment Edited] (FLINK-11139) stream non window join support state ttl

2018-12-13 Thread zhaoshijie (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16720330#comment-16720330 ] zhaoshijie edited comment on FLINK-11139 at 12/13/18 4:04 PM: -- [~hequn8128]

[jira] [Commented] (FLINK-11139) stream non window join support state ttl

2018-12-13 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16720345#comment-16720345 ] Fabian Hueske commented on FLINK-11139: --- [~zhaoshijie] Which join are you using? One of the

[jira] [Updated] (FLINK-11154) Upgrade Netty to 4.1.32

2018-12-13 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-11154: Affects Version/s: (was: 1.8.0) > Upgrade Netty to 4.1.32 > --- > >

[jira] [Created] (FLINK-11158) Do not show empty page for unknown jobs

2018-12-13 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-11158: --- Summary: Do not show empty page for unknown jobs Key: FLINK-11158 URL: https://issues.apache.org/jira/browse/FLINK-11158 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-11120) The bug of timestampadd handles time

2018-12-13 Thread xuqianjin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuqianjin reassigned FLINK-11120: - Assignee: xuqianjin > The bug of timestampadd handles time >

[jira] [Updated] (FLINK-11154) Upgrade Netty to 4.1.32

2018-12-13 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-11154: Fix Version/s: 1.8.0 > Upgrade Netty to 4.1.32 > --- > > Key:

[jira] [Created] (FLINK-11157) Web UI should show timestamps relative to server time zone

2018-12-13 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-11157: --- Summary: Web UI should show timestamps relative to server time zone Key: FLINK-11157 URL: https://issues.apache.org/jira/browse/FLINK-11157 Project: Flink

[jira] [Commented] (FLINK-11139) stream non window join support state ttl

2018-12-13 Thread zhaoshijie (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16720330#comment-16720330 ] zhaoshijie commented on FLINK-11139: [~hequn8128] ok. we use stream non window join(this part of

[jira] [Created] (FLINK-11156) ZooKeeperCompletedCheckpointStoreMockitoTest fails with IncompatibleClassChangeError

2018-12-13 Thread Gary Yao (JIRA)
Gary Yao created FLINK-11156: Summary: ZooKeeperCompletedCheckpointStoreMockitoTest fails with IncompatibleClassChangeError Key: FLINK-11156 URL: https://issues.apache.org/jira/browse/FLINK-11156

[jira] [Assigned] (FLINK-6214) WindowAssigners do not allow negative offsets

2018-12-13 Thread leesf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] leesf reassigned FLINK-6214: Assignee: (was: leesf) > WindowAssigners do not allow negative offsets >

[jira] [Updated] (FLINK-11155) HadoopFreeFsFactoryTest fails with ClassCastException

2018-12-13 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-11155: - Component/s: Tests > HadoopFreeFsFactoryTest fails with ClassCastException >

[jira] [Updated] (FLINK-11155) HadoopFreeFsFactoryTest fails with ClassCastException

2018-12-13 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-11155: - Affects Version/s: 1.8.0 > HadoopFreeFsFactoryTest fails with ClassCastException >

[jira] [Updated] (FLINK-11155) HadoopFreeFsFactoryTest fails with ClassCastException

2018-12-13 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-11155: - Description: {{HadoopFreeFsFactoryTest#testHadoopFactoryInstantiationWithoutHadoop}} fails with a

[jira] [Commented] (FLINK-11084) Incorrect ouput after two consecutive split and select

2018-12-13 Thread Shimin Yang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16720304#comment-16720304 ] Shimin Yang commented on FLINK-11084: - Hi [~dawidwys], thank you for providing the case! I agree

[jira] [Updated] (FLINK-11155) HadoopFreeFsFactoryTest fails with ClassCastException

2018-12-13 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-11155: - Fix Version/s: 1.8.0 > HadoopFreeFsFactoryTest fails with ClassCastException >

[GitHub] azagrebin commented on a change in pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS

2018-12-13 Thread GitBox
azagrebin commented on a change in pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS URL: https://github.com/apache/flink/pull/6777#discussion_r241444723 ## File path:

[GitHub] azagrebin commented on a change in pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS

2018-12-13 Thread GitBox
azagrebin commented on a change in pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS URL: https://github.com/apache/flink/pull/6777#discussion_r241437932 ## File path:

[GitHub] azagrebin commented on a change in pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS

2018-12-13 Thread GitBox
azagrebin commented on a change in pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS URL: https://github.com/apache/flink/pull/6777#discussion_r241435878 ## File path:

[GitHub] azagrebin commented on a change in pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS

2018-12-13 Thread GitBox
azagrebin commented on a change in pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS URL: https://github.com/apache/flink/pull/6777#discussion_r241435617 ## File path:

  1   2   3   >