tzulitai edited a comment on issue #8570: [FLINK-12688] [state] Make serializer
lazy initialization thread safe in StateDescriptor
URL: https://github.com/apache/flink/pull/8570#issuecomment-497585843
One slight clarification regarding a comment that was mentioned in the
description:
tzulitai edited a comment on issue #8570: [FLINK-12688] [state] Make serializer
lazy initialization thread safe in StateDescriptor
URL: https://github.com/apache/flink/pull/8570#issuecomment-497585843
One slight clarification regarding a comment that was mentioned in the
description:
tzulitai edited a comment on issue #8570: [FLINK-12688] [state] Make serializer
lazy initialization thread safe in StateDescriptor
URL: https://github.com/apache/flink/pull/8570#issuecomment-497585843
One slight clarification regarding a comment that was mentioned in the
description:
tzulitai commented on issue #8570: [FLINK-12688] [state] Make serializer lazy
initialization thread safe in StateDescriptor
URL: https://github.com/apache/flink/pull/8570#issuecomment-497585843
One slight clarification regarding a comment that was mentioned in the
description:
```
liyafan82 commented on issue #8579: [FLINK-12687][Runtime / Operators]
ByteHashSet is always in dense mode
URL: https://github.com/apache/flink/pull/8579#issuecomment-497585646
Hi @JingsongLi, would you please take a look?
zhijiangW commented on a change in pull request #8362: [FLINK-11391] Introduce
shuffle master interface
URL: https://github.com/apache/flink/pull/8362#discussion_r289264560
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/NettyShuffleMaster.java
zhijiangW commented on a change in pull request #8362: [FLINK-11391] Introduce
shuffle master interface
URL: https://github.com/apache/flink/pull/8362#discussion_r289264560
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/NettyShuffleMaster.java
tzulitai commented on a change in pull request #8570: [FLINK-12688] [state]
Make serializer lazy initialization thread safe in StateDescriptor
URL: https://github.com/apache/flink/pull/8570#discussion_r289262686
##
File path:
tzulitai commented on a change in pull request #8570: [FLINK-12688] [state]
Make serializer lazy initialization thread safe in StateDescriptor
URL: https://github.com/apache/flink/pull/8570#discussion_r289264163
##
File path:
tzulitai commented on a change in pull request #8570: [FLINK-12688] [state]
Make serializer lazy initialization thread safe in StateDescriptor
URL: https://github.com/apache/flink/pull/8570#discussion_r289262391
##
File path:
tzulitai commented on a change in pull request #8570: [FLINK-12688] [state]
Make serializer lazy initialization thread safe in StateDescriptor
URL: https://github.com/apache/flink/pull/8570#discussion_r289263899
##
File path:
tzulitai commented on a change in pull request #8570: [FLINK-12688] [state]
Make serializer lazy initialization thread safe in StateDescriptor
URL: https://github.com/apache/flink/pull/8570#discussion_r289262323
##
File path:
tzulitai commented on a change in pull request #8570: [FLINK-12688] [state]
Make serializer lazy initialization thread safe in StateDescriptor
URL: https://github.com/apache/flink/pull/8570#discussion_r289262617
##
File path:
tzulitai commented on a change in pull request #8570: [FLINK-12688] [state]
Make serializer lazy initialization thread safe in StateDescriptor
URL: https://github.com/apache/flink/pull/8570#discussion_r289263588
##
File path:
bowenli86 commented on issue #8567: [FLINK-12676][table][sql-client] Add
descriptor, validator, and factory of GenericInMemoryCatalog for table
discovery service
URL: https://github.com/apache/flink/pull/8567#issuecomment-497580939
@xuefuz can you take another look?
bowenli86 commented on a change in pull request #8522:
[FLINK-12572][hive]Implement HiveInputFormat to read Hive tables
URL: https://github.com/apache/flink/pull/8522#discussion_r289260306
##
File path:
bowenli86 commented on a change in pull request #8522:
[FLINK-12572][hive]Implement HiveInputFormat to read Hive tables
URL: https://github.com/apache/flink/pull/8522#discussion_r289260559
##
File path:
bowenli86 commented on a change in pull request #8522:
[FLINK-12572][hive]Implement HiveInputFormat to read Hive tables
URL: https://github.com/apache/flink/pull/8522#discussion_r289260297
##
File path:
bowenli86 commented on a change in pull request #8536: [FLINK-12568][hive]
Implement OutputFormat to write Hive tables
URL: https://github.com/apache/flink/pull/8536#discussion_r289259721
##
File path:
bowenli86 commented on a change in pull request #8536: [FLINK-12568][hive]
Implement OutputFormat to write Hive tables
URL: https://github.com/apache/flink/pull/8536#discussion_r289259721
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-5243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852672#comment-16852672
]
Jasleen Kaur commented on FLINK-5243:
-
[~greghogan] Thanks for your reply. I was planning to
tzulitai edited a comment on issue #8570: [FLINK-12688] [state] Make serializer
lazy initialization thread safe in StateDescriptor
URL: https://github.com/apache/flink/pull/8570#issuecomment-497577479
@flinkbot approve consensus
I'm approving the consensus to fix the problem like
tzulitai edited a comment on issue #8570: [FLINK-12688] [state] Make serializer
lazy initialization thread safe in StateDescriptor
URL: https://github.com/apache/flink/pull/8570#issuecomment-497577479
@flinkbot approve consensus
I'm approving the consensus to fix the problem like
[
https://issues.apache.org/jira/browse/FLINK-12683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852668#comment-16852668
]
vinoyang commented on FLINK-12683:
--
I think for logging, the good practice is that it should provide
tzulitai commented on issue #8570: [FLINK-12688] [state] Make serializer lazy
initialization thread safe in StateDescriptor
URL: https://github.com/apache/flink/pull/8570#issuecomment-497577479
@flinkbot approve consensus
I'm approving the consensus to fix the problem like this,
bowenli86 commented on a change in pull request #8564: [FLINK-12649][hive] Add
a shim layer to support multiple versions of HMS
URL: https://github.com/apache/flink/pull/8564#discussion_r289258274
##
File path: flink-connectors/flink-connector-hive/pom.xml
##
@@ -423,4
bowenli86 commented on a change in pull request #8564: [FLINK-12649][hive] Add
a shim layer to support multiple versions of HMS
URL: https://github.com/apache/flink/pull/8564#discussion_r289258387
##
File path:
bowenli86 commented on a change in pull request #8564: [FLINK-12649][hive] Add
a shim layer to support multiple versions of HMS
URL: https://github.com/apache/flink/pull/8564#discussion_r289258244
##
File path: flink-connectors/flink-connector-hive/pom.xml
##
@@ -423,4
bowenli86 commented on a change in pull request #8564: [FLINK-12649][hive] Add
a shim layer to support multiple versions of HMS
URL: https://github.com/apache/flink/pull/8564#discussion_r289258274
##
File path: flink-connectors/flink-connector-hive/pom.xml
##
@@ -423,4
bowenli86 commented on a change in pull request #8564: [FLINK-12649][hive] Add
a shim layer to support multiple versions of HMS
URL: https://github.com/apache/flink/pull/8564#discussion_r289258121
##
File path:
bowenli86 commented on a change in pull request #8564: [FLINK-12649][hive] Add
a shim layer to support multiple versions of HMS
URL: https://github.com/apache/flink/pull/8564#discussion_r289257720
##
File path: flink-connectors/flink-connector-hive/pom.xml
##
@@ -423,4
bowenli86 commented on a change in pull request #8564: [FLINK-12649][hive] Add
a shim layer to support multiple versions of HMS
URL: https://github.com/apache/flink/pull/8564#discussion_r289257545
##
File path: flink-connectors/flink-connector-hive/pom.xml
##
@@ -423,4
bowenli86 commented on a change in pull request #8564: [FLINK-12649][hive] Add
a shim layer to support multiple versions of HMS
URL: https://github.com/apache/flink/pull/8564#discussion_r289258121
##
File path:
bowenli86 commented on a change in pull request #8564: [FLINK-12649][hive] Add
a shim layer to support multiple versions of HMS
URL: https://github.com/apache/flink/pull/8564#discussion_r289257720
##
File path: flink-connectors/flink-connector-hive/pom.xml
##
@@ -423,4
bowenli86 commented on a change in pull request #8564: [FLINK-12649][hive] Add
a shim layer to support multiple versions of HMS
URL: https://github.com/apache/flink/pull/8564#discussion_r289257545
##
File path: flink-connectors/flink-connector-hive/pom.xml
##
@@ -423,4
[
https://issues.apache.org/jira/browse/FLINK-11987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852663#comment-16852663
]
Yu Li commented on FLINK-11987:
---
Regarding the issue mentioned by [~chethanuk], from the posted stack the
[
https://issues.apache.org/jira/browse/FLINK-12683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852658#comment-16852658
]
Congxian Qiu(klion26) commented on FLINK-12683:
---
In my opinion, the jm log of current
[
https://issues.apache.org/jira/browse/FLINK-11987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852656#comment-16852656
]
Yu Li commented on FLINK-11987:
---
Have created FLINK-12688 to fix the issue from inside {{StateDescriptor}}
flinkbot commented on issue #8580: [FLINK-12683] Provide task manager location
information for checkpoint coordinator specific log messages
URL: https://github.com/apache/flink/pull/8580#issuecomment-497573926
Thanks a lot for your contribution to the Apache Flink project. I'm the
Yu Li created FLINK-12688:
-
Summary: Make serializer lazy initialization thread safe in
StateDescriptor
Key: FLINK-12688
URL: https://issues.apache.org/jira/browse/FLINK-12688
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-12683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12683:
---
Labels: pull-request-available (was: )
> Provide task manager's location information for
yanghua opened a new pull request #8580: [FLINK-12683] Provide task manager
location information for checkpoint coordinator specific log messages
URL: https://github.com/apache/flink/pull/8580
## What is the purpose of the change
*This pull request provides task manager location
[
https://issues.apache.org/jira/browse/FLINK-12687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12687:
---
Labels: pull-request-available (was: )
> ByteHashSet is always in dense mode
>
flinkbot commented on issue #8579: [FLINK-12687][Runtime / Operators]
ByteHashSet is always in dense mode
URL: https://github.com/apache/flink/pull/8579#issuecomment-497573552
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to
liyafan82 opened a new pull request #8579: [FLINK-12687][Runtime / Operators]
ByteHashSet is always in dense mode
URL: https://github.com/apache/flink/pull/8579
## What is the purpose of the change
Improve the performance and code structure for
Liya Fan created FLINK-12687:
Summary: ByteHashSet is always in dense mode
Key: FLINK-12687
URL: https://issues.apache.org/jira/browse/FLINK-12687
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-12686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Biao Liu updated FLINK-12686:
-
Description: This is a part of merging Blink batch runner. I would like to
improvement the StreamGraph
Biao Liu created FLINK-12686:
Summary: StreamGraph Supports Blink Batch Mode
Key: FLINK-12686
URL: https://issues.apache.org/jira/browse/FLINK-12686
Project: Flink
Issue Type: Improvement
zhijiangW commented on a change in pull request #8362: [FLINK-11391] Introduce
shuffle master interface
URL: https://github.com/apache/flink/pull/8362#discussion_r289249491
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/PartitionDescriptor.java
zhijiangW commented on a change in pull request #8362: [FLINK-11391] Introduce
shuffle master interface
URL: https://github.com/apache/flink/pull/8362#discussion_r289249256
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/PartitionDescriptor.java
zhijiangW commented on a change in pull request #8362: [FLINK-11391] Introduce
shuffle master interface
URL: https://github.com/apache/flink/pull/8362#discussion_r289247475
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/ProducerDescriptor.java
zhijiangW commented on a change in pull request #8362: [FLINK-11391] Introduce
shuffle master interface
URL: https://github.com/apache/flink/pull/8362#discussion_r289247275
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/ProducerDescriptor.java
zhijiangW commented on a change in pull request #8362: [FLINK-11391] Introduce
shuffle master interface
URL: https://github.com/apache/flink/pull/8362#discussion_r289247275
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/ProducerDescriptor.java
asfgit closed pull request #8531: [FLINK-12440][python] Add all connector
support align Java Table API.
URL: https://github.com/apache/flink/pull/8531
This is an automated message from the Apache Git Service.
To respond to
[
https://issues.apache.org/jira/browse/FLINK-12440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-12440.
---
Resolution: Fixed
Fix Version/s: 1.9.0
Fixed in master:
zhijiangW commented on a change in pull request #8362: [FLINK-11391] Introduce
shuffle master interface
URL: https://github.com/apache/flink/pull/8362#discussion_r289246143
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/ShuffleMaster.java
##
lirui-apache commented on issue #8564: [FLINK-12649][hive] Add a shim layer to
support multiple versions of HMS
URL: https://github.com/apache/flink/pull/8564#issuecomment-497560367
> For Hive versions, I think for now we can claim support only for versions
like 1.2.1 explicitly. In
wisgood commented on a change in pull request #8571: [FLINK-12682][connectors]
StringWriter support custom row delimiter
URL: https://github.com/apache/flink/pull/8571#discussion_r289245475
##
File path:
zhijiangW commented on a change in pull request #8362: [FLINK-11391] Introduce
shuffle master interface
URL: https://github.com/apache/flink/pull/8362#discussion_r289244295
##
File path:
zhijiangW commented on a change in pull request #8362: [FLINK-11391] Introduce
shuffle master interface
URL: https://github.com/apache/flink/pull/8362#discussion_r289243434
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/ShuffleDescriptor.java
zhijiangW commented on a change in pull request #8362: [FLINK-11391] Introduce
shuffle master interface
URL: https://github.com/apache/flink/pull/8362#discussion_r289242090
##
File path:
sunjincheng121 commented on issue #8531: [FLINK-12440][python] Add all
connector support align Java Table API.
URL: https://github.com/apache/flink/pull/8531#issuecomment-497555012
LGTM. +1 to merged.
@flinkbot approve all
Myasuka commented on a change in pull request #8571: [FLINK-12682][connectors]
StringWriter support custom row delimiter
URL: https://github.com/apache/flink/pull/8571#discussion_r289240462
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-12683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852600#comment-16852600
]
vinoyang commented on FLINK-12683:
--
Hi [~klion26] Here is my plan:
Changing these two methods'
zhijiangW commented on a change in pull request #8566: [FLINK-12673][network]
Introduce NetworkEnvironment.getUnreleasedPartitions instead of using
getResultPartitionManager
URL: https://github.com/apache/flink/pull/8566#discussion_r289239909
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-12683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-12683:
-
Summary: Provide task manager's location information for checkpoint
coordinator specific log messages
[
https://issues.apache.org/jira/browse/FLINK-12683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-12683:
-
Summary: Provide task manager's location information for checkpoint
acknowledge log message (was:
[
https://issues.apache.org/jira/browse/FLINK-12683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852592#comment-16852592
]
vinoyang commented on FLINK-12683:
--
[~klion26] you are right, thanks, will change this issue title.
>
flinkbot commented on issue #8578: [FLINK-12685] [table-planner-blink] Supports
UNNEST query in blink planner
URL: https://github.com/apache/flink/pull/8578#issuecomment-497551523
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to
godfreyhe opened a new pull request #8578: [FLINK-12685] [table-planner-blink]
Supports UNNEST query in blink planner
URL: https://github.com/apache/flink/pull/8578
## What is the purpose of the change
*Supports UNNEST query in blink planner*
## Brief change log
[
https://issues.apache.org/jira/browse/FLINK-12685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12685:
---
Labels: pull-request-available (was: )
> Supports UNNEST query in blink planner
>
klion26 commented on a change in pull request #8573: [FLINK-12670][runtime]
Implement FailureRateRestartBackoffTimeStrategy
URL: https://github.com/apache/flink/pull/8573#discussion_r289237692
##
File path:
klion26 commented on a change in pull request #8573: [FLINK-12670][runtime]
Implement FailureRateRestartBackoffTimeStrategy
URL: https://github.com/apache/flink/pull/8573#discussion_r289237526
##
File path:
sunjincheng121 commented on issue #8474: [FLINK-12409][python] Adds
from_elements in TableEnvironment
URL: https://github.com/apache/flink/pull/8474#issuecomment-497548692
Thanks for the quick updated! @dianfu
LGTM.
From my side, +1 to merged.
[
https://issues.apache.org/jira/browse/FLINK-12683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852572#comment-16852572
]
Congxian Qiu(klion26) commented on FLINK-12683:
---
Please have a look at FLINK-1165.:)
>
[
https://issues.apache.org/jira/browse/FLINK-12683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852572#comment-16852572
]
Congxian Qiu(klion26) edited comment on FLINK-12683 at 5/31/19 2:03 AM:
godfrey he created FLINK-12685:
--
Summary: Supports UNNEST query in blink planner
Key: FLINK-12685
URL: https://issues.apache.org/jira/browse/FLINK-12685
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852565#comment-16852565
]
sunjincheng commented on FLINK-10455:
-
Hi, [~cslotterback] thanks for your reply. and do not worry
[
https://issues.apache.org/jira/browse/FLINK-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng reassigned FLINK-10455:
---
Assignee: Jiangjie Qin
> Potential Kafka producer leak in case of failures
>
[
https://issues.apache.org/jira/browse/FLINK-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852563#comment-16852563
]
sunjincheng commented on FLINK-10455:
-
Hi [~becket_qin], I am very glad that you are willing to help
danny0405 commented on a change in pull request #8548: [FLINK-6962] [table] Add
create(drop) table SQL DDL
URL: https://github.com/apache/flink/pull/8548#discussion_r289230491
##
File path:
bowenli86 commented on a change in pull request #8567:
[FLINK-12676][table][sql-client] Add descriptor, validator, and factory of
GenericInMemoryCatalog for table discovery service
URL: https://github.com/apache/flink/pull/8567#discussion_r289169055
##
File path:
bowenli86 commented on a change in pull request #8567:
[FLINK-12676][table][sql-client] Add descriptor, validator, and factory of
GenericInMemoryCatalog for table discovery service
URL: https://github.com/apache/flink/pull/8567#discussion_r289166409
##
File path:
bowenli86 commented on a change in pull request #8567:
[FLINK-12676][table][sql-client] Add descriptor, validator, and factory of
GenericInMemoryCatalog for table discovery service
URL: https://github.com/apache/flink/pull/8567#discussion_r289167578
##
File path:
Richard Moorhead created FLINK-12684:
Summary: User defined configuration for per job clusters
Key: FLINK-12684
URL: https://issues.apache.org/jira/browse/FLINK-12684
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-10817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852258#comment-16852258
]
Alexander Fedulov commented on FLINK-10817:
---
[~aljoscha] do you see anything that would block
xuefuz commented on issue #8564: [FLINK-12649][hive] Add a shim layer to
support multiple versions of HMS
URL: https://github.com/apache/flink/pull/8564#issuecomment-497440703
For Hive versions, I think for now we can claim support only for versions
like 1.2.1 explicitly. In theory is
[
https://issues.apache.org/jira/browse/FLINK-11921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852147#comment-16852147
]
Rong Rong commented on FLINK-11921:
---
Hi [~twalthr], [~danny0405] and I discussed briefly that we will
xuefuz commented on a change in pull request #8567:
[FLINK-12676][table][sql-client] Add descriptor, validator, and factory of
GenericInMemoryCatalog for table discovery service
URL: https://github.com/apache/flink/pull/8567#discussion_r289084623
##
File path:
xuefuz commented on a change in pull request #8567:
[FLINK-12676][table][sql-client] Add descriptor, validator, and factory of
GenericInMemoryCatalog for table discovery service
URL: https://github.com/apache/flink/pull/8567#discussion_r289079158
##
File path:
flinkbot commented on issue #8577: [FLINK-10921] [kinesis] Shard watermark
synchronization in Kinesis consumer
URL: https://github.com/apache/flink/pull/8577#issuecomment-497399565
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
tweise opened a new pull request #8577: [FLINK-10921] [kinesis] Shard watermark
synchronization in Kinesis consumer
URL: https://github.com/apache/flink/pull/8577
Backport https://github.com/apache/flink/pull/8517
This is an
xuefuz commented on a change in pull request #8567:
[FLINK-12676][table][sql-client] Add descriptor, validator, and factory of
GenericInMemoryCatalog for table discovery service
URL: https://github.com/apache/flink/pull/8567#discussion_r289070336
##
File path:
xuefuz commented on a change in pull request #8567:
[FLINK-12676][table][sql-client] Add descriptor, validator, and factory of
GenericInMemoryCatalog for table discovery service
URL: https://github.com/apache/flink/pull/8567#discussion_r289069456
##
File path:
xuefuz commented on a change in pull request #8567:
[FLINK-12676][table][sql-client] Add descriptor, validator, and factory of
GenericInMemoryCatalog for table discovery service
URL: https://github.com/apache/flink/pull/8567#discussion_r289068202
##
File path:
zhijiangW commented on a change in pull request #8320:
[FLINK-12201][network,metrics] Introduce InputGateWithMetrics in Task to
increment numBytesIn metric
URL: https://github.com/apache/flink/pull/8320#discussion_r289016052
##
File path:
zhijiangW commented on issue #8518: [FLINK-12564][network] Remove
getBufferProvider method from ResultPartitionWriter
URL: https://github.com/apache/flink/pull/8518#issuecomment-497348585
@zentol Thanks for reviews and I pushed a fixup commit for removing
`getBufferProvider` from
zhijiangW commented on a change in pull request #8518: [FLINK-12564][network]
Remove getBufferProvider method from ResultPartitionWriter
URL: https://github.com/apache/flink/pull/8518#discussion_r289011719
##
File path:
dianfu commented on issue #8474: [FLINK-12409][python] Adds from_elements in
TableEnvironment
URL: https://github.com/apache/flink/pull/8474#issuecomment-497346537
@sunjincheng121 Thanks a lot for your review. Have updated the PR
accordingly.
dianfu commented on a change in pull request #8474: [FLINK-12409][python] Adds
from_elements in TableEnvironment
URL: https://github.com/apache/flink/pull/8474#discussion_r289010188
##
File path: docs/ops/cli.md
##
@@ -100,40 +100,40 @@ These examples about how to submit
1 - 100 of 216 matches
Mail list logo
