[
https://issues.apache.org/jira/browse/FLINK-7402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16151397#comment-16151397
]
ASF GitHub Bot commented on FLINK-7402:
---
Github user tedyu commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-7432:
--
Description:
{code}
public QueryableStateClient(Configuration config) throws Exception {
this(config, High
Github user tedyu commented on the issue:
https://github.com/apache/flink/pull/4562
lgtm
---
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
[
https://issues.apache.org/jira/browse/FLINK-7433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-7433:
--
Description:
{code}
try {
if (throwable != null) {
completed.put
[
https://issues.apache.org/jira/browse/FLINK-4319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16151309#comment-16151309
]
Shuyi Chen edited comment on FLINK-4319 at 9/1/17 11:48 PM:
Hi
[
https://issues.apache.org/jira/browse/FLINK-4319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16151309#comment-16151309
]
Shuyi Chen commented on FLINK-4319:
---
Hi Till,
I am looking into integrating Flink with
[
https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16151151#comment-16151151
]
ASF GitHub Bot commented on FLINK-7491:
---
Github user suez1224 commented on the issue
Github user suez1224 commented on the issue:
https://github.com/apache/flink/pull/4585
Hi @fhueske , I've filled out the PR template. Please take a look. Thanks a
lot.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If y
[
https://issues.apache.org/jira/browse/FLINK-7571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16151088#comment-16151088
]
ASF GitHub Bot commented on FLINK-7571:
---
GitHub user fhueske opened a pull request:
GitHub user fhueske opened a pull request:
https://github.com/apache/flink/pull/4635
[FLINK-7571] [table] Fix translation of TableSource with time indicators
## What is the purpose of the change
This PR fixes the translation / code generation for table scans against
table s
Fabian Hueske created FLINK-7571:
Summary: Execution of TableSources with Time Indicators fails
Key: FLINK-7571
URL: https://issues.apache.org/jira/browse/FLINK-7571
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-7570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16150915#comment-16150915
]
Hai Zhou commented on FLINK-7570:
-
PR: https://github.com/apache/flink-web/pull/83
> Fix
Hai Zhou created FLINK-7570:
---
Summary: Fix broken link on faq page
Key: FLINK-7570
URL: https://issues.apache.org/jira/browse/FLINK-7570
Project: Flink
Issue Type: Bug
Components: Project
[
https://issues.apache.org/jira/browse/FLINK-7422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16150868#comment-16150868
]
ASF GitHub Bot commented on FLINK-7422:
---
Github user bowenli86 closed the pull reque
Github user bowenli86 closed the pull request at:
https://github.com/apache/flink/pull/4627
---
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
[
https://issues.apache.org/jira/browse/FLINK-6016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16150860#comment-16150860
]
Luke Hutchison commented on FLINK-6016:
---
Yes, that's what I'm suggesting. The data d
[
https://issues.apache.org/jira/browse/FLINK-6016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16150827#comment-16150827
]
Mikhail Lipkovich commented on FLINK-6016:
--
Thank you for the reply Luke
For now
[
https://issues.apache.org/jira/browse/FLINK-6733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mikhail Lipkovich reassigned FLINK-6733:
Assignee: Mikhail Lipkovich
> Remove commented out AvgAggregationFunction.java
> --
[
https://issues.apache.org/jira/browse/FLINK-5944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mikhail Lipkovich reassigned FLINK-5944:
Assignee: Mikhail Lipkovich
> Flink should support reading Snappy Files
> -
[
https://issues.apache.org/jira/browse/FLINK-7552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16150797#comment-16150797
]
ASF GitHub Bot commented on FLINK-7552:
---
Github user EronWright commented on a diff
Github user EronWright commented on a diff in the pull request:
https://github.com/apache/flink/pull/4616#discussion_r136615982
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/SinkFunction.java
---
@@ -35,6 +35,39 @@
*
*
[
https://issues.apache.org/jira/browse/FLINK-7552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16150792#comment-16150792
]
ASF GitHub Bot commented on FLINK-7552:
---
Github user EronWright commented on a diff
Github user EronWright commented on a diff in the pull request:
https://github.com/apache/flink/pull/4616#discussion_r136615089
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/SinkFunction.java
---
@@ -35,6 +35,39 @@
*
*
[
https://issues.apache.org/jira/browse/FLINK-7552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16150789#comment-16150789
]
ASF GitHub Bot commented on FLINK-7552:
---
Github user EronWright commented on a diff
Github user EronWright commented on a diff in the pull request:
https://github.com/apache/flink/pull/4616#discussion_r136614448
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/SinkFunction.java
---
@@ -35,6 +35,39 @@
*
*
[
https://issues.apache.org/jira/browse/FLINK-7547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16150754#comment-16150754
]
ASF GitHub Bot commented on FLINK-7547:
---
Github user yew1eb commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16150753#comment-16150753
]
ASF GitHub Bot commented on FLINK-7438:
---
Github user yew1eb commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16150755#comment-16150755
]
ASF GitHub Bot commented on FLINK-7494:
---
Github user yew1eb commented on the issue:
Github user yew1eb commented on the issue:
https://github.com/apache/flink/pull/4614
CC @aljoscha :satisfied:
---
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 s
Github user yew1eb commented on the issue:
https://github.com/apache/flink/pull/4570
CC @aljoscha :satisfied:
---
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 s
Github user yew1eb commented on the issue:
https://github.com/apache/flink/pull/4575
CC @aljoscha :satisfied:
---
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 s
[
https://issues.apache.org/jira/browse/FLINK-7569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
olivier sohn updated FLINK-7569:
Description:
In the example below (described at the end of the class documentation), we see
that Fl
olivier sohn created FLINK-7569:
---
Summary: '1 record' delay for counted windowed streams
Key: FLINK-7569
URL: https://issues.apache.org/jira/browse/FLINK-7569
Project: Flink
Issue Type: Bug
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4630
The failed test is know to be unstable, it's not related to these changes.
+1 to merge.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
[
https://issues.apache.org/jira/browse/FLINK-6733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16150588#comment-16150588
]
ASF GitHub Bot commented on FLINK-6733:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-6860.
---
Resolution: Fixed
Fixed in 08990df185e5f5bb8d3b03a3e307b797aef0cc0b.
> update Apache Beam in
[
https://issues.apache.org/jira/browse/FLINK-7568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16150535#comment-16150535
]
ASF GitHub Bot commented on FLINK-7568:
---
GitHub user aljoscha opened a pull request:
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/4634
[FLINK-7568] Improve Windowing Documentation
R: @twalthr
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aljoscha/flink jira-7568-window-docume
[
https://issues.apache.org/jira/browse/FLINK-7552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16150531#comment-16150531
]
ASF GitHub Bot commented on FLINK-7552:
---
Github user aljoscha commented on a diff in
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/4616#discussion_r136575860
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerBase.java
---
@@ -311,7 +
[
https://issues.apache.org/jira/browse/FLINK-7552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16150438#comment-16150438
]
ASF GitHub Bot commented on FLINK-7552:
---
Github user pnowojski commented on a diff i
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4616#discussion_r136563378
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerBase.java
---
@@ -311,7
[
https://issues.apache.org/jira/browse/FLINK-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16150436#comment-16150436
]
ASF GitHub Bot commented on FLINK-7169:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4331
---
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 mlipkovich commented on the issue:
https://github.com/apache/flink/pull/4630
The build has failed but it seems like Travis issue. My changes could not
break it
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well.
[
https://issues.apache.org/jira/browse/FLINK-6733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16150395#comment-16150395
]
ASF GitHub Bot commented on FLINK-6733:
---
Github user mlipkovich commented on the iss
[
https://issues.apache.org/jira/browse/FLINK-5944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hai Zhou reassigned FLINK-5944:
---
Assignee: (was: Hai Zhou)
> Flink should support reading Snappy Files
> -
[
https://issues.apache.org/jira/browse/FLINK-5944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hai Zhou reassigned FLINK-5944:
---
Assignee: Hai Zhou
> Flink should support reading Snappy Files
>
[
https://issues.apache.org/jira/browse/FLINK-6163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-6163:
Issue Type: Sub-task (was: Improvement)
Parent: FLINK-7568
> Document per-window st
Aljoscha Krettek created FLINK-7568:
---
Summary: Bring window documentation up-to-date with latest changes
and improve
Key: FLINK-7568
URL: https://issues.apache.org/jira/browse/FLINK-7568
Project: Fl
Peter Ertl created FLINK-7567:
-
Summary: DataStream#iterate() on env.fromElements() /
env.fromCollection() does not work
Key: FLINK-7567
URL: https://issues.apache.org/jira/browse/FLINK-7567
Project: Flin
[
https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16150282#comment-16150282
]
Xingcan Cui commented on FLINK-6233:
Hi [~fhueske], thanks for your comments. They are
[
https://issues.apache.org/jira/browse/FLINK-7299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16150246#comment-16150246
]
ASF GitHub Bot commented on FLINK-7299:
---
Github user soniclavier closed the pull req
Github user soniclavier closed the pull request at:
https://github.com/apache/flink/pull/4422
---
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
[
https://issues.apache.org/jira/browse/FLINK-7422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16150244#comment-16150244
]
ASF GitHub Bot commented on FLINK-7422:
---
Github user aljoscha commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-7422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-7422.
---
Resolution: Fixed
Resolved in
c87275154cec0b305b3210a9244927d18b7ec26e
> Upgrade Kinesis Clie
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/4627
Thanks, @bowenli86! ð
I merged this, could you please close the 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 yo
[
https://issues.apache.org/jira/browse/FLINK-7299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-7299.
---
Resolution: Fixed
Fix Version/s: 1.4.0
Implemente in
391e39bc7647625c7ea59b5c3ce2cf23e8
[
https://issues.apache.org/jira/browse/FLINK-7299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16150223#comment-16150223
]
ASF GitHub Bot commented on FLINK-7299:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/4422
Thanks a lot! I merged this. ð
Could you please close 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 pr
[
https://issues.apache.org/jira/browse/FLINK-7552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16150206#comment-16150206
]
ASF GitHub Bot commented on FLINK-7552:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/4616
It seems we completely have to ignore `SinkFunction`, because japicmp will
check its serialiVersionUID, which changed by adding a new method to the
interface. (And yes, I know that checking the seri
[
https://issues.apache.org/jira/browse/FLINK-7564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16150193#comment-16150193
]
ASF GitHub Bot commented on FLINK-7564:
---
GitHub user xccui opened a pull request:
GitHub user xccui opened a pull request:
https://github.com/apache/flink/pull/4633
[FLINK-7564] [table] Fix Watermark semantics in RowTimeUnboundedOver
## What is the purpose of the change
This PR aims to fix the watermark boundary check problem (mentioned in
[this
thread]
[
https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16150155#comment-16150155
]
Shuyi Chen commented on FLINK-7491:
---
Hi [~fhue...@gmail.com], I've updated the PR descri
[
https://issues.apache.org/jira/browse/FLINK-7223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16150154#comment-16150154
]
Bowen Li commented on FLINK-7223:
-
[~StephanEwen] We've already filed such a request to AW
66 matches
Mail list logo
