[jira] [Commented] (FLINK-6886) Fix Timestamp field can not be selected in event time case when toDataStream[T], `T` not a `Row` Type.

2017-06-15 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051466#comment-16051466 ] sunjincheng commented on FLINK-6886: So, We have two chances to deal with the problem,

[jira] [Comment Edited] (FLINK-6886) Fix Timestamp field can not be selected in event time case when toDataStream[T], `T` not a `Row` Type.

2017-06-15 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051451#comment-16051451 ] sunjincheng edited comment on FLINK-6886 at 6/16/17 6:27 AM: -

[jira] [Commented] (FLINK-6886) Fix Timestamp field can not be selected in event time case when toDataStream[T], `T` not a `Row` Type.

2017-06-15 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051451#comment-16051451 ] sunjincheng commented on FLINK-6886: But, I think not the optimization issue, because,

[jira] [Commented] (FLINK-6904) Support for quantifier range to CEP's pattern API

2017-06-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051442#comment-16051442 ] ASF GitHub Bot commented on FLINK-6904: --- Github user dianfu commented on the issue:

[GitHub] flink issue #4121: [FLINK-6904] [cep] Support for quantifier range to CEP's ...

2017-06-15 Thread dianfu
Github user dianfu commented on the issue: https://github.com/apache/flink/pull/4121 Hi @dawidwys thanks a lot for the review, what's your thought for the updated patch? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[jira] [Commented] (FLINK-6886) Fix Timestamp field can not be selected in event time case when toDataStream[T], `T` not a `Row` Type.

2017-06-15 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051425#comment-16051425 ] sunjincheng commented on FLINK-6886: Hi, [~fhueske] Thanks for check this issue. Calci

[jira] [Commented] (FLINK-6930) Selecting window start / end on row-based Tumble/Slide window causes NPE

2017-06-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051384#comment-16051384 ] ASF GitHub Bot commented on FLINK-6930: --- Github user hustfxj commented on the issue:

[GitHub] flink issue #4133: [FLINK-6930] [table] Forbid selecting window start/end on...

2017-06-15 Thread hustfxj
Github user hustfxj commented on the issue: https://github.com/apache/flink/pull/4133 +1 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature

[jira] [Assigned] (FLINK-6930) Selecting window start / end on row-based Tumble/Slide window causes NPE

2017-06-15 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-6930: -- Assignee: Jark Wu > Selecting window start / end on row-based Tumble/Slide window causes NPE >

[jira] [Assigned] (FLINK-6925) Add CONCAT/CONCAT_WS supported in SQL

2017-06-15 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-6925: -- Assignee: sunjincheng > Add CONCAT/CONCAT_WS supported in SQL > ---

[jira] [Commented] (FLINK-6934) Consider moving LRUCache class

2017-06-15 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051346#comment-16051346 ] mingleizhang commented on FLINK-6934: - I would say just suggest remove it. Actually, i

[jira] [Created] (FLINK-6934) Consider moving LRUCache class

2017-06-15 Thread mingleizhang (JIRA)
mingleizhang created FLINK-6934: --- Summary: Consider moving LRUCache class Key: FLINK-6934 URL: https://issues.apache.org/jira/browse/FLINK-6934 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-6930) Selecting window start / end on row-based Tumble/Slide window causes NPE

2017-06-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051342#comment-16051342 ] ASF GitHub Bot commented on FLINK-6930: --- GitHub user wuchong opened a pull request:

[GitHub] flink pull request #4133: [FLINK-6930] [table] Forbid selecting window start...

2017-06-15 Thread wuchong
GitHub user wuchong opened a pull request: https://github.com/apache/flink/pull/4133 [FLINK-6930] [table] Forbid selecting window start/end on row-based Tumble/Slide windows Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check

[jira] [Commented] (FLINK-6933) Refactor NFACompiler to reduce code duplication

2017-06-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051335#comment-16051335 ] ASF GitHub Bot commented on FLINK-6933: --- GitHub user dianfu opened a pull request:

[GitHub] flink pull request #4132: [FLINK-6933] [cep] Refactor NFACompiler to reduce ...

2017-06-15 Thread dianfu
GitHub user dianfu opened a pull request: https://github.com/apache/flink/pull/4132 [FLINK-6933] [cep] Refactor NFACompiler to reduce code duplication Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration.

[jira] [Created] (FLINK-6933) Refactor NFACompiler to reduce code duplication

2017-06-15 Thread Dian Fu (JIRA)
Dian Fu created FLINK-6933: -- Summary: Refactor NFACompiler to reduce code duplication Key: FLINK-6933 URL: https://issues.apache.org/jira/browse/FLINK-6933 Project: Flink Issue Type: Bug C

[jira] [Updated] (FLINK-6891) Add LOG(X) supported in SQL

2017-06-15 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6891: --- Description: LOG(X), LOG(B,X) If called with one parameter, this function returns the natural logarit

[jira] [Updated] (FLINK-6891) Add LOG(X) supported in SQL

2017-06-15 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6891: --- Description: LOG(X), LOG(B,X) If called with one parameter, this function returns the natural logarit

[jira] [Commented] (FLINK-6896) Creating a table from a POJO and use table sink to output fail

2017-06-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051320#comment-16051320 ] ASF GitHub Bot commented on FLINK-6896: --- Github user wuchong commented on the issue:

[GitHub] flink issue #4111: [FLINK-6896][table] Fix generate PojoType input result ex...

2017-06-15 Thread wuchong
Github user wuchong commented on the issue: https://github.com/apache/flink/pull/4111 Travis reported a bug about composite type. Fixed it. Waiting for the new CI pass. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[jira] [Commented] (FLINK-6932) Update the inaccessible Dataflow Model paper link

2017-06-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051269#comment-16051269 ] ASF GitHub Bot commented on FLINK-6932: --- Github user zhangminglei commented on a dif

[GitHub] flink pull request #4131: [FLINK-6932] [doc] Update inaccessible Dataflow Mo...

2017-06-15 Thread zhangminglei
Github user zhangminglei commented on a diff in the pull request: https://github.com/apache/flink/pull/4131#discussion_r122348284 --- Diff: docs/dev/event_time.md --- @@ -146,7 +146,7 @@ to use timestamp assignment and watermark generation in the Flink DataStream API *Note: Fl

[jira] [Updated] (FLINK-6310) LocalExecutor#endSession() uses wrong lock for synchronization

2017-06-15 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-6310: -- Description: Here is related code: {code} public void endSession(JobID jobID) throws Exception { synchron

[jira] [Updated] (FLINK-6105) Properly handle InterruptedException in HadoopInputFormatBase

2017-06-15 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-6105: -- Description: When catching InterruptedException, we should throw InterruptedIOException instead of IOException.

[jira] [Comment Edited] (FLINK-6928) Kafka sink: default topic should not need to exist

2017-06-15 Thread Erik van Oosten (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050925#comment-16050925 ] Erik van Oosten edited comment on FLINK-6928 at 6/15/17 6:39 PM: ---

[jira] [Commented] (FLINK-6928) Kafka sink: default topic should not need to exist

2017-06-15 Thread Erik van Oosten (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050925#comment-16050925 ] Erik van Oosten commented on FLINK-6928: In my ideal world method {{getTargetTopic

[jira] [Commented] (FLINK-6932) Update the inaccessible Dataflow Model paper link

2017-06-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050830#comment-16050830 ] ASF GitHub Bot commented on FLINK-6932: --- Github user greghogan commented on a diff i

[GitHub] flink pull request #4131: [FLINK-6932] [doc] Update inaccessible Dataflow Mo...

2017-06-15 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/4131#discussion_r122263994 --- Diff: docs/dev/event_time.md --- @@ -146,7 +146,7 @@ to use timestamp assignment and watermark generation in the Flink DataStream API *Note: Flink

[jira] [Commented] (FLINK-6932) Update the inaccessible Dataflow Model paper link

2017-06-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050785#comment-16050785 ] ASF GitHub Bot commented on FLINK-6932: --- GitHub user zhangminglei opened a pull requ

[GitHub] flink pull request #4131: [FLINK-6932] [doc] Update inaccessible Dataflow Mo...

2017-06-15 Thread zhangminglei
GitHub user zhangminglei opened a pull request: https://github.com/apache/flink/pull/4131 [FLINK-6932] [doc] Update inaccessible Dataflow Model paper link Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into considerat

[jira] [Commented] (FLINK-6693) Support DATE_FORMAT function in the Table / SQL API

2017-06-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050782#comment-16050782 ] ASF GitHub Bot commented on FLINK-6693: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-6693) Support DATE_FORMAT function in the Table / SQL API

2017-06-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050783#comment-16050783 ] ASF GitHub Bot commented on FLINK-6693: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-6693) Support DATE_FORMAT function in the Table / SQL API

2017-06-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050784#comment-16050784 ] ASF GitHub Bot commented on FLINK-6693: --- Github user fhueske commented on a diff in

[GitHub] flink pull request #4078: [FLINK-6693] [table] Support DATE_FORMAT function ...

2017-06-15 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4078#discussion_r122254102 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/DateTimeFunctionTest.scala --- @@ -0,0 +1,49 @@ +/* + * Lice

[jira] [Commented] (FLINK-6693) Support DATE_FORMAT function in the Table / SQL API

2017-06-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050781#comment-16050781 ] ASF GitHub Bot commented on FLINK-6693: --- Github user fhueske commented on a diff in

[GitHub] flink pull request #4078: [FLINK-6693] [table] Support DATE_FORMAT function ...

2017-06-15 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4078#discussion_r122240819 --- Diff: flink-libraries/flink-table/src/main/java/org/apache/flink/table/runtime/DateTimeFunctions.java --- @@ -0,0 +1,158 @@ +/* + * Licensed to

[GitHub] flink pull request #4078: [FLINK-6693] [table] Support DATE_FORMAT function ...

2017-06-15 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4078#discussion_r122255933 --- Diff: flink-libraries/flink-table/pom.xml --- @@ -110,6 +110,12 @@ under the License. compile + +

[GitHub] flink pull request #4078: [FLINK-6693] [table] Support DATE_FORMAT function ...

2017-06-15 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4078#discussion_r122255414 --- Diff: flink-libraries/flink-table/src/main/java/org/apache/flink/table/runtime/DateTimeFunctions.java --- @@ -0,0 +1,158 @@ +/* + * Licensed to

[jira] [Created] (FLINK-6932) Update the inaccessible Dataflow Model paper link

2017-06-15 Thread mingleizhang (JIRA)
mingleizhang created FLINK-6932: --- Summary: Update the inaccessible Dataflow Model paper link Key: FLINK-6932 URL: https://issues.apache.org/jira/browse/FLINK-6932 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-6932) Update the inaccessible Dataflow Model paper link

2017-06-15 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-6932: Description: I tried to access the Dataflow Model paper link which under [https://ci.apache.org/pro

[jira] [Commented] (FLINK-4641) Support branching CEP patterns

2017-06-15 Thread Alexander Chermenin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050551#comment-16050551 ] Alexander Chermenin commented on FLINK-4641: Hi [~dian.fu]! Yes of course, you

[jira] [Commented] (FLINK-6896) Creating a table from a POJO and use table sink to output fail

2017-06-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050537#comment-16050537 ] ASF GitHub Bot commented on FLINK-6896: --- Github user fhueske commented on a diff in

[GitHub] flink pull request #4111: [FLINK-6896][table] Fix generate PojoType input re...

2017-06-15 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4111#discussion_r122212537 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala --- @@ -871,12 +871,24 @@ class CodeGenerator(

[jira] [Commented] (FLINK-6886) Fix Timestamp field can not be selected in event time case when toDataStream[T], `T` not a `Row` Type.

2017-06-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050535#comment-16050535 ] Fabian Hueske commented on FLINK-6886: -- Maybe there's another way to fix this problem

[GitHub] flink issue #4130: [FLINK-6773] [checkpoint] Introduce compression (snappy) ...

2017-06-15 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/4130 CC @tillrohrmann --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes

[jira] [Commented] (FLINK-6773) Use compression (e.g. snappy) for full check/savepoints

2017-06-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050508#comment-16050508 ] ASF GitHub Bot commented on FLINK-6773: --- GitHub user StefanRRichter opened a pull re

[jira] [Commented] (FLINK-6773) Use compression (e.g. snappy) for full check/savepoints

2017-06-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050513#comment-16050513 ] ASF GitHub Bot commented on FLINK-6773: --- Github user StefanRRichter commented on the

[GitHub] flink pull request #4130: [FLINK-6773] [checkpoint] Introduce compression (s...

2017-06-15 Thread StefanRRichter
GitHub user StefanRRichter opened a pull request: https://github.com/apache/flink/pull/4130 [FLINK-6773] [checkpoint] Introduce compression (snappy) for keyed st… This PR introduce optional snappy compression for the keyed state in full checkpoints and savepoints. This feature can

[jira] [Commented] (FLINK-6896) Creating a table from a POJO and use table sink to output fail

2017-06-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050502#comment-16050502 ] ASF GitHub Bot commented on FLINK-6896: --- Github user sunjincheng121 commented on a d

[GitHub] flink pull request #4111: [FLINK-6896][table] Fix generate PojoType input re...

2017-06-15 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4111#discussion_r122205799 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala --- @@ -871,12 +871,24 @@ class CodeGenerator

[jira] [Created] (FLINK-6931) Support custom compression formats for checkpoints (+Upgrade/Compatibility)

2017-06-15 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-6931: - Summary: Support custom compression formats for checkpoints (+Upgrade/Compatibility) Key: FLINK-6931 URL: https://issues.apache.org/jira/browse/FLINK-6931 Project:

[jira] [Commented] (FLINK-6836) Failing YARNSessionCapacitySchedulerITCase.testTaskManagerFailure

2017-06-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050495#comment-16050495 ] ASF GitHub Bot commented on FLINK-6836: --- Github user zentol commented on the issue:

[GitHub] flink issue #4120: [FLINK-6836] [tests] Fix YARNSessionCapacitySchedulerITCa...

2017-06-15 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4120 +1 to merge. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[jira] [Commented] (FLINK-6896) Creating a table from a POJO and use table sink to output fail

2017-06-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050474#comment-16050474 ] ASF GitHub Bot commented on FLINK-6896: --- Github user wuchong commented on a diff in

[GitHub] flink pull request #4111: [FLINK-6896][table] Fix generate PojoType input re...

2017-06-15 Thread wuchong
Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/4111#discussion_r122201344 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala --- @@ -871,12 +871,24 @@ class CodeGenerator(

[jira] [Created] (FLINK-6930) Selecting window start / end on row-based Tumble/Slide window causes NPE

2017-06-15 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-6930: Summary: Selecting window start / end on row-based Tumble/Slide window causes NPE Key: FLINK-6930 URL: https://issues.apache.org/jira/browse/FLINK-6930 Project: Flink

[jira] [Commented] (FLINK-5908) Blob Cache can (rarely) get corrupted on failed blob downloads

2017-06-15 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050456#comment-16050456 ] Nico Kruber commented on FLINK-5908: let's solve this during the re-write of the BLOB

[jira] [Updated] (FLINK-5908) Blob Cache can (rarely) get corrupted on failed blob downloads

2017-06-15 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-5908: --- Component/s: Network > Blob Cache can (rarely) get corrupted on failed blob downloads > --

[jira] [Updated] (FLINK-5908) Blob Cache can (rarely) get corrupted on failed blob downloads

2017-06-15 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-5908: --- Affects Version/s: 1.4.0 1.3.0 > Blob Cache can (rarely) get corrupted on faile

[jira] [Updated] (FLINK-5908) Blob Cache can (rarely) get corrupted on failed blob downloads

2017-06-15 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-5908: --- Fix Version/s: (was: 1.4.0) (was: 1.2.2) > Blob Cache can (rarely) get corr

[jira] [Commented] (FLINK-6046) Add support for oversized messages during deployment

2017-06-15 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050450#comment-16050450 ] Nico Kruber commented on FLINK-6046: since the broken cleanup for the current blob sto

[jira] [Updated] (FLINK-6046) Add support for oversized messages during deployment

2017-06-15 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-6046: --- Component/s: Network > Add support for oversized messages during deployment >

[GitHub] flink pull request #4111: [FLINK-6896][table] Fix generate PojoType input re...

2017-06-15 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4111#discussion_r122194058 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala --- @@ -871,12 +871,24 @@ class CodeGenerator(

[jira] [Commented] (FLINK-6896) Creating a table from a POJO and use table sink to output fail

2017-06-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050423#comment-16050423 ] ASF GitHub Bot commented on FLINK-6896: --- Github user fhueske commented on a diff in

[jira] [Updated] (FLINK-5991) Expose Broadcast Operator State through public APIs

2017-06-15 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-5991: --- Labels: api-breaking api-deprecation (was: ) > Expose Broadcast Operator State throug

[jira] [Updated] (FLINK-5991) Expose Broadcast Operator State through public APIs

2017-06-15 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-5991: --- Labels: (was: api-breaking api-deprecation) > Expose Broadcast Operator State throug

[jira] [Commented] (FLINK-6682) Improve error message in case parallelism exceeds maxParallelism

2017-06-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050370#comment-16050370 ] ASF GitHub Bot commented on FLINK-6682: --- Github user zhangminglei commented on the i

[GitHub] flink issue #4125: [FLINK-6682] [checkpoints] Improve error message in case ...

2017-06-15 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/4125 Hi @zentol . Please helps review if you are free, should I add some extra information ? Thanks. --- If your project is set up for it, you can reply to this email and have your reply appear on G

[jira] [Commented] (FLINK-6896) Creating a table from a POJO and use table sink to output fail

2017-06-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050358#comment-16050358 ] ASF GitHub Bot commented on FLINK-6896: --- Github user fhueske commented on a diff in

[GitHub] flink pull request #4111: [FLINK-6896][table] Fix generate PojoType input re...

2017-06-15 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4111#discussion_r122180812 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala --- @@ -871,12 +871,24 @@ class CodeGenerator(

[jira] [Commented] (FLINK-6896) Creating a table from a POJO and use table sink to output fail

2017-06-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050341#comment-16050341 ] ASF GitHub Bot commented on FLINK-6896: --- Github user wuchong commented on a diff in

[GitHub] flink pull request #4111: [FLINK-6896][table] Fix generate PojoType input re...

2017-06-15 Thread wuchong
Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/4111#discussion_r122178152 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala --- @@ -871,12 +871,24 @@ class CodeGenerator(

[jira] [Commented] (FLINK-6896) Creating a table from a POJO and use table sink to output fail

2017-06-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050332#comment-16050332 ] ASF GitHub Bot commented on FLINK-6896: --- Github user sunjincheng121 commented on a d

[GitHub] flink pull request #4111: [FLINK-6896][table] Fix generate PojoType input re...

2017-06-15 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4111#discussion_r122176847 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala --- @@ -871,12 +871,24 @@ class CodeGenerator

[jira] [Commented] (FLINK-6896) Creating a table from a POJO and use table sink to output fail

2017-06-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050326#comment-16050326 ] ASF GitHub Bot commented on FLINK-6896: --- Github user sunjincheng121 commented on a d

[GitHub] flink pull request #4111: [FLINK-6896][table] Fix generate PojoType input re...

2017-06-15 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4111#discussion_r122176275 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala --- @@ -871,12 +871,24 @@ class CodeGenerator

[GitHub] flink pull request #4111: [FLINK-6896][table] Fix generate PojoType input re...

2017-06-15 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4111#discussion_r122168658 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala --- @@ -871,12 +871,24 @@ class CodeGenerator(

[jira] [Commented] (FLINK-6896) Creating a table from a POJO and use table sink to output fail

2017-06-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050272#comment-16050272 ] ASF GitHub Bot commented on FLINK-6896: --- Github user fhueske commented on a diff in

[jira] [Updated] (FLINK-6917) Introduce test base for end-to-end testing serializer config snapshotting, restoring, and compatibility check roundtrips

2017-06-15 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6917: --- Labels: ta (was: ) > Introduce test base for end-to-end testing serializer config sna

[jira] [Commented] (FLINK-6896) Creating a table from a POJO and use table sink to output fail

2017-06-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050271#comment-16050271 ] ASF GitHub Bot commented on FLINK-6896: --- Github user fhueske commented on a diff in

[GitHub] flink pull request #4111: [FLINK-6896][table] Fix generate PojoType input re...

2017-06-15 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4111#discussion_r122168412 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala --- @@ -871,12 +871,24 @@ class CodeGenerator(

[jira] [Updated] (FLINK-6917) Introduce test base for end-to-end testing serializer config snapshotting, restoring, and compatibility check roundtrips

2017-06-15 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6917: --- Labels: (was: ta) > Introduce test base for end-to-end testing serializer config sna

[jira] [Created] (FLINK-6929) Add documentation for Table API OVER windows

2017-06-15 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-6929: Summary: Add documentation for Table API OVER windows Key: FLINK-6929 URL: https://issues.apache.org/jira/browse/FLINK-6929 Project: Flink Issue Type: Improv

[jira] [Closed] (FLINK-5354) Split up Table API documentation into multiple pages

2017-06-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-5354. Resolution: Done Fix Version/s: 1.4.0 1.3.1 Done for 1.3.1 with 398012aa16

[jira] [Updated] (FLINK-6751) Table API / SQL Docs: UDFs Page

2017-06-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-6751: - Description: Update and extend the documentation of UDFs in the Table API / SQL: {{./docs/dev/tab

[jira] [Updated] (FLINK-6750) Table API / SQL Docs: Table Sources & Sinks Page

2017-06-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-6750: - Description: Update and refine the documentation about TableSources and TableSinks. There are a fe

[jira] [Updated] (FLINK-6751) Table API / SQL Docs: UDFs Page

2017-06-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-6751: - Issue Type: Task (was: Sub-task) Parent: (was: FLINK-5354) > Table API / SQL Docs: UD

[jira] [Updated] (FLINK-6750) Table API / SQL Docs: Table Sources & Sinks Page

2017-06-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-6750: - Issue Type: Task (was: Sub-task) Parent: (was: FLINK-5354) > Table API / SQL Docs: Ta

[jira] [Updated] (FLINK-6747) Table API / SQL Docs: Streaming Page

2017-06-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-6747: - Description: Extend {{./docs/dev/table/streaming.md}} page. Missing are sections about - Dynamic

[jira] [Updated] (FLINK-6747) Table API / SQL Docs: Streaming Page

2017-06-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-6747: - Issue Type: Task (was: Sub-task) Parent: (was: FLINK-5354) > Table API / SQL Docs: St

[jira] [Assigned] (FLINK-6747) Table API / SQL Docs: Streaming Page

2017-06-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-6747: Assignee: Fabian Hueske > Table API / SQL Docs: Streaming Page > --

[jira] [Issue Comment Deleted] (FLINK-6750) Table API / SQL Docs: Table Sources & Sinks Page

2017-06-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-6750: - Comment: was deleted (was: Done for 1.3.1 with 89850f21dc596b2b845ce98433263496e512ef54 Done for 1

[jira] [Closed] (FLINK-6748) Table API / SQL Docs: Table API Page

2017-06-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6748. Resolution: Done Fix Version/s: 1.4.0 1.3.1 Done for 1.3.1 with 89850f21dc

[jira] [Reopened] (FLINK-6750) Table API / SQL Docs: Table Sources & Sinks Page

2017-06-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reopened FLINK-6750: -- > Table API / SQL Docs: Table Sources & Sinks Page > ---

[jira] [Resolved] (FLINK-6750) Table API / SQL Docs: Table Sources & Sinks Page

2017-06-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-6750. -- Resolution: Fixed Fix Version/s: 1.4.0 1.3.1 Done for 1.3.1 with 89850

[jira] [Commented] (FLINK-6748) Table API / SQL Docs: Table API Page

2017-06-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050243#comment-16050243 ] ASF GitHub Bot commented on FLINK-6748: --- Github user asfgit closed the pull request

issues@flink.apache.org

2017-06-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4094 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Commented] (FLINK-6750) Table API / SQL Docs: Table Sources & Sinks Page

2017-06-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050244#comment-16050244 ] ASF GitHub Bot commented on FLINK-6750: --- Github user asfgit closed the pull request

[GitHub] flink pull request #4093: [FLINK-6748] [table] [docs] Reworked Table API Pag...

2017-06-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4093 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

  1   2   >