lamber-ken opened a new pull request #7551: [hotfix][runtime] add default
statement in switch block when judge taskAcknowledgeResult
URL: https://github.com/apache/flink/pull/7551
## What is the purpose of the change
add default statement in switch block when judge
eaglewatcherwb commented on a change in pull request #7436: [FLINK-11071][core]
add support for dynamic proxy classes resolution …
URL: https://github.com/apache/flink/pull/7436#discussion_r249663932
##
File path:
Clark opened a new pull request #7550: [FLINK-10245] [Streaming Connector]
Add Pojo, Tuple, Row and Scala Product DataStream Sink and Upsert Table Sink
for HBase
URL: https://github.com/apache/flink/pull/7550
## What is the purpose of the change
- Add datastream sink and upsert
[
https://issues.apache.org/jira/browse/FLINK-5703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-5703:
--
Labels: pull-request-available (was: )
> ExecutionGraph recovery based on reconciliation with
zhijiangW commented on issue #3340: [FLINK-5703] [Job Manager] ExecutionGraph
recovery via reconciliation with TaskManager reports
URL: https://github.com/apache/flink/pull/3340#issuecomment-456296041
Close this pr temporarily, and this feature would be re-submitted if needed
in future.
zhijiangW closed pull request #3340: [FLINK-5703] [Job Manager] ExecutionGraph
recovery via reconciliation with TaskManager reports
URL: https://github.com/apache/flink/pull/3340
This is an automated message from the Apache
[
https://issues.apache.org/jira/browse/FLINK-11403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11403:
---
Labels: pull-request-available (was: )
> Remove ResultPartitionConsumableNotifier from
zhijiangW opened a new pull request #7549: [FLINK-11403][network] Remove
ResultPartitionConsumableNotifier from ResultPartition
URL: https://github.com/apache/flink/pull/7549
## What is the purpose of the change
*This is the precondition for introducing pluggable `ShuffleService` on
[
https://issues.apache.org/jira/browse/FLINK-10245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shimin Yang updated FLINK-10245:
Summary: Add HBase Streaming Sink (was: Add DataStream HBase Sink)
> Add HBase Streaming Sink
>
lining created FLINK-11405:
--
Summary: rest api can see exception by start end time filter
Key: FLINK-11405
URL: https://issues.apache.org/jira/browse/FLINK-11405
Project: Flink
Issue Type: Sub-task
lining created FLINK-11404:
--
Summary: web ui add see page and can filter by time
Key: FLINK-11404
URL: https://issues.apache.org/jira/browse/FLINK-11404
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-11404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lining reassigned FLINK-11404:
--
Assignee: Yadong Xie (was: lining)
> web ui add see page and can filter by time
>
[
https://issues.apache.org/jira/browse/FLINK-11374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lining updated FLINK-11374:
---
Comment: was deleted
(was: agg by vertex
!image-2019-01-22-11-42-33-808.png!)
> See more failover and can
Myasuka commented on issue #7544: [FLINK-11366][tests] Port
TaskManagerMetricsTest to new code base
URL: https://github.com/apache/flink/pull/7544#issuecomment-456287424
I close-reopen this PR to rebuild checks for unexpected ITcase broken (
refer to
Myasuka closed pull request #7544: [FLINK-11366][tests] Port
TaskManagerMetricsTest to new code base
URL: https://github.com/apache/flink/pull/7544
This is an automated message from the Apache Git Service.
To respond to the
Myasuka opened a new pull request #7544: [FLINK-11366][tests] Port
TaskManagerMetricsTest to new code base
URL: https://github.com/apache/flink/pull/7544
## What is the purpose of the change
Port `TaskManagerMetricsTest` to new code base.
## Brief change log
- Move
Myasuka commented on issue #7525: [FLINK-11363][test] Check and remove
TaskManagerConfigurationTest
URL: https://github.com/apache/flink/pull/7525#issuecomment-456287098
I close-reopen this PR to rebuild checks for unexpected ITcase crashed (
refer to
[
https://issues.apache.org/jira/browse/FLINK-9920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16748419#comment-16748419
]
Yun Tang commented on FLINK-9920:
-
Another instance:
alexeyt820 commented on a change in pull request #6615: [FLINK-8354]
[flink-connectors] Add ability to access and provider Kafka headers
URL: https://github.com/apache/flink/pull/6615#discussion_r249653432
##
File path:
Aitozi commented on issue #4514: [FLINK-7384][cep] Unify event and processing
time handling in the Abs…
URL: https://github.com/apache/flink/pull/4514#issuecomment-456284959
Hi @dawidwys
I have gone through this PR, I think the unified solution is more clear.
Maybe better check about
Aitozi removed a comment on issue #7543: [FLINK-10996]Fix the possible state
leak with CEP processing time model
URL: https://github.com/apache/flink/pull/7543#issuecomment-456284633
Hi @dawidwys
I have gone through the `FLINK-7384`, I think the unified solution is more
clear. Maybe
Aitozi commented on issue #7543: [FLINK-10996]Fix the possible state leak with
CEP processing time model
URL: https://github.com/apache/flink/pull/7543#issuecomment-456284633
Hi @dawidwys
I have gone through the `FLINK-7384`, I think the unified solution is more
clear. Maybe better
alexeyt820 commented on a change in pull request #6615: [FLINK-8354]
[flink-connectors] Add ability to access and provider Kafka headers
URL: https://github.com/apache/flink/pull/6615#discussion_r249637189
##
File path:
zhijiang created FLINK-11403:
Summary: Remove ResultPartitionConsumableNotifier from
ResultPartition
Key: FLINK-11403
URL: https://issues.apache.org/jira/browse/FLINK-11403
Project: Flink
Issue
Myasuka opened a new pull request #7525: [FLINK-11363][test] Check and remove
TaskManagerConfigurationTest
URL: https://github.com/apache/flink/pull/7525
## What is the purpose of the change
Check whether `TaskManagerConfigurationTest` contains any relevant tests for
the new code
Myasuka closed pull request #7525: [FLINK-11363][test] Check and remove
TaskManagerConfigurationTest
URL: https://github.com/apache/flink/pull/7525
This is an automated message from the Apache Git Service.
To respond to the
alexeyt820 commented on a change in pull request #6615: [FLINK-8354]
[flink-connectors] Add ability to access and provider Kafka headers
URL: https://github.com/apache/flink/pull/6615#discussion_r249637422
##
File path:
alexeyt820 commented on a change in pull request #6615: [FLINK-8354]
[flink-connectors] Add ability to access and provider Kafka headers
URL: https://github.com/apache/flink/pull/6615#discussion_r249637189
##
File path:
alexeyt820 commented on a change in pull request #6615: [FLINK-8354]
[flink-connectors] Add ability to access and provider Kafka headers
URL: https://github.com/apache/flink/pull/6615#discussion_r249637189
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16748360#comment-16748360
]
lining commented on FLINK-11374:
list detail exception count 100 and can see by page
[
https://issues.apache.org/jira/browse/FLINK-11374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16748362#comment-16748362
]
lining commented on FLINK-11374:
Hi, [~till.rohrmann]. I have added some details about this. What do you
leesf commented on issue #7536: [hotfix][docs] Remove redundant symbols
URL: https://github.com/apache/flink/pull/7536#issuecomment-456261374
cc @GJL @zentol
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/FLINK-11374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lining updated FLINK-11374:
---
Attachment: image-2019-01-22-11-42-33-808.png
> See more failover and can filter by time range
>
[
https://issues.apache.org/jira/browse/FLINK-11374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16748361#comment-16748361
]
lining commented on FLINK-11374:
agg by vertex
!image-2019-01-22-11-42-33-808.png!
> See more failover
[
https://issues.apache.org/jira/browse/FLINK-11374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lining updated FLINK-11374:
---
Attachment: image-2019-01-22-11-40-53-135.png
> See more failover and can filter by time range
>
Clark closed pull request #6628: [FLINK-10245] [Streaming Connector] Add
Pojo, Tuple, Row and Scala Product DataStream Sink for HBase
URL: https://github.com/apache/flink/pull/6628
This is an automated message from the
[
https://issues.apache.org/jira/browse/FLINK-11380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16748350#comment-16748350
]
Yun Tang commented on FLINK-11380:
--
Another instance https://api.travis-ci.org/v3/job/481937341/log.txt
[
https://issues.apache.org/jira/browse/FLINK-6101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln.lee closed FLINK-6101.
--
Resolution: Later
> GroupBy fields with arithmetic expression (include UDF) can not be selected
>
[
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
>
dianfu closed pull request #7354: [FLINK-11214] [table] Support non mergable
aggregates for group windows on batch table
URL: https://github.com/apache/flink/pull/7354
This is an automated message from the Apache Git
KarmaGYZ commented on a change in pull request #7260: [hotfix][docs] Fix typo
and make improvement in Kafka Connectors doc
URL: https://github.com/apache/flink/pull/7260#discussion_r249611548
##
File path: docs/dev/connectors/kafka.md
##
@@ -681,13 +681,13 @@ chosen by
[
https://issues.apache.org/jira/browse/FLINK-11326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11326:
---
Labels: pull-request-available (was: )
> Using offsets to adjust windows to timezones
kezhuw opened a new pull request #7548: [FLINK-11326] Fix forbidden negative
offset in window assigners
URL: https://github.com/apache/flink/pull/7548
## What is the purpose of the change
Allow negative window offset in window assignment as the javadoc says.
## Brief change log
KarmaGYZ commented on issue #7423: [hotfix][docs] Remove the legacy hint in
production-ready doc
URL: https://github.com/apache/flink/pull/7423#issuecomment-456233322
@alpinegizmo Thanks for the review.
In the stale version, this sentence point to the asynchronous snapshotting.
stevenzwu commented on a change in pull request #6615: [FLINK-8354]
[flink-connectors] Add ability to access and provider Kafka headers
URL: https://github.com/apache/flink/pull/6615#discussion_r249607011
##
File path:
stevenzwu commented on a change in pull request #6615: [FLINK-8354]
[flink-connectors] Add ability to access and provider Kafka headers
URL: https://github.com/apache/flink/pull/6615#discussion_r249607011
##
File path:
alexeyt820 commented on a change in pull request #6615: [FLINK-8354]
[flink-connectors] Add ability to access and provider Kafka headers
URL: https://github.com/apache/flink/pull/6615#discussion_r249606898
##
File path:
alexeyt820 commented on a change in pull request #6615: [FLINK-8354]
[flink-connectors] Add ability to access and provider Kafka headers
URL: https://github.com/apache/flink/pull/6615#discussion_r249606803
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kezhu Wang updated FLINK-11326:
---
Affects Version/s: 1.7.1
> Using offsets to adjust windows to timezones UTC-8 throws
>
stevenzwu commented on a change in pull request #6615: [FLINK-8354]
[flink-connectors] Add ability to access and provider Kafka headers
URL: https://github.com/apache/flink/pull/6615#discussion_r249606472
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-11402:
Component/s: Local Runtime
> User code can fail with an UnsatisfiedLinkError in the presence of
[
https://issues.apache.org/jira/browse/FLINK-11402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16748241#comment-16748241
]
Ufuk Celebi commented on FLINK-11402:
-
Similar issue for RocksDB (FLINK-5408)
> User code can fail
[
https://issues.apache.org/jira/browse/FLINK-11402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-11402:
Attachment: hello-snappy.tgz
> User code can fail with an UnsatisfiedLinkError in the presence of
[
https://issues.apache.org/jira/browse/FLINK-11402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-11402:
Attachment: hello-snappy-1.0-SNAPSHOT.jar
> User code can fail with an UnsatisfiedLinkError in
Ufuk Celebi created FLINK-11402:
---
Summary: User code can fail with an UnsatisfiedLinkError in the
presence of multiple classloaders
Key: FLINK-11402
URL: https://issues.apache.org/jira/browse/FLINK-11402
[
https://issues.apache.org/jira/browse/FLINK-11401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11401:
---
Labels: pull-request-available (was: )
> Allow compression on ParquetBulkWriter
>
Fokko opened a new pull request #7547: [FLINK-11401] Allow setting of
compression on ParquetWriter
URL: https://github.com/apache/flink/pull/7547
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather
Fokko Driesprong created FLINK-11401:
Summary: Allow compression on ParquetBulkWriter
Key: FLINK-11401
URL: https://issues.apache.org/jira/browse/FLINK-11401
Project: Flink
Issue Type:
bowenli86 commented on issue #7011: [FLINK-10768][Table & SQL] Move external
catalog related code from TableEnvironment to CatalogManager
URL: https://github.com/apache/flink/pull/7011#issuecomment-456154882
closing this PR in favor of new plan
bowenli86 commented on issue #6997: [FLINK-10697][Table & SQL] Create an
in-memory catalog that stores Flink's meta objects
URL: https://github.com/apache/flink/pull/6997#issuecomment-456154907
closing this PR in favor of new plan
bowenli86 commented on issue #7012: [FLINK-10769][Table & SQL] port
InMemoryExternalCatalog to java
URL: https://github.com/apache/flink/pull/7012#issuecomment-456154851
closing this PR in favor of new plan
This is an
bowenli86 closed pull request #7011: [FLINK-10768][Table & SQL] Move external
catalog related code from TableEnvironment to CatalogManager
URL: https://github.com/apache/flink/pull/7011
This is an automated message from the
bowenli86 closed pull request #6970: [FLINK-10696][Table API & SQL]Add APIs to
ExternalCatalog, CrudExternalCatalog and InMemoryCrudExternalCatalog for views
and UDFs
URL: https://github.com/apache/flink/pull/6970
This is
bowenli86 closed pull request #7012: [FLINK-10769][Table & SQL] port
InMemoryExternalCatalog to java
URL: https://github.com/apache/flink/pull/7012
This is an automated message from the Apache Git Service.
To respond to the
GJL opened a new pull request #7546: [FLINK-11390][tests] Port
YARNSessionCapacitySchedulerITCase#testTaskManagerFailure to new code base
URL: https://github.com/apache/flink/pull/7546
## What is the purpose of the change
*Port
[
https://issues.apache.org/jira/browse/FLINK-11400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16748078#comment-16748078
]
TisonKun commented on FLINK-11400:
--
Do you mean introduce a {{recoveryOperation}} in
azagrebin commented on a change in pull request #6615: [FLINK-8354]
[flink-connectors] Add ability to access and provider Kafka headers
URL: https://github.com/apache/flink/pull/6615#discussion_r249512219
##
File path:
azagrebin commented on a change in pull request #6615: [FLINK-8354]
[flink-connectors] Add ability to access and provider Kafka headers
URL: https://github.com/apache/flink/pull/6615#discussion_r249368384
##
File path:
azagrebin commented on a change in pull request #6615: [FLINK-8354]
[flink-connectors] Add ability to access and provider Kafka headers
URL: https://github.com/apache/flink/pull/6615#discussion_r249478973
##
File path:
azagrebin commented on a change in pull request #6615: [FLINK-8354]
[flink-connectors] Add ability to access and provider Kafka headers
URL: https://github.com/apache/flink/pull/6615#discussion_r249510977
##
File path:
azagrebin commented on a change in pull request #6615: [FLINK-8354]
[flink-connectors] Add ability to access and provider Kafka headers
URL: https://github.com/apache/flink/pull/6615#discussion_r249482757
##
File path:
Till Rohrmann created FLINK-11400:
-
Summary: JobManagerRunner does not wait for suspension of JobMaster
Key: FLINK-11400
URL: https://issues.apache.org/jira/browse/FLINK-11400
Project: Flink
StefanRRichter commented on issue #7009: [FLINK-10712] Support to restore state
when using RestartPipelinedRegionStrategy
URL: https://github.com/apache/flink/pull/7009#issuecomment-456105318
I think I agree with the assessment of the existing operators.
About adding a
azagrebin commented on a change in pull request #6615: [FLINK-8354]
[flink-connectors] Add ability to access and provider Kafka headers
URL: https://github.com/apache/flink/pull/6615#discussion_r249367559
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kezhu Wang reassigned FLINK-11326:
--
Assignee: Kezhu Wang
> Using offsets to adjust windows to timezones UTC-8 throws
>
hequn8128 commented on a change in pull request #6787: [FLINK-8577][table]
Implement proctime DataStream to Table upsert conversion
URL: https://github.com/apache/flink/pull/6787#discussion_r249476414
##
File path:
Benoît Paris created FLINK-11399:
Summary: Parsing nested ROW()s in SQL
Key: FLINK-11399
URL: https://issues.apache.org/jira/browse/FLINK-11399
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-11398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng updated FLINK-11398:
Description:
As discussed
Hequn Cheng created FLINK-11398:
---
Summary: Add a dedicated phase to materialize time indicators for
nodes produce updates
Key: FLINK-11398
URL: https://issues.apache.org/jira/browse/FLINK-11398
dawidwys commented on a change in pull request #7436: [FLINK-11071][core] add
support for dynamic proxy classes resolution …
URL: https://github.com/apache/flink/pull/7436#discussion_r249462832
##
File path:
flink-core/src/test/java/org/apache/flink/util/InstantiationUtilTest.java
fhueske commented on issue #6873: [hotfix] Add Review Progress section to PR
description template.
URL: https://github.com/apache/flink/pull/6873#issuecomment-456085278
I think if we modify the review checklist in place (i.e., update it in the
PR description) this is almost automatically
rmetzger commented on issue #6873: [hotfix] Add Review Progress section to PR
description template.
URL: https://github.com/apache/flink/pull/6873#issuecomment-456081384
@zentol: I'm a bit against this `**NOTE: THE REVIEW PROGRESS MUST ONLY BE
UPDATED BY AN APACHE FLINK COMMITTER!**`
[
https://issues.apache.org/jira/browse/FLINK-11249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16747937#comment-16747937
]
Piotr Nowojski commented on FLINK-11249:
I have realised about one more issue. This fix alone
[
https://issues.apache.org/jira/browse/FLINK-7834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-7834:
--
Labels: pull-request-available (was: )
> cost model (RelOptCost) extends network cost and
clarkyzl closed pull request #3623: [FLINK-6196] [table] Support dynamic schema
in Table Function
URL: https://github.com/apache/flink/pull/3623
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-6196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-6196:
--
Labels: pull-request-available (was: )
> Support dynamic schema in Table Function
>
[
https://issues.apache.org/jira/browse/FLINK-7065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-7065:
--
Labels: pull-request-available (was: )
> separate the flink-streaming-java module from
XuPingyong commented on issue #4267: [FLINK-7018][streaming] Refactor
streamGraph to make interfaces clear
URL: https://github.com/apache/flink/pull/4267#issuecomment-456053593
no need
This is an automated message from the
XuPingyong closed pull request #4267: [FLINK-7018][streaming] Refactor
streamGraph to make interfaces clear
URL: https://github.com/apache/flink/pull/4267
This is an automated message from the Apache Git Service.
To respond
[
https://issues.apache.org/jira/browse/FLINK-5833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-5833:
--
Labels: pull-request-available (was: )
> Support for Hive GenericUDF
>
XuPingyong closed pull request #4273: [FLINK-7065] Separate the
flink-streaming-java module from flink-clients
URL: https://github.com/apache/flink/pull/4273
This is an automated message from the Apache Git Service.
To
XuPingyong closed pull request #4241: [FLINK-7015] [streaming] separate
OperatorConfig from StreamConfig
URL: https://github.com/apache/flink/pull/4241
This is an automated message from the Apache Git Service.
To respond to
clarkyzl closed pull request #3473: [FLINK-5833] [table] Support for Hive
GenericUDF
URL: https://github.com/apache/flink/pull/3473
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/FLINK-7015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-7015:
--
Labels: pull-request-available (was: )
> Separate OperatorConfig from StreamConfig
>
XuPingyong opened a new pull request #4267: [FLINK-7018][streaming] Refactor
streamGraph to make interfaces clear
URL: https://github.com/apache/flink/pull/4267
This is an automated message from the Apache Git Service.
To
XuPingyong removed a comment on issue #4267: [FLINK-7018][streaming] Refactor
streamGraph to make interfaces clear
URL: https://github.com/apache/flink/pull/4267#issuecomment-456053593
no need
This is an automated message
[
https://issues.apache.org/jira/browse/FLINK-5514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-5514:
--
Labels: pull-request-available (was: )
> Implement an efficient physical execution for
XuPingyong closed pull request #4267: [FLINK-7018][streaming] Refactor
streamGraph to make interfaces clear
URL: https://github.com/apache/flink/pull/4267
This is an automated message from the Apache Git Service.
To respond
[
https://issues.apache.org/jira/browse/FLINK-6516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-6516:
--
Labels: pull-request-available (was: )
> using real row count instead of dummy row count when
[
https://issues.apache.org/jira/browse/FLINK-7018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-7018:
--
Labels: pull-request-available (was: )
> Refactor streamGraph to make interfaces clear
>
1 - 100 of 129 matches
Mail list logo
