mingleizhang created FLINK-9650:
---
Summary: Support Protocol Buffers formats
Key: FLINK-9650
URL: https://issues.apache.org/jira/browse/FLINK-9650
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-9650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9650:
Description: We need to generate a \{{TypeInformation}} from a standard
[Protobuf
[
https://issues.apache.org/jira/browse/FLINK-9614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9614:
Affects Version/s: 1.5.0
> Improve the error message for Compiler#compile
>
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/6203
There's a problem with how we designed the `FileUploads` cleanup. The
`AbstractHandler` cleans it up when `AbstractHandler#respondToRequest` returns.
There is however no guarantee that the request
[
https://issues.apache.org/jira/browse/FLINK-9280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16521025#comment-16521025
]
ASF GitHub Bot commented on FLINK-9280:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9642:
--
Labels: pull-request-available (was: )
> Reduce the count to deal with state during a CEP
mingleizhang created FLINK-9651:
---
Summary: Add a Kafka table source factory with Protobuf format
support
Key: FLINK-9651
URL: https://issues.apache.org/jira/browse/FLINK-9651
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-6846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16521188#comment-16521188
]
ASF GitHub Bot commented on FLINK-6846:
---
Github user walterddr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16521189#comment-16521189
]
ASF GitHub Bot commented on FLINK-6846:
---
Github user walterddr commented on a diff in the pull
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6188#discussion_r197613157
--- Diff: docs/dev/table/tableApi.md ---
@@ -2804,6 +2804,17 @@ dateFormat(TIMESTAMP, STRING)
+
+
+
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6188#discussion_r197614566
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/time.scala
---
@@ -328,6 +330,42 @@ case class TemporalOverlaps(
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6188#discussion_r197613995
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/time.scala
---
@@ -328,6 +330,42 @@ case class TemporalOverlaps(
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6188#discussion_r197613915
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/time.scala
---
@@ -328,6 +330,42 @@ case class TemporalOverlaps(
[
https://issues.apache.org/jira/browse/FLINK-6846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16521197#comment-16521197
]
ASF GitHub Bot commented on FLINK-6846:
---
Github user hequn8128 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16521193#comment-16521193
]
ASF GitHub Bot commented on FLINK-6846:
---
Github user hequn8128 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16521195#comment-16521195
]
ASF GitHub Bot commented on FLINK-6846:
---
Github user hequn8128 commented on a diff in the pull
Github user hequn8128 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6188#discussion_r197614200
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/time.scala
---
@@ -328,6 +330,42 @@ case class TemporalOverlaps(
[
https://issues.apache.org/jira/browse/FLINK-6846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16521194#comment-16521194
]
ASF GitHub Bot commented on FLINK-6846:
---
Github user hequn8128 commented on a diff in the pull
Github user hequn8128 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6188#discussion_r197614217
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/time.scala
---
@@ -328,6 +330,42 @@ case class TemporalOverlaps(
Github user hequn8128 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6188#discussion_r197614210
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/time.scala
---
@@ -328,6 +330,42 @@ case class TemporalOverlaps(
Github user hequn8128 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6188#discussion_r197614223
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/time.scala
---
@@ -328,6 +330,42 @@ case class TemporalOverlaps(
Github user hequn8128 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6188#discussion_r197614206
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/time.scala
---
@@ -328,6 +330,42 @@ case class TemporalOverlaps(
[
https://issues.apache.org/jira/browse/FLINK-6846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16521196#comment-16521196
]
ASF GitHub Bot commented on FLINK-6846:
---
Github user hequn8128 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16521209#comment-16521209
]
ASF GitHub Bot commented on FLINK-6846:
---
Github user xueyumusic commented on a diff in the pull
GitHub user Aitozi opened a pull request:
https://github.com/apache/flink/pull/6205
[FLINK-9642]Reduce the count to deal with state during a CEP process
## What is the purpose of the change
With the rework of sharedBuffer Flink-9418, the lock & release operation is
deal
[
https://issues.apache.org/jira/browse/FLINK-9642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16521092#comment-16521092
]
ASF GitHub Bot commented on FLINK-9642:
---
GitHub user Aitozi opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-5860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16521103#comment-16521103
]
Mahesh Senniappan commented on FLINK-5860:
--
[~Zentol]
I have removed `java.io.tmpdir` in the
[
https://issues.apache.org/jira/browse/FLINK-6846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16521187#comment-16521187
]
ASF GitHub Bot commented on FLINK-6846:
---
Github user walterddr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16521190#comment-16521190
]
ASF GitHub Bot commented on FLINK-6846:
---
Github user walterddr commented on a diff in the pull
Github user xueyumusic commented on a diff in the pull request:
https://github.com/apache/flink/pull/6188#discussion_r197616443
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/time.scala
---
@@ -328,6 +330,42 @@ case class TemporalOverlaps(
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6188#discussion_r197622239
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/time.scala
---
@@ -328,6 +330,42 @@ case class TemporalOverlaps(
[
https://issues.apache.org/jira/browse/FLINK-6846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16521256#comment-16521256
]
ASF GitHub Bot commented on FLINK-6846:
---
Github user walterddr commented on a diff in the pull
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/6205#discussion_r197627451
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBuffer.java
---
@@ -75,6 +76,9 @@
private
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/6205#discussion_r197627410
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBuffer.java
---
@@ -346,16 +351,87 @@ private void
[
https://issues.apache.org/jira/browse/FLINK-9642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16521362#comment-16521362
]
ASF GitHub Bot commented on FLINK-9642:
---
Github user zhangminglei commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16521364#comment-16521364
]
ASF GitHub Bot commented on FLINK-9642:
---
Github user zhangminglei commented on a diff in the pull
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/6205
Hi, @Aitozi Could you please take a look on the travis error
```
Tests run: 2, Failures: 2, Errors: 0, Skipped: 0, Time elapsed: 0.014 sec
<<< FAILURE! - in
[
https://issues.apache.org/jira/browse/FLINK-9642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16521363#comment-16521363
]
ASF GitHub Bot commented on FLINK-9642:
---
Github user zhangminglei commented on a diff in the pull
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/6205#discussion_r197627422
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBuffer.java
---
@@ -346,16 +351,87 @@ private void
[
https://issues.apache.org/jira/browse/FLINK-9642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16521365#comment-16521365
]
ASF GitHub Bot commented on FLINK-9642:
---
Github user zhangminglei commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16521377#comment-16521377
]
aitozi commented on FLINK-6759:
---
Can i ask how to skip this error? I encountered the same error when maven
Github user Aitozi commented on a diff in the pull request:
https://github.com/apache/flink/pull/6205#discussion_r197629205
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBuffer.java
---
@@ -346,16 +351,87 @@ private void
42 matches
Mail list logo
