[
https://issues.apache.org/jira/browse/FLINK-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14942140#comment-14942140
]
Chengxuan Wang edited comment on FLINK-2066 at 10/3/15 6:32 AM:
[
https://issues.apache.org/jira/browse/FLINK-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14942140#comment-14942140
]
Chengxuan Wang commented on FLINK-2066:
---
Hi, Ewen, so the delay also should be speci
[
https://issues.apache.org/jira/browse/FLINK-2815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14942089#comment-14942089
]
ASF GitHub Bot commented on FLINK-2815:
---
GitHub user hsaputra opened a pull request:
GitHub user hsaputra opened a pull request:
https://github.com/apache/flink/pull/1218
[FLINK-2815] [REFACTOR] Remove Pact from class and file names since it is
no longer valid reference
Remove Pact word from class and file names in Apache Flink.
Pact was the name used in Stratos
Henry Saputra created FLINK-2815:
Summary: [REFACTOR] Remove Pact from class and file names since it
is no longer valid reference
Key: FLINK-2815
URL: https://issues.apache.org/jira/browse/FLINK-2815
[
https://issues.apache.org/jira/browse/FLINK-2765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-2765:
--
Description:
Currently 0.98.11 is used:
{code}
0.98.11-hadoop2
{code}
Stable release for hadoop-
[
https://issues.apache.org/jira/browse/FLINK-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941774#comment-14941774
]
Chengxuan Wang commented on FLINK-2066:
---
Ok. Let me try this. Thanks.
> Make delay
Greg Hogan created FLINK-2814:
-
Summary: DeltaIteration: DualInputPlanNode cannot be cast to
SingleInputPlanNode
Key: FLINK-2814
URL: https://issues.apache.org/jira/browse/FLINK-2814
Project: Flink
Github user hsaputra commented on a diff in the pull request:
https://github.com/apache/flink/pull/1209#discussion_r41051842
--- Diff:
flink-staging/flink-table/src/main/scala/org/apache/flink/api/table/plan/PlanTranslator.scala
---
@@ -110,7 +110,8 @@ abstract class PlanTranslato
[
https://issues.apache.org/jira/browse/FLINK-2642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941529#comment-14941529
]
ASF GitHub Bot commented on FLINK-2642:
---
Github user hsaputra commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941528#comment-14941528
]
ASF GitHub Bot commented on FLINK-2642:
---
Github user hsaputra commented on a diff in
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/1209#issuecomment-145115050
+1
---
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 an
[
https://issues.apache.org/jira/browse/FLINK-2666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941466#comment-14941466
]
ASF GitHub Bot commented on FLINK-2666:
---
Github user aljoscha commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1201#issuecomment-145096795
Ok, I saw a failure in the WatermarkITCase that could be a real problem.
I'm investigating.
---
If your project is set up for it, you can reply to this email and have
[
https://issues.apache.org/jira/browse/FLINK-2666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941418#comment-14941418
]
ASF GitHub Bot commented on FLINK-2666:
---
Github user gyfora commented on the pull re
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/1201#issuecomment-145088560
I think it should be good to merge :+1:
---
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 d
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/1135#issuecomment-145085684
Prove reading for README, Web documenation, and examples JavaDoc would be
appreciated ;) It's a lot if renaming going on and I might have missed
something.
---
If your p
[
https://issues.apache.org/jira/browse/FLINK-2566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941388#comment-14941388
]
ASF GitHub Bot commented on FLINK-2566:
---
Github user mjsax commented on the pull req
[
https://issues.apache.org/jira/browse/FLINK-2566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941386#comment-14941386
]
ASF GitHub Bot commented on FLINK-2566:
---
Github user mjsax commented on the pull req
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/1135#issuecomment-145085340
Just updated this PR. It additionally contains the maven module
restructuring and internal code cleanup in a second commit. If no objects, I
will push this into master.
[
https://issues.apache.org/jira/browse/FLINK-2716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941379#comment-14941379
]
Greg Hogan commented on FLINK-2716:
---
[~StephanEwen], I would like to use {{TypeComparato
[
https://issues.apache.org/jira/browse/FLINK-2809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941359#comment-14941359
]
ASF GitHub Bot commented on FLINK-2809:
---
GitHub user ggevay opened a pull request:
GitHub user ggevay opened a pull request:
https://github.com/apache/flink/pull/1217
[FLINK-2809] [scala-api] Added UnitTypeInfo and UnitSerializer.
Created UnitTypeInfo and UnitSerializer, which will be created for a
DataSet[Unit].
Also added a test.
There is a funny si
[
https://issues.apache.org/jira/browse/FLINK-2802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941348#comment-14941348
]
ASF GitHub Bot commented on FLINK-2802:
---
GitHub user gyfora opened a pull request:
GitHub user gyfora opened a pull request:
https://github.com/apache/flink/pull/1216
[FLINK-2802] [streaming] Remove cyclic watermark dependencies for iterations
This PR contains a simple change so that if timestamps are enabled,
iteration sources automatically emit a `Long.MAX_VALUE
[
https://issues.apache.org/jira/browse/FLINK-2811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sachin Goel reassigned FLINK-2811:
--
Assignee: Sachin Goel
> Add page with configuration overview
>
Maximilian Michels created FLINK-2813:
-
Summary: Document off-heap configuration
Key: FLINK-2813
URL: https://issues.apache.org/jira/browse/FLINK-2813
Project: Flink
Issue Type: Bug
Márton Balassi created FLINK-2812:
-
Summary: KeySelectorUtil.getSelectorForKeys and
TypeExtractor.getKeySelectorTypes are incompatible
Key: FLINK-2812
URL: https://issues.apache.org/jira/browse/FLINK-2812
Robert Metzger created FLINK-2811:
-
Summary: Add page with configuration overview
Key: FLINK-2811
URL: https://issues.apache.org/jira/browse/FLINK-2811
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-1052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger closed FLINK-1052.
-
Resolution: Won't Fix
> Access to stdout and log information of Taskmanagers from the web interfac
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/1214#issuecomment-145059638
It doesn't really make sense to call `print` or `collect` in detached mode.
Even if the result is printed on JobManager, client cannot access it anyway
[short of
[
https://issues.apache.org/jira/browse/FLINK-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941250#comment-14941250
]
ASF GitHub Bot commented on FLINK-2797:
---
Github user sachingoel0101 commented on the
[
https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941227#comment-14941227
]
ASF GitHub Bot commented on FLINK-2354:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1153#discussion_r41030614
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/ZooKeeperCheckpointIDCounter.java
---
@@ -0,0 +1,130 @@
+/*
+ * Licens
[
https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941223#comment-14941223
]
ASF GitHub Bot commented on FLINK-2354:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1153#discussion_r41029773
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/SuccessfulCheckpoint.java
---
@@ -19,29 +19,28 @@
package org.apache.flin
[
https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941221#comment-14941221
]
ASF GitHub Bot commented on FLINK-2354:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-2727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2727.
---
> Add a base class for MessageQueue-with-acknowledgement sources
> ---
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/1215
Stream API Refactoring
This is a WIP of the refactoring. I still want to add Javadocs and a new
join operator based on tagged union that uses the new windowing operators.
You can merge this
[
https://issues.apache.org/jira/browse/FLINK-2727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2727.
-
Resolution: Implemented
Fix Version/s: 0.10
Implemented in daeab84985bb510351b04e08f83cdd6c
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1153#discussion_r41029601
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StateForTask.java
---
@@ -48,9 +55,9 @@
private final int subtask;
[
https://issues.apache.org/jira/browse/FLINK-2727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941218#comment-14941218
]
ASF GitHub Bot commented on FLINK-2727:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1163
---
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-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941214#comment-14941214
]
ASF GitHub Bot commented on FLINK-2797:
---
Github user mxm commented on the pull reque
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1214#issuecomment-145044584
The current version of the detached mode doesn't really work for eager
execution calls like `count()` or `collect()`. Those calls will also be
executed detached and thus the
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1210#issuecomment-145042315
Let's hope the world moves beyond Hadoop 2.3 quickly so we can activate it
again for the default version
+1
---
If your project is set up for it, you can r
[
https://issues.apache.org/jira/browse/FLINK-2810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-2810:
--
Description:
taskmanager.sh will print the following message when starting the cluster if bc
is not ins
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1210#issuecomment-145036429
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 w
[
https://issues.apache.org/jira/browse/FLINK-2799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-2799:
--
Fix Version/s: 0.10
> Yarn tests cannot be executed with DEBUG log level
> -
[
https://issues.apache.org/jira/browse/FLINK-2799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-2799:
--
Affects Version/s: 0.10
0.9
> Yarn tests cannot be executed with
[
https://issues.apache.org/jira/browse/FLINK-2810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-2810:
--
Fix Version/s: 0.10
> Warn user if bc not installed
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-2810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-2810:
--
Affects Version/s: (was: master)
0.10
> Warn user if bc not i
[
https://issues.apache.org/jira/browse/FLINK-2810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941185#comment-14941185
]
Maximilian Michels commented on FLINK-2810:
---
Yes, bash cannot perform floating p
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1153#discussion_r41025127
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
---
@@ -178,9 +195,9 @@ public void run() {
[
https://issues.apache.org/jira/browse/FLINK-2779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941179#comment-14941179
]
ASF GitHub Bot commented on FLINK-2779:
---
Github user senorcarbone commented on the p
Github user senorcarbone commented on the pull request:
https://github.com/apache/flink/pull/1208#issuecomment-145032778
Ah Indeed. I just reviewed this with the prospect of custom
pre-aggregations in mind and it seems like pre-aggregation strategies operate
on bucket-granularity. Sol
[
https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941177#comment-14941177
]
ASF GitHub Bot commented on FLINK-2354:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941173#comment-14941173
]
ASF GitHub Bot commented on FLINK-2354:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-2810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941172#comment-14941172
]
Greg Hogan commented on FLINK-2810:
---
Bash arithmetic evaluation is limited to integers.
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1153#discussion_r41024851
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
---
@@ -110,61 +120,68 @@
public Chec
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1208#issuecomment-145029475
@senorcarbone It doesn't restrict. You can use an assigner that assigns to
one single window. Then using, trigger and evictor you can implement everything
that was poss
[
https://issues.apache.org/jira/browse/FLINK-2779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941163#comment-14941163
]
ASF GitHub Bot commented on FLINK-2779:
---
Github user aljoscha commented on the pull
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1214#issuecomment-145029090
Looks good but the Maven Checkstyle check doesn't pass...
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
Github user senorcarbone commented on the pull request:
https://github.com/apache/flink/pull/1208#issuecomment-145028978
From a quick read on the documentation (and prior knowledge from google
dataflow) it is easy to get a full picture of the new semantics. Even though I
like it from
[
https://issues.apache.org/jira/browse/FLINK-2779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941160#comment-14941160
]
ASF GitHub Bot commented on FLINK-2779:
---
Github user senorcarbone commented on the p
[
https://issues.apache.org/jira/browse/FLINK-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941161#comment-14941161
]
ASF GitHub Bot commented on FLINK-2797:
---
Github user mxm commented on the pull reque
[
https://issues.apache.org/jira/browse/FLINK-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941151#comment-14941151
]
ASF GitHub Bot commented on FLINK-1789:
---
Github user mxm commented on the pull reque
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/593#issuecomment-145026274
This looks good to merge. However, there are a lot of merge conflicts.
Could you rebase to the master again? We're are thinking about creating a
release candidate for 0.10 un
[
https://issues.apache.org/jira/browse/FLINK-2779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941150#comment-14941150
]
ASF GitHub Bot commented on FLINK-2779:
---
Github user senorcarbone commented on the p
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1208#issuecomment-145025216
Would be a nice addition to the docs, to state that global time reduce (and
other aggregations) are pre-aggregated in parallel.
---
If your project is set up for it
[
https://issues.apache.org/jira/browse/FLINK-2779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941148#comment-14941148
]
ASF GitHub Bot commented on FLINK-2779:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-2779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941144#comment-14941144
]
ASF GitHub Bot commented on FLINK-2779:
---
Github user StephanEwen commented on the pu
Github user senorcarbone commented on the pull request:
https://github.com/apache/flink/pull/1208#issuecomment-145025577
Nice doc so far ^^
One tiny fix on the *Advanced window constructs* subsection:
[0,1000], [100,1100], **[200,1200]**, ..., [1000, 2000]
---
If yo
[
https://issues.apache.org/jira/browse/FLINK-2779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941146#comment-14941146
]
ASF GitHub Bot commented on FLINK-2779:
---
Github user gyfora commented on the pull re
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/1208#issuecomment-145024860
That is what I mean, global time reduce.
---
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 d
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/1214#issuecomment-145023847
I tested the normal execution mode. However, I don't have a yarn setup. Can
someone give it a quick check with yarn?
Quick question though: In detached mode, p
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1208#issuecomment-145024435
Global windows are not parallel, not in any system, it is inherent in the
operation.
You can pre-aggregate in parallel, if the windows are time windows. Thes
[
https://issues.apache.org/jira/browse/FLINK-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941142#comment-14941142
]
ASF GitHub Bot commented on FLINK-2797:
---
Github user sachingoel0101 commented on the
[
https://issues.apache.org/jira/browse/FLINK-2810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941138#comment-14941138
]
Stephan Ewen commented on FLINK-2810:
-
Do the scripts strictly need {{bc}} ? You can d
GitHub user sachingoel0101 opened a pull request:
https://github.com/apache/flink/pull/1214
[FLINK-2797][cli] Add support for running jobs in detached mode from CLI
Adds an option `-d` to run jobs in detached mode.
You can merge this pull request into a Git repository by running:
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1208#issuecomment-145021034
There should be some streaming specific stuff in the `Execution Config`
section. For example, there is `enableTimestamps()` and
`setAutoWatermarkInterval()`.
---
If y
[
https://issues.apache.org/jira/browse/FLINK-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941137#comment-14941137
]
ASF GitHub Bot commented on FLINK-2797:
---
GitHub user sachingoel0101 opened a pull re
[
https://issues.apache.org/jira/browse/FLINK-2779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941136#comment-14941136
]
ASF GitHub Bot commented on FLINK-2779:
---
Github user aljoscha commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941133#comment-14941133
]
ASF GitHub Bot commented on FLINK-2779:
---
Github user aljoscha commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941132#comment-14941132
]
ASF GitHub Bot commented on FLINK-2779:
---
Github user aljoscha commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941134#comment-14941134
]
ASF GitHub Bot commented on FLINK-2779:
---
Github user gyfora commented on the pull re
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1208#issuecomment-145020534
If split is mentioned select should also be mentioned.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. I
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/1208#issuecomment-145020604
"Windows on unkeyed data streams (non-parallel windows)"
I still think that this gives a bad false impression of executing all
global windows including time in a non-p
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1208#issuecomment-145020475
The ConnectedStreams example formatting is off (in Transformations
section), also there should be something like:
```java
ConnectedStreams<> connectedStreams = s
[
https://issues.apache.org/jira/browse/FLINK-2779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941130#comment-14941130
]
ASF GitHub Bot commented on FLINK-2779:
---
Github user aljoscha commented on the pull
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/1208#issuecomment-145020261
@aljoscha : what I meant was just that we define some time semantics with
the window assigner
---
If your project is set up for it, you can reply to this email and have
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1208#issuecomment-145020330
@gyfora, yes, thats right
---
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
[
https://issues.apache.org/jira/browse/FLINK-2779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941129#comment-14941129
]
ASF GitHub Bot commented on FLINK-2779:
---
Github user gyfora commented on the pull re
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1208#issuecomment-145020080
@gyfora Yes, they work with the same semantics. What do you mean by "fix
time trigger/eviction determined by the window assigner"?
---
If your project is set up for it
[
https://issues.apache.org/jira/browse/FLINK-2779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941128#comment-14941128
]
ASF GitHub Bot commented on FLINK-2779:
---
Github user aljoscha commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1208#issuecomment-145019903
The WindowFunction has a different signature for regular windows and all
windows. This should maybe be visible in the transformations section.
---
If your project is s
[
https://issues.apache.org/jira/browse/FLINK-2779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941127#comment-14941127
]
ASF GitHub Bot commented on FLINK-2779:
---
Github user aljoscha commented on the pull
Greg Hogan created FLINK-2810:
-
Summary: Warn user if bc not installed
Key: FLINK-2810
URL: https://issues.apache.org/jira/browse/FLINK-2810
Project: Flink
Issue Type: Improvement
Compo
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/1208#issuecomment-145017991
The description of Evictors for the keyed windows are a little bit messy,
what gets evicted from where. There is also some conflict with the example and
the description:
[
https://issues.apache.org/jira/browse/FLINK-2779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14941119#comment-14941119
]
ASF GitHub Bot commented on FLINK-2779:
---
Github user gyfora commented on the pull re
1 - 100 of 182 matches
Mail list logo
