[
https://issues.apache.org/jira/browse/FLINK-5994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950530#comment-15950530
]
ASF GitHub Bot commented on FLINK-5994:
---
GitHub user sunjincheng121 opened a pull request:
GitHub user sunjincheng121 opened a pull request:
https://github.com/apache/flink/pull/3656
[FLINK-5994][table] Add Janino to flink-dist JAR file
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
[
https://issues.apache.org/jira/browse/FLINK-6226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-6226:
--
Component/s: Table API & SQL
> ScalarFunction and TableFunction do not support parameters of
[
https://issues.apache.org/jira/browse/FLINK-5227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950565#comment-15950565
]
Fabian Hueske commented on FLINK-5227:
--
Yes.
IMO, it should be added to {{./flink-dist/pom.xml}} and
[
https://issues.apache.org/jira/browse/FLINK-5915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950571#comment-15950571
]
ASF GitHub Bot commented on FLINK-5915:
---
Github user shaoxuan-wang commented on the issue:
Github user shaoxuan-wang commented on the issue:
https://github.com/apache/flink/pull/3647
Thanks @fhueske, I overlooked a list is not always an arraylist. I change
it to scala array, but keep the type as integer, as this is type returned (and
not easy to be casted to Int) from
sunjincheng created FLINK-6228:
--
Summary: Integrating the OVER windows in the Table API
Key: FLINK-6228
URL: https://issues.apache.org/jira/browse/FLINK-6228
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-4557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-4557:
---
Comment: was deleted
(was: [~fhueske] Thanks for converter the "FLINK-5803" & "FLINK-5804" to
[
https://issues.apache.org/jira/browse/FLINK-5227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng reassigned FLINK-5227:
--
Assignee: sunjincheng
> Add warning to include flink-table in job fat jars
>
Zhuoluo Yang created FLINK-6226:
---
Summary: ScalarFunction and TableFunction do not support
parameters of byte, short and float
Key: FLINK-6226
URL: https://issues.apache.org/jira/browse/FLINK-6226
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3655
It would be less intrusive, that's true. I do prefer staying away from
mockito magic as far as possible though Mockito often results in failing tests
even though no public contract was
[
https://issues.apache.org/jira/browse/FLINK-6175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950498#comment-15950498
]
ASF GitHub Bot commented on FLINK-6175:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950531#comment-15950531
]
Vladislav Pernin commented on FLINK-6214:
-
Let's take the example of a simple one day window, but
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950542#comment-15950542
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user rtudoran commented on the issue:
Github user rtudoran commented on the issue:
https://github.com/apache/flink/pull/3641
@fhueske it is good to know, but i think we can optimize the computation as
mentioned above
---
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-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950540#comment-15950540
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user rtudoran commented on the issue:
Github user rtudoran commented on the issue:
https://github.com/apache/flink/pull/3641
I found a workaround this issue - i will accumulate events in
processElement and compute and emit in onTImer
---
If your project is set up for it, you can reply to this email and have your
reply
[
https://issues.apache.org/jira/browse/FLINK-6219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950557#comment-15950557
]
Fabian Hueske edited comment on FLINK-6219 at 3/31/17 9:01 AM:
---
The problem
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6228:
---
Description:
Syntax:
{code}
table
.overWindows(
(Rows|Range [ partitionBy value_expression ,
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6228:
---
Description:
Syntax:
{code}
table
.overWindows(
(Rows|Range [ partitionBy value_expression ,
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950608#comment-15950608
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user rtudoran commented on the issue:
hongyuhong created FLINK-6233:
-
Summary: Support rowtime inner equi-join between two streams in
the SQL API
Key: FLINK-6233
URL: https://issues.apache.org/jira/browse/FLINK-6233
Project: Flink
Github user rtudoran commented on the issue:
https://github.com/apache/flink/pull/3641
@fhueske Thanks for the feedback.
It has on the one hand that the few events that arrive with the same
proctime are not computed iteratively, but in a batch (all in the same time - 1
ms later),
[
https://issues.apache.org/jira/browse/FLINK-5227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950631#comment-15950631
]
Fabian Hueske commented on FLINK-5227:
--
I think adding {{flink-table}} to {{flink-dist}} should be a
[
https://issues.apache.org/jira/browse/FLINK-5227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950568#comment-15950568
]
sunjincheng edited comment on FLINK-5227 at 3/31/17 10:03 AM:
--
[~fhueske] So,
[
https://issues.apache.org/jira/browse/FLINK-5227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950645#comment-15950645
]
sunjincheng commented on FLINK-5227:
Yes, Agree! I got you.
> Add warning to include flink-table in
[
https://issues.apache.org/jira/browse/FLINK-6219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950504#comment-15950504
]
sunjincheng commented on FLINK-6219:
Hi,[~xiaogang.shi] thanks for sharing this to us. I agree with
[
https://issues.apache.org/jira/browse/FLINK-6115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950505#comment-15950505
]
Luke Hutchison commented on FLINK-6115:
---
[~Zentol] In point (1), I wasn't referring to the overhead
[
https://issues.apache.org/jira/browse/FLINK-6219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950557#comment-15950557
]
Fabian Hueske edited comment on FLINK-6219 at 3/31/17 8:56 AM:
---
The problem
Chesnay Schepler created FLINK-6230:
---
Summary: Make mmap size configurable
Key: FLINK-6230
URL: https://issues.apache.org/jira/browse/FLINK-6230
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-5227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950568#comment-15950568
]
sunjincheng edited comment on FLINK-5227 at 3/31/17 9:26 AM:
-
[~fhueske] So,
[
https://issues.apache.org/jira/browse/FLINK-5994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950541#comment-15950541
]
sunjincheng commented on FLINK-5994:
Hi, [~twalthr] I have opened the PR.I took the user's way to
[
https://issues.apache.org/jira/browse/FLINK-5725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950543#comment-15950543
]
Fabian Hueske commented on FLINK-5725:
--
Yes, I agree with the approach @hongyuhong.
Can you create
[
https://issues.apache.org/jira/browse/FLINK-6219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950557#comment-15950557
]
Fabian Hueske commented on FLINK-6219:
--
The problem with `ValueState` is that it always deserializes
[
https://issues.apache.org/jira/browse/FLINK-6227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang reassigned FLINK-6227:
---
Assignee: zhijiang
> Introduce the DataConsumptionException for downstream task failure
>
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3641
you're right. That works as well. :-)
---
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
Chesnay Schepler created FLINK-6229:
---
Summary: Rework setup of PythonPlanBinder/operators
Key: FLINK-6229
URL: https://issues.apache.org/jira/browse/FLINK-6229
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-4680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-4680.
--
Resolution: Duplicate
> Add SlidingRow row-windows to Table API
>
[
https://issues.apache.org/jira/browse/FLINK-6226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950509#comment-15950509
]
Zhuoluo Yang commented on FLINK-6226:
-
I have tested the different types of parameters.
Byte, Short
[
https://issues.apache.org/jira/browse/FLINK-5994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-5994:
---
Component/s: Distributed Coordination
> Add Janino to flink-table JAR file
>
[
https://issues.apache.org/jira/browse/FLINK-5994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-5994:
---
Component/s: (was: Distributed Coordination)
> Add Janino to flink-table JAR file
>
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950535#comment-15950535
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3641
Hi @rtudoran,
the calls to `processElement()` and `onTimer()` and guarded by a lock. So
both methods won't be called at that the same time.
---
If your project is set up for it, you can reply
[
https://issues.apache.org/jira/browse/FLINK-5227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950555#comment-15950555
]
sunjincheng commented on FLINK-5227:
Hi,[~fhueske] Maybe we can add `flink-table` dependency in
zhijiang created FLINK-6227:
---
Summary: Introduce the DataConsumptionException for downstream
task failure
Key: FLINK-6227
URL: https://issues.apache.org/jira/browse/FLINK-6227
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950562#comment-15950562
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950568#comment-15950568
]
sunjincheng commented on FLINK-5227:
[~fhueske] So, Can I take this JIRA. and fix it?
> Add warning
[
https://issues.apache.org/jira/browse/FLINK-4680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950589#comment-15950589
]
sunjincheng commented on FLINK-4680:
I had created FLINK-6228.
> Add SlidingRow row-windows to Table
Chao Zhao created FLINK-6231:
Summary: completed PendingCheckpoint not release state caused oom
Key: FLINK-6231
URL: https://issues.apache.org/jira/browse/FLINK-6231
Project: Flink
Issue Type:
hongyuhong created FLINK-6232:
-
Summary: Support proctime inner equi-join between two streams in
the SQL API
Key: FLINK-6232
URL: https://issues.apache.org/jira/browse/FLINK-6232
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950568#comment-15950568
]
sunjincheng edited comment on FLINK-5227 at 3/31/17 10:06 AM:
--
[~fhueske] So,
[
https://issues.apache.org/jira/browse/FLINK-6219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950388#comment-15950388
]
Xiaogang Shi commented on FLINK-6219:
-
I prefer to use sorted states (e.g., {{SortedMapState}}) rather
Github user rtudoran commented on the issue:
https://github.com/apache/flink/pull/3641
@fhueske
I just thought of an example. Assume you have 2 events coming at
consecutime processintimes
Ev1,1
Ev2, 2
When ev1 arrives you accumulate it and register the timer at
Github user haohui commented on the issue:
https://github.com/apache/flink/pull/3655
Looks good to me overall. Instead of changing in the normal code path,
maybe it is a little bit less intrusive to use Mockito to change the field? For
example:
```
JobArchiveFetcherTask
[
https://issues.apache.org/jira/browse/FLINK-6175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950425#comment-15950425
]
ASF GitHub Bot commented on FLINK-6175:
---
Github user haohui commented on the issue:
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/3611
I think we can merge this
---
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
[
https://issues.apache.org/jira/browse/FLINK-6183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15951072#comment-15951072
]
ASF GitHub Bot commented on FLINK-6183:
---
Github user rmetzger commented on the issue:
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/3610
Not being an expert in this area of the code, I think this change is good
to merge :)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
[
https://issues.apache.org/jira/browse/FLINK-5005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15951071#comment-15951071
]
Greg Hogan commented on FLINK-5005:
---
[~j...@goyeau.com] [~michael.meyers] [~jenskat] are you looking for
[
https://issues.apache.org/jira/browse/FLINK-6183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15951074#comment-15951074
]
ASF GitHub Bot commented on FLINK-6183:
---
Github user rmetzger commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-6220:
--
Component/s: State Backends, Checkpointing
> Fine-grained copy-on-write for
[
https://issues.apache.org/jira/browse/FLINK-6214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-6214:
--
Component/s: DataStream API
> WindowAssigners do not allow negative offsets
>
GitHub user patricklucas opened a pull request:
https://github.com/apache/flink/pull/3658
[hotfix] [docs] Remove empty Docker docs page
This will be re-added when we have a coherent plan for Docker support
and after the official Docker images are available.
You can merge this
[
https://issues.apache.org/jira/browse/FLINK-6172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-6172:
--
Component/s: JobManager
> Potentially unclosed RandomAccessFile in
[
https://issues.apache.org/jira/browse/FLINK-5913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-5913.
-
Resolution: Implemented
Implemented in a48357db8c4187fd08f3b17880899ebbcb5d3b5e
> Example drivers
>
[
https://issues.apache.org/jira/browse/FLINK-3695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15951253#comment-15951253
]
ASF GitHub Bot commented on FLINK-3695:
---
Github user greghogan closed the pull request at:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3641
Thanks for the update @rtudoran.
I will clean that up and merge this PR.
Thanks, Fabian
---
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-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15951254#comment-15951254
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-2814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-2814.
-
Resolution: Fixed
Fixed in 43158a86d9c3f3d6e3d612c8871625e9d22e7ba3
> DeltaIteration: DualInputPlanNode
[
https://issues.apache.org/jira/browse/FLINK-2814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-2814:
--
Fix Version/s: 1.3.0
> DeltaIteration: DualInputPlanNode cannot be cast to SingleInputPlanNode
>
[
https://issues.apache.org/jira/browse/FLINK-2814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15951243#comment-15951243
]
ASF GitHub Bot commented on FLINK-2814:
---
Github user greghogan commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-3695.
-
Resolution: Implemented
Implemented in 963f46e7179db034fd1d69f4af58eac87409
> ValueArray types
>
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2029
@rehevkor5 thanks for this identifying bug and submitting this PR. My
apologies for taking so long to look into this issue. With #3563 accepted I
think you can go ahead and close this PR.
---
If
[
https://issues.apache.org/jira/browse/FLINK-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15951280#comment-15951280
]
Haohui Mai commented on FLINK-5998:
---
All failed tests passed locally. :-|
[~rmetzger], is it possible
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3626
---
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-2814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15951233#comment-15951233
]
ASF GitHub Bot commented on FLINK-2814:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-5913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15951235#comment-15951235
]
ASF GitHub Bot commented on FLINK-5913:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3563
---
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
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3635
---
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-5912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15951234#comment-15951234
]
ASF GitHub Bot commented on FLINK-5912:
---
Github user asfgit closed the pull request at:
Github user greghogan closed the pull request at:
https://github.com/apache/flink/pull/3382
---
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-5912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-5912.
-
Resolution: Implemented
Implemented in ded25be4d8fc51f2a58cbd3264daffe48dca6b04
> Inputs for CSV and
[
https://issues.apache.org/jira/browse/FLINK-6205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950661#comment-15950661
]
ASF GitHub Bot commented on FLINK-6205:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-5915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950702#comment-15950702
]
ASF GitHub Bot commented on FLINK-5915:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3647
Thanks @shaoxuan-wang, I found a way to cast the `Integer` to `Int`. Will
change that and merge the PR.
Thanks, Fabian
---
If your project is set up for it, you can reply to this email and
[
https://issues.apache.org/jira/browse/FLINK-5994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950541#comment-15950541
]
sunjincheng edited comment on FLINK-5994 at 3/31/17 12:00 PM:
--
Hi, [~twalthr]
[
https://issues.apache.org/jira/browse/FLINK-5994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950541#comment-15950541
]
sunjincheng edited comment on FLINK-5994 at 3/31/17 12:03 PM:
--
Hi, [~twalthr]
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3644
---
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-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950672#comment-15950672
]
shijinkui commented on FLINK-6233:
--
Is this the sub-issue of FLINK-4557?
> Support rowtime inner
[
https://issues.apache.org/jira/browse/FLINK-6069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas closed FLINK-6069.
-
Resolution: Fixed
Merged with 48890285d4b1c285bebb971ae0dbfc310c6fcc0e
> Add documentation CEP -
[
https://issues.apache.org/jira/browse/FLINK-6205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas closed FLINK-6205.
-
Resolution: Fixed
Merged with 48890285d4b1c285bebb971ae0dbfc310c6fcc0e
> Put late elements in
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950712#comment-15950712
]
Fabian Hueske commented on FLINK-6228:
--
Hi, [~sunjincheng121],
Thanks for opening the JIRA and
[
https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-6233:
-
Description:
The goal of this issue is to add support for inner equi-join on proc time
streams
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950771#comment-15950771
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user rtudoran commented on the issue:
Github user rtudoran commented on the issue:
https://github.com/apache/flink/pull/3641
@fhueske Great - i was just randomly searching for cases to be valid in
single unit runs/cluster run/ide run ...which apparently have widely different
latencies :))
---
If your project is set up
[
https://issues.apache.org/jira/browse/FLINK-5994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950541#comment-15950541
]
sunjincheng edited comment on FLINK-5994 at 3/31/17 12:21 PM:
--
Hi, [~twalthr]
[
https://issues.apache.org/jira/browse/FLINK-5994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950541#comment-15950541
]
sunjincheng edited comment on FLINK-5994 at 3/31/17 12:22 PM:
--
Hi, [~twalthr]
[
https://issues.apache.org/jira/browse/FLINK-5755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950744#comment-15950744
]
Tzu-Li (Gordon) Tai commented on FLINK-5755:
Hi [~fddias],
are you still having problems with
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950743#comment-15950743
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user rtudoran commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-5755.
--
Resolution: Not A Problem
> Flink with Kafka connection
> ---
>
1 - 100 of 166 matches
Mail list logo
