[jira] [Created] (FLINK-4347) Implement SlotManager for new ResourceManager

2016-08-09 Thread Kurt Young (JIRA)
Kurt Young created FLINK-4347: - Summary: Implement SlotManager for new ResourceManager Key: FLINK-4347 URL: https://issues.apache.org/jira/browse/FLINK-4347 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-4347) Implement SlotManager for new ResourceManager

2016-08-09 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-4347: -- Description: The slot manager is responsible to maintain the list of slot requests and slot

[jira] [Updated] (FLINK-4373) Introduce SlotID, AllocationID, ResourceProfile

2016-08-12 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-4373: -- Summary: Introduce SlotID, AllocationID, ResourceProfile (was: Introduce SlotID & ResourceProfile) >

[jira] [Assigned] (FLINK-4347) Implement SlotManager for new ResourceManager

2016-08-12 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-4347: - Assignee: Kurt Young > Implement SlotManager for new ResourceManager >

[jira] [Created] (FLINK-4348) implement communication from ResourceManager to TaskManager

2016-08-10 Thread Kurt Young (JIRA)
Kurt Young created FLINK-4348: - Summary: implement communication from ResourceManager to TaskManager Key: FLINK-4348 URL: https://issues.apache.org/jira/browse/FLINK-4348 Project: Flink Issue

[jira] [Assigned] (FLINK-4373) Introduce SlotID & ResourceProfile

2016-08-11 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-4373: - Assignee: Kurt Young > Introduce SlotID & ResourceProfile > -- >

[jira] [Created] (FLINK-4373) Introduce SlotID & ResourceProfile

2016-08-11 Thread Kurt Young (JIRA)
Kurt Young created FLINK-4373: - Summary: Introduce SlotID & ResourceProfile Key: FLINK-4373 URL: https://issues.apache.org/jira/browse/FLINK-4373 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-5727) Unify some API of batch and stream TableEnvironment

2017-02-06 Thread Kurt Young (JIRA)
Kurt Young created FLINK-5727: - Summary: Unify some API of batch and stream TableEnvironment Key: FLINK-5727 URL: https://issues.apache.org/jira/browse/FLINK-5727 Project: Flink Issue Type:

[jira] [Commented] (FLINK-5435) Cleanup the rules introduced by FLINK-5144 when calcite releases 1.12

2017-02-07 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15857276#comment-15857276 ] Kurt Young commented on FLINK-5435: --- Hi [~anmu], Thanks for pointing this out, i will pay attention to

[jira] [Closed] (FLINK-5569) Migrate current table registration to in-memory catalog

2017-02-21 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-5569. - > Migrate current table registration to in-memory catalog >

[jira] [Updated] (FLINK-5568) Introduce interface for catalog, and provide an in-memory implementation, and integrate with calcite schema

2017-02-22 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-5568: -- Summary: Introduce interface for catalog, and provide an in-memory implementation, and integrate with

[jira] [Commented] (FLINK-5859) support partition pruning on Table API & SQL

2017-02-23 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15881737#comment-15881737 ] Kurt Young commented on FLINK-5859: --- Hi [~fhueske], How about this approach: We both provide

[jira] [Commented] (FLINK-5907) RowCsvInputFormat bug on parsing tsv

2017-02-25 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15884152#comment-15884152 ] Kurt Young commented on FLINK-5907: --- You can add one more '\t' at the end of each line to work around

[jira] [Assigned] (FLINK-5907) RowCsvInputFormat bug on parsing tsv

2017-02-24 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-5907: - Assignee: Kurt Young > RowCsvInputFormat bug on parsing tsv >

[jira] [Updated] (FLINK-5907) RowCsvInputFormat bug on parsing tsv

2017-02-24 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-5907: -- Component/s: (was: Table API & SQL) Java API > RowCsvInputFormat bug on parsing

[jira] [Commented] (FLINK-5907) RowCsvInputFormat bug on parsing tsv

2017-02-24 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15884013#comment-15884013 ] Kurt Young commented on FLINK-5907: --- Looks like RowCsvInputFormat didn't handle rows which ended with

[jira] [Commented] (FLINK-5859) support partition pruning on Table API & SQL

2017-02-23 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15880359#comment-15880359 ] Kurt Young commented on FLINK-5859: --- Hi [~fhueske], With the approach you proposed, how can we handle

[jira] [Assigned] (FLINK-5524) Support early out for code generated conjunctive conditions

2017-02-20 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-5524: - Assignee: Kurt Young > Support early out for code generated conjunctive conditions >

[jira] [Commented] (FLINK-5859) support partition pruning on Table API & SQL

2017-02-22 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15879991#comment-15879991 ] Kurt Young commented on FLINK-5859: --- Hi [~fhueske], You raised a very good question, which is

[jira] [Commented] (FLINK-5568) Introduce interface for catalog, and provide an in-memory implementation, and integrate with calcite schema

2017-02-22 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15879942#comment-15879942 ] Kurt Young commented on FLINK-5568: --- Hi [~fhueske], I want to emphasize there exists a very big

[jira] [Commented] (FLINK-5570) Support register external catalog to table environment

2017-02-15 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15868903#comment-15868903 ] Kurt Young commented on FLINK-5570: --- Hi [~wheat9], thanks for the offering, i think we are implementing

[jira] [Assigned] (FLINK-5586) Extend TableProgramsTestBase for object reuse modes

2017-02-17 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-5586: - Assignee: Kurt Young > Extend TableProgramsTestBase for object reuse modes >

[jira] [Commented] (FLINK-5586) Extend TableProgramsTestBase for object reuse modes

2017-02-17 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15871463#comment-15871463 ] Kurt Young commented on FLINK-5586: --- It looks like {{TableProgramsTestBase}} is only used in batch mode

[jira] [Created] (FLINK-5568) Introduce interface for catalog, and provide an in-memory implementation

2017-01-18 Thread Kurt Young (JIRA)
Kurt Young created FLINK-5568: - Summary: Introduce interface for catalog, and provide an in-memory implementation Key: FLINK-5568 URL: https://issues.apache.org/jira/browse/FLINK-5568 Project: Flink

[jira] [Created] (FLINK-5566) Introduce structure to hold table and column level statistics

2017-01-18 Thread Kurt Young (JIRA)
Kurt Young created FLINK-5566: - Summary: Introduce structure to hold table and column level statistics Key: FLINK-5566 URL: https://issues.apache.org/jira/browse/FLINK-5566 Project: Flink Issue

[jira] [Created] (FLINK-5569) Migrate current table registration to in-memory catalog

2017-01-18 Thread Kurt Young (JIRA)
Kurt Young created FLINK-5569: - Summary: Migrate current table registration to in-memory catalog Key: FLINK-5569 URL: https://issues.apache.org/jira/browse/FLINK-5569 Project: Flink Issue Type:

[jira] [Updated] (FLINK-5567) Introduce and migrate current table statistics to FlinkStatistics

2017-01-18 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-5567: -- Issue Type: Sub-task (was: Bug) Parent: FLINK-5565 > Introduce and migrate current table

[jira] [Created] (FLINK-5565) Improve flink cost model framework

2017-01-18 Thread Kurt Young (JIRA)
Kurt Young created FLINK-5565: - Summary: Improve flink cost model framework Key: FLINK-5565 URL: https://issues.apache.org/jira/browse/FLINK-5565 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-5567) Introduce and migrate current table statistics to FlinkStatistics

2017-01-18 Thread Kurt Young (JIRA)
Kurt Young created FLINK-5567: - Summary: Introduce and migrate current table statistics to FlinkStatistics Key: FLINK-5567 URL: https://issues.apache.org/jira/browse/FLINK-5567 Project: Flink

[jira] [Created] (FLINK-5570) Support register external catalog to table environment

2017-01-18 Thread Kurt Young (JIRA)
Kurt Young created FLINK-5570: - Summary: Support register external catalog to table environment Key: FLINK-5570 URL: https://issues.apache.org/jira/browse/FLINK-5570 Project: Flink Issue Type:

[jira] [Closed] (FLINK-5452) Make table unit tests pass under cluster mode

2017-01-19 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-5452. - > Make table unit tests pass under cluster mode > - > >

[jira] [Resolved] (FLINK-5452) Make table unit tests pass under cluster mode

2017-01-19 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young resolved FLINK-5452. --- Resolution: Fixed > Make table unit tests pass under cluster mode >

[jira] [Created] (FLINK-4442) Implement Standalone ResourceManager

2016-08-21 Thread Kurt Young (JIRA)
Kurt Young created FLINK-4442: - Summary: Implement Standalone ResourceManager Key: FLINK-4442 URL: https://issues.apache.org/jira/browse/FLINK-4442 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-4427) Add slot / container releasing logic to SlotManager (Standalone / Yarn / Mesos)

2016-08-19 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-4427: -- Description: Currently we only have allocation logic for SlotManager / ResourceManager, for some batch

[jira] [Updated] (FLINK-4427) Add slot / Implement container releasing logic (Standalone / Yarn / Mesos)

2016-08-19 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-4427: -- Summary: Add slot / Implement container releasing logic (Standalone / Yarn / Mesos) (was: Add slot /

[jira] [Updated] (FLINK-4427) Add slot / Implement container releasing logic (Standalone / Yarn / Mesos)

2016-08-19 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-4427: -- Description: Currently we only have allocation logic for SlotManager / ResourceManager, for some batch

[jira] [Created] (FLINK-4430) prevent BLOCKING partition data lose when task is finished

2016-08-19 Thread Kurt Young (JIRA)
Kurt Young created FLINK-4430: - Summary: prevent BLOCKING partition data lose when task is finished Key: FLINK-4430 URL: https://issues.apache.org/jira/browse/FLINK-4430 Project: Flink Issue

[jira] [Updated] (FLINK-4427) Add slot / container releasing logic to SlotManager (Standalone / Yarn / Mesos)

2016-08-19 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-4427: -- Description: Currently we only have allocation logic for SlotManager / ResourceManager, for some batch

[jira] [Created] (FLINK-4427) Add slot / container releasing logic to SlotManager (Standalone / Yarn / Mesos)

2016-08-18 Thread Kurt Young (JIRA)
Kurt Young created FLINK-4427: - Summary: Add slot / container releasing logic to SlotManager (Standalone / Yarn / Mesos) Key: FLINK-4427 URL: https://issues.apache.org/jira/browse/FLINK-4427 Project:

[jira] [Updated] (FLINK-4347) Implement SlotManager core

2016-08-18 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-4347: -- Summary: Implement SlotManager core (was: Implement SlotManager core for new ResourceManager) >

[jira] [Commented] (FLINK-5859) support partition pruning on Table API & SQL

2017-02-26 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15885179#comment-15885179 ] Kurt Young commented on FLINK-5859: --- Hi [~fhueske], i think your API suggestion is good way to start

[jira] [Commented] (FLINK-5922) Remove FlinkAggregateJoinTransposeRule when upgrading to Calcite 1.12

2017-02-27 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15885455#comment-15885455 ] Kurt Young commented on FLINK-5922: --- Hi, i think this is duplicated with

[jira] [Updated] (FLINK-5435) Cleanup the rules introduced by FLINK-5144 when calcite releases 1.12

2017-02-27 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-5435: -- Description: When fixing https://issues.apache.org/jira/browse/FLINK-5144, we actually copied some

[jira] [Updated] (FLINK-4339) Implement Slot Pool Core

2016-08-24 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-4339: -- Description: Impements the core slot structures and behavior of the {{SlotPool}}: - pool of available

[jira] [Assigned] (FLINK-4339) Implement Slot Pool Core

2016-08-24 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-4339: - Assignee: Kurt Young > Implement Slot Pool Core > > >

[jira] [Assigned] (FLINK-4408) Submit Job and setup ExecutionGraph

2016-08-25 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-4408: - Assignee: Kurt Young (was: Xiaogang Shi) > Submit Job and setup ExecutionGraph >

[jira] [Created] (FLINK-4490) Decouple Slot and Instance

2016-08-25 Thread Kurt Young (JIRA)
Kurt Young created FLINK-4490: - Summary: Decouple Slot and Instance Key: FLINK-4490 URL: https://issues.apache.org/jira/browse/FLINK-4490 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-4376) Implement job master skeleton for managing single job

2016-09-07 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-4376. - Resolution: Duplicate I think this is duplicated with https://issues.apache.org/jira/browse/FLINK-4408 >

[jira] [Updated] (FLINK-4406) Implement job master registration at resource manager

2016-09-07 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-4406: -- Assignee: (was: Kurt Young) > Implement job master registration at resource manager >

[jira] [Updated] (FLINK-4427) Implement container releasing logic (Standalone / Yarn / Mesos)

2016-09-07 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-4427: -- Summary: Implement container releasing logic (Standalone / Yarn / Mesos) (was: Add slot / Implement

[jira] [Resolved] (FLINK-4408) Submit Job and setup ExecutionGraph

2016-09-26 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young resolved FLINK-4408. --- Resolution: Fixed > Submit Job and setup ExecutionGraph > --- > >

[jira] [Created] (FLINK-4689) Implement a simple slot provider for the new job manager

2016-09-26 Thread Kurt Young (JIRA)
Kurt Young created FLINK-4689: - Summary: Implement a simple slot provider for the new job manager Key: FLINK-4689 URL: https://issues.apache.org/jira/browse/FLINK-4689 Project: Flink Issue Type:

[jira] [Created] (FLINK-4735) Migrate some job execution related akka messages to rpc calls

2016-10-04 Thread Kurt Young (JIRA)
Kurt Young created FLINK-4735: - Summary: Migrate some job execution related akka messages to rpc calls Key: FLINK-4735 URL: https://issues.apache.org/jira/browse/FLINK-4735 Project: Flink Issue

[jira] [Created] (FLINK-4657) Implement HighAvailabilityServices based on zookeeper

2016-09-21 Thread Kurt Young (JIRA)
Kurt Young created FLINK-4657: - Summary: Implement HighAvailabilityServices based on zookeeper Key: FLINK-4657 URL: https://issues.apache.org/jira/browse/FLINK-4657 Project: Flink Issue Type:

[jira] [Updated] (FLINK-4657) Implement HighAvailabilityServices based on zookeeper

2016-09-21 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-4657: -- Description: For flip-6, we will have ResourceManager and every JobManager as potential leader

[jira] [Updated] (FLINK-4347) Implement SlotManager core for new ResourceManager

2016-08-18 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-4347: -- Summary: Implement SlotManager core for new ResourceManager (was: Implement SlotManager for new

[jira] [Updated] (FLINK-4376) Implement job master skeleton for managing single job

2016-08-22 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-4376: -- Summary: Implement job master skeleton for managing single job (was: implement job manager init

[jira] [Updated] (FLINK-4376) Implement job master skeleton for managing single job

2016-08-22 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-4376: -- Description: This jira targets to set up a skeleton of the new JobMaster, translate scala codes to

[jira] [Updated] (FLINK-4376) Implement job master skeleton for managing single job

2016-08-22 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-4376: -- Description: This jira targets to set up a skeleton of the new JobMaster, translate scala codes to

[jira] [Assigned] (FLINK-4376) Implement job master skeleton for managing single job

2016-08-22 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-4376: - Assignee: Kurt Young > Implement job master skeleton for managing single job >

[jira] [Updated] (FLINK-4376) Implement job master skeleton for managing single job

2016-08-22 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-4376: -- Description: This jira targets to set up a skeleton of the new JobMaster, translate scala codes to

[jira] [Assigned] (FLINK-4459) Introduce SlotProvider for Scheduler

2016-08-25 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-4459: - Assignee: Kurt Young > Introduce SlotProvider for Scheduler >

[jira] [Updated] (FLINK-4344) Implement new JobManager

2016-09-28 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-4344: -- Assignee: (was: Kurt Young) > Implement new JobManager > > >

[jira] [Assigned] (FLINK-4406) Implement job master registration at resource manager

2016-09-28 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-4406: - Assignee: Kurt Young (was: zhuhaifeng) > Implement job master registration at resource manager

[jira] [Commented] (FLINK-4530) Generalize TaskExecutorToResourceManagerConnection to be reusable

2016-09-28 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15529460#comment-15529460 ] Kurt Young commented on FLINK-4530: --- fixed by b955465ff2f230da0ecd195d7d0e8312fdf0578e > Generalize

[jira] [Resolved] (FLINK-4530) Generalize TaskExecutorToResourceManagerConnection to be reusable

2016-09-28 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young resolved FLINK-4530. --- Resolution: Fixed > Generalize TaskExecutorToResourceManagerConnection to be reusable >

[jira] [Created] (FLINK-4690) Replace SlotAllocationFuture with flink's own future

2016-09-26 Thread Kurt Young (JIRA)
Kurt Young created FLINK-4690: - Summary: Replace SlotAllocationFuture with flink's own future Key: FLINK-4690 URL: https://issues.apache.org/jira/browse/FLINK-4690 Project: Flink Issue Type:

[jira] [Created] (FLINK-5185) Decouple BatchTableSourceScan with TableSourceTable

2016-11-28 Thread Kurt Young (JIRA)
Kurt Young created FLINK-5185: - Summary: Decouple BatchTableSourceScan with TableSourceTable Key: FLINK-5185 URL: https://issues.apache.org/jira/browse/FLINK-5185 Project: Flink Issue Type:

[jira] [Updated] (FLINK-5185) Decouple BatchTableSourceScan with TableSourceTable

2016-11-28 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-5185: -- Description: As the components' relationship show in this design doc:

[jira] [Updated] (FLINK-5185) Decouple BatchTableSourceScan with TableSourceTable

2016-11-28 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-5185: -- Description: As the components' relationship show in this design doc:

[jira] [Updated] (FLINK-5185) Decouple BatchTableSourceScan with TableSourceTable

2016-11-28 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-5185: -- Description: As the components' relationship show in this design doc:

[jira] [Updated] (FLINK-5185) Decouple BatchTableSourceScan with TableSourceTable

2016-11-28 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-5185: -- Description: As the components' relationship show in this design doc:

[jira] [Updated] (FLINK-5185) Decouple BatchTableSourceScan with TableSourceTable

2016-11-28 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-5185: -- Description: As the components' relationship show in this design doc:

[jira] [Updated] (FLINK-4806) ResourceManager stop listening JobManager's leader address

2016-10-11 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-4806: -- Description: Currently in flip-6 branch, when RM receives a registration from JM, it will verify the

[jira] [Updated] (FLINK-4806) ResourceManager stop listening JobManager's leader address

2016-10-11 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-4806: -- Description: Currently in flip-6 branch, when RM receives a registration from JM, it will verify the

[jira] [Created] (FLINK-4806) ResourceManager stop listening JobManager's leader address

2016-10-11 Thread Kurt Young (JIRA)
Kurt Young created FLINK-4806: - Summary: ResourceManager stop listening JobManager's leader address Key: FLINK-4806 URL: https://issues.apache.org/jira/browse/FLINK-4806 Project: Flink Issue

[jira] [Updated] (FLINK-4806) ResourceManager stop listening JobManager's leader address

2016-10-11 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-4806: -- Description: Currently in flip-6 branch, when RM receives a registration from JM, it will verify the

[jira] [Created] (FLINK-4807) ResourceManager clean up JobManager's registration

2016-10-11 Thread Kurt Young (JIRA)
Kurt Young created FLINK-4807: - Summary: ResourceManager clean up JobManager's registration Key: FLINK-4807 URL: https://issues.apache.org/jira/browse/FLINK-4807 Project: Flink Issue Type:

[jira] [Resolved] (FLINK-4735) Migrate some job execution related akka messages to rpc calls

2016-10-13 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young resolved FLINK-4735. --- Resolution: Fixed > Migrate some job execution related akka messages to rpc calls >

[jira] [Resolved] (FLINK-4339) Implement Slot Pool Core

2016-10-13 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young resolved FLINK-4339. --- Resolution: Fixed Fix Version/s: (was: 1.2.0) > Implement Slot Pool Core >

[jira] [Closed] (FLINK-4806) ResourceManager stop listening JobManager's leader address

2016-10-12 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-4806. - Resolution: Won't Fix > ResourceManager stop listening JobManager's leader address >

[jira] [Commented] (FLINK-4806) ResourceManager stop listening JobManager's leader address

2016-10-12 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568527#comment-15568527 ] Kurt Young commented on FLINK-4806: --- Yes, you are right about this. [~mxm] > ResourceManager stop

[jira] [Assigned] (FLINK-4351) JobManager handle TaskManager's registration

2016-10-16 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-4351: - Assignee: Kurt Young > JobManager handle TaskManager's registration >

[jira] [Updated] (FLINK-4351) JobManager handle TaskManager's registration

2016-10-16 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-4351: -- Summary: JobManager handle TaskManager's registration (was: interaction between new JobManager and new

[jira] [Updated] (FLINK-4351) JobManager handle TaskManager's registration

2016-10-16 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-4351: -- Description: was: 1. Receive slot offer from TaskExecutor, ack it or reject it 2. Release slot

[jira] [Resolved] (FLINK-4689) Implement a simple slot provider for the new job manager

2016-10-16 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young resolved FLINK-4689. --- Resolution: Fixed resolved by e91b82d3c868e18611064f905b345906f1414f84 > Implement a simple slot

[jira] [Resolved] (FLINK-4351) JobManager handle TaskManager's registration

2016-10-16 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young resolved FLINK-4351. --- Resolution: Fixed resolved by a19cae3b07963776c07c0aae7bee806004f59429 > JobManager handle

[jira] [Created] (FLINK-4839) JobManager handle TaskManager's slot offering

2016-10-16 Thread Kurt Young (JIRA)
Kurt Young created FLINK-4839: - Summary: JobManager handle TaskManager's slot offering Key: FLINK-4839 URL: https://issues.apache.org/jira/browse/FLINK-4839 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-3475) DISTINCT aggregate function support for SQL queries

2016-12-12 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15743753#comment-15743753 ] Kurt Young commented on FLINK-3475: --- We are willing to offer some helps on this issue, [~fhueske]

[jira] [Closed] (FLINK-5314) Add tpch query explain test

2016-12-12 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-5314. - Resolution: Won't Fix > Add tpch query explain test > --- > >

[jira] [Commented] (FLINK-5314) Add tpch query explain test

2016-12-12 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15741332#comment-15741332 ] Kurt Young commented on FLINK-5314: --- Seems like it's not allowed to include tpch queries in open source

[jira] [Created] (FLINK-5315) Support distinct aggregations in table api

2016-12-11 Thread Kurt Young (JIRA)
Kurt Young created FLINK-5315: - Summary: Support distinct aggregations in table api Key: FLINK-5315 URL: https://issues.apache.org/jira/browse/FLINK-5315 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-5314) Add tpch query explain test

2016-12-11 Thread Kurt Young (JIRA)
Kurt Young created FLINK-5314: - Summary: Add tpch query explain test Key: FLINK-5314 URL: https://issues.apache.org/jira/browse/FLINK-5314 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-3475) DISTINCT aggregate function support for SQL queries

2016-12-13 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15744604#comment-15744604 ] Kurt Young commented on FLINK-3475: --- Hi [~fhueske], cool, will definitely let you know if we have some

[jira] [Commented] (FLINK-5266) Eagerly project unused fields when selecting aggregation fields

2016-12-06 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15727375#comment-15727375 ] Kurt Young commented on FLINK-5266: --- Hi [~fhueske], i have checked your PR #2926, and it doesn't solve

[jira] [Commented] (FLINK-5266) Eagerly project unused fields when selecting aggregation fields

2016-12-07 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15728297#comment-15728297 ] Kurt Young commented on FLINK-5266: --- You mean "Aggregate.construct()"? Hmm..I didn't think about that,

[jira] [Assigned] (FLINK-5144) Error while applying rule AggregateJoinTransposeRule

2016-12-14 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-5144: - Assignee: Kurt Young > Error while applying rule AggregateJoinTransposeRule >

[jira] [Commented] (FLINK-5144) Error while applying rule AggregateJoinTransposeRule

2016-12-14 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15750108#comment-15750108 ] Kurt Young commented on FLINK-5144: --- I'm interested to solve this problem :) > Error while applying

[jira] [Created] (FLINK-5313) Supporting all tpch queries

2016-12-11 Thread Kurt Young (JIRA)
Kurt Young created FLINK-5313: - Summary: Supporting all tpch queries Key: FLINK-5313 URL: https://issues.apache.org/jira/browse/FLINK-5313 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-5435) Cleanup the rules introduced by FLINK-5144 when calcite releases 1.12

2017-01-10 Thread Kurt Young (JIRA)
Kurt Young created FLINK-5435: - Summary: Cleanup the rules introduced by FLINK-5144 when calcite releases 1.12 Key: FLINK-5435 URL: https://issues.apache.org/jira/browse/FLINK-5435 Project: Flink

  1   2   3   4   5   6   7   8   9   10   >