[
https://issues.apache.org/jira/browse/FLINK-7293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16106877#comment-16106877
]
Dian Fu commented on FLINK-7293:
As the {{event-time}}/{{process-time}} has higher priorit
[
https://issues.apache.org/jira/browse/FLINK-7293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16106872#comment-16106872
]
Dawid Wysakowicz commented on FLINK-7293:
-
My personal feeling is that it is not n
[
https://issues.apache.org/jira/browse/FLINK-7292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz updated FLINK-7292:
Issue Type: Sub-task (was: New Feature)
Parent: FLINK-6935
> Fix EMPTY MATCH bug in
[
https://issues.apache.org/jira/browse/FLINK-7294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16106860#comment-16106860
]
Bhumika Bayani commented on FLINK-7294:
---
My Mesos version is 1.0.0
Also, i am using
Tzu-Li (Gordon) Tai created FLINK-7300:
--
Summary: End-to-end tests are instable on Travis
Key: FLINK-7300
URL: https://issues.apache.org/jira/browse/FLINK-7300
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-6588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16106833#comment-16106833
]
ASF GitHub Bot commented on FLINK-6588:
---
Github user zjureel closed the pull request
Github user zjureel closed the pull request at:
https://github.com/apache/flink/pull/4292
---
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-7270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fang Yong reassigned FLINK-7270:
Assignee: Fang Yong
> Add support for dynamic properties to cluster entry point
> -
[
https://issues.apache.org/jira/browse/FLINK-7299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16106809#comment-16106809
]
ASF GitHub Bot commented on FLINK-7299:
---
GitHub user soniclavier opened a pull reque
GitHub user soniclavier opened a pull request:
https://github.com/apache/flink/pull/4422
[FLINK-7299][AVRO] Write GenericRecord using AvroOutputFormat
## What is the purpose of the change
Allow writing Avro GenericRecord using AvroOutputFormat.
## Brief change log
Vishnu Viswanath created FLINK-7299:
---
Summary: Write GenericRecord using AvroOutputFormat
Key: FLINK-7299
URL: https://issues.apache.org/jira/browse/FLINK-7299
Project: Flink
Issue Type: Im
[
https://issues.apache.org/jira/browse/FLINK-7298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16106797#comment-16106797
]
ASF GitHub Bot commented on FLINK-7298:
---
Github user hequn8128 commented on the issu
Github user hequn8128 commented on the issue:
https://github.com/apache/flink/pull/4421
Also, I think we need to remove `!validTimestamp` from `while
(keyIter.hasNext && !validTimestamp) {` . Because, new records may be inserted
at the head of rowMapState, in this case expired data wi
[
https://issues.apache.org/jira/browse/FLINK-7298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16106794#comment-16106794
]
ASF GitHub Bot commented on FLINK-7298:
---
GitHub user hequn8128 opened a pull request
GitHub user hequn8128 opened a pull request:
https://github.com/apache/flink/pull/4421
[FLINK-7298] [table] Records can be cleared all at once when all data in
state is invalid
In `ProcTimeWindowInnerJoin`.`expireOutTimeRow`, we need not to remove
records one by one from state when
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4415
@tillrohrmann Thank you for your suggestion, I have update the PR template
and add test caseï¼ thanks
---
If your project is set up for it, you can reply to this email and have your
reply appear on
[
https://issues.apache.org/jira/browse/FLINK-7269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16106783#comment-16106783
]
ASF GitHub Bot commented on FLINK-7269:
---
Github user zjureel commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16106770#comment-16106770
]
ASF GitHub Bot commented on FLINK-7169:
---
Github user dianfu commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16106772#comment-16106772
]
ASF GitHub Bot commented on FLINK-7169:
---
Github user dianfu commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16106769#comment-16106769
]
ASF GitHub Bot commented on FLINK-7169:
---
Github user dianfu commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16106771#comment-16106771
]
ASF GitHub Bot commented on FLINK-7169:
---
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/4331#discussion_r130264164
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -551,18 +579,47 @@ private boolean isSelfIgnore(final StateTransiti
Github user dianfu commented on a diff in the pull request:
https://github.com/apache/flink/pull/4331#discussion_r130266394
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -551,18 +579,47 @@ private boolean isSelfIgnore(final StateTransiti
Github user dianfu commented on a diff in the pull request:
https://github.com/apache/flink/pull/4331#discussion_r130264936
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -551,18 +579,47 @@ private boolean isSelfIgnore(final StateTransiti
Github user dianfu commented on a diff in the pull request:
https://github.com/apache/flink/pull/4331#discussion_r130265354
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -551,18 +579,47 @@ private boolean isSelfIgnore(final StateTransiti
[
https://issues.apache.org/jira/browse/FLINK-7298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng updated FLINK-7298:
---
Description: In {{ProcTimeWindowInnerJoin}}.{{expireOutTimeRow}}, we need
not to remove records from s
[
https://issues.apache.org/jira/browse/FLINK-7298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-7298:
--
Assignee: Hequn Cheng
> Records can be cleared when all data in state is invalid
>
Hequn Cheng created FLINK-7298:
--
Summary: Records can be cleared when all data in state is invalid
Key: FLINK-7298
URL: https://issues.apache.org/jira/browse/FLINK-7298
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-6493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16106728#comment-16106728
]
ASF GitHub Bot commented on FLINK-6493:
---
Github user zhangminglei commented on the i
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/4328
Thanks to @tedyu . It is a good idea and code have been updated based on
your suggestion. Please check it out again ~
---
If your project is set up for it, you can reply to this email and have
[
https://issues.apache.org/jira/browse/FLINK-7239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16106724#comment-16106724
]
Hequn Cheng commented on FLINK-7239:
hi, [~fhueske] RetractionRules will make sure tha
[
https://issues.apache.org/jira/browse/FLINK-7213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16106672#comment-16106672
]
ASF GitHub Bot commented on FLINK-7213:
---
Github user StefanRRichter commented on the
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/4353
BTW, one alternative I was once considering for the scale down case is
merging state handles that are backed by different physical files in one
logical state handle, using something based on `
[
https://issues.apache.org/jira/browse/FLINK-7213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16106669#comment-16106669
]
ASF GitHub Bot commented on FLINK-7213:
---
Github user StefanRRichter commented on the
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/4353
I think that idea is problematic because in the rescaling case, all the
collections can have different sizes. For example there can be 5 managed keyed
state handles and 7 managed operator stat
[
https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4534:
--
Description:
Iteration over state.bucketStates is protected by synchronization in other
methods, except for the
[
https://issues.apache.org/jira/browse/FLINK-5486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-5486:
--
Description:
Here is related code:
{code}
handlePendingFilesForPreviousCheckpoints(bucketState.pendingFil
[
https://issues.apache.org/jira/browse/FLINK-7115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-7115.
--
Resolution: Fixed
Fix Version/s: 1.4.0
Closing this issue for the moment because it shoul
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4416
---
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-7279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-7279.
--
Resolution: Fixed
Fix Version/s: 1.4.0
Fixed via 49acd09ec19b5da3f6e9861d658728ec1306e3d5
[
https://issues.apache.org/jira/browse/FLINK-7279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16106586#comment-16106586
]
ASF GitHub Bot commented on FLINK-7279:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-7080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16106581#comment-16106581
]
ASF GitHub Bot commented on FLINK-7080:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-7080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-7080.
Resolution: Done
Fix Version/s: 1.4.0
Added via a954ea113bc29a4480af579387c6e9b81bd76f85
> D
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4284
---
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-7080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16106578#comment-16106578
]
ASF GitHub Bot commented on FLINK-7080:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/4284
Travis passed. Merging 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 project does not have this feature
enabled
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/4380
Hi @rtudoran,
I had the impression that your main motivation was to fill the syntactic
gaps of SQL on streams and not so much to support certain kinds of use cases.
The semantics o
[
https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16106399#comment-16106399
]
Xingcan Cui commented on FLINK-7245:
Thanks for the answer and the suggestion, [~fhues
[
https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16106397#comment-16106397
]
Fabian Hueske commented on FLINK-7245:
--
Hi [~xccui], thanks for the questions. I thin
[
https://issues.apache.org/jira/browse/FLINK-7179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16106389#comment-16106389
]
Fabian Hueske commented on FLINK-7179:
--
I think a {{ProjectableTableSource}} knows th
[
https://issues.apache.org/jira/browse/FLINK-7291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16106367#comment-16106367
]
Fabian Hueske commented on FLINK-7291:
--
I think you are right that {{getArity()}} was
[
https://issues.apache.org/jira/browse/FLINK-6333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16095490#comment-16095490
]
Ted Yu edited comment on FLINK-6333 at 7/30/17 7:33 AM:
Looks like
[
https://issues.apache.org/jira/browse/FLINK-6493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16106355#comment-16106355
]
ASF GitHub Bot commented on FLINK-6493:
---
Github user tedyu commented on a diff in th
Github user tedyu commented on a diff in the pull request:
https://github.com/apache/flink/pull/4328#discussion_r130235370
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/RegisteredOperatorBackendStateMetaInfo.java
---
@@ -175,14 +175,21 @@ public boolean equa
[
https://issues.apache.org/jira/browse/FLINK-6838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-6838:
--
Description:
{code}
Tests in error:
RescalingITCase.testSavepointRescalingInKeyedState[1] » JobExecution Job
55 matches
Mail list logo
