[
https://issues.apache.org/jira/browse/FLINK-3026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903272#comment-15903272
]
Ismaël Mejía commented on FLINK-3026:
-
Great, taking a look right now, I will rebase m
[
https://issues.apache.org/jira/browse/FLINK-6007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903269#comment-15903269
]
Kostas Kloudas edited comment on FLINK-6007 at 3/9/17 4:04 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-6007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903293#comment-15903293
]
Kostas Kloudas commented on FLINK-6007:
---
[~aljoscha] Now that I come to think about
[
https://issues.apache.org/jira/browse/FLINK-3026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903317#comment-15903317
]
Patrick Lucas commented on FLINK-3026:
--
Yes, I gave you contributor permissions. This
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3491
merging
---
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 fea
[
https://issues.apache.org/jira/browse/FLINK-5804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903325#comment-15903325
]
ASF GitHub Bot commented on FLINK-5804:
---
Github user fhueske commented on the issue:
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/3431
@vasia, I was only thinking of this being used in gelly examples. The
documentation for the use of the example drivers will be updated but I am
anticipating that users will enclose new and existing
[
https://issues.apache.org/jira/browse/FLINK-5910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903344#comment-15903344
]
ASF GitHub Bot commented on FLINK-5910:
---
Github user greghogan commented on the issu
Github user iemejia commented on the issue:
https://github.com/apache/flink/pull/3500
Hey I probably should be more patient, I will wait until #3494 is merged
and rebase from it. So closing for the moment.
---
If your project is set up for it, you can reply to this email and have you
[
https://issues.apache.org/jira/browse/FLINK-6003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903383#comment-15903383
]
ASF GitHub Bot commented on FLINK-6003:
---
Github user iemejia commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903384#comment-15903384
]
ASF GitHub Bot commented on FLINK-6003:
---
Github user iemejia closed the pull request
Github user iemejia closed the pull request at:
https://github.com/apache/flink/pull/3500
---
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 ena
[
https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903423#comment-15903423
]
ASF GitHub Bot commented on FLINK-5874:
---
GitHub user kl0u opened a pull request:
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/3501
[FLINK-5874] Restrict key types in the DataStream API.
Rejects a type from being a key in `DataStream.keyBy()` if it is:
1. it is a POJO type but does not override the `hashCode()` and
relies
Nico Kruber created FLINK-6008:
--
Summary: collection of BlobServer improvements
Key: FLINK-6008
URL: https://issues.apache.org/jira/browse/FLINK-6008
Project: Flink
Issue Type: Improvement
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3484#discussion_r105225561
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java
---
@@ -419,6 +435,14 @@ public void me
[
https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903460#comment-15903460
]
ASF GitHub Bot commented on FLINK-4460:
---
Github user kl0u commented on a diff in the
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3352
---
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
[
https://issues.apache.org/jira/browse/FLINK-5838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903509#comment-15903509
]
ASF GitHub Bot commented on FLINK-5838:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-5838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-5838.
-
Resolution: Fixed
Fixed in 3fcc4e37c282a07e09c19934e71c141beefd8073
> Print shell script usage
>
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3491
---
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
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/3402
@StephanEwen, I updated the test to include the original test plus a new
test with object reuse enabled.
@vasia, would you be also be able to review this change?
---
If your project is se
[
https://issues.apache.org/jira/browse/FLINK-5890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903529#comment-15903529
]
ASF GitHub Bot commented on FLINK-5890:
---
Github user greghogan commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-5804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903527#comment-15903527
]
ASF GitHub Bot commented on FLINK-5804:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-5804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-5804.
Resolution: Implemented
Fix Version/s: 1.3.0
Implemented with 7456d78d271b217c80d46e24029c557
Github user clarkyzl commented on the issue:
https://github.com/apache/flink/pull/3389
Hi @twalthr . I've updated the patch as your comments.
---
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 t
[
https://issues.apache.org/jira/browse/FLINK-5881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903546#comment-15903546
]
ASF GitHub Bot commented on FLINK-5881:
---
Github user clarkyzl commented on the issue
Github user chenqin commented on a diff in the pull request:
https://github.com/apache/flink/pull/3484#discussion_r105235710
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java
---
@@ -419,6 +435,14 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903561#comment-15903561
]
ASF GitHub Bot commented on FLINK-4460:
---
Github user chenqin commented on a diff in
Github user DmytroShkvyra commented on a diff in the pull request:
https://github.com/apache/flink/pull/2870#discussion_r105238764
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/codegen/CodeGenerator.scala
---
@@ -870,6 +870,16 @@ class CodeGenerat
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903586#comment-15903586
]
ASF GitHub Bot commented on FLINK-4565:
---
Github user DmytroShkvyra commented on a di
Github user DmytroShkvyra commented on a diff in the pull request:
https://github.com/apache/flink/pull/2870#discussion_r105241841
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/table.scala
---
@@ -150,7 +150,35 @@ class Table(
* }}}
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903615#comment-15903615
]
ASF GitHub Bot commented on FLINK-4565:
---
Github user DmytroShkvyra commented on a di
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3501#discussion_r105239223
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/SavepointITCase.java
---
@@ -736,7 +736,7 @@ public void restoreState(List state) thr
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3501#discussion_r105241140
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/DataStreamTest.java
---
@@ -906,6 +919,256 @@ public void testChannelSelectors()
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3501#discussion_r105240510
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java
---
@@ -114,9 +121,53 @@ public KeyedStream(DataStrea
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3501#discussion_r105240608
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java
---
@@ -114,9 +121,53 @@ public KeyedStream(DataStrea
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3501#discussion_r105241562
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/DataStreamTest.java
---
@@ -906,6 +919,256 @@ public void testChannelSelectors()
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3501#discussion_r105242176
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/DataStreamTest.java
---
@@ -906,6 +919,256 @@ public void testChannelSelectors()
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3501#discussion_r105241450
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/DataStreamTest.java
---
@@ -906,6 +919,256 @@ public void testChannelSelectors()
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3501#discussion_r105239060
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/DataStreamTest.java
---
@@ -906,6 +919,256 @@ public void testChannelSelectors()
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3501#discussion_r105239799
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java
---
@@ -114,9 +121,53 @@ public KeyedStream(DataStrea
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3501#discussion_r105240936
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/DataStreamTest.java
---
@@ -906,6 +919,256 @@ public void testChannelSelectors()
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3501#discussion_r105240820
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java
---
@@ -114,9 +121,53 @@ public KeyedStream(DataStrea
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3501#discussion_r105238197
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/DataStreamTest.java
---
@@ -906,6 +919,256 @@ public void testChannelSelectors()
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3501#discussion_r105238457
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/DataStreamTest.java
---
@@ -906,6 +919,256 @@ public void testChannelSelectors()
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3501#discussion_r105241262
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/DataStreamTest.java
---
@@ -906,6 +919,256 @@ public void testChannelSelectors()
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3501#discussion_r105241358
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/DataStreamTest.java
---
@@ -906,6 +919,256 @@ public void testChannelSelectors()
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3501#discussion_r105239687
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java
---
@@ -114,9 +121,53 @@ public KeyedStream(DataStrea
[
https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903627#comment-15903627
]
ASF GitHub Bot commented on FLINK-5874:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903639#comment-15903639
]
ASF GitHub Bot commented on FLINK-5874:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903625#comment-15903625
]
ASF GitHub Bot commented on FLINK-5874:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903637#comment-15903637
]
ASF GitHub Bot commented on FLINK-5874:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903631#comment-15903631
]
ASF GitHub Bot commented on FLINK-5874:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903635#comment-15903635
]
ASF GitHub Bot commented on FLINK-5874:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903628#comment-15903628
]
ASF GitHub Bot commented on FLINK-5874:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903633#comment-15903633
]
ASF GitHub Bot commented on FLINK-5874:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903638#comment-15903638
]
ASF GitHub Bot commented on FLINK-5874:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903634#comment-15903634
]
ASF GitHub Bot commented on FLINK-5874:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903630#comment-15903630
]
ASF GitHub Bot commented on FLINK-5874:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903626#comment-15903626
]
ASF GitHub Bot commented on FLINK-5874:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903629#comment-15903629
]
ASF GitHub Bot commented on FLINK-5874:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903632#comment-15903632
]
ASF GitHub Bot commented on FLINK-5874:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903624#comment-15903624
]
ASF GitHub Bot commented on FLINK-5874:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903636#comment-15903636
]
ASF GitHub Bot commented on FLINK-5874:
---
Github user zentol commented on a diff in t
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3501
This should work and is well tested, good job. Had a bunch of minor
comments, but nothing critical.
---
If your project is set up for it, you can reply to this email and have your
reply appear on Git
[
https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903645#comment-15903645
]
ASF GitHub Bot commented on FLINK-5874:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903654#comment-15903654
]
ASF GitHub Bot commented on FLINK-4565:
---
Github user DmytroShkvyra commented on a di
Github user DmytroShkvyra commented on a diff in the pull request:
https://github.com/apache/flink/pull/2870#discussion_r105244663
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/api/table/expressions/ScalarFunctionsTest.scala
---
@@ -1101,6 +1101,45 @@ class
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903759#comment-15903759
]
ASF GitHub Bot commented on FLINK-4565:
---
GitHub user DmytroShkvyra opened a pull req
GitHub user DmytroShkvyra opened a pull request:
https://github.com/apache/flink/pull/3502
[FLINK-4565] Support for SQL IN operator
[FLINK-4565] Support for SQL IN operator
This PR is a part of work on SQL IN operator in Table API, which implements
IN for literals.
Two cases
Greg Hogan created FLINK-6009:
-
Summary: Deprecate DataSetUtils#checksumHashCode
Key: FLINK-6009
URL: https://issues.apache.org/jira/browse/FLINK-6009
Project: Flink
Issue Type: Improvement
Bowen Li created FLINK-6010:
---
Summary: Documentation: correct IntelliJ IDEA Plugins path in
'Installing the Scala plugin' section
Key: FLINK-6010
URL: https://issues.apache.org/jira/browse/FLINK-6010
Projec
[
https://issues.apache.org/jira/browse/FLINK-5829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai reassigned FLINK-5829:
-
Assignee: Haohui Mai
> Bump Calcite version to 1.12 once available
>
Haohui Mai created FLINK-6011:
-
Summary: Support TUMBLE, HOP, SESSION window in streaming SQL
Key: FLINK-6011
URL: https://issues.apache.org/jira/browse/FLINK-6011
Project: Flink
Issue Type: Sub-
Haohui Mai created FLINK-6012:
-
Summary: Support WindowStart / WindowEnd functions in stream SQL
Key: FLINK-6012
URL: https://issues.apache.org/jira/browse/FLINK-6012
Project: Flink
Issue Type: S
Github user haohui closed the pull request at:
https://github.com/apache/flink/pull/3461
---
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
[
https://issues.apache.org/jira/browse/FLINK-5954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904042#comment-15904042
]
ASF GitHub Bot commented on FLINK-5954:
---
Github user haohui closed the pull request
Github user haohui commented on the issue:
https://github.com/apache/flink/pull/3461
Sorry for the late response. This is a prerequisite step for FLINK-6012 --
translating the group auxiliary functions (e.g., `TUMBLE_START`) to the
corresponding Flink expressions (e.g., `WindowStart`)
[
https://issues.apache.org/jira/browse/FLINK-5954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904048#comment-15904048
]
ASF GitHub Bot commented on FLINK-5954:
---
Github user haohui commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904050#comment-15904050
]
ASF GitHub Bot commented on FLINK-5954:
---
GitHub user haohui reopened a pull request:
GitHub user haohui reopened a pull request:
https://github.com/apache/flink/pull/3461
[FLINK-5954] Always assign names to the window in the Stream SQL API.
Please see jira for more details.
You can merge this pull request into a Git repository by running:
$ git pull https://gi
Github user addisonj commented on the issue:
https://github.com/apache/flink/pull/1668
Very interested in this work. It sounds like there are few loose ends and
then some cleanup before it might be ready for merge, @senorcarbone or
@StephanEwen anything that can be supported by someon
[
https://issues.apache.org/jira/browse/FLINK-3257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904089#comment-15904089
]
ASF GitHub Bot commented on FLINK-3257:
---
Github user addisonj commented on the issue
Github user sunjincheng121 commented on the issue:
https://github.com/apache/flink/pull/3461
Hi, @haohui Thanks for your explanation, and I'll see the detail in the
FLINK-5954.
Thanks,
SunJincheng
---
If your project is set up for it, you can reply to this email and have yo
[
https://issues.apache.org/jira/browse/FLINK-5954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904189#comment-15904189
]
ASF GitHub Bot commented on FLINK-5954:
---
Github user sunjincheng121 commented on the
Bowen Li created FLINK-6013:
---
Summary: Add Datadog HTTP metrics reporter
Key: FLINK-6013
URL: https://issues.apache.org/jira/browse/FLINK-6013
Project: Flink
Issue Type: Improvement
Compo
Github user KurtYoung commented on the issue:
https://github.com/apache/flink/pull/3406
Hi @fhueske , i like your propose about moving the annotation from
`TableSource` to `TableSourceConverter`. Lets do it this way.
BTW, i noticed that you offered three possible methods to the
`
Github user beyond1920 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3406#discussion_r105316858
--- Diff:
flink-libraries/flink-table/src/main/java/org/apache/flink/table/annotation/ExternalCatalogCompatible.java
---
@@ -0,0 +1,63 @@
+/*
+ *
Github user liuyuzhong7 commented on the issue:
https://github.com/apache/flink/pull/3485
OK, get it. So how about just do it now in flink-tests like this pull
request?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
[
https://issues.apache.org/jira/browse/FLINK-5976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904258#comment-15904258
]
ASF GitHub Bot commented on FLINK-5976:
---
Github user liuyuzhong7 commented on the is
Xiaogang Shi created FLINK-6014:
---
Summary: Allow the registration of state objects in checkpoints
Key: FLINK-6014
URL: https://issues.apache.org/jira/browse/FLINK-6014
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-5859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904271#comment-15904271
]
Kurt Young commented on FLINK-5859:
---
Hi [~fhueske], i can continue working on {{Filterab
[
https://issues.apache.org/jira/browse/FLINK-5976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904280#comment-15904280
]
ASF GitHub Bot commented on FLINK-5976:
---
Github user liuyuzhong7 commented on the is
Github user liuyuzhong7 commented on the issue:
https://github.com/apache/flink/pull/3485
@StephanEwen
FlatMapFunction "Tokenizer" has move to
org.apache.flink.test.testfunctions.
Help me to review this. Thanks.
And collect other reusable functions to org.apache.flin
[
https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young reassigned FLINK-3849:
-
Assignee: Kurt Young
> Add FilterableTableSource interface and translation rule
> ---
Github user ifndef-SleePy closed the pull request at:
https://github.com/apache/flink/pull/3395
---
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
Github user ifndef-SleePy commented on the issue:
https://github.com/apache/flink/pull/3395
Hi Till, I almost miss this comments! I didn't see it until a few minutes
ago.
I fully understand your concern. Just let me explain more about your
comments.
1. I agree most of you
[
https://issues.apache.org/jira/browse/FLINK-5861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904311#comment-15904311
]
ASF GitHub Bot commented on FLINK-5861:
---
Github user ifndef-SleePy closed the pull r
[
https://issues.apache.org/jira/browse/FLINK-5861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904310#comment-15904310
]
ASF GitHub Bot commented on FLINK-5861:
---
Github user ifndef-SleePy commented on the
1 - 100 of 301 matches
Mail list logo
