[
https://issues.apache.org/jira/browse/FLINK-6581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012357#comment-16012357
]
ASF GitHub Bot commented on FLINK-6581:
---
Github user tillrohrmann commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6600:
---
Description:
Currently, only the key serializer is included in what's written for a
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/3903
@johnboy14 I can merge this PR also into the `1.2` branch. This means that
it will be included in the next bug fix release `1.2.2`. How quickly it will be
included in EMR depends a little bit
[
https://issues.apache.org/jira/browse/FLINK-6587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012507#comment-16012507
]
ASF GitHub Bot commented on FLINK-6587:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/3923
@shaoxuan-wang the function catalog is case insensitive anyway. With this
PR we have almost no keywords anymore. So a "sum" could be overwritten by "SUM".
---
If your project is set up for it, you
[
https://issues.apache.org/jira/browse/FLINK-6543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther reassigned FLINK-6543:
---
Assignee: Timo Walther
> Deprecate toDataStream
> --
>
>
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3924
+1 to merge
---
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
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/3920
@sunjincheng121 thanks for this PR. @fhueske what do you think of enabling
checkstyle's `includeTestSourceDirectory`?
---
If your project is set up for it, you can reply to this email and have
[
https://issues.apache.org/jira/browse/FLINK-6598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012482#comment-16012482
]
sunjincheng commented on FLINK-6598:
Do we need support in `DISTINCT` in `SELECT Clause`, e.g.:
Timo Walther created FLINK-6601:
---
Summary: Use time indicators in
DataStreamLogicalWindowAggregateRule
Key: FLINK-6601
URL: https://issues.apache.org/jira/browse/FLINK-6601
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-6381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-6381:
Summary: Unnecessary synchronized object in BucketingSink (was:
Unnecessary synchronizing object
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3920
@greghogan that would make sense to me. Not sure why we excluded the tests
in the first place.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
Github user huafengw commented on the issue:
https://github.com/apache/flink/pull/3898
Can anyone take a look at this one?
---
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
[
https://issues.apache.org/jira/browse/FLINK-6581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012410#comment-16012410
]
ASF GitHub Bot commented on FLINK-6581:
---
Github user tillrohrmann commented on the issue:
Github user johnboy14 commented on the issue:
https://github.com/apache/flink/pull/3903
At this time I am looking a workaround in the meantime. Is there anyway to
override the log4j.properties file for each application deployed to EMR?
---
If your project is set up for it, you can
[
https://issues.apache.org/jira/browse/FLINK-6581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012445#comment-16012445
]
ASF GitHub Bot commented on FLINK-6581:
---
Github user johnboy14 commented on the issue:
Timo Walther created FLINK-6602:
---
Summary: Table source with defined time attributes allows empty
string
Key: FLINK-6602
URL: https://issues.apache.org/jira/browse/FLINK-6602
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-6587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012582#comment-16012582
]
ASF GitHub Bot commented on FLINK-6587:
---
Github user fhueske commented on the issue:
Tzu-Li (Gordon) Tai created FLINK-6600:
--
Summary: Add key serializer's config snapshot to
KeyedBackendSerializationProxy
Key: FLINK-6600
URL: https://issues.apache.org/jira/browse/FLINK-6600
[
https://issues.apache.org/jira/browse/FLINK-6600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6600:
---
Fix Version/s: 1.4.0
1.3.0
> Add key serializer's config snapshot
[
https://issues.apache.org/jira/browse/FLINK-6492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012399#comment-16012399
]
ASF GitHub Bot commented on FLINK-6492:
---
Github user huafengw commented on the issue:
Github user shaoxuan-wang commented on the issue:
https://github.com/apache/flink/pull/3923
@twalthr, it seems we have reserved the keyword with the case insensitive.
For instance, we cannot use "Sum" and "SUM", as "sum" is reserved. Did we
intent to filter the keyword like this?
[
https://issues.apache.org/jira/browse/FLINK-6583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012383#comment-16012383
]
ASF GitHub Bot commented on FLINK-6583:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012386#comment-16012386
]
ASF GitHub Bot commented on FLINK-6583:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012389#comment-16012389
]
ASF GitHub Bot commented on FLINK-6583:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012391#comment-16012391
]
ASF GitHub Bot commented on FLINK-6583:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3919#discussion_r116740828
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/triggers/CountTriggerWithCleanupState.scala
---
@@ -0,0 +1,146 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3919#discussion_r116741416
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harness/CountTriggerWithCleanupStateHarnessTest.scala
---
@@ -0,0
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3919#discussion_r116727812
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamGroupWindowAggregate.scala
---
@@ -296,6 +322,8
[
https://issues.apache.org/jira/browse/FLINK-6583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012384#comment-16012384
]
ASF GitHub Bot commented on FLINK-6583:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3919#discussion_r116740271
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/triggers/CountTriggerWithCleanupState.scala
---
@@ -0,0 +1,146 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3919#discussion_r116733901
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/triggers/CountTriggerWithCleanupState.scala
---
@@ -0,0 +1,146 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3919#discussion_r116729795
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/triggers/CountTriggerWithCleanupState.scala
---
@@ -0,0 +1,146 @@
[
https://issues.apache.org/jira/browse/FLINK-6583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012390#comment-16012390
]
ASF GitHub Bot commented on FLINK-6583:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3919#discussion_r116727685
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamGroupWindowAggregate.scala
---
@@ -245,6 +266,8
[
https://issues.apache.org/jira/browse/FLINK-6583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012387#comment-16012387
]
ASF GitHub Bot commented on FLINK-6583:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012385#comment-16012385
]
ASF GitHub Bot commented on FLINK-6583:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012393#comment-16012393
]
ASF GitHub Bot commented on FLINK-6583:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012392#comment-16012392
]
ASF GitHub Bot commented on FLINK-6583:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012380#comment-16012380
]
ASF GitHub Bot commented on FLINK-2055:
---
Github user fhueske commented on the issue:
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3919#discussion_r116740788
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/triggers/CountTriggerWithCleanupState.scala
---
@@ -0,0 +1,146 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3919#discussion_r116738258
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harness/CountTriggerWithCleanupStateHarnessTest.scala
---
@@ -0,0
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3919#discussion_r116739074
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harness/CountTriggerWithCleanupStateHarnessTest.scala
---
@@ -0,0
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2332
Hi @nragon, the PR seems to be stale.
Are you interested in contributing a streaming HBase sink?
---
If your project is set up for it, you can reply to this email and have your
reply appear on
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3919#discussion_r116740173
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harness/CountTriggerWithCleanupStateHarnessTest.scala
---
@@ -0,0
[
https://issues.apache.org/jira/browse/FLINK-6583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012382#comment-16012382
]
ASF GitHub Bot commented on FLINK-6583:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3919#discussion_r116739961
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harness/CountTriggerWithCleanupStateHarnessTest.scala
---
@@ -0,0
[
https://issues.apache.org/jira/browse/FLINK-6583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012388#comment-16012388
]
ASF GitHub Bot commented on FLINK-6583:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012472#comment-16012472
]
sunjincheng edited comment on FLINK-6598 at 5/16/17 2:28 PM:
-
Yes, DISTINCT
[
https://issues.apache.org/jira/browse/FLINK-6598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012537#comment-16012537
]
Fabian Hueske commented on FLINK-6598:
--
I just checked and FLINK-6428 is already supported.
During
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3923
The PR looks good to me. +1 from my side.
---
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
[
https://issues.apache.org/jira/browse/FLINK-6581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012373#comment-16012373
]
ASF GitHub Bot commented on FLINK-6581:
---
Github user johnboy14 commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/3903
This is not decided yet. Usually we do it depending on the urgency of the
fixes and the time since the last bug fix release. Currently, we're working on
the `1.3` release which requires most of
[
https://issues.apache.org/jira/browse/FLINK-6598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012472#comment-16012472
]
sunjincheng edited comment on FLINK-6598 at 5/16/17 2:26 PM:
-
Yes, DISTINCT
[
https://issues.apache.org/jira/browse/FLINK-6598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012472#comment-16012472
]
sunjincheng commented on FLINK-6598:
Yes, DISTINCT works by `group by ` + `join`. in DataSet. In this
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/3924
[FLINK-6601] [table] Use time indicators in
DataStreamLogicalWindowAggregateRule
See description in FLINK-6601.
You can merge this pull request into a Git repository by running:
$ git pull
[
https://issues.apache.org/jira/browse/FLINK-6601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012494#comment-16012494
]
ASF GitHub Bot commented on FLINK-6601:
---
GitHub user twalthr opened a pull request:
Greg Hogan created FLINK-6603:
-
Summary: Enable checkstyle on test sources
Key: FLINK-6603
URL: https://issues.apache.org/jira/browse/FLINK-6603
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16013553#comment-16013553
]
ASF GitHub Bot commented on FLINK-2055:
---
Github user ramkrish86 commented on the issue:
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/2332
@delding
Are you still working on this?
@nragon
Let me know how can be of help here? I can work on this PR too since I have
some context on the existing PR though it is stale.
---
Github user WangTaoTheTonic commented on the issue:
https://github.com/apache/flink/pull/3525
Thanks for your fix, i'll check in a day or two.
---
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-6020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16013566#comment-16013566
]
ASF GitHub Bot commented on FLINK-6020:
---
Github user WangTaoTheTonic commented on the issue:
Tzu-Li (Gordon) Tai created FLINK-6607:
--
Summary: Confusing statement in docs that Kafka 010 consumer does
not require timestamp extractors
Key: FLINK-6607
URL:
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16013573#comment-16013573
]
ASF GitHub Bot commented on FLINK-2055:
---
Github user delding commented on the issue:
Github user delding commented on the issue:
https://github.com/apache/flink/pull/2332
Hi @ramkrish86 , sorry I don't have bandwidth working on it..
---
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
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/3746
@haohui I can not guarantee this, but I can try revisiting this for a
workaround after I've done some testing on the current RC1.
---
If your project is set up for it, you can reply to this email
[
https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16013493#comment-16013493
]
ASF GitHub Bot commented on FLINK-4022:
---
Github user tzulitai commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3917
+1 to this from my side. Makes logs in cases of TaskManager easier to
search through.
---
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-6600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012769#comment-16012769
]
ASF GitHub Bot commented on FLINK-6600:
---
GitHub user tzulitai opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-6440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012731#comment-16012731
]
ASF GitHub Bot commented on FLINK-6440:
---
Github user StephanEwen commented on the issue:
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/3925
[FLINK-6600] Add key serializer config snapshot to keyed backend checkpoints
This PR adds the config snapshot of the key serializer of keyed
backends to its checkpoints. This allows the
[
https://issues.apache.org/jira/browse/FLINK-6559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012733#comment-16012733
]
Stephan Ewen commented on FLINK-6559:
-
Sounds like a good approach.
> Rename 'slaves' to 'workers'
>
Github user johnboy14 commented on the issue:
https://github.com/apache/flink/pull/3903
When's the next bug fix release scheduled for @tillrohrmann ?
---
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
[
https://issues.apache.org/jira/browse/FLINK-6587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012438#comment-16012438
]
ASF GitHub Bot commented on FLINK-6587:
---
Github user shaoxuan-wang commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012472#comment-16012472
]
sunjincheng edited comment on FLINK-6598 at 5/16/17 2:29 PM:
-
Yes, DISTINCT
[
https://issues.apache.org/jira/browse/FLINK-6581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16013217#comment-16013217
]
ASF GitHub Bot commented on FLINK-6581:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3903
---
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-6581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-6581.
Resolution: Fixed
Fix Version/s: 1.4.0
1.2.2
1.3.0
[
https://issues.apache.org/jira/browse/FLINK-6598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012159#comment-16012159
]
Fabian Hueske commented on FLINK-6598:
--
Why should {{agg.getAggCallList.isEmpty}} not be allowed? I
GitHub user sunjincheng121 opened a pull request:
https://github.com/apache/flink/pull/3922
[FLINK-6598][table] Fix `DataStreamGroupAggregateRule` and `DataStreaâ¦
The changes of this PR. is modify the `matches` method of
`DataStreamGroupAggregateRule` and
[
https://issues.apache.org/jira/browse/FLINK-6598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012162#comment-16012162
]
ASF GitHub Bot commented on FLINK-6598:
---
GitHub user sunjincheng121 opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-6598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6598:
---
Summary: Fix `DataStreamGroupAggregateRule`and
`DataStreamGroupWindowAggregateRule` matches error.
[
https://issues.apache.org/jira/browse/FLINK-6598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6598:
---
Description:
Changes as follows:
1. Add {{!agg.getAggCallList.isEmpty}} condition for
Github user tony810430 commented on the issue:
https://github.com/apache/flink/pull/3633
Hi @StephanEwen
Have you been reviewing this PR? If not, I would like to rebase it and fix
those conflicts. What do you think?
---
If your project is set up for it, you can reply to
[
https://issues.apache.org/jira/browse/FLINK-5982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16011984#comment-16011984
]
ASF GitHub Bot commented on FLINK-5982:
---
Github user tony810430 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16011988#comment-16011988
]
Julien Preisner commented on FLINK-6062:
Yes, it is the solution that I designed to do my use
[
https://issues.apache.org/jira/browse/FLINK-6062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Julien Preisner closed FLINK-6062.
--
Resolution: Done
I wrote a shell script that restart the job. So my use case is done.
>
[
https://issues.apache.org/jira/browse/FLINK-6593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-6593:
--
Description:
the ProctimeAttribute or RowtimeAttribute should not be take into codegenerator
was:
[
https://issues.apache.org/jira/browse/FLINK-6593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-6593:
--
Summary: Fix Bug in ProctimeAttribute or RowtimeAttribute with
CodeGenerator (was: Fix Bug in
GitHub user Xpray opened a pull request:
https://github.com/apache/flink/pull/3918
[FLINK-6593] Fix Bug in ProctimeAttribute or RowtimeAttribute with Coâ¦
â¦deGenerator
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following
[
https://issues.apache.org/jira/browse/FLINK-6593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012034#comment-16012034
]
ASF GitHub Bot commented on FLINK-6593:
---
GitHub user Xpray opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-6598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012206#comment-16012206
]
sunjincheng commented on FLINK-6598:
Hi, [~fhueske], I think:
1. for `DataStreamGroupAggregate`, if we
[
https://issues.apache.org/jira/browse/FLINK-6552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012208#comment-16012208
]
ASF GitHub Bot commented on FLINK-6552:
---
Github user aljoscha commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3885
Thanks @tedyu and @zentol! I pushed another commit with these minor fixes.
---
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
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/3923
[FLINK-6587] [table] Simplification and bug fixing of the ExpressionParser
This PR fixes several issues related to the ExpressionParser and the
resolution of expression produced by it. Only special
[
https://issues.apache.org/jira/browse/FLINK-6587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16012241#comment-16012241
]
ASF GitHub Bot commented on FLINK-6587:
---
GitHub user twalthr opened a pull request:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/3918
Merging 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 wishes so, or
Github user zhangminglei closed the pull request at:
https://github.com/apache/flink/pull/3820
---
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 zhangminglei commented on the issue:
https://github.com/apache/flink/pull/3820
@kl0u Okay. I will do this soon. Thanks again.
---
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
[
https://issues.apache.org/jira/browse/FLINK-6381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang resolved FLINK-6381.
-
Resolution: Fixed
Fix Version/s: 1.3.0
> Unnecessary synchronizing object in BucketingSink
1 - 100 of 246 matches
Mail list logo
