[
https://issues.apache.org/jira/browse/FLINK-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16143416#comment-16143416
]
ASF GitHub Bot commented on FLINK-7378:
---
Github user zhijiangW commented on the issu
Github user zhijiangW commented on the issue:
https://github.com/apache/flink/pull/4485
@NicoK , thank you for giving this discussion and comments!
Actually I proposed the same way of using fixed-size `LocalBufferPool` for
managing exclusive buffers for per `RemoteInputChannel
Github user dianfu commented on the issue:
https://github.com/apache/flink/pull/4513
@dawidwys It would be great if you could take a look. Very appreciated!
---
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
[
https://issues.apache.org/jira/browse/FLINK-6938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16143403#comment-16143403
]
ASF GitHub Bot commented on FLINK-6938:
---
Github user dianfu commented on the issue:
Github user dianfu commented on a diff in the pull request:
https://github.com/apache/flink/pull/4296#discussion_r135441351
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java
---
@@ -421,6 +437,15 @@ private void addStopStateToLoop
[
https://issues.apache.org/jira/browse/FLINK-7147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16143367#comment-16143367
]
ASF GitHub Bot commented on FLINK-7147:
---
Github user dianfu commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-7147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16143360#comment-16143360
]
ASF GitHub Bot commented on FLINK-7147:
---
Github user dianfu commented on a diff in t
Github user dianfu commented on a diff in the pull request:
https://github.com/apache/flink/pull/4296#discussion_r135440842
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java
---
@@ -526,18 +551,32 @@ private boolean isPatternOptio
[
https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16143342#comment-16143342
]
sunjincheng commented on FLINK-7465:
Hi [~jparkie]When we deal with a [Dynamic
table|
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/4536#discussion_r135430307
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/FlinkTableFunctionImpl.scala
---
@@ -71,6 +69,9 @@ class FlinkTableF
[
https://issues.apache.org/jira/browse/FLINK-7439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16143299#comment-16143299
]
ASF GitHub Bot commented on FLINK-7439:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16143297#comment-16143297
]
ASF GitHub Bot commented on FLINK-7439:
---
Github user wuchong commented on a diff in
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/4536#discussion_r135430161
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/FlinkTableFunctionImpl.scala
---
@@ -36,10 +36,8 @@ import org.apach
[
https://issues.apache.org/jira/browse/FLINK-7439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16143282#comment-16143282
]
ASF GitHub Bot commented on FLINK-7439:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-7439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16143278#comment-16143278
]
ASF GitHub Bot commented on FLINK-7439:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-7439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16143280#comment-16143280
]
ASF GitHub Bot commented on FLINK-7439:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-7439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16143276#comment-16143276
]
ASF GitHub Bot commented on FLINK-7439:
---
Github user sunjincheng121 commented on a d
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4536#discussion_r135425816
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/TableSqlFunction.scala
---
@@ -74,48 +75,102 @@ class Tab
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4536#discussion_r135425060
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -350,8 +350,8 @@ abstract class TableEn
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4536#discussion_r135425261
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/TableSqlFunction.scala
---
@@ -18,39 +18,40 @@
[
https://issues.apache.org/jira/browse/FLINK-7439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16143279#comment-16143279
]
ASF GitHub Bot commented on FLINK-7439:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-7439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16143283#comment-16143283
]
ASF GitHub Bot commented on FLINK-7439:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-7439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16143281#comment-16143281
]
ASF GitHub Bot commented on FLINK-7439:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-7439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16143277#comment-16143277
]
ASF GitHub Bot commented on FLINK-7439:
---
Github user sunjincheng121 commented on a d
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4536#discussion_r135425326
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/TableSqlFunction.scala
---
@@ -18,39 +18,40 @@
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4536#discussion_r135425277
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/TableSqlFunction.scala
---
@@ -18,39 +18,40 @@
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4536#discussion_r135426183
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/FlinkTableFunctionImpl.scala
---
@@ -71,6 +69,9 @@ class Flin
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4536#discussion_r135426134
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/FlinkTableFunctionImpl.scala
---
@@ -36,10 +36,8 @@ import or
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4536#discussion_r135426250
--- Diff:
flink-libraries/flink-table/src/test/java/org/apache/flink/table/runtime/utils/JavaUserDefinedTableFunctions.java
---
@@ -35,4 +35,15 @@ pu
[
https://issues.apache.org/jira/browse/FLINK-6306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16143246#comment-16143246
]
ASF GitHub Bot commented on FLINK-6306:
---
Github user sjwiesman commented on the issu
Github user sjwiesman commented on the issue:
https://github.com/apache/flink/pull/4607
CC: @aljoscha
I screwed up the rebase so I cherry picked the updates into a new branch
and re-opened the pr.
---
If your project is set up for it, you can reply to this email and have y
[
https://issues.apache.org/jira/browse/FLINK-6306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16143244#comment-16143244
]
ASF GitHub Bot commented on FLINK-6306:
---
GitHub user sjwiesman opened a pull request
GitHub user sjwiesman opened a pull request:
https://github.com/apache/flink/pull/4607
[FLINK-6306][connectors] Sink for eventually consistent file systems
## What is the purpose of the change
This pull request implements a sink for writing out to an eventually
consistent f
[
https://issues.apache.org/jira/browse/FLINK-6306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16143229#comment-16143229
]
ASF GitHub Bot commented on FLINK-6306:
---
Github user sjwiesman closed the pull reque
Github user sjwiesman closed the pull request at:
https://github.com/apache/flink/pull/3752
---
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 e
Github user ggevay commented on the issue:
https://github.com/apache/flink/pull/3511
Thank @heytitle , I'll try to do the code generation for
`FixedLengthRecordSorter` tomorrow, and I will also take a look at the failing
tests.
Btw. you can force push (`git push -f`) the reba
[
https://issues.apache.org/jira/browse/FLINK-7539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16143139#comment-16143139
]
ASF GitHub Bot commented on FLINK-7539:
---
GitHub user packet23 opened a pull request:
GitHub user packet23 opened a pull request:
https://github.com/apache/flink/pull/4606
[FLINK-7539] Made AvroOutputFormat default codec configurable.
Implement site-wide codec defaults.
## Brief change log
- Added connect.avro.output.codec option
## Verifyin
Sebastian Klemke created FLINK-7539:
---
Summary: Make AvroOutputFormat default codec configurable
Key: FLINK-7539
URL: https://issues.apache.org/jira/browse/FLINK-7539
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-7410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16143111#comment-16143111
]
Jark Wu commented on FLINK-7410:
Hi [~hequn8128] do you mean users may use {{toString}} f
[
https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16143104#comment-16143104
]
Jark Wu commented on FLINK-7491:
Hi [~suez1224] , what I mean use {{Array}} instead of {{A
41 matches
Mail list logo
