[
https://issues.apache.org/jira/browse/FLINK-7798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16199876#comment-16199876
]
Fabian Hueske commented on FLINK-7798:
--
And we need to adjust the Table API docs, i.e
[
https://issues.apache.org/jira/browse/FLINK-7711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16199865#comment-16199865
]
Tzu-Li (Gordon) Tai commented on FLINK-7711:
Hi [~till.rohrmann], my work on t
[
https://issues.apache.org/jira/browse/FLINK-7714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16199863#comment-16199863
]
Tzu-Li (Gordon) Tai commented on FLINK-7714:
Hi [~till.rohrmann], my work on t
[
https://issues.apache.org/jira/browse/FLINK-7798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16199854#comment-16199854
]
Fabian Hueske commented on FLINK-7798:
--
Thanks for looking into this [~xccui].
Yes, I
[
https://issues.apache.org/jira/browse/FLINK-7798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16199824#comment-16199824
]
Xingcan Cui commented on FLINK-7798:
Hi [~fhueske], as you said, most of the related c
godfrey he created FLINK-7802:
-
Summary: Bug in PushProjectIntoTableSourceScanRule when empty
field collection was pushed into TableSource
Key: FLINK-7802
URL: https://issues.apache.org/jira/browse/FLINK-7802
[
https://issues.apache.org/jira/browse/FLINK-7661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16199749#comment-16199749
]
ASF GitHub Bot commented on FLINK-7661:
---
Github user zhijiangW commented on the issu
Github user zhijiangW commented on the issue:
https://github.com/apache/flink/pull/4698
@zentol , I have rebased the latest master codes and solved the conflicts.
---
Github user tony810430 commented on the issue:
https://github.com/apache/flink/pull/3478
Hi @ramkrish86
Are you still working on this PR?
---
[
https://issues.apache.org/jira/browse/FLINK-7423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16199716#comment-16199716
]
ASF GitHub Bot commented on FLINK-7423:
---
Github user XuPingyong closed the pull requ
[
https://issues.apache.org/jira/browse/FLINK-7798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingcan Cui reassigned FLINK-7798:
--
Assignee: Xingcan Cui
> Add support for windowed joins to Table API
> -
Github user XuPingyong closed the pull request at:
https://github.com/apache/flink/pull/4525
---
[
https://issues.apache.org/jira/browse/FLINK-7394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16199702#comment-16199702
]
zhijiang commented on FLINK-7394:
-
[~Zentol], thank you for merging and let me know the ru
[
https://issues.apache.org/jira/browse/FLINK-7762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hai Zhou UTC+8 reassigned FLINK-7762:
-
Assignee: Hai Zhou UTC+8
> Make WikipediaEditsSourceTest a proper test
>
[
https://issues.apache.org/jira/browse/FLINK-7669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16199687#comment-16199687
]
Raymond Tay commented on FLINK-7669:
I tried that suggestion but it didn't work and he
[
https://issues.apache.org/jira/browse/FLINK-5486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16199652#comment-16199652
]
ASF GitHub Bot commented on FLINK-5486:
---
Github user zhangminglei commented on the i
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/4356
OKay. Thanks , Ted. Will retest again soon enough./
---
[
https://issues.apache.org/jira/browse/FLINK-4808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16199614#comment-16199614
]
Jing Fan commented on FLINK-4808:
-
[~StephanEwen] Do we have any update on this jira?
>
[
https://issues.apache.org/jira/browse/FLINK-6697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16199524#comment-16199524
]
ASF GitHub Bot commented on FLINK-6697:
---
GitHub user fhueske opened a pull request:
GitHub user fhueske opened a pull request:
https://github.com/apache/flink/pull/4796
[FLINK-6697] [table] Add support for window.rowtime to batch Table API.
## What is the purpose of the change
This PR adds support for the `windowAlias.rowtime` property to the batch
Table A
[
https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16199500#comment-16199500
]
ASF GitHub Bot commented on FLINK-7657:
---
Github user kmurra commented on the issue:
Github user kmurra commented on the issue:
https://github.com/apache/flink/pull/4746
The biggest change here is in the test cases -- I generalized the test
table source to have some basic filtering logic and allow for generic datasets.
I moved the Literal build logic to the
R
Till Rohrmann created FLINK-7801:
Summary: Integrate list command into REST client
Key: FLINK-7801
URL: https://issues.apache.org/jira/browse/FLINK-7801
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-6569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai closed FLINK-6569.
-
Resolution: Invalid
Fix Version/s: (was: 1.4.0)
> flink-table KafkaJsonTableSource example does
[
https://issues.apache.org/jira/browse/FLINK-7793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16199448#comment-16199448
]
ASF GitHub Bot commented on FLINK-7793:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/4795
[FLINK-7793] [flip6] Defer slot release to ResourceManager
## What is the purpose of the change
This commit changes the SlotManager behaviour such that upon a TaskManager
timeout
t
Fabian Hueske created FLINK-7800:
Summary: Enable window joins without equi-join predicates
Key: FLINK-7800
URL: https://issues.apache.org/jira/browse/FLINK-7800
Project: Flink
Issue Type: Su
Fabian Hueske created FLINK-7799:
Summary: Improve performance of windowed joins
Key: FLINK-7799
URL: https://issues.apache.org/jira/browse/FLINK-7799
Project: Flink
Issue Type: Sub-task
Fabian Hueske created FLINK-7798:
Summary: Add support for windowed joins to Table API
Key: FLINK-7798
URL: https://issues.apache.org/jira/browse/FLINK-7798
Project: Flink
Issue Type: Sub-tas
[
https://issues.apache.org/jira/browse/FLINK-5725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-5725:
-
Summary: Support windowed JOIN between two streaming tables (was: Support
windowed JOIN between t
Fabian Hueske created FLINK-7797:
Summary: Add support for windowed outer joins for streaming tables
Key: FLINK-7797
URL: https://issues.apache.org/jira/browse/FLINK-7797
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-5725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-5725:
-
Summary: Support windowed JOIN between two streams in the SQL API (was:
Support JOIN between two
[
https://issues.apache.org/jira/browse/FLINK-7410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-7410.
Resolution: Implemented
Fix Version/s: 1.4.0
Implemented for 1.4.0 with 427dfe42e2bea891b40e6
[
https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-7491.
Resolution: Fixed
Fix Version/s: 1.4.0
Implemented for 1.4.0 with dccdba199a8fbb8b5186f095241
[
https://issues.apache.org/jira/browse/FLINK-7776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-7776.
Resolution: Fixed
Fix Version/s: 1.4.0
Implemented for 1.4.0 with 4047be49e10cacc5e4ce932a0b8
[
https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-6233.
Resolution: Fixed
Fix Version/s: 1.4.0
Implemented for 1.4.0 with 655d8b16193ac7131fa1f58fb4b
[
https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16199358#comment-16199358
]
ASF GitHub Bot commented on FLINK-6233:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-7776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16199359#comment-16199359
]
ASF GitHub Bot commented on FLINK-7776:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16199360#comment-16199360
]
ASF GitHub Bot commented on FLINK-7491:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-7410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16199361#comment-16199361
]
ASF GitHub Bot commented on FLINK-7410:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4585
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4624
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4785
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4625
---
[
https://issues.apache.org/jira/browse/FLINK-7704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-7704.
--
Resolution: Done
Done via 9829ca00dff201879724847b498fe0432219cb53
> Port JobPlanHandler to new
[
https://issues.apache.org/jira/browse/FLINK-7704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16199343#comment-16199343
]
ASF GitHub Bot commented on FLINK-7704:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4768
---
Ted Yu created FLINK-7796:
-
Summary: RocksDBKeyedStateBackend#RocksDBFullSnapshotOperation
should close snapshotCloseableRegistry
Key: FLINK-7796
URL: https://issues.apache.org/jira/browse/FLINK-7796
Project:
[
https://issues.apache.org/jira/browse/FLINK-7750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16199262#comment-16199262
]
Razvan commented on FLINK-7750:
---
[~aljoscha] Many thanks for clarifying this. Is there a way
[
https://issues.apache.org/jira/browse/FLINK-5486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16199255#comment-16199255
]
ASF GitHub Bot commented on FLINK-5486:
---
Github user tedyu commented on the issue:
Github user tedyu commented on the issue:
https://github.com/apache/flink/pull/4356
retest this please
---
Ted Yu created FLINK-7795:
-
Summary: Utilize error-prone to discover common coding mistakes
Key: FLINK-7795
URL: https://issues.apache.org/jira/browse/FLINK-7795
Project: Flink
Issue Type: Improvemen
GitHub user yew1eb opened a pull request:
https://github.com/apache/flink/pull/4794
[build][minor] Add missing licenses
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/yew1eb/flink add_missing_licenses
Alternatively you can revi
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/4790
cc @aljoscha and @pnowojski
I think there is some work for Flink 1.4 to make the Kafka 0.10 sink a
regular sink function, so that the code that constructs the sink transformation
is not need
[
https://issues.apache.org/jira/browse/FLINK-7764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16199129#comment-16199129
]
ASF GitHub Bot commented on FLINK-7764:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16199094#comment-16199094
]
ASF GitHub Bot commented on FLINK-6225:
---
Github user PangZhi commented on the issue:
Github user PangZhi commented on the issue:
https://github.com/apache/flink/pull/3748
@zentol Do you mind taking another look.
---
[
https://issues.apache.org/jira/browse/FLINK-7737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16199070#comment-16199070
]
Ryan Hobbs commented on FLINK-7737:
---
In the case of hflush() it is simply flushing the b
[
https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16198954#comment-16198954
]
ASF GitHub Bot commented on FLINK-6233:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16198952#comment-16198952
]
ASF GitHub Bot commented on FLINK-7776:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/4625
Merging
---
[
https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16198950#comment-16198950
]
ASF GitHub Bot commented on FLINK-7491:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16198948#comment-16198948
]
ASF GitHub Bot commented on FLINK-7410:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/4785
Merging
---
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/4585
Merging
---
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/4624
Merging
---
Paul Wu created FLINK-7794:
--
Summary: Link Broken in --
https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/connectors/index.html
Key: FLINK-7794
URL: https://issues.apache.org/jira/browse/FLINK-7794
[
https://issues.apache.org/jira/browse/FLINK-7737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16198898#comment-16198898
]
Vijay Srinivasaraghavan commented on FLINK-7737:
I believe hflush() routes
Till Rohrmann created FLINK-7793:
Summary: SlotManager releases idle TaskManager in standalone mode
Key: FLINK-7793
URL: https://issues.apache.org/jira/browse/FLINK-7793
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-7709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16198841#comment-16198841
]
ASF GitHub Bot commented on FLINK-7709:
---
Github user tillrohrmann closed the pull re
Github user tillrohrmann closed the pull request at:
https://github.com/apache/flink/pull/4763
---
[
https://issues.apache.org/jira/browse/FLINK-7709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-7709.
--
Resolution: Done
Added via 0a286d0ff98afa68034daff4634f526eaaf97897
> Port CheckpointStatsDetai
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/4793
[FLINK-7653] Properly implement Dispatcher#requestClusterOverview
## What is the purpose of the change
This commit implements the ClusterOverview generation on the Dispatcher. In
or
[
https://issues.apache.org/jira/browse/FLINK-7653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16198819#comment-16198819
]
ASF GitHub Bot commented on FLINK-7653:
---
GitHub user tillrohrmann opened a pull requ
[
https://issues.apache.org/jira/browse/FLINK-7652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16198803#comment-16198803
]
ASF GitHub Bot commented on FLINK-7652:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/4734
I agree with @zentol. Moreover, I would like to change
`MultipleJobsDetails` to not split the job details into running and finished.
Just a collection of `JobDetails`.
---
[
https://issues.apache.org/jira/browse/FLINK-7790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16198797#comment-16198797
]
ASF GitHub Bot commented on FLINK-7790:
---
Github user zentol closed the pull request
Github user zentol closed the pull request at:
https://github.com/apache/flink/pull/4788
---
[
https://issues.apache.org/jira/browse/FLINK-7790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-7790.
---
Resolution: Fixed
1.4: 6b3fdc288587fe0982f2ffa2e476e0fd3cd61188
> Unresolved query parameters
[
https://issues.apache.org/jira/browse/FLINK-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16198784#comment-16198784
]
ASF GitHub Bot commented on FLINK-7378:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-7394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16198781#comment-16198781
]
Chesnay Schepler commented on FLINK-7394:
-
1.4: 1f4bdf44b6fa4fd071d9a45aca7dd6b7a4
[
https://issues.apache.org/jira/browse/FLINK-7699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16198785#comment-16198785
]
ASF GitHub Bot commented on FLINK-7699:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-7394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16198787#comment-16198787
]
Chesnay Schepler commented on FLINK-7394:
-
[~zjwang] Please leave it to the commit
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4485
---
[
https://issues.apache.org/jira/browse/FLINK-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16198780#comment-16198780
]
Chesnay Schepler commented on FLINK-7378:
-
1.4: 450d9df9e96718575ab2979f256f99be4d
[
https://issues.apache.org/jira/browse/FLINK-7394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16198783#comment-16198783
]
ASF GitHub Bot commented on FLINK-7394:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4735
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4499
---
[
https://issues.apache.org/jira/browse/FLINK-7699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reopened FLINK-7699:
-
> Define the BufferListener interface to replace EventListener in BufferProvider
> ---
[
https://issues.apache.org/jira/browse/FLINK-7699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-7699.
---
Resolution: Fixed
1.4: 331b7778e4533cd140ffe6e3edaa79994122a592
> Define the BufferListener i
[
https://issues.apache.org/jira/browse/FLINK-7792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16198747#comment-16198747
]
ASF GitHub Bot commented on FLINK-7792:
---
GitHub user zentol opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/4792
[FLINK-7792] [tests][client] Only suppress stdout for CLI tests
## What is the purpose of the change
This PR modifies the CliFrontendTestUtils to only suppress stdout.
Previously we were als
[
https://issues.apache.org/jira/browse/FLINK-7699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang closed FLINK-7699.
---
Resolution: Fixed
> Define the BufferListener interface to replace EventListener in BufferProvider
> -
[
https://issues.apache.org/jira/browse/FLINK-7792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-7792:
Priority: Trivial (was: Major)
> CliFrontend tests suppress logging
> -
Chesnay Schepler created FLINK-7792:
---
Summary: CliFrontend tests suppress logging
Key: FLINK-7792
URL: https://issues.apache.org/jira/browse/FLINK-7792
Project: Flink
Issue Type: Bug
GitHub user GJL opened a pull request:
https://github.com/apache/flink/pull/4791
[hotfix] [Javadoc] Fix typos
Fix typos in Javadoc for classes:
- `org.apache.flink.api.java.typeutils.InputTypeConfigurable`
- `org.apache.flink.core.fs.FileSystem`
You can merge this pull
[
https://issues.apache.org/jira/browse/FLINK-7394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang closed FLINK-7394.
---
Resolution: Fixed
> Manage exclusive buffers in RemoteInputChannel
> -
[
https://issues.apache.org/jira/browse/FLINK-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang closed FLINK-7378.
---
Resolution: Fixed
> Create a fix size (non rebalancing) buffer pool type for the floating buffers
> --
[
https://issues.apache.org/jira/browse/FLINK-7704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16198732#comment-16198732
]
ASF GitHub Bot commented on FLINK-7704:
---
Github user yew1eb commented on the issue:
Github user yew1eb commented on the issue:
https://github.com/apache/flink/pull/4768
CC @tillrohrmann
---
1 - 100 of 236 matches
Mail list logo