Dian Fu created FLINK-8227:
--
Summary: Optimize the performance of SharedBufferSerializer
Key: FLINK-8227
URL: https://issues.apache.org/jira/browse/FLINK-8227
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-8226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16284560#comment-16284560
]
Dian Fu commented on FLINK-8226:
It will cause exceptions such as when serializing the NFA.
{code}
Caused
[
https://issues.apache.org/jira/browse/FLINK-8227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu resolved FLINK-8227.
Resolution: Fixed
> Optimize the performance of SharedBufferSerializer
>
[
https://issues.apache.org/jira/browse/FLINK-8227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-8227.
--
> Optimize the performance of SharedBufferSerializer
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-6935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16555201#comment-16555201
]
Dian Fu commented on FLINK-6935:
The community is focusing on modules such as runtime, table, etc in the
[
https://issues.apache.org/jira/browse/FLINK-6935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16555332#comment-16555332
]
Dian Fu commented on FLINK-6935:
[~twalthr] Thanks a lot for your reply. I'll update the PR soon and
[
https://issues.apache.org/jira/browse/FLINK-10577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16654571#comment-16654571
]
Dian Fu commented on FLINK-10577:
-
Hi [~simahoa], this is currently by design. For pattern (start
[
https://issues.apache.org/jira/browse/FLINK-8159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16662091#comment-16662091
]
Dian Fu commented on FLINK-8159:
Thanks [~dawidwys] for your feedback.
1. I prefer adding an abstract
[
https://issues.apache.org/jira/browse/FLINK-8159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16656534#comment-16656534
]
Dian Fu commented on FLINK-8159:
Hi [~dawidwys],
For the concern #1 you described:
my init thoughts was
[
https://issues.apache.org/jira/browse/FLINK-8159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16687524#comment-16687524
]
Dian Fu commented on FLINK-8159:
Thanks a lot for the reply and advice. I will submit a PR later today.
[
https://issues.apache.org/jira/browse/FLINK-11243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-11243:
---
Assignee: Dian Fu
> GroupBy udf() can not be select in TableAPI
>
[
https://issues.apache.org/jira/browse/FLINK-11242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16731567#comment-16731567
]
Dian Fu commented on FLINK-11242:
-
Hi [~sunjincheng121] Thanks a lot for reporting this issue. I think
[
https://issues.apache.org/jira/browse/FLINK-11242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-11242:
---
Assignee: Dian Fu
> The predicate `'o_c_id === Null(Types.STRING)` not work in TableAPI
>
[
https://issues.apache.org/jira/browse/FLINK-11246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-11246:
---
Assignee: Dian Fu
> Fix distinct AGG visibility issues
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-10593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16730848#comment-16730848
]
Dian Fu commented on FLINK-10593:
-
Hi [~xueyu] have you started this work? Actually I have already
[
https://issues.apache.org/jira/browse/FLINK-11243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-11243.
---
Resolution: Duplicate
> GroupBy udf() can not be select in TableAPI
>
[
https://issues.apache.org/jira/browse/FLINK-11214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-11214.
---
Resolution: Won't Do
> Support non mergable aggregates for group windows on batch table
>
[
https://issues.apache.org/jira/browse/FLINK-7293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-7293.
--
> Support custom order by in PatternStream
>
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-4641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-4641:
--
Assignee: (was: Dian Fu)
> Support alterations in patterns
>
>
[
https://issues.apache.org/jira/browse/FLINK-11222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16729345#comment-16729345
]
Dian Fu commented on FLINK-11222:
-
This is just a modification of the method signature of a test method
[
https://issues.apache.org/jira/browse/FLINK-11222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16729359#comment-16729359
]
Dian Fu commented on FLINK-11222:
-
The package name will not be changed. Just need to update the
[
https://issues.apache.org/jira/browse/FLINK-11222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-11222:
---
Assignee: Dian Fu
> Change api.scala.DataStream to api.datastream.DataStream in HarnessTestBase
>
[
https://issues.apache.org/jira/browse/FLINK-11067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718401#comment-16718401
]
Dian Fu commented on FLINK-11067:
-
Hi [~twalthr], Thanks a lot for the solution. Agree with you that we
Dian Fu created FLINK-11136:
---
Summary: Fix the logical of merge for DISTINCT aggregates
Key: FLINK-11136
URL: https://issues.apache.org/jira/browse/FLINK-11136
Project: Flink
Issue Type: Test
Dian Fu created FLINK-11176:
---
Summary: Improve the harness tests to use the code-generated
operator
Key: FLINK-11176
URL: https://issues.apache.org/jira/browse/FLINK-11176
Project: Flink
Issue
Dian Fu created FLINK-11214:
---
Summary: Support non mergable aggregates for group windows on
batch table
Key: FLINK-11214
URL: https://issues.apache.org/jira/browse/FLINK-11214
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-11214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-11214:
Description: Currently, it does not support non-mergable aggregates for
group window on batch table. It
[
https://issues.apache.org/jira/browse/FLINK-7209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-7209:
--
Assignee: Dian Fu
> Support DataView in Java and Scala Tuples and case classes or as the
>
Dian Fu created FLINK-11074:
---
Summary: Improve the harness test to make it possible test with
state backend
Key: FLINK-11074
URL: https://issues.apache.org/jira/browse/FLINK-11074
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-8739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16706595#comment-16706595
]
Dian Fu commented on FLINK-8739:
[~walterddr] Thanks a lot. I'll provide a PR ASAP and looking forward to
[
https://issues.apache.org/jira/browse/FLINK-8739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-8739:
--
Assignee: Dian Fu
> Optimize runtime support for distinct filter
>
[
https://issues.apache.org/jira/browse/FLINK-7208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-7208:
--
Assignee: Dian Fu
> Refactor build-in agg(MaxWithRetractAccumulator and
> MinWithRetractAccumulator)
[
https://issues.apache.org/jira/browse/FLINK-8739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704356#comment-16704356
]
Dian Fu commented on FLINK-8739:
Hi [~walterddr], are you still working on this ticket? I'd like to help
[
https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692723#comment-16692723
]
Dian Fu commented on FLINK-7599:
Sure, go ahead.
> Support aggregation functions in the define and
Dian Fu created FLINK-10958:
---
Summary: Add overload support for user defined function
Key: FLINK-10958
URL: https://issues.apache.org/jira/browse/FLINK-10958
Project: Flink
Issue Type: Task
[
https://issues.apache.org/jira/browse/FLINK-10976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-10976:
---
Assignee: Dian Fu (was: Hequn Cheng)
> Add Aggregate operator to Table API
>
[
https://issues.apache.org/jira/browse/FLINK-10972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-10972:
Affects Version/s: (was: 1.7.1)
1.8.0
> Enhancements to Flink Table API
>
[
https://issues.apache.org/jira/browse/FLINK-10974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-10974:
---
Assignee: Dian Fu
> Add FlatMap to TableAPI
> ---
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-10973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-10973:
---
Assignee: Dian Fu
> Add Map operator to Table API
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-10972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-10972:
Affects Version/s: (was: 1.8.0)
> Enhancements to Flink Table API
> ---
>
[
https://issues.apache.org/jira/browse/FLINK-10972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-10972:
Fix Version/s: 1.8.0
> Enhancements to Flink Table API
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-10973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-10973:
Fix Version/s: 1.8.0
> Add Map operator to Table API
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-10973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-10973:
Affects Version/s: (was: 1.8.0)
> Add Map operator to Table API
> -
>
>
Dian Fu created FLINK-11009:
---
Summary: Add support for FILTER clause for non-windowed
aggregation in Table API and SQL
Key: FLINK-11009
URL: https://issues.apache.org/jira/browse/FLINK-11009
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-11009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-11009:
Fix Version/s: 1.8.0
> Add support for FILTER clause for non-windowed aggregation in Table API and
> SQL
[
https://issues.apache.org/jira/browse/FLINK-11009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-11009:
Description:
Currently the following clause is not supported in Flink, the *FILTER* clause
is ignored in
[
https://issues.apache.org/jira/browse/FLINK-6938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-6938:
--
Assignee: Dian Fu (was: Jark Wu)
> IterativeCondition should support RichFunction interface
>
Dian Fu created FLINK-11013:
---
Summary: Fix distinct aggregates for group window in Table API
Key: FLINK-11013
URL: https://issues.apache.org/jira/browse/FLINK-11013
Project: Flink
Issue Type: Bug
Dian Fu created FLINK-11291:
---
Summary: Reorganize the package of flink-cep module
Key: FLINK-11291
URL: https://issues.apache.org/jira/browse/FLINK-11291
Project: Flink
Issue Type: Task
[
https://issues.apache.org/jira/browse/FLINK-11285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-11285.
---
Resolution: Not A Problem
> Change the modifier of CsvTableSourceFactoryBase.createTableSource and
>
[
https://issues.apache.org/jira/browse/FLINK-11285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16737759#comment-16737759
]
Dian Fu commented on FLINK-11285:
-
[~twalthr] Currently the Descriptor related classes are all located
[
https://issues.apache.org/jira/browse/FLINK-11285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16737748#comment-16737748
]
Dian Fu commented on FLINK-11285:
-
[~twalthr] Thanks a lot for the comments. I think you are right. Will
[
https://issues.apache.org/jira/browse/FLINK-11291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-11291:
Description: Currently, there is no package such as
org.apache.flink.cep.api in flink-cep module and the
[
https://issues.apache.org/jira/browse/FLINK-11220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-11220:
---
Assignee: Dian Fu
> Can not Select row time field in JOIN query
>
[
https://issues.apache.org/jira/browse/FLINK-11220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16740028#comment-16740028
]
Dian Fu commented on FLINK-11220:
-
Thanks a lot for the discussion. +1 to the solution of improving
[
https://issues.apache.org/jira/browse/FLINK-11291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738117#comment-16738117
]
Dian Fu commented on FLINK-11291:
-
[~dawidwys] Thanks a lot for the feedback. Yes, it will break the
[
https://issues.apache.org/jira/browse/FLINK-11291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738117#comment-16738117
]
Dian Fu edited comment on FLINK-11291 at 1/9/19 11:18 AM:
--
[~dawidwys] Thanks a
[
https://issues.apache.org/jira/browse/FLINK-11291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-11291.
---
Resolution: Later
> Reorganize the package of flink-cep module
> --
[
https://issues.apache.org/jira/browse/FLINK-11285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738073#comment-16738073
]
Dian Fu commented on FLINK-11285:
-
Yes, it will break the backward compatibility. We have to leave it as
Dian Fu created FLINK-11285:
---
Summary: Change the modifier of
CsvTableSourceFactoryBase.createTableSource and
CsvTableSinkFactoryBase.createTableSink to private[flink]
Key: FLINK-11285
URL:
[
https://issues.apache.org/jira/browse/FLINK-11285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-11285:
Issue Type: Improvement (was: New Feature)
> Change the modifier of
[
https://issues.apache.org/jira/browse/FLINK-11285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-11285:
Description: The modifier of CsvTableSourceFactoryBase.createTableSource
and
[
https://issues.apache.org/jira/browse/FLINK-11052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-11052:
---
Assignee: Dian Fu
> Add Bounded(Group Window) FlatAggregate operator to batch Table API
>
[
https://issues.apache.org/jira/browse/FLINK-11967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16802348#comment-16802348
]
Dian Fu commented on FLINK-11967:
-
Hi [~sunjincheng121], I have not started the work yet. Feel free to
[
https://issues.apache.org/jira/browse/FLINK-11967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-11967:
---
Assignee: (was: Dian Fu)
> Add Column Operators/Operations
> ---
>
[
https://issues.apache.org/jira/browse/FLINK-10755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16777941#comment-16777941
]
Dian Fu commented on FLINK-10755:
-
hi, [~twalthr] As the release 1.8 branch has been cut, I think we can
[
https://issues.apache.org/jira/browse/FLINK-10755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16777941#comment-16777941
]
Dian Fu edited comment on FLINK-10755 at 2/26/19 2:10 PM:
--
hi, [~twalthr] As
[
https://issues.apache.org/jira/browse/FLINK-10755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16777962#comment-16777962
]
Dian Fu commented on FLINK-10755:
-
Thanks a lot for the suggestion. Sounds good. I'll prepare the PR
[
https://issues.apache.org/jira/browse/FLINK-10755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16777980#comment-16777980
]
Dian Fu commented on FLINK-10755:
-
Good suggestion. Will do that. :)
> Port external catalogs in Table
[
https://issues.apache.org/jira/browse/FLINK-11816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16783527#comment-16783527
]
Dian Fu commented on FLINK-11816:
-
Thanks [~carp84] for reporting this issue. I'll take a look at it.
>
[
https://issues.apache.org/jira/browse/FLINK-11816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-11816.
---
Resolution: Cannot Reproduce
I cannot reproduce this issue locally and I guess it's a cache issue and you
[
https://issues.apache.org/jira/browse/FLINK-11814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-11814.
---
Resolution: Cannot Reproduce
> Changes of FLINK-11516 causes compilation failure
>
[
https://issues.apache.org/jira/browse/FLINK-11967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-11967:
---
Assignee: Dian Fu
> Add Column Operators/Operations
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-11450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16755713#comment-16755713
]
Dian Fu commented on FLINK-11450:
-
[~twalthr] Sounds great. Will submit a PR ASAP.
> Port and move
[
https://issues.apache.org/jira/browse/FLINK-11447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16755785#comment-16755785
]
Dian Fu commented on FLINK-11447:
-
Thanks [~dawidwys] for the sharing your thoughts. If we choose option
[
https://issues.apache.org/jira/browse/FLINK-11450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-11450:
---
Assignee: Dian Fu (was: sunjincheng)
> Port and move TableSource and TableSink to
[
https://issues.apache.org/jira/browse/FLINK-11447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-11447:
---
Assignee: Dian Fu (was: sunjincheng)
> Deprecate "new Table(TableEnvironment, String)"
>
[
https://issues.apache.org/jira/browse/FLINK-11447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16756205#comment-16756205
]
Dian Fu commented on FLINK-11447:
-
If so, we need to remove the implicit which converts TableFunction to
[
https://issues.apache.org/jira/browse/FLINK-11447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16756205#comment-16756205
]
Dian Fu edited comment on FLINK-11447 at 1/30/19 3:06 PM:
--
If so, we need to
[
https://issues.apache.org/jira/browse/FLINK-10755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16758138#comment-16758138
]
Dian Fu commented on FLINK-10755:
-
Hi [~phoenixjiangnan]，when I worked on FLINK-11450, I have not
Dian Fu created FLINK-11516:
---
Summary: Port and move some Descriptor classes to
flink-table-common
Key: FLINK-11516
URL: https://issues.apache.org/jira/browse/FLINK-11516
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-11447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16758487#comment-16758487
]
Dian Fu commented on FLINK-11447:
-
Personally I like the approach suggested by [~hequn8128] to add a
[
https://issues.apache.org/jira/browse/FLINK-10755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16758467#comment-16758467
]
Dian Fu commented on FLINK-10755:
-
[~twalthr] As discussed offline, as the return type of method
[
https://issues.apache.org/jira/browse/FLINK-10755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-10755:
---
Assignee: Dian Fu (was: Bowen Li)
> Port external catalogs in Table API extension points to
[
https://issues.apache.org/jira/browse/FLINK-10755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16758844#comment-16758844
]
Dian Fu commented on FLINK-10755:
-
[~phoenixjiangnan] Thanks a lot.
> Port external catalogs in Table
Dian Fu created FLINK-11522:
---
Summary: Deprecate ExternalCatalogTable.builder()
Key: FLINK-11522
URL: https://issues.apache.org/jira/browse/FLINK-11522
Project: Flink
Issue Type: Task
[
https://issues.apache.org/jira/browse/FLINK-11447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16759831#comment-16759831
]
Dian Fu commented on FLINK-11447:
-
Thanks [~twalthr] [~dawidwys] [~hequn8128] [~sunjincheng121] [~jark]
[
https://issues.apache.org/jira/browse/FLINK-10755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16759818#comment-16759818
]
Dian Fu commented on FLINK-10755:
-
[~twalthr] Thanks for the suggestion. Make sense. I have created a
[
https://issues.apache.org/jira/browse/FLINK-11447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16760474#comment-16760474
]
Dian Fu commented on FLINK-11447:
-
[~twalthr] Thanks a lot for offering the help. I have uploaded the PR
Dian Fu created FLINK-11532:
---
Summary: Remove the deprecation of ExternalCatalogTable.builder()
Key: FLINK-11532
URL: https://issues.apache.org/jira/browse/FLINK-11532
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-11522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16760725#comment-16760725
]
Dian Fu commented on FLINK-11522:
-
Hi [~twalthr] , thanks a lot for the commit of this PR and the kind
[
https://issues.apache.org/jira/browse/FLINK-11450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16754937#comment-16754937
]
Dian Fu edited comment on FLINK-11450 at 1/29/19 12:15 PM:
---
Thanks
[
https://issues.apache.org/jira/browse/FLINK-11447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16754956#comment-16754956
]
Dian Fu edited comment on FLINK-11447 at 1/29/19 12:30 PM:
---
Thanks [~twalthr]
[
https://issues.apache.org/jira/browse/FLINK-11450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16754937#comment-16754937
]
Dian Fu commented on FLINK-11450:
-
Thanks [~sunjincheng121] [~twalthr] for the discussion. Yes,
[
https://issues.apache.org/jira/browse/FLINK-11447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16754956#comment-16754956
]
Dian Fu commented on FLINK-11447:
-
Thanks [~twalthr] for creating the ticket and [~sunjincheng121] for
[
https://issues.apache.org/jira/browse/FLINK-11447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16754956#comment-16754956
]
Dian Fu edited comment on FLINK-11447 at 1/29/19 12:29 PM:
---
Thanks [~twalthr]
[
https://issues.apache.org/jira/browse/FLINK-11214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16838216#comment-16838216
]
Dian Fu commented on FLINK-11214:
-
Sounds good. BYW, you can take this ticket and continue the work. :)
[
https://issues.apache.org/jira/browse/FLINK-11214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-11214:
---
Assignee: (was: Dian Fu)
> Support non mergable aggregates for group windows on batch table
>
[
https://issues.apache.org/jira/browse/FLINK-12541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-12541:
---
Assignee: Dian Fu
> Add deploy a Python Flink job and session cluster on Kubernetes support.
>
[
https://issues.apache.org/jira/browse/FLINK-12609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16855620#comment-16855620
]
Dian Fu commented on FLINK-12609:
-
[~rmetzger] Thanks a lot for the suggestions. Make sense and will
101 - 200 of 4090 matches
Mail list logo
