[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

[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:

[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=16792326#comment-16792326 ] Hequn Cheng commented on FLINK-11068: - [~sunjincheng121] Thanks for your suggestions. I think it

[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:

[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=16792316#comment-16792316 ] sunjincheng edited comment on FLINK-11068 at 3/14/19 4:16 AM: -- Hi,

[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=16792316#comment-16792316 ] sunjincheng edited comment on FLINK-11068 at 3/14/19 4:09 AM: -- Hi,

[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=16792316#comment-16792316 ] sunjincheng commented on FLINK-11068: - Hi, [~hequn8128] [~twalthr] , I also agree rename `Window` to

[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:

[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

[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

[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

[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

[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:

[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:

[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=16792304#comment-16792304 ] vinoyang commented on FLINK-11909: -- [~walterddr] oh... sorry, I will release this issue. > Provide

[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=16792294#comment-16792294 ] Rong Rong commented on FLINK-11909: --- [~yanghua] Hi Vino, we haven't reach an agreement and a target

[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

[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

[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

[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=16792277#comment-16792277 ] Kurt Young commented on FLINK-11905: I will take a look and fix this, thanks for the reporting

[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=16792272#comment-16792272 ] vinoyang commented on FLINK-11733: -- [~fhueske] Of cause, if there is another choice, I would like to

[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

[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=16792207#comment-16792207 ] Shuyi Chen commented on FLINK-11914: Hi [~Zentol], [~trohrm...@apache.org], [~gyao], what do you

[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=16792155#comment-16792155 ] Shuyi Chen edited comment on FLINK-11912 at 3/14/19 12:24 AM: -- Hi

[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=16792155#comment-16792155 ] Shuyi Chen edited comment on FLINK-11912 at 3/14/19 12:22 AM: -- Hi

[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

[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

[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=16792155#comment-16792155 ] Shuyi Chen edited comment on FLINK-11912 at 3/13/19 10:36 PM: -- Hi

[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

[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

[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=16792155#comment-16792155 ] Shuyi Chen edited comment on FLINK-11912 at 3/13/19 10:29 PM: -- Hi

[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=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

[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

[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

[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

[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

[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:

[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

[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,

[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=16792126#comment-16792126 ] Maximilian Michels commented on FLINK-2491: --- I think we should take the time to finally address

[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

[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

[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

[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=16791994#comment-16791994 ] Ken Krugler commented on FLINK-11906: - Hi Ramesh - for a problem like this, please first post to the

[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

[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

[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=16791832#comment-16791832 ] Jürgen Kreileder commented on FLINK-11654: -- [~aljoscha] There might be an additional issue

[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=16791812#comment-16791812 ] Hequn Cheng commented on FLINK-11908: - Hi [~twalthr], One thing need to confirm with you is I find

[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=16791806#comment-16791806 ] Hequn Cheng commented on FLINK-11068: - I have created FLINK-11908 for porting window classes and we

[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:

[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:

[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:

[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=16791790#comment-16791790 ] Hequn Cheng commented on FLINK-11068: - Hi [~twalthr], Great to have your suggestions. Thanks for

[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.

[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:

[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

[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

[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=16791765#comment-16791765 ] Yun Tang commented on FLINK-11107: -- User also meet this problem and report it in [chinese mail

[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:

[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 >

[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=16791752#comment-16791752 ] Timo Walther commented on FLINK-11905: -- CC: [~ykt836] > BlockCompressionTest does not compile with

[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=16791749#comment-16791749 ] Ashish Pokharel commented on FLINK-6131: Thanks Fabian! Looking forward to try out Blink

[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

[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:

[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,

[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=16791730#comment-16791730 ] Fabian Hueske commented on FLINK-11733: --- OK, I was thinking of something else but it doesn't seem

[GitHub] [flink] flinkbot edited a comment on issue #7975: [FLINK-11901][build] Update NOTICE files with year 2019

2019-03-13 Thread GitBox
flinkbot edited a comment on issue #7975: [FLINK-11901][build] Update NOTICE files with year 2019 URL: https://github.com/apache/flink/pull/7975#issuecomment-472424089 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] [flink] twalthr commented on issue #7975: [FLINK-11901][build] Update NOTICE files with year 2019

2019-03-13 Thread GitBox
twalthr commented on issue #7975: [FLINK-11901][build] Update NOTICE files with year 2019 URL: https://github.com/apache/flink/pull/7975#issuecomment-472432284 Thanks @zentol. Will merge this to master and 1.8 branch...

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

2019-03-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11901: --- Labels: pull-request-available (was: ) > Update the year in NOTICE files >

[GitHub] [flink] sunhaibotb commented on a change in pull request #7959: [FLINK-11876] Introduce new TwoInputSelectable, BoundedOneInput and BoundedTwoInput interfaces

2019-03-13 Thread GitBox
sunhaibotb commented on a change in pull request #7959: [FLINK-11876] Introduce new TwoInputSelectable, BoundedOneInput and BoundedTwoInput interfaces URL: https://github.com/apache/flink/pull/7959#discussion_r265115073 ## File path:

[GitHub] [flink] flinkbot commented on issue #7975: [FLINK-11901][build] Update NOTICE files with year 2019

2019-03-13 Thread GitBox
flinkbot commented on issue #7975: [FLINK-11901][build] Update NOTICE files with year 2019 URL: https://github.com/apache/flink/pull/7975#issuecomment-472424089 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[GitHub] [flink] twalthr opened a new pull request #7975: [FLINK-11901][build] Update NOTICE files with year 2019

2019-03-13 Thread GitBox
twalthr opened a new pull request #7975: [FLINK-11901][build] Update NOTICE files with year 2019 URL: https://github.com/apache/flink/pull/7975 ## What is the purpose of the change Provides a script for updating the NOTICE file year and updates it to 2019. ## Brief

[GitHub] [flink] sunhaibotb commented on a change in pull request #7959: [FLINK-11876] Introduce new TwoInputSelectable, BoundedOneInput and BoundedTwoInput interfaces

2019-03-13 Thread GitBox
sunhaibotb commented on a change in pull request #7959: [FLINK-11876] Introduce new TwoInputSelectable, BoundedOneInput and BoundedTwoInput interfaces URL: https://github.com/apache/flink/pull/7959#discussion_r265126375 ## File path:

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

2019-03-13 Thread GitBox
flinkbot commented 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 to

[jira] [Updated] (FLINK-11902) JarRunHandler wraps all exceptions in a RestHandlerException

2019-03-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11902: --- Labels: pull-request-available (was: ) > JarRunHandler wraps all exceptions in a

[GitHub] [flink] zentol opened a new pull request #7974: [FLINK-11902][rest] Do not wrap all exceptions in RestHandlerException

2019-03-13 Thread GitBox
zentol opened a new pull request #7974: [FLINK-11902][rest] Do not wrap all exceptions in RestHandlerException URL: https://github.com/apache/flink/pull/7974 ## What is the purpose of the change Modifies the `JarRunHandler` to not blanket-wrap all exceptions in a

[jira] [Created] (FLINK-11904) Improve MemoryStateBackendTest by using JUnit's Parameterized

2019-03-13 Thread Congxian Qiu(klion26) (JIRA)
Congxian Qiu(klion26) created FLINK-11904: - Summary: Improve MemoryStateBackendTest by using JUnit's Parameterized Key: FLINK-11904 URL: https://issues.apache.org/jira/browse/FLINK-11904

  1   2   3   >