[GitHub] [flink] klion26 commented on a change in pull request #7978: [FLINK-11910] [Yarn] add customizable yarn application type

2019-03-13 Thread GitBox
klion26 commented on a change in pull request #7978: [FLINK-11910] [Yarn] add customizable yarn application type URL: https://github.com/apache/flink/pull/7978#discussion_r265435977 ## File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java #

[GitHub] [flink] klion26 commented on a change in pull request #7978: [FLINK-11910] [Yarn] add customizable yarn application type

2019-03-13 Thread GitBox
klion26 commented on a change in pull request #7978: [FLINK-11910] [Yarn] add customizable yarn application type URL: https://github.com/apache/flink/pull/7978#discussion_r265436293 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java ###

[GitHub] [flink] flinkbot edited a comment on issue #7976: [FLINK-11908] Port window classes into flink-api-java

2019-03-13 Thread GitBox
flinkbot edited a comment on issue #7976: [FLINK-11908] Port window classes into flink-api-java URL: https://github.com/apache/flink/pull/7976#issuecomment-472496692 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pu

[GitHub] [flink] sunjincheng121 commented on issue #7976: [FLINK-11908] Port window classes into flink-api-java

2019-03-13 Thread GitBox
sunjincheng121 commented on issue #7976: [FLINK-11908] Port window classes into flink-api-java URL: https://github.com/apache/flink/pull/7976#issuecomment-472724193 @flinkbot approve description @flinkbot approve consensus

[GitHub] [flink] sunjincheng121 commented on a change in pull request #7976: [FLINK-11908] Port window classes into flink-api-java

2019-03-13 Thread GitBox
sunjincheng121 commented on a change in pull request #7976: [FLINK-11908] Port window classes into flink-api-java URL: https://github.com/apache/flink/pull/7976#discussion_r265428159 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/Over.java

[GitHub] [flink] sunjincheng121 commented on a change in pull request #7976: [FLINK-11908] Port window classes into flink-api-java

2019-03-13 Thread GitBox
sunjincheng121 commented on a change in pull request #7976: [FLINK-11908] Port window classes into flink-api-java URL: https://github.com/apache/flink/pull/7976#discussion_r265430557 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/Tumble.java

[GitHub] [flink] sunjincheng121 commented on a change in pull request #7976: [FLINK-11908] Port window classes into flink-api-java

2019-03-13 Thread GitBox
sunjincheng121 commented on a change in pull request #7976: [FLINK-11908] Port window classes into flink-api-java URL: https://github.com/apache/flink/pull/7976#discussion_r265431296 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/api/table.scala

[GitHub] [flink] sunjincheng121 commented on a change in pull request #7976: [FLINK-11908] Port window classes into flink-api-java

2019-03-13 Thread GitBox
sunjincheng121 commented on a change in pull request #7976: [FLINK-11908] Port window classes into flink-api-java URL: https://github.com/apache/flink/pull/7976#discussion_r265435172 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/api/windows.sca

[jira] [Commented] (FLINK-11890) Replace Table API string-based expressions by a Java DSL

2019-03-13 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16792393#comment-16792393 ] Hequn Cheng commented on FLINK-11890: - Cool, looking forward to the proposal. > Rep

[jira] [Commented] (FLINK-11914) Expose a REST endpoint in JobManager to kill specific TaskManager

2019-03-13 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16792380#comment-16792380 ] Gary Yao commented on FLINK-11914: -- [~suez1224] I assume that you need this because you

[jira] [Updated] (FLINK-11914) Expose a REST endpoint in JobManager to kill specific TaskManager

2019-03-13 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-11914: - Summary: Expose a REST endpoint in JobManager to kill specific TaskManager (was: Expose a REST endpoint

[jira] [Updated] (FLINK-11528) Translate the "Use Cases" page into Chinese

2019-03-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11528: --- Labels: pull-request-available (was: ) > Translate the "Use Cases" page into Chinese >

[jira] [Updated] (FLINK-11908) Port window classes into flink-api-java

2019-03-13 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-11908: Issue Type: Sub-task (was: Improvement) Parent: FLINK-11068 > Port window classes into fl

[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] [Commented] (FLINK-11068) Convert the API classes *Table, *Window to interfaces

2019-03-13 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16792326#comment-16792326 ] Hequn Cheng commented on FLINK-11068: - [~sunjincheng121] Thanks for your suggestions

[GitHub] [flink] sunjincheng121 commented on a change in pull request #7976: [FLINK-11908] Port window classes into flink-api-java

2019-03-13 Thread GitBox
sunjincheng121 commented on a change in pull request #7976: [FLINK-11908] Port window classes into flink-api-java URL: https://github.com/apache/flink/pull/7976#discussion_r265415615 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/GroupWindow

[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] [Updated] (FLINK-11909) Provide default failure/timeout/backoff handling strategy for AsyncIO functions

2019-03-13 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11909: -- Summary: Provide default failure/timeout/backoff handling strategy for AsyncIO functions (was: Provid

[jira] [Updated] (FLINK-11909) Provide default failure/timeout handling strategy for AsyncIO functions

2019-03-13 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11909: -- Description: Currently Flink AsyncIO by default fails the entire job when async function invoke fails

[jira] [Updated] (FLINK-11909) Provide default failure/timeout handling strategy for AsyncIO functions

2019-03-13 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11909: -- Description: Currently Flink AsyncIO by default fails the entire job when async function invoke fails

[jira] [Updated] (FLINK-11909) Provide default failure/timeout handling strategy for AsyncIO functions

2019-03-13 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11909: -- Description: Currently Flink AsyncIO by default fails the entire job when async function invoke fails

[jira] [Assigned] (FLINK-11909) Provide default failure/timeout handling strategy for AsyncIO functions

2019-03-13 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong reassigned FLINK-11909: - Assignee: Rong Rong > Provide default failure/timeout handling strategy for AsyncIO functions >

[jira] [Assigned] (FLINK-11909) Provide default failure/timeout handling strategy for AsyncIO functions

2019-03-13 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-11909: Assignee: (was: vinoyang) > Provide default failure/timeout handling strategy for AsyncIO fun

[GitHub] [flink] KurtYoung commented on a change in pull request #7958: [FLINK-11881][table-planner-blink] Introduce code generated typed sort to blink table

2019-03-13 Thread GitBox
KurtYoung commented on a change in pull request #7958: [FLINK-11881][table-planner-blink] Introduce code generated typed sort to blink table URL: https://github.com/apache/flink/pull/7958#discussion_r265407720 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/a

[GitHub] [flink] KurtYoung commented on a change in pull request #7958: [FLINK-11881][table-planner-blink] Introduce code generated typed sort to blink table

2019-03-13 Thread GitBox
KurtYoung commented on a change in pull request #7958: [FLINK-11881][table-planner-blink] Introduce code generated typed sort to blink table URL: https://github.com/apache/flink/pull/7958#discussion_r265407794 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/a

[jira] [Commented] (FLINK-11909) Provide default failure/timeout handling strategy for AsyncIO functions

2019-03-13 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16792304#comment-16792304 ] vinoyang commented on FLINK-11909: -- [~walterddr] oh... sorry, I will release this issue

[jira] [Commented] (FLINK-11909) Provide default failure/timeout handling strategy for AsyncIO functions

2019-03-13 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16792294#comment-16792294 ] Rong Rong commented on FLINK-11909: --- [~yanghua] Hi Vino, we haven't reach an agreement

[jira] [Created] (FLINK-11917) Allow state schema migration from Kryo to POJO / Avro

2019-03-13 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-11917: --- Summary: Allow state schema migration from Kryo to POJO / Avro Key: FLINK-11917 URL: https://issues.apache.org/jira/browse/FLINK-11917 Project: Flink

[GitHub] [flink] chummyhe89 commented on issue #5394: [FLINK-6571][tests] Catch InterruptedException in StreamSourceOperato…

2019-03-13 Thread GitBox
chummyhe89 commented on issue #5394: [FLINK-6571][tests] Catch InterruptedException in StreamSourceOperato… URL: https://github.com/apache/flink/pull/5394#issuecomment-472685821 Does this resolve the problem? ```java @Override public void run(SourceContext ctx) throws Exception {

[GitHub] [flink] flinkbot commented on issue #7981: [FLINK-11905][table-runtime-blink] Fix BlockCompressionTest does not compile with Java 9

2019-03-13 Thread GitBox
flinkbot commented on issue #7981: [FLINK-11905][table-runtime-blink] Fix BlockCompressionTest does not compile with Java 9 URL: https://github.com/apache/flink/pull/7981#issuecomment-472684588 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the co

[GitHub] [flink] KurtYoung opened a new pull request #7981: [FLINK-11905][table-runtime-blink] Fix BlockCompressionTest does not compile with Java 9

2019-03-13 Thread GitBox
KurtYoung opened a new pull request #7981: [FLINK-11905][table-runtime-blink] Fix BlockCompressionTest does not compile with Java 9 URL: https://github.com/apache/flink/pull/7981 ## What is the purpose of the change Fix BlockCompressionTest does not compile with Java 9 ##

[jira] [Updated] (FLINK-11905) BlockCompressionTest does not compile with Java 9

2019-03-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11905: --- Labels: blink pull-request-available (was: blink) > BlockCompressionTest does not compile w

[GitHub] [flink] tzulitai commented on issue #7979: [FLINK-11911] Make KafkaTopicPartition a valid POJO

2019-03-13 Thread GitBox
tzulitai commented on issue #7979: [FLINK-11911] Make KafkaTopicPartition a valid POJO URL: https://github.com/apache/flink/pull/7979#issuecomment-472684022 @flinkbot disapprove consensus The main problem with this change is that this breaks state compatibility with previous savepoi

[jira] [Created] (FLINK-11916) Join with a Temporal Table should throw exception for left join

2019-03-13 Thread Hequn Cheng (JIRA)
Hequn Cheng created FLINK-11916: --- Summary: Join with a Temporal Table should throw exception for left join Key: FLINK-11916 URL: https://issues.apache.org/jira/browse/FLINK-11916 Project: Flink

[jira] [Commented] (FLINK-11905) BlockCompressionTest does not compile with Java 9

2019-03-13 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16792277#comment-16792277 ] Kurt Young commented on FLINK-11905: I will take a look and fix this, thanks for the

[jira] [Commented] (FLINK-11733) Provide HadoopMapFunction for org.apache.hadoop.mapreduce.Mapper

2019-03-13 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16792272#comment-16792272 ] vinoyang commented on FLINK-11733: -- [~fhueske] Of cause, if there is another choice, I

[jira] [Assigned] (FLINK-11909) Provide default failure/timeout handling strategy for AsyncIO functions

2019-03-13 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-11909: Assignee: vinoyang > Provide default failure/timeout handling strategy for AsyncIO functions > --

[jira] [Assigned] (FLINK-11905) BlockCompressionTest does not compile with Java 9

2019-03-13 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-11905: -- Assignee: Kurt Young > BlockCompressionTest does not compile with Java 9 > --

[jira] [Created] (FLINK-11915) DataInputViewStream skip returns wrong value

2019-03-13 Thread Andrew Prudhomme (JIRA)
Andrew Prudhomme created FLINK-11915: Summary: DataInputViewStream skip returns wrong value Key: FLINK-11915 URL: https://issues.apache.org/jira/browse/FLINK-11915 Project: Flink Issue Ty

[jira] [Commented] (FLINK-11914) Expose a REST endpoint in JobManager to disconnect specific TaskManager

2019-03-13 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16792207#comment-16792207 ] Shuyi Chen commented on FLINK-11914: Hi [~Zentol], [~trohrm...@apache.org], [~gyao],

[jira] [Comment Edited] (FLINK-11912) Expose per partition Kafka lag metric in Flink Kafka connector

2019-03-13 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16792155#comment-16792155 ] Shuyi Chen edited comment on FLINK-11912 at 3/14/19 12:24 AM:

[jira] [Comment Edited] (FLINK-11912) Expose per partition Kafka lag metric in Flink Kafka connector

2019-03-13 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16792155#comment-16792155 ] Shuyi Chen edited comment on FLINK-11912 at 3/14/19 12:22 AM:

[GitHub] [flink] flinkbot commented on issue #7980: [FLINK-11913] Shadding cassandra driver dependencies in cassandra conector

2019-03-13 Thread GitBox
flinkbot commented on issue #7980: [FLINK-11913] Shadding cassandra driver dependencies in cassandra conector URL: https://github.com/apache/flink/pull/7980#issuecomment-472641520 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Updated] (FLINK-11913) Cassandra connector should shade it's usage of cassandra-driver classes to avoid conflicts

2019-03-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11913: --- Labels: cassandra pull-request-available (was: cassandra) > Cassandra connector should shad

[GitHub] [flink] gustavo-momente opened a new pull request #7980: [FLINK-11913] Shadding cassandra driver dependencies in cassandra conector

2019-03-13 Thread GitBox
gustavo-momente opened a new pull request #7980: [FLINK-11913] Shadding cassandra driver dependencies in cassandra conector URL: https://github.com/apache/flink/pull/7980 ## What is the purpose of the change The Cassandra connector have some dependencies that need to be available and

[jira] [Created] (FLINK-11914) Expose a REST endpoint in JobManager to disconnect specific TaskManager

2019-03-13 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-11914: -- Summary: Expose a REST endpoint in JobManager to disconnect specific TaskManager Key: FLINK-11914 URL: https://issues.apache.org/jira/browse/FLINK-11914 Project: Flink

[jira] [Comment Edited] (FLINK-11912) Expose per partition Kafka lag metric in Flink Kafka connector

2019-03-13 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16792155#comment-16792155 ] Shuyi Chen edited comment on FLINK-11912 at 3/13/19 10:36 PM:

[GitHub] [flink] Fokko removed a comment on issue #7979: [FLINK-11911] Make KafkaTopicPartition a valid POJO

2019-03-13 Thread GitBox
Fokko removed a comment on issue #7979: [FLINK-11911] Make KafkaTopicPartition a valid POJO URL: https://github.com/apache/flink/pull/7979#issuecomment-472632208 @flinkbot approve description This is an automated message from

[GitHub] [flink] Fokko commented on issue #7979: [FLINK-11911] Make KafkaTopicPartition a valid POJO

2019-03-13 Thread GitBox
Fokko commented on issue #7979: [FLINK-11911] Make KafkaTopicPartition a valid POJO URL: https://github.com/apache/flink/pull/7979#issuecomment-472632208 @flinkbot approve description This is an automated message from the Apa

[jira] [Comment Edited] (FLINK-11912) Expose per partition Kafka lag metric in Flink Kafka connector

2019-03-13 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16792155#comment-16792155 ] Shuyi Chen edited comment on FLINK-11912 at 3/13/19 10:29 PM:

[jira] [Commented] (FLINK-11912) Expose per partition Kafka lag metric in Flink Kafka connector

2019-03-13 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16792155#comment-16792155 ] Shuyi Chen commented on FLINK-11912: Hi [~tzulitai], I've attached a proposed change

[jira] [Updated] (FLINK-11912) Expose per partition Kafka lag metric in Flink Kafka connector

2019-03-13 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen updated FLINK-11912: --- Summary: Expose per partition Kafka lag metric in Flink Kafka connector (was: Expose per partition

[jira] [Created] (FLINK-11913) Cassandra connector should shade it's usage of cassandra-driver classes to avoid conflicts

2019-03-13 Thread JIRA
Gustavo Momenté created FLINK-11913: --- Summary: Cassandra connector should shade it's usage of cassandra-driver classes to avoid conflicts Key: FLINK-11913 URL: https://issues.apache.org/jira/browse/FLINK-11913

[jira] [Updated] (FLINK-11912) Expose per partition Kafka lag metric in Flink Kafka connector

2019-03-13 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen updated FLINK-11912: --- Description: In production, it's important that we expose the Kafka lag by partition metric in orde

[jira] [Created] (FLINK-11912) Expose per partition Kafka lag metric in Flink Kafka consumer

2019-03-13 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-11912: -- Summary: Expose per partition Kafka lag metric in Flink Kafka consumer Key: FLINK-11912 URL: https://issues.apache.org/jira/browse/FLINK-11912 Project: Flink Is

[GitHub] [flink] flinkbot commented on issue #7979: Fd patch kafka topic partition

2019-03-13 Thread GitBox
flinkbot commented on issue #7979: Fd patch kafka topic partition URL: https://github.com/apache/flink/pull/7979#issuecomment-472626266 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this co

[GitHub] [flink] Fokko opened a new pull request #7979: Fd patch kafka topic partition

2019-03-13 Thread GitBox
Fokko opened a new pull request #7979: Fd patch kafka topic partition URL: https://github.com/apache/flink/pull/7979 ## What is the purpose of the change KafkaTopicPartition is not a POJO, and therefore it cannot be serialized efficiently. This is using the KafkaDeserializationSchema

[jira] [Closed] (FLINK-11883) Harmonize the version of maven-shade-plugin

2019-03-13 Thread Fokko Driesprong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fokko Driesprong closed FLINK-11883. Resolution: Won't Fix > Harmonize the version of maven-shade-plugin >

[jira] [Updated] (FLINK-11911) KafkaTopicPartition is not a valid POJO

2019-03-13 Thread Fokko Driesprong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fokko Driesprong updated FLINK-11911: - Affects Version/s: (was: 1.7.2) 1.8.0 > KafkaTopicPartition i

[jira] [Created] (FLINK-11911) KafkaTopicPartition is not a valid POJO

2019-03-13 Thread Fokko Driesprong (JIRA)
Fokko Driesprong created FLINK-11911: Summary: KafkaTopicPartition is not a valid POJO Key: FLINK-11911 URL: https://issues.apache.org/jira/browse/FLINK-11911 Project: Flink Issue Type: B

[GitHub] [flink] Fokko commented on issue #7962: [FLINK-11883] Harmonize the version of maven-shade-plugin

2019-03-13 Thread GitBox
Fokko commented on issue #7962: [FLINK-11883] Harmonize the version of maven-shade-plugin URL: https://github.com/apache/flink/pull/7962#issuecomment-472624464 Thanks for the explanation @zentol This is an automated message f

[GitHub] [flink] Fokko closed pull request #7962: [FLINK-11883] Harmonize the version of maven-shade-plugin

2019-03-13 Thread GitBox
Fokko closed pull request #7962: [FLINK-11883] Harmonize the version of maven-shade-plugin URL: https://github.com/apache/flink/pull/7962 This is an automated message from the Apache Git Service. To respond to the message, p

[jira] [Commented] (FLINK-2491) Checkpointing only works if all operators/tasks are still running

2019-03-13 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16792126#comment-16792126 ] Maximilian Michels commented on FLINK-2491: --- I think we should take the time to

[GitHub] [flink] flinkbot commented on issue #7978: [FLINK-11910] [Yarn] add customizable yarn application type

2019-03-13 Thread GitBox
flinkbot commented on issue #7978: [FLINK-11910] [Yarn] add customizable yarn application type URL: https://github.com/apache/flink/pull/7978#issuecomment-472607121 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pul

[GitHub] [flink] HuangZhenQiu opened a new pull request #7978: [FLINK-11910] [Yarn] add customizable yarn application type

2019-03-13 Thread GitBox
HuangZhenQiu opened a new pull request #7978: [FLINK-11910] [Yarn] add customizable yarn application type URL: https://github.com/apache/flink/pull/7978 ## What is the purpose of the change Let user customize yarn application type tag by using dynamic properties. ## Brief chan

[jira] [Updated] (FLINK-11910) Make Yarn Application Type Customizable with Flink Version

2019-03-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11910: --- Labels: pull-request-available (was: ) > Make Yarn Application Type Customizable with Flink

[jira] [Created] (FLINK-11910) Make Yarn Application Type Customizable with Flink Version

2019-03-13 Thread Zhenqiu Huang (JIRA)
Zhenqiu Huang created FLINK-11910: - Summary: Make Yarn Application Type Customizable with Flink Version Key: FLINK-11910 URL: https://issues.apache.org/jira/browse/FLINK-11910 Project: Flink

[jira] [Updated] (FLINK-12) [GitHub] Rework Configuration Objects

2019-03-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-12: Component/s: Runtime / Configuration > [GitHub] Rework Configuration Objects > --

[jira] [Commented] (FLINK-11906) Getting error while submitting job

2019-03-13 Thread Ken Krugler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16791994#comment-16791994 ] Ken Krugler commented on FLINK-11906: - Hi Ramesh - for a problem like this, please f

[GitHub] [flink] flinkbot commented on issue #7977: [hotfix][runtime] Delete unused code from ExecutionGraph

2019-03-13 Thread GitBox
flinkbot commented on issue #7977: [hotfix][runtime] Delete unused code from ExecutionGraph URL: https://github.com/apache/flink/pull/7977#issuecomment-472536271 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull r

[GitHub] [flink] GJL opened a new pull request #7977: [hotfix][runtime] Delete unused code from ExecutionGraph

2019-03-13 Thread GitBox
GJL opened a new pull request #7977: [hotfix][runtime] Delete unused code from ExecutionGraph URL: https://github.com/apache/flink/pull/7977 ## What is the purpose of the change *This deletes unused code from ExecutionGraph.* ## Brief change log - *See commits*

[jira] [Created] (FLINK-11909) Provide default failure/timeout handling strategy for AsyncIO functions

2019-03-13 Thread Rong Rong (JIRA)
Rong Rong created FLINK-11909: - Summary: Provide default failure/timeout handling strategy for AsyncIO functions Key: FLINK-11909 URL: https://issues.apache.org/jira/browse/FLINK-11909 Project: Flink

[jira] [Updated] (FLINK-11908) Port window classes into flink-api-java

2019-03-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11908: --- Labels: pull-request-available (was: ) > Port window classes into flink-api-java >

[GitHub] [flink] flinkbot commented on issue #7976: [FLINK-11908] Port window classes into flink-api-java

2019-03-13 Thread GitBox
flinkbot commented on issue #7976: [FLINK-11908] Port window classes into flink-api-java URL: https://github.com/apache/flink/pull/7976#issuecomment-472496692 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull requ

[GitHub] [flink] hequn8128 opened a new pull request #7976: [FLINK-11908] Port window classes into flink-api-java

2019-03-13 Thread GitBox
hequn8128 opened a new pull request #7976: [FLINK-11908] Port window classes into flink-api-java URL: https://github.com/apache/flink/pull/7976 ## What is the purpose of the change This pull request ports window classes into flink-api-java module. ## Brief change log

[jira] [Commented] (FLINK-11654) Multiple transactional KafkaProducers writing to same cluster have clashing transaction IDs

2019-03-13 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-11654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16791832#comment-16791832 ] Jürgen Kreileder commented on FLINK-11654: -- [~aljoscha] There might be an addit

[jira] [Commented] (FLINK-11908) Port window classes into flink-api-java

2019-03-13 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16791812#comment-16791812 ] Hequn Cheng commented on FLINK-11908: - Hi [~twalthr], One thing need to confirm with

[GitHub] [flink] tweise commented on issue #7896: [FLINK-9007] [kinesis] [e2e] Add Kinesis end-to-end test

2019-03-13 Thread GitBox
tweise commented on issue #7896: [FLINK-9007] [kinesis] [e2e] Add Kinesis end-to-end test URL: https://github.com/apache/flink/pull/7896#issuecomment-472473747 @StefanRRichter thanks for taking a look. It's good to learn that we have an effort to provide a Java based e2e framework.

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

2019-03-13 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16791806#comment-16791806 ] Hequn Cheng commented on FLINK-11068: - I have created FLINK-11908 for porting window

[jira] [Created] (FLINK-11906) Getting error while submitting job

2019-03-13 Thread Ramesh Srinivasalu (JIRA)
Ramesh Srinivasalu created FLINK-11906: -- Summary: Getting error while submitting job Key: FLINK-11906 URL: https://issues.apache.org/jira/browse/FLINK-11906 Project: Flink Issue Type: B

[jira] [Created] (FLINK-11908) Port window classes into flink-api-java

2019-03-13 Thread Hequn Cheng (JIRA)
Hequn Cheng created FLINK-11908: --- Summary: Port window classes into flink-api-java Key: FLINK-11908 URL: https://issues.apache.org/jira/browse/FLINK-11908 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-11907) GenericTypeInfoTest fails on Java 9

2019-03-13 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-11907: Summary: GenericTypeInfoTest fails on Java 9 Key: FLINK-11907 URL: https://issues.apache.org/jira/browse/FLINK-11907 Project: Flink Issue Type: Sub-t

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

2019-03-13 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16791790#comment-16791790 ] Hequn Cheng commented on FLINK-11068: - Hi [~twalthr], Great to have your suggestions

[GitHub] [flink] asfgit closed pull request #7389: [FLINK-11237] [table] Enhance LocalExecutor to wrap TableEnvironment w/ classloader

2019-03-13 Thread GitBox
asfgit closed pull request #7389: [FLINK-11237] [table] Enhance LocalExecutor to wrap TableEnvironment w/ classloader URL: https://github.com/apache/flink/pull/7389 This is an automated message from the Apache Git Service. T

[jira] [Closed] (FLINK-11237) Enhance LocalExecutor to wrap TableEnvironment w/ user classloader

2019-03-13 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-11237. Resolution: Fixed Fix Version/s: 1.9.0 Fixed in 1.9.0: 4973d8a4121e1eb711a8acba02fb7ced813d

[jira] [Updated] (FLINK-11237) Enhance LocalExecutor to wrap TableEnvironment w/ user classloader

2019-03-13 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-11237: - Component/s: (was: API / Table SQL) SQL / Client > Enhance LocalExecutor to

[jira] [Updated] (FLINK-11237) Enhance LocalExecutor to wrap TableEnvironment w/ user classloader

2019-03-13 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-11237: - Issue Type: Improvement (was: Sub-task) Parent: (was: FLINK-10744) > Enhance LocalE

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

2019-03-13 Thread Yun Tang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16791765#comment-16791765 ] Yun Tang commented on FLINK-11107: -- User also meet this problem and report it in [chine

[GitHub] [flink] flinkbot edited a comment on issue #7974: [FLINK-11902][rest] Do not wrap all exceptions in RestHandlerException

2019-03-13 Thread GitBox
flinkbot edited a comment on issue #7974: [FLINK-11902][rest] Do not wrap all exceptions in RestHandlerException URL: https://github.com/apache/flink/pull/7974#issuecomment-472421030 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] GJL commented on a change in pull request #7974: [FLINK-11902][rest] Do not wrap all exceptions in RestHandlerException

2019-03-13 Thread GitBox
GJL commented on a change in pull request #7974: [FLINK-11902][rest] Do not wrap all exceptions in RestHandlerException URL: https://github.com/apache/flink/pull/7974#discussion_r265156558 ## File path: flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/handlers/J

[jira] [Updated] (FLINK-11905) BlockCompressionTest does not compile with Java 9

2019-03-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11905: - Component/s: (was: API / Table SQL) Runtime / Operators > BlockComp

[jira] [Commented] (FLINK-11905) BlockCompressionTest does not compile with Java 9

2019-03-13 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16791752#comment-16791752 ] Timo Walther commented on FLINK-11905: -- CC: [~ykt836] > BlockCompressionTest does

[jira] [Commented] (FLINK-6131) Add side inputs for DataStream API

2019-03-13 Thread Ashish Pokharel (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16791749#comment-16791749 ] Ashish Pokharel commented on FLINK-6131: Thanks Fabian! Looking forward to try ou

[jira] [Updated] (FLINK-11905) BlockCompressionTest does not compile with Java 9

2019-03-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11905: - Labels: blink (was: ) > BlockCompressionTest does not compile with Java 9 > ---

[jira] [Created] (FLINK-11905) BlockCompressionTest does not compile with Java 9

2019-03-13 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-11905: Summary: BlockCompressionTest does not compile with Java 9 Key: FLINK-11905 URL: https://issues.apache.org/jira/browse/FLINK-11905 Project: Flink Iss

[jira] [Closed] (FLINK-11901) Update the year in NOTICE files

2019-03-13 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-11901. Resolution: Fixed Fix Version/s: 1.8.0 Fixed in 1.9.0: 64086ab0e314481cf1ed800ebb5125256bc2

[GitHub] [flink] asfgit closed pull request #7975: [FLINK-11901][build] Update NOTICE files with year 2019

2019-03-13 Thread GitBox
asfgit closed pull request #7975: [FLINK-11901][build] Update NOTICE files with year 2019 URL: https://github.com/apache/flink/pull/7975 This is an automated message from the Apache Git Service. To respond to the message, p

[jira] [Commented] (FLINK-11733) Provide HadoopMapFunction for org.apache.hadoop.mapreduce.Mapper

2019-03-13 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16791730#comment-16791730 ] Fabian Hueske commented on FLINK-11733: --- OK, I was thinking of something else but

  1   2   3   >