[
https://issues.apache.org/jira/browse/FLINK-7337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16124831#comment-16124831
]
ASF GitHub Bot commented on FLINK-7337:
---
Github user xccui commented on a diff in th
Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4532#discussion_r132833668
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/OutputRowtimeProcessFunction.scala
---
@@ -0,0 +1,62 @@
+/*
+ * Li
[
https://issues.apache.org/jira/browse/FLINK-7366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16124822#comment-16124822
]
ASF GitHub Bot commented on FLINK-7366:
---
Github user bowenli86 commented on the issu
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/4522
@tzulitai OK, I only upgraded KPL
---
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
[
https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16124821#comment-16124821
]
ASF GitHub Bot commented on FLINK-7367:
---
Github user bowenli86 commented on the issu
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/4473
@tzulitai Let me know what you think about this PR now :)
---
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 ha
[
https://issues.apache.org/jira/browse/FLINK-7423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16124791#comment-16124791
]
ASF GitHub Bot commented on FLINK-7423:
---
Github user XuPingyong commented on the iss
Github user XuPingyong commented on the issue:
https://github.com/apache/flink/pull/4525
@greghoganï¼ if the object passed to nextRecord may be reused internally
by the InputFormat, do the similar cases need to be re-considered?
In `DataSourceTask.java`:
Ted Yu created FLINK-7438:
-
Summary: Some classes are eclipsed by classes in package scala
Key: FLINK-7438
URL: https://issues.apache.org/jira/browse/FLINK-7438
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-7337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16124639#comment-16124639
]
ASF GitHub Bot commented on FLINK-7337:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/4532#discussion_r132822158
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/StreamTableEnvironment.scala
---
@@ -667,30 +719,62 @@ abstract class Stream
[
https://issues.apache.org/jira/browse/FLINK-7337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16124631#comment-16124631
]
ASF GitHub Bot commented on FLINK-7337:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/4488
@wuchong could you take a look at #4532 as well? It is based on this PR.
---
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 projec
[
https://issues.apache.org/jira/browse/FLINK-7437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-7437.
---
Resolution: Duplicate
This is a duplicate of FLINK-7051.
> Upgrade calcite to calcite 1.14
>
[
https://issues.apache.org/jira/browse/FLINK-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16124622#comment-16124622
]
ASF GitHub Bot commented on FLINK-7169:
---
Github user yestinchen commented on the iss
Github user yestinchen commented on the issue:
https://github.com/apache/flink/pull/4331
Thanks for your reviews @dawidwys ! I'll update the doc in the following
commits.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. I
Ted Yu created FLINK-7437:
-
Summary: Upgrade calcite to calcite 1.14
Key: FLINK-7437
URL: https://issues.apache.org/jira/browse/FLINK-7437
Project: Flink
Issue Type: Task
Reporter: Ted Yu
[
https://issues.apache.org/jira/browse/FLINK-7410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16124621#comment-16124621
]
Jark Wu commented on FLINK-7410:
How about using the `toString()` method to return the cus
[
https://issues.apache.org/jira/browse/FLINK-6738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16124619#comment-16124619
]
Ted Yu commented on FLINK-6738:
---
With CALCITE-1859 fixed, let's see if the test passes when
[
https://issues.apache.org/jira/browse/FLINK-7337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16124611#comment-16124611
]
ASF GitHub Bot commented on FLINK-7337:
---
Github user xccui commented on a diff in th
Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4532#discussion_r132820853
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/StreamTableEnvironment.scala
---
@@ -667,30 +719,62 @@ abstract class StreamTa
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16124604#comment-16124604
]
ASF GitHub Bot commented on FLINK-7416:
---
GitHub user zhijiangW opened a pull request
GitHub user zhijiangW opened a pull request:
https://github.com/apache/flink/pull/4533
[FLINK-7416][network] Implement Netty receiver outgoing pipeline for
credit-based
## What is the purpose of the change
The receiver notifies the available buffers called unannounced credi
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/4488#discussion_r132819009
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/CRowInputTupleOutputMapRunner.scala
---
@@ -19,7 +19,9 @@
package o
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/4488#discussion_r132817997
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -1247,27 +1258,32 @@ abstract class CodeGener
[
https://issues.apache.org/jira/browse/FLINK-7337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16124601#comment-16124601
]
ASF GitHub Bot commented on FLINK-7337:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16124600#comment-16124600
]
ASF GitHub Bot commented on FLINK-7337:
---
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/4488#discussion_r132818559
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/StreamTableSourceScan.scala
---
@@ -46,29 +47,29 @@ class
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/4488#discussion_r132819122
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/WrappingTimestampSetterProcessFunction.scala
---
@@ -0,0 +1,61 @@
+/
[
https://issues.apache.org/jira/browse/FLINK-7337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16124599#comment-16124599
]
ASF GitHub Bot commented on FLINK-7337:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16124602#comment-16124602
]
ASF GitHub Bot commented on FLINK-7337:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16124588#comment-16124588
]
ASF GitHub Bot commented on FLINK-7337:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/4532#discussion_r132819240
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/StreamTableEnvironment.scala
---
@@ -667,30 +719,62 @@ abstract class Stream
[
https://issues.apache.org/jira/browse/FLINK-7337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16124586#comment-16124586
]
ASF GitHub Bot commented on FLINK-7337:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/4532#discussion_r132819174
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/StreamTableEnvironment.scala
---
@@ -667,30 +719,62 @@ abstract class Stream
daiqing created FLINK-7435:
--
Summary: FsStateBackend with incremental backup enable does not
work with Keyed CEP
Key: FLINK-7435
URL: https://issues.apache.org/jira/browse/FLINK-7435
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16124556#comment-16124556
]
ASF GitHub Bot commented on FLINK-7337:
---
Github user xccui commented on a diff in th
Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4532#discussion_r132817252
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/StreamTableEnvironment.scala
---
@@ -667,30 +719,62 @@ abstract class StreamTa
[
https://issues.apache.org/jira/browse/FLINK-7337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16124548#comment-16124548
]
ASF GitHub Bot commented on FLINK-7337:
---
GitHub user twalthr opened a pull request:
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/4532
[FLINK-7337] [table] Refactor internal handling of time indicator
attributes and efficiency
## What is the purpose of the change
*This PR is an improvement of @fhueske's PR #4488. For an de
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/4525
As I understand Flink does not allow `null` records since what does it mean
to partition or window a null record? `null` fields are sometimes allowed but
`null` records are meaningless.
Th
[
https://issues.apache.org/jira/browse/FLINK-7423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16124538#comment-16124538
]
ASF GitHub Bot commented on FLINK-7423:
---
Github user greghogan commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-7434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16124533#comment-16124533
]
ASF GitHub Bot commented on FLINK-7434:
---
GitHub user sv3nd opened a pull request:
GitHub user sv3nd opened a pull request:
https://github.com/apache/flink/pull/4531
[FLINK-7434][doc] scafolding with "sbt new"
## What is the purpose of the change
Current [documentation for scala project scafolding from
template](https://ci.apache.org/projects/flink/f
[
https://issues.apache.org/jira/browse/FLINK-7434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Svend Vanderveken updated FLINK-7434:
-
Summary: Scafolding of a scala project should rely on "sbt new" (was:
Scafolding of an sc
Svend Vanderveken created FLINK-7434:
Summary: Scafolding of an scala project should rely on "sbt new"
Key: FLINK-7434
URL: https://issues.apache.org/jira/browse/FLINK-7434
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16124525#comment-16124525
]
Jark Wu commented on FLINK-7426:
Shouldn't this be pushed into DataStream component? I'm j
[
https://issues.apache.org/jira/browse/FLINK-7423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16124497#comment-16124497
]
ASF GitHub Bot commented on FLINK-7423:
---
Github user XuPingyong commented on the iss
Github user XuPingyong commented on the issue:
https://github.com/apache/flink/pull/4525
Thanks @greghogan.
I think the InputFormat can return anything, may be null or other
immutable objects that cannot be passed to nextRecord.
And I am also not clear why the
49 matches
Mail list logo
