[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=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=16051346#comment-16051346 ] mingleizhang commented on FLINK-6934: - I would say just suggest remove it. Actually, it belongs to

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

[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

[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

[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

[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=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=16051269#comment-16051269 ] ASF GitHub Bot commented on FLINK-6932: --- Github user zhangminglei commented on a diff in the pull

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

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

[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

[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=16050925#comment-16050925 ] Erik van Oosten edited comment on FLINK-6928 at 6/15/17 6:39 PM: - In my

[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=16050925#comment-16050925 ] Erik van Oosten commented on FLINK-6928: In my ideal world method {{getTargetTopic}} would be

[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=16050830#comment-16050830 ] ASF GitHub Bot commented on FLINK-6932: --- Github user greghogan commented on a diff in the pull

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

[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=16050785#comment-16050785 ] ASF GitHub Bot commented on FLINK-6932: --- GitHub user zhangminglei opened a pull request:

[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

[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=16050782#comment-16050782 ] ASF GitHub Bot commented on FLINK-6693: --- Github user fhueske commented on a diff in the pull

[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=16050783#comment-16050783 ] ASF GitHub Bot commented on FLINK-6693: --- Github user fhueske commented on a diff in the pull

[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=16050784#comment-16050784 ] ASF GitHub Bot commented on FLINK-6693: --- Github user fhueske commented on a diff in the pull

[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 @@ +/* + *

[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=16050781#comment-16050781 ] ASF GitHub Bot commented on FLINK-6693: --- Github user fhueske commented on a diff in the pull

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

[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

[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=16050551#comment-16050551 ] Alexander Chermenin commented on FLINK-4641: Hi [~dian.fu]! Yes of course, you're welcome!

[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=16050537#comment-16050537 ] ASF GitHub Bot commented on FLINK-6896: --- Github user fhueske commented on a diff in the pull

[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=16050535#comment-16050535 ] Fabian Hueske commented on FLINK-6886: -- Maybe there's another way to fix this problem. I played a bit

[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=16050508#comment-16050508 ] ASF GitHub Bot commented on FLINK-6773: --- GitHub user StefanRRichter opened a pull request:

[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=16050513#comment-16050513 ] ASF GitHub Bot commented on FLINK-6773: --- Github user StefanRRichter commented on the issue:

[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

[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=16050502#comment-16050502 ] ASF GitHub Bot commented on FLINK-6896: --- Github user sunjincheng121 commented on a diff in the pull

[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

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

[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=16050474#comment-16050474 ] ASF GitHub Bot commented on FLINK-6896: --- Github user wuchong commented on a diff in the pull

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

[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=16050456#comment-16050456 ] Nico Kruber commented on FLINK-5908: let's solve this during the re-write of the BLOB store with

[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

[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

[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=16050450#comment-16050450 ] Nico Kruber commented on FLINK-6046: since the broken cleanup for the current blob store is a deal

[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=16050423#comment-16050423 ] ASF GitHub Bot commented on FLINK-6896: --- Github user fhueske commented on a diff in the pull

[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

[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

[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=16050370#comment-16050370 ] ASF GitHub Bot commented on FLINK-6682: --- Github user zhangminglei commented on the issue:

[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

[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=16050358#comment-16050358 ] ASF GitHub Bot commented on FLINK-6896: --- Github user fhueske commented on a diff in the pull

[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=16050341#comment-16050341 ] ASF GitHub Bot commented on FLINK-6896: --- Github user wuchong commented on a diff in the pull

[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=16050332#comment-16050332 ] ASF GitHub Bot commented on FLINK-6896: --- Github user sunjincheng121 commented on a diff in the pull

[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

[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=16050326#comment-16050326 ] ASF GitHub Bot commented on FLINK-6896: --- Github user sunjincheng121 commented on a diff in the pull

[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

[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=16050272#comment-16050272 ] ASF GitHub Bot commented on FLINK-6896: --- Github user fhueske commented on a diff in the pull

[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

[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=16050271#comment-16050271 ] ASF GitHub Bot commented on FLINK-6896: --- Github user fhueske commented on a diff in the pull

[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

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

[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

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

[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

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

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

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

[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

[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

[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

[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=16050243#comment-16050243 ] ASF GitHub Bot commented on FLINK-6748: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #4094: [FLINK-6750] [table] [docs] Rework Table Sources &...

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

[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=16050244#comment-16050244 ] ASF GitHub Bot commented on FLINK-6750: --- Github user asfgit closed the pull request at:

[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

[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=16050238#comment-16050238 ] ASF GitHub Bot commented on FLINK-6836: --- Github user tillrohrmann commented on the issue:

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

2017-06-15 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4120 I first thought I had to downgrade, because of the aforementioned problem. However, Hadoop 2.8.0 needs at least httpclient `4.5.2`. Luckily, they fixed the problem with the

[jira] [Commented] (FLINK-6602) Table source with defined time attributes allows empty string

2017-06-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050224#comment-16050224 ] Fabian Hueske commented on FLINK-6602: -- The fix looks good! Please open a pull request with that :-)

[jira] [Assigned] (FLINK-6602) Table source with defined time attributes allows empty string

2017-06-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-6602: Assignee: Zhe Li > Table source with defined time attributes allows empty string >

[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=16050205#comment-16050205 ] ASF GitHub Bot commented on FLINK-6896: --- Github user wuchong commented on a diff in the pull

[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=16050206#comment-16050206 ] ASF GitHub Bot commented on FLINK-6896: --- Github user wuchong commented on a diff in the pull

  1   2   >