[jira] [Commented] (FLINK-10984) Move flink-shaded-hadoop to flink-shaded

2019-04-17 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16820036#comment-16820036 ] sunjincheng commented on FLINK-10984: - Hi [~Zentol], I had open a new PR about move

[jira] [Closed] (FLINK-12169) Improve Javadoc of MessageAcknowledgingSourceBase

2019-04-12 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-12169. --- Resolution: Fixed Fix Version/s: 1.8.1 1.9.0 1.7.3 Fixe

[jira] [Closed] (FLINK-12009) Wrong check message about heartbeat interval for HeartbeatServices

2019-04-08 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-12009. --- Resolution: Fixed Fix Version/s: 1.8.1 1.9.0 1.7.3 Fixe

[jira] [Commented] (FLINK-10984) Move flink-shaded-hadoop to flink-shaded

2019-04-08 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16812268#comment-16812268 ] sunjincheng commented on FLINK-10984: - +1 for this proposal. I think this JIRA shoul

[jira] [Closed] (FLINK-10973) Add Map operator to Table API

2019-04-05 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-10973. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in master: 656bd9caf62355b3936831c9ef6f0f026326f

[jira] [Closed] (FLINK-12028) Add Column Operators(add/rename/drop)

2019-04-01 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-12028. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in master: b32cd4180dde20742186845371436f71efb6f

[jira] [Closed] (FLINK-12074) Fix typo in `flinkDev/building.md`

2019-03-31 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-12074. --- Resolution: Fixed Already hotfix by aafc881. > Fix typo in `flinkDev/building.md` > ---

[jira] [Created] (FLINK-12074) Fix typo in `flinkDev/building.md`

2019-03-31 Thread sunjincheng (JIRA)
sunjincheng created FLINK-12074: --- Summary: Fix typo in `flinkDev/building.md` Key: FLINK-12074 URL: https://issues.apache.org/jira/browse/FLINK-12074 Project: Flink Issue Type: Bug Co

[jira] [Updated] (FLINK-11918) Deprecated Window and Rename it to GroupWindow

2019-03-27 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-11918: Fix Version/s: 1.8.0 > Deprecated Window and Rename it to GroupWindow > --

[jira] [Closed] (FLINK-12001) Test AvroExternalJarProgramITCase, get `JAR file does not exist` Error.

2019-03-27 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-12001. --- Resolution: Fixed Fix Version/s: (was: 1.8.0) 1.8.1

[jira] [Assigned] (FLINK-11967) Add Column Operators/Operations

2019-03-26 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-11967: --- Assignee: sunjincheng > Add Column Operators/Operations > --- >

[jira] [Created] (FLINK-12029) Add Column selections

2019-03-26 Thread sunjincheng (JIRA)
sunjincheng created FLINK-12029: --- Summary: Add Column selections Key: FLINK-12029 URL: https://issues.apache.org/jira/browse/FLINK-12029 Project: Flink Issue Type: Sub-task Components

[jira] [Created] (FLINK-12028) Add Column Operators(add/rename/drop)

2019-03-26 Thread sunjincheng (JIRA)
sunjincheng created FLINK-12028: --- Summary: Add Column Operators(add/rename/drop) Key: FLINK-12028 URL: https://issues.apache.org/jira/browse/FLINK-12028 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-11967) Add Column Operators/Operations

2019-03-26 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16802388#comment-16802388 ] sunjincheng commented on FLINK-11967: -  Thanks a lot for your quick reply, [~dian.fu

[jira] [Updated] (FLINK-12026) Remove the `xxxInternal` method from TableImpl

2019-03-26 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-12026: Description: At present, each operator of TableImpl has an internal method of `xxxInternal`, and

[jira] [Created] (FLINK-12026) Remove the `xxxInternal` method from TableImpl

2019-03-26 Thread sunjincheng (JIRA)
sunjincheng created FLINK-12026: --- Summary: Remove the `xxxInternal` method from TableImpl Key: FLINK-12026 URL: https://issues.apache.org/jira/browse/FLINK-12026 Project: Flink Issue Type: Impr

[jira] [Commented] (FLINK-11967) Add Column Operators/Operations

2019-03-26 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16802329#comment-16802329 ] sunjincheng commented on FLINK-11967: - Hi [~dian.fu] Thanks for taking this ticket,

[jira] [Updated] (FLINK-12001) Test AvroExternalJarProgramITCase, get `JAR file does not exist` Error.

2019-03-25 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-12001: Description: When I run `mvn clean verify` I got the follows error: {code} [ERROR] Tests run: 1,

[jira] [Created] (FLINK-12001) Test AvroExternalJarProgramITCase, get `JAR file does not exist` Error.

2019-03-25 Thread sunjincheng (JIRA)
sunjincheng created FLINK-12001: --- Summary: Test AvroExternalJarProgramITCase, get `JAR file does not exist` Error. Key: FLINK-12001 URL: https://issues.apache.org/jira/browse/FLINK-12001 Project: Flink

[jira] [Closed] (FLINK-10975) Add support for TimeAttribute in Map/FlatMap operator

2019-03-24 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-10975. --- Resolution: Later > Add support for TimeAttribute in Map/FlatMap operator >

[jira] [Commented] (FLINK-10975) Add support for TimeAttribute in Map/FlatMap operator

2019-03-24 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16800347#comment-16800347 ] sunjincheng commented on FLINK-10975: - As the Google doc mentioned, the time attribu

[jira] [Commented] (FLINK-11972) The classpath is missing the `flink-shaded-hadoop2-uber-2.8.3-1.8.0.jar` JAR during the end-to-end test.

2019-03-21 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16797899#comment-16797899 ] sunjincheng commented on FLINK-11972: - [~carp84] I have close this JIRA due to you a

[jira] [Closed] (FLINK-11972) The classpath is missing the `flink-shaded-hadoop2-uber-2.8.3-1.8.0.jar` JAR during the end-to-end test.

2019-03-21 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-11972. --- Resolution: Fixed Fix Version/s: 1.9.0 1.8.0 Release Note: Add necessa

[jira] [Updated] (FLINK-11972) The classpath is missing the `flink-shaded-hadoop2-uber-2.8.3-1.8.0.jar` JAR during the end-to-end test.

2019-03-20 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-11972: Attachment: screenshot-1.png > The classpath is missing the `flink-shaded-hadoop2-uber-2.8.3-1.8.0

[jira] [Updated] (FLINK-11972) The classpath is missing the `flink-shaded-hadoop2-uber-2.8.3-1.8.0.jar` JAR during the end-to-end test.

2019-03-20 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-11972: Attachment: image-2019-03-21-06-26-49-787.png > The classpath is missing the `flink-shaded-hadoop2

[jira] [Commented] (FLINK-11972) The classpath is missing the `flink-shaded-hadoop2-uber-2.8.3-1.8.0.jar` JAR during the end-to-end test.

2019-03-20 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16797561#comment-16797561 ] sunjincheng commented on FLINK-11972: - Sounds good! > The classpath is missing the

[jira] [Commented] (FLINK-11971) Fix `Command: start_kubernetes_if_not_ruunning failed` error

2019-03-20 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16797516#comment-16797516 ] sunjincheng commented on FLINK-11971: - Thanks for taking this JIRA. [~hequn8128]! Du

[jira] [Commented] (FLINK-11972) The classpath is missing the `flink-shaded-hadoop2-uber-2.8.3-1.8.0.jar` JAR during the end-to-end test.

2019-03-20 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16797524#comment-16797524 ] sunjincheng commented on FLINK-11972: - Hi [~carp84] Thanks for your feedback! and do

[jira] [Closed] (FLINK-11971) Fix `Command: start_kubernetes_if_not_ruunning failed` error

2019-03-20 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-11971. --- Resolution: Fixed Fix Version/s: 1.9.0 1.8.0 Release Note: Fix kuberne

[jira] [Updated] (FLINK-11972) The classpath is missing the `flink-shaded-hadoop2-uber-2.8.3-1.8.0.jar` JAR during the end-to-end test.

2019-03-19 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-11972: Description: Since the difference between 1.8.0 and 1.7.x is that 1.8.x does not put the `hadoop-

[jira] [Updated] (FLINK-11971) Fix `Command: start_kubernetes_if_not_ruunning failed` error

2019-03-19 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-11971: Description: When I did the end-to-end test under Mac OS, I found the following two problems: 1.

[jira] [Updated] (FLINK-11971) Fix `Command: start_kubernetes_if_not_ruunning failed` error

2019-03-19 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-11971: Description: When I did the end-to-end test under Mac OS, I found the following two problems: 1.

[jira] [Updated] (FLINK-11971) Fix `Command: start_kubernetes_if_not_ruunning failed` error

2019-03-19 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-11971: Summary: Fix `Command: start_kubernetes_if_not_ruunning failed` error (was: The classpath is miss

[jira] [Updated] (FLINK-11971) Fix `Command: start_kubernetes_if_not_ruunning failed` error

2019-03-19 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-11971: Attachment: screenshot-1.png > Fix `Command: start_kubernetes_if_not_ruunning failed` error >

[jira] [Updated] (FLINK-11971) The classpath is missing the `flink-shaded-hadoop2-uber-2.8.3-1.8.0.jar` JAR during the end-to-end test.

2019-03-19 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-11971: Summary: The classpath is missing the `flink-shaded-hadoop2-uber-2.8.3-1.8.0.jar` JAR during the e

[jira] [Updated] (FLINK-11972) The classpath is missing the `flink-shaded-hadoop2-uber-2.8.3-1.8.0.jar` JAR during the end-to-end test.

2019-03-19 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-11972: Summary: The classpath is missing the `flink-shaded-hadoop2-uber-2.8.3-1.8.0.jar` JAR during the e

[jira] [Updated] (FLINK-11972) Fix `Command: start_kubernetes_if_not_ruunning failed` error

2019-03-19 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-11972: Description: Since the difference between 1.8.0 and 1.7.x is that 1.8.x does not put the `hadoop-

[jira] [Updated] (FLINK-11972) The classpath is missing the `flink-shaded-hadoop2-uber-2.8.3-1.8.0.jar` JAR during the end-to-end test.

2019-03-19 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-11972: Attachment: (was: image-2019-03-20-14-04-17-933.png) > The classpath is missing the `flink-sha

[jira] [Updated] (FLINK-11971) Fix `Command: start_kubernetes_if_not_ruunning failed` error

2019-03-19 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-11971: Description: When I did the end-to-end test under Mac OS, I found the following two problems: 1.

[jira] [Updated] (FLINK-11971) Fix `Command: start_kubernetes_if_not_ruunning failed` error

2019-03-19 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-11971: Summary: Fix `Command: start_kubernetes_if_not_ruunning failed` error (was: The classpath is miss

[jira] [Updated] (FLINK-11972) Fix `Command: start_kubernetes_if_not_ruunning failed` error

2019-03-19 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-11972: Attachment: (was: image-2019-03-20-14-01-05-647.png) > Fix `Command: start_kubernetes_if_not_r

[jira] [Updated] (FLINK-11972) Fix `Command: start_kubernetes_if_not_ruunning failed` error

2019-03-19 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-11972: Description: When I did the end-to-end test under Mac OS, I found the following two problems: 1.

[jira] [Updated] (FLINK-11972) Fix `Command: start_kubernetes_if_not_ruunning failed` error

2019-03-19 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-11972: Description: When I did the end-to-end test under Mac OS, I found the following two problems: 1.

[jira] [Updated] (FLINK-11972) Fix `Command: start_kubernetes_if_not_ruunning failed` error

2019-03-19 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-11972: Attachment: image-2019-03-20-14-04-17-933.png > Fix `Command: start_kubernetes_if_not_ruunning fai

[jira] [Updated] (FLINK-11972) Fix `Command: start_kubernetes_if_not_ruunning failed` error

2019-03-19 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-11972: Attachment: (was: image-2019-03-20-14-02-29-636.png) > Fix `Command: start_kubernetes_if_not_r

[jira] [Created] (FLINK-11971) The classpath is missing the `flink-shaded-hadoop2-uber-2.8.3-1.8.0.jar` JAR during the end-to-end test.

2019-03-19 Thread sunjincheng (JIRA)
sunjincheng created FLINK-11971: --- Summary: The classpath is missing the `flink-shaded-hadoop2-uber-2.8.3-1.8.0.jar` JAR during the end-to-end test. Key: FLINK-11971 URL: https://issues.apache.org/jira/browse/FLINK-1

[jira] [Created] (FLINK-11972) Fix `Command: start_kubernetes_if_not_ruunning failed` error

2019-03-19 Thread sunjincheng (JIRA)
sunjincheng created FLINK-11972: --- Summary: Fix `Command: start_kubernetes_if_not_ruunning failed` error Key: FLINK-11972 URL: https://issues.apache.org/jira/browse/FLINK-11972 Project: Flink I

[jira] [Created] (FLINK-11967) Add Column Operators/Operations

2019-03-19 Thread sunjincheng (JIRA)
sunjincheng created FLINK-11967: --- Summary: Add Column Operators/Operations Key: FLINK-11967 URL: https://issues.apache.org/jira/browse/FLINK-11967 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-11967) Add Column Operators/Operations

2019-03-19 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-11967: Description: In this Jira will add column operators/operations as follows: 1)   Table(schema) ope

[jira] [Updated] (FLINK-10972) Enhancements to Flink Table API

2019-03-19 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-10972: Description: [link title|http://example.com/]With the continuous efforts from the community, the

[jira] [Closed] (FLINK-11950) Add missing dependencies in NOTICE file of flink-dist.

2019-03-18 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-11950. --- Resolution: Fixed Fix Version/s: 1.9.0 Release Note: Add `frocksdbjni` dependency in NOTI

[jira] [Created] (FLINK-11950) Add missing dependencies in NOTICE file of flink-dist.

2019-03-18 Thread sunjincheng (JIRA)
sunjincheng created FLINK-11950: --- Summary: Add missing dependencies in NOTICE file of flink-dist. Key: FLINK-11950 URL: https://issues.apache.org/jira/browse/FLINK-11950 Project: Flink Issue Ty

[jira] [Closed] (FLINK-11918) Deprecated Window and Rename it to GroupWindow

2019-03-15 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-11918. --- Resolution: Fixed Release Note: The window classes org.apache.flink.table.api.{java, scala}.{T

[jira] [Created] (FLINK-11918) Deprecated Window and Rename it to GroupWindow

2019-03-13 Thread sunjincheng (JIRA)
sunjincheng created FLINK-11918: --- Summary: Deprecated Window and Rename it to GroupWindow Key: FLINK-11918 URL: https://issues.apache.org/jira/browse/FLINK-11918 Project: Flink Issue Type: Impr

[jira] [Comment Edited] (FLINK-11068) Convert the API classes *Table, *Window to interfaces

2019-03-13 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16792316#comment-16792316 ] sunjincheng edited comment on FLINK-11068 at 3/14/19 4:16 AM:

[jira] [Comment Edited] (FLINK-11068) Convert the API classes *Table, *Window to interfaces

2019-03-13 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16792316#comment-16792316 ] sunjincheng edited comment on FLINK-11068 at 3/14/19 4:09 AM:

[jira] [Commented] (FLINK-11068) Convert the API classes *Table, *Window to interfaces

2019-03-13 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16792316#comment-16792316 ] sunjincheng commented on FLINK-11068: - Hi, [~hequn8128] [~twalthr] , I also agree re

[jira] [Closed] (FLINK-11892) Port conflict problem when do the end-to-end nightly-tests.

2019-03-13 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-11892. --- Resolution: Fixed Fix Version/s: 1.9.0 1.8.0 Fixed in Master: 884d26b2731b

[jira] [Commented] (FLINK-11892) Port conflict problem when do the end-to-end nightly-tests.

2019-03-12 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16791286#comment-16791286 ] sunjincheng commented on FLINK-11892: - Hi Thanks for your nice check [~carp84] ! Of

[jira] [Assigned] (FLINK-11892) Port conflict problem when do the end-to-end nightly-tests.

2019-03-12 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-11892: --- Assignee: Yu Li > Port conflict problem when do the end-to-end nightly-tests. > ---

[jira] [Updated] (FLINK-11892) Port conflict problem when do the end-to-end nightly-tests.

2019-03-12 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-11892: Description: When I do the end-to-end check according to `[https://github.com/apache/flink/tree/m

[jira] [Commented] (FLINK-11892) Port conflict problem when do the end-to-end nightly-tests.

2019-03-12 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16791183#comment-16791183 ] sunjincheng commented on FLINK-11892: - Just now I try to use `flink-end-to-end-tests

[jira] [Created] (FLINK-11892) Port conflict problem when do the end-to-end nightly-tests.

2019-03-12 Thread sunjincheng (JIRA)
sunjincheng created FLINK-11892: --- Summary: Port conflict problem when do the end-to-end nightly-tests. Key: FLINK-11892 URL: https://issues.apache.org/jira/browse/FLINK-11892 Project: Flink Is

[jira] [Created] (FLINK-11891) Fix some script or test case bug in 1.8 RC

2019-03-12 Thread sunjincheng (JIRA)
sunjincheng created FLINK-11891: --- Summary: Fix some script or test case bug in 1.8 RC Key: FLINK-11891 URL: https://issues.apache.org/jira/browse/FLINK-11891 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-11379) "java.lang.OutOfMemoryError: Direct buffer memory" when TM loads a large size TDD

2019-02-28 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-11379. --- Resolution: Fixed Fixed in master: 1f5359a5259987b3c9d506d559b6421af961ab0a Fixed in release-1.8: c

[jira] [Commented] (FLINK-11785) Replace case class Null(type) in Table API

2019-02-28 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16780616#comment-16780616 ] sunjincheng commented on FLINK-11785: - +1 for your personal [~twalthr] > Replace ca

[jira] [Closed] (FLINK-11777) fix hadoop_compatibility.md link bug

2019-02-27 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-11777. --- Resolution: Fixed Fix Version/s: 1.9.0 1.8.0 Fixed in master: 626cbc6ef3ff

[jira] [Created] (FLINK-11777) fix hadoop_compatibility.md link bug

2019-02-27 Thread sunjincheng (JIRA)
sunjincheng created FLINK-11777: --- Summary: fix hadoop_compatibility.md link bug Key: FLINK-11777 URL: https://issues.apache.org/jira/browse/FLINK-11777 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-11091) Clear the use of deprecated methods of KeyedStream in table operators

2019-02-27 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-11091. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in master: d1d0bd1b85fc501c67498acaf8dc528b15aa1

[jira] [Closed] (FLINK-11728) Deprecate CalciteConfig temporarily

2019-02-26 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-11728. --- Resolution: Fixed Fix Version/s: 1.9.0 1.8.0 Fixed in master: 7fafb2080f16

[jira] [Commented] (FLINK-11067) Convert TableEnvironments to interfaces

2019-02-26 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16777961#comment-16777961 ] sunjincheng commented on FLINK-11067: - Thanks for the summary [~hequn8128]  And than

[jira] [Updated] (FLINK-11091) Clear the use of deprecated methods of KeyedStream in table operators

2019-02-25 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-11091: Affects Version/s: 1.9.0 > Clear the use of deprecated methods of KeyedStream in table operators >

[jira] [Commented] (FLINK-10875) Add `toTableWithTimestamp` method in `DataStreamConversions`

2019-02-25 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16777616#comment-16777616 ] sunjincheng commented on FLINK-10875: - Did not find a better way. close JIRA first.

[jira] [Closed] (FLINK-10875) Add `toTableWithTimestamp` method in `DataStreamConversions`

2019-02-25 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-10875. --- Resolution: Won't Fix Release Note: Did not find a better way. close JIRA first Will  > Add

[jira] [Commented] (FLINK-11068) Convert the API classes *Table, *Window to interfaces

2019-02-20 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16773732#comment-16773732 ] sunjincheng commented on FLINK-11068: - Hi [~twalthr] for the current JIRA. we do not

[jira] [Commented] (FLINK-11067) Convert TableEnvironments to interfaces

2019-02-20 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16773726#comment-16773726 ] sunjincheng commented on FLINK-11067: - Yes,+1 for {{api.BaseTableEnvironment}} to {{

[jira] [Commented] (FLINK-11067) Convert TableEnvironments to interfaces

2019-02-18 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16771442#comment-16771442 ] sunjincheng commented on FLINK-11067: - Thanks for taking this ticket, I think [~twal

[jira] [Commented] (FLINK-11068) Convert the API classes *Table, *Window to interfaces

2019-02-18 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16771009#comment-16771009 ] sunjincheng commented on FLINK-11068: - Thanks for update the description [~twalthr],

[jira] [Commented] (FLINK-11067) Convert TableEnvironments to interfaces

2019-02-17 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16770765#comment-16770765 ] sunjincheng commented on FLINK-11067: - Hi [~twalthr] thanks for redefining the curre

[jira] [Updated] (FLINK-10241) Reduce performance/stability impact of latency metrics

2019-02-14 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-10241: Fix Version/s: (was: 1.6.4) 1.6.5 > Reduce performance/stability impact of

[jira] [Updated] (FLINK-10954) Hardlink from files of previous local stored state might cross devices

2019-02-14 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-10954: Fix Version/s: (was: 1.6.4) 1.6.5 > Hardlink from files of previous local s

[jira] [Updated] (FLINK-9680) Reduce heartbeat timeout for E2E tests

2019-02-14 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-9680: --- Fix Version/s: (was: 1.6.4) 1.6.5 > Reduce heartbeat timeout for E2E tests > -

[jira] [Updated] (FLINK-9228) log details about task fail/task manager is shutting down

2019-02-14 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-9228: --- Fix Version/s: (was: 1.6.4) 1.6.5 > log details about task fail/task manager i

[jira] [Updated] (FLINK-8803) Mini Cluster Shutdown with HA unstable, causing test failures

2019-02-14 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-8803: --- Fix Version/s: (was: 1.6.4) 1.6.5 > Mini Cluster Shutdown with HA unstable, ca

[jira] [Updated] (FLINK-10317) Configure Metaspace size by default

2019-02-14 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-10317: Fix Version/s: (was: 1.6.4) 1.6.5 > Configure Metaspace size by default > -

[jira] [Updated] (FLINK-10435) Client sporadically hangs after Ctrl + C

2019-02-14 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-10435: Fix Version/s: (was: 1.6.4) 1.6.5 > Client sporadically hangs after Ctrl +

[jira] [Updated] (FLINK-9879) Find sane defaults for (advanced) SSL session parameters

2019-02-14 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-9879: --- Fix Version/s: (was: 1.6.4) 1.6.5 > Find sane defaults for (advanced) SSL sess

[jira] [Updated] (FLINK-11107) [state] Avoid memory stateBackend to create arbitrary folders under HA path when no checkpoint path configured

2019-02-14 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-11107: Fix Version/s: (was: 1.6.4) 1.6.5 > [state] Avoid memory stateBackend to cr

[jira] [Updated] (FLINK-8899) Submitting YARN job with FLIP-6 may lead to ApplicationAttemptNotFoundException

2019-02-14 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-8899: --- Fix Version/s: (was: 1.6.4) 1.6.5 > Submitting YARN job with FLIP-6 may lead t

[jira] [Updated] (FLINK-9469) Add tests that cover PatternStream#flatSelect

2019-02-14 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-9469: --- Fix Version/s: (was: 1.6.4) 1.6.5 > Add tests that cover PatternStream#flatSel

[jira] [Updated] (FLINK-9457) Cancel container requests when cancelling pending slot allocations

2019-02-14 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-9457: --- Fix Version/s: (was: 1.6.4) 1.6.5 > Cancel container requests when cancelling

[jira] [Updated] (FLINK-9142) Lower the minimum number of buffers for incoming channels to 1

2019-02-14 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-9142: --- Fix Version/s: (was: 1.6.4) 1.6.5 > Lower the minimum number of buffers for in

[jira] [Updated] (FLINK-10694) ZooKeeperHaServices Cleanup

2019-02-14 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-10694: Fix Version/s: (was: 1.6.4) 1.6.5 > ZooKeeperHaServices Cleanup > -

[jira] [Updated] (FLINK-10368) 'Kerberized YARN on Docker test' unstable

2019-02-14 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-10368: Fix Version/s: (was: 1.6.4) 1.6.5 > 'Kerberized YARN on Docker test' unstab

[jira] [Updated] (FLINK-9481) FlinkKafkaProducer011ITCase deadlock in initializeState

2019-02-14 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-9481: --- Fix Version/s: (was: 1.6.4) 1.6.5 > FlinkKafkaProducer011ITCase deadlock in in

[jira] [Updated] (FLINK-9761) Potential buffer leak in PartitionRequestClientHandler during job failures

2019-02-14 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-9761: --- Fix Version/s: (was: 1.6.4) 1.6.5 > Potential buffer leak in PartitionRequestC

[jira] [Updated] (FLINK-8902) Re-scaling job sporadically fails with KeeperException

2019-02-14 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-8902: --- Fix Version/s: (was: 1.6.4) 1.6.5 > Re-scaling job sporadically fails with Kee

[jira] [Updated] (FLINK-10292) Generate JobGraph in StandaloneJobClusterEntrypoint only once

2019-02-14 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-10292: Fix Version/s: (was: 1.6.4) 1.6.5 > Generate JobGraph in StandaloneJobClust

[jira] [Updated] (FLINK-7351) test instability in JobClientActorRecoveryITCase#testJobClientRecovery

2019-02-14 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-7351: --- Fix Version/s: (was: 1.6.4) 1.6.5 > test instability in JobClientActorRecovery

[jira] [Updated] (FLINK-5125) ContinuousFileProcessingCheckpointITCase is Flaky

2019-02-14 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-5125: --- Fix Version/s: (was: 1.6.4) 1.6.5 > ContinuousFileProcessingCheckpointITCase i

<    1   2   3   4   5   6   7   8   9   10   >