KurtYoung commented on issue #7996: [FLINK-11871][table-runtime-blink]
Introduce LongHybridHashTable to improve performance when join key fits in long
URL: https://github.com/apache/flink/pull/7996#issuecomment-473506470
cc @JingsongLi
-
flinkbot commented on issue #7996: [FLINK-11871][table-runtime-blink] Introduce
LongHybridHashTable to improve performance when join key fits in long
URL: https://github.com/apache/flink/pull/7996#issuecomment-473506446
Thanks a lot for your contribution to the Apache Flink project. I'm the
KurtYoung opened a new pull request #7996: [FLINK-11871][table-runtime-blink]
Introduce LongHybridHashTable to improve performance when join key fits in long
URL: https://github.com/apache/flink/pull/7996
## What is the purpose of the change
We can do further optimization
[
https://issues.apache.org/jira/browse/FLINK-11871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11871:
---
Labels: pull-request-available (was: )
> Introduce LongHashTable to improve performance whe
[
https://issues.apache.org/jira/browse/FLINK-11926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16794104#comment-16794104
]
chaiyongqiang commented on FLINK-11926:
---
Let's suppose we hava a watermark with a
KurtYoung commented on issue #7952: [FLINK-11872][table-runtime-blink] update
lz4 license file.
URL: https://github.com/apache/flink/pull/7952#issuecomment-473490315
Thanks @twalthr , since lz4 is widely used in other projects, i would shade
it into `flink-table`.
[
https://issues.apache.org/jira/browse/FLINK-10019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10019:
---
Labels: pull-request-available (was: )
> singleton row type objects returned from sub query
[
https://issues.apache.org/jira/browse/FLINK-10273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10273:
---
Labels: pull-request-available (was: )
> Access composite type fields after a function
> --
flinkbot commented on issue #7995: [FLINK-10019][SQL/Planner] Fix singleton row
type objects returned from expression cannot be chained with other operators
URL: https://github.com/apache/flink/pull/7995#issuecomment-473488384
Thanks a lot for your contribution to the Apache Flink project.
walterddr opened a new pull request #7994: [FLINK-10273][SQL/Planner] Support
access to sub-fields of a composite type after a function
URL: https://github.com/apache/flink/pull/7994
## What is the purpose of the change
This PR adds tests to ensure that any row expression extensions
walterddr opened a new pull request #7995: [FLINK-10019][SQL/Planner] Fix
singleton row type objects returned from expression cannot be chained with
other operators
URL: https://github.com/apache/flink/pull/7995
## What is the purpose of the change
This PR adds tests to ensure that
flinkbot commented on issue #7994: [FLINK-10273][SQL/Planner] Support access to
sub-fields of a composite type after a function
URL: https://github.com/apache/flink/pull/7994#issuecomment-473488386
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help th
[
https://issues.apache.org/jira/browse/FLINK-10019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-10019:
--
Summary: singleton row type objects returned from sub query cannot be
chained with other operators (w
[
https://issues.apache.org/jira/browse/FLINK-11935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong reassigned FLINK-11935:
-
Assignee: (was: Rong Rong)
> Remove DateTimeUtils pull-in and fix datetime casting problem
[
https://issues.apache.org/jira/browse/FLINK-11936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-11936:
--
Description:
AuxiliaryConverter was pulled in FLINK-6409. Since CALCITE-1761 has been fixed,
we shoul
[
https://issues.apache.org/jira/browse/FLINK-7237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16793957#comment-16793957
]
Rong Rong commented on FLINK-7237:
--
oops. I closed this task as duplicate, but it should
bowenli86 commented on issue #7848: [FLINK-10755][table] Port external catalogs
in Table API extension points to flink-table-common
URL: https://github.com/apache/flink/pull/7848#issuecomment-473416252
@twalthr re: The current catalog APIs are still intended to be used. What my
team is thi
[
https://issues.apache.org/jira/browse/FLINK-11254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16793815#comment-16793815
]
Lakshmi Rao commented on FLINK-11254:
-
Thanks for this effort [~tzulitai] and [~klio
Rong Rong created FLINK-11936:
-
Summary: Remove AuxiliaryConverter pull-in from calcite and fix
auxiliary converter issue.
Key: FLINK-11936
URL: https://issues.apache.org/jira/browse/FLINK-11936
Project:
[
https://issues.apache.org/jira/browse/FLINK-7237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong closed FLINK-7237.
Resolution: Duplicate
> Remove DateTimeUtils from Flink once Calcite is upgraded to 1.14
>
Rong Rong created FLINK-11935:
-
Summary: Remove DateTimeUtils pull-in and fix datetime casting
problem
Key: FLINK-11935
URL: https://issues.apache.org/jira/browse/FLINK-11935
Project: Flink
Issu
[
https://issues.apache.org/jira/browse/FLINK-7235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong closed FLINK-7235.
Resolution: Invalid
> Backport CALCITE-1884 to the Flink repository before Calcite 1.14
> -
[
https://issues.apache.org/jira/browse/FLINK-7235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16793786#comment-16793786
]
Rong Rong commented on FLINK-7235:
--
This {{DateTimeUtils}} is still needed, but in a ver
[
https://issues.apache.org/jira/browse/FLINK-11819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16793760#comment-16793760
]
Lifei Chen commented on FLINK-11819:
Ok, I will close the issue.
Best, Lifei
> Add
[
https://issues.apache.org/jira/browse/FLINK-11819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lifei Chen closed FLINK-11819.
--
Resolution: Won't Do
> Additional attribute for order by not support by flink sql, but told
> support
zhijiangW commented on issue #7963: [FLINK-11885][network] Introduce
RecordWriterBuilder for creating RecordWriter instance
URL: https://github.com/apache/flink/pull/7963#issuecomment-473332804
@pnowojski , I have updated the codes rebased the latest master.
---
[
https://issues.apache.org/jira/browse/FLINK-11933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16793700#comment-16793700
]
Ken Krugler commented on FLINK-11933:
-
Hi thinktothings - please post problems like
tweise commented on issue #7896: [FLINK-9007] [kinesis] [e2e] Add Kinesis
end-to-end test
URL: https://github.com/apache/flink/pull/7896#issuecomment-473308435
@zentol I subscribed to https://github.com/apache/flink/pull/7605 - let me
know once it is far enough and I will port this test.
[
https://issues.apache.org/jira/browse/FLINK-9007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise resolved FLINK-9007.
-
Resolution: Implemented
Fix Version/s: 1.9.0
> End-to-end test: Kinesis connector
> --
hequn8128 edited a comment on issue #7976: [FLINK-11908][table] Port window
classes into flink-api-java
URL: https://github.com/apache/flink/pull/7976#issuecomment-473309642
@twalthr Sorry. I missed the important messages from you. Converting the
ExpressionParser into an interface is a goo
hequn8128 commented on issue #7976: [FLINK-11908][table] Port window classes
into flink-api-java
URL: https://github.com/apache/flink/pull/7976#issuecomment-473309642
@twalthr Sorry. I missed the important messages from you. Convert the
ExpressionParser into an interface is a good solution
[
https://issues.apache.org/jira/browse/FLINK-10912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16793662#comment-16793662
]
Yun Tang edited comment on FLINK-10912 at 3/15/19 2:22 PM:
---
[~
tweise merged pull request #7896: [FLINK-9007] [kinesis] [e2e] Add Kinesis
end-to-end test
URL: https://github.com/apache/flink/pull/7896
This is an automated message from the Apache Git Service.
To respond to the message, p
[
https://issues.apache.org/jira/browse/FLINK-10912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16793662#comment-16793662
]
Yun Tang commented on FLINK-10912:
--
[~ZhenqiuHuang] If you really want to apply this fe
[
https://issues.apache.org/jira/browse/FLINK-9363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9363:
--
Labels: pull-request-available security (was: security)
> Bump up the Jackson version
> --
zhijiangW commented on a change in pull request #7713: [FLINK-10995][network]
Copy intermediate serialization results only once for broadcast mode
URL: https://github.com/apache/flink/pull/7713#discussion_r265996143
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime
zhijiangW commented on a change in pull request #7911: [FLINK-11082][network]
Fix the logic of getting backlog in sub partition
URL: https://github.com/apache/flink/pull/7911#discussion_r265991992
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partiti
pnowojski commented on a change in pull request #7713: [FLINK-10995][network]
Copy intermediate serialization results only once for broadcast mode
URL: https://github.com/apache/flink/pull/7713#discussion_r265990663
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime
[
https://issues.apache.org/jira/browse/FLINK-10912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16793637#comment-16793637
]
Chesnay Schepler commented on FLINK-10912:
--
[~ZhenqiuHuang] no, it is only avai
pnowojski commented on a change in pull request #7911: [FLINK-11082][network]
Fix the logic of getting backlog in sub partition
URL: https://github.com/apache/flink/pull/7911#discussion_r265982238
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partiti
pnowojski commented on a change in pull request #7911: [FLINK-11082][network]
Fix the logic of getting backlog in sub partition
URL: https://github.com/apache/flink/pull/7911#discussion_r265985944
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partiti
zentol commented on issue #7896: [FLINK-9007] [kinesis] [e2e] Add Kinesis
end-to-end test
URL: https://github.com/apache/flink/pull/7896#issuecomment-473288324
I won't block this PR.
This is an automated message from the Apac
twalthr commented on issue #7848: [FLINK-10755][table] Port external catalogs
in Table API extension points to flink-table-common
URL: https://github.com/apache/flink/pull/7848#issuecomment-473287180
@bowenli86 thanks for your suggestion. I agree that the catalog API will
change in the nea
sunjincheng121 commented on issue #7985: [FLINK-11918][table] Deprecated Window
and Rename it to GroupWindow
URL: https://github.com/apache/flink/pull/7985#issuecomment-473286478
Thanks for the reminder @twalthr!
This is an a
pnowojski merged pull request #7989: [hotfix] Deduplicate the common codes in
RecordWriterTest
URL: https://github.com/apache/flink/pull/7989
This is an automated message from the Apache Git Service.
To respond to the messag
[
https://issues.apache.org/jira/browse/FLINK-11918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-11918.
---
Resolution: Fixed
Release Note: The window classes org.apache.flink.table.api.{java,
scala}.{T
ysn2233 commented on a change in pull request #7991: [FLINK-11928][Connectors /
FileSystem]Create a Compression string writer for flink-connectors-filesystem
URL: https://github.com/apache/flink/pull/7991#discussion_r265978795
##
File path:
flink-connectors/flink-connector-filesyst
[
https://issues.apache.org/jira/browse/FLINK-11596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11596:
-
Summary: Remove ResourceManagerTest (was: Check & port ResourceManagerTest
to new code
pnowojski commented on a change in pull request #7959: [FLINK-11876] Introduce
new TwoInputSelectable, BoundedOneInput and BoundedTwoInput interfaces
URL: https://github.com/apache/flink/pull/7959#discussion_r265971160
##
File path:
flink-streaming-java/src/main/java/org/apache/fli
pnowojski commented on a change in pull request #7959: [FLINK-11876] Introduce
new TwoInputSelectable, BoundedOneInput and BoundedTwoInput interfaces
URL: https://github.com/apache/flink/pull/7959#discussion_r265969468
##
File path:
flink-streaming-java/src/main/java/org/apache/fli
[
https://issues.apache.org/jira/browse/FLINK-10912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16793600#comment-16793600
]
Zhenqiu Huang commented on FLINK-10912:
---
Can this feature be used in Flink 1.6 rel
[
https://issues.apache.org/jira/browse/FLINK-10912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16793600#comment-16793600
]
Zhenqiu Huang edited comment on FLINK-10912 at 3/15/19 12:59 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-11549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11549:
-
Summary: Remove ResourceManagerITCase (was: Check and port
ResourceManagerITCase to new
[
https://issues.apache.org/jira/browse/FLINK-11821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11821:
-
Issue Type: Improvement (was: Bug)
> Fix package declaration and location of internal K
[
https://issues.apache.org/jira/browse/FLINK-11514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11514:
-
Summary: Port ClusterClientTest (was: Check and port ClusterClientTest to
new code base
[
https://issues.apache.org/jira/browse/FLINK-11365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11365:
-
Summary: Remove TaskManagerFailureRecoveryITCase (was: Check and port
TaskManagerFailur
[
https://issues.apache.org/jira/browse/FLINK-11367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11367:
-
Summary: Port TaskManagerProcessReapingTestBase (was: Check and port
TaskManagerProcess
[
https://issues.apache.org/jira/browse/FLINK-11364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11364:
-
Summary: Port TaskManagerFailsITCase (was: Check and port
TaskManagerFailsITCase to new
[
https://issues.apache.org/jira/browse/FLINK-11358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11358:
-
Summary: Port LeaderChangeStateCleanupTest to new code base (was: Check
and port Leader
Hequn Cheng created FLINK-11934:
---
Summary: Remove the deprecate methods in TableEnvironment
Key: FLINK-11934
URL: https://issues.apache.org/jira/browse/FLINK-11934
Project: Flink
Issue Type: Ne
[
https://issues.apache.org/jira/browse/FLINK-11587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11587:
-
Summary: Port CoLocationConstraintITCase (was: Check and port
CoLocationConstraintITCas
[
https://issues.apache.org/jira/browse/FLINK-11586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11586:
-
Summary: Remove SlotSharingITCase (was: Check and port SlotSharingITCase
to new code ba
[
https://issues.apache.org/jira/browse/FLINK-11594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11594:
-
Summary: Port TaskManagerRegistrationTest (was: Check & port
TaskManagerRegistrationTes
[
https://issues.apache.org/jira/browse/FLINK-11355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11355:
-
Summary: Port JobManagerProcessReapingTest to new code base (was: Check
and port JobMan
[
https://issues.apache.org/jira/browse/FLINK-11577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11577:
-
Summary: Port StackTraceSampleCoordinatorITCase (was: Check and port
StackTraceSampleCo
[
https://issues.apache.org/jira/browse/FLINK-11354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11354:
-
Summary: Port JobManagerHARecoveryTest to new code base (was: Check and
port JobManager
[
https://issues.apache.org/jira/browse/FLINK-11548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11548:
-
Summary: Remove ClusterShutdownITCase (was: Check and port
ClusterShutdownITCase to new
[
https://issues.apache.org/jira/browse/FLINK-11578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11578:
-
Summary: Port BackPressureStatsTrackerImplITCase (was: Check and port
BackPressureStats
[
https://issues.apache.org/jira/browse/FLINK-11515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11515:
-
Summary: Port ClientTest (was: Check and port ClientTest to new code base
if necessary)
[
https://issues.apache.org/jira/browse/FLINK-11527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11527:
-
Fix Version/s: (was: 1.8.0)
> Support multiple languages for the framework of flink-
[
https://issues.apache.org/jira/browse/FLINK-11370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11370:
-
Summary: Port ZooKeeperLeaderElectionITCase (was: Check and port
ZooKeeperLeaderElectio
[
https://issues.apache.org/jira/browse/FLINK-11362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11362:
-
Summary: Port TaskManagerComponentsStartupShutdownTest (was: Check and
port TaskManager
[
https://issues.apache.org/jira/browse/FLINK-11363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11363:
-
Summary: Port TaskManagerConfigurationTest (was: Check and remove
TaskManagerConfigurat
[
https://issues.apache.org/jira/browse/FLINK-11358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11358:
-
Summary: Port LeaderChangeStateCleanupTest (was: Port
LeaderChangeStateCleanupTest to n
[
https://issues.apache.org/jira/browse/FLINK-11360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11360:
-
Summary: Remove LocalFlinkMiniClusterITCase (was: Check and remove
LocalFlinkMiniCluste
[
https://issues.apache.org/jira/browse/FLINK-11356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11356:
-
Summary: Port JobManagerStartupTest to new code base (was: Check and port
JobManagerSta
[
https://issues.apache.org/jira/browse/FLINK-11357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11357:
-
Summary: Remove LeaderChangeJobRecoveryTest (was: Check and port
LeaderChangeJobRecover
[
https://issues.apache.org/jira/browse/FLINK-11918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-11918:
-
Component/s: (was: API / DataStream)
API / Table SQL
> Deprecated Window an
[
https://issues.apache.org/jira/browse/FLINK-11353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11353:
-
Summary: Port JobManagerHAJobGraphRecoveryITCase to new code base (was:
Check & port Jo
[
https://issues.apache.org/jira/browse/FLINK-11352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11352:
-
Summary: Port JobManagerHACheckpointRecoveryITCase to new code base (was:
Check and por
twalthr commented on issue #7952: [FLINK-11872][table-runtime-blink] update lz4
license file.
URL: https://github.com/apache/flink/pull/7952#issuecomment-473270208
@KurtYoung Currently, we shade everything for the `flink-table` package
except for Calcite and Janino. Calcite could not be sh
[
https://issues.apache.org/jira/browse/FLINK-11134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11134:
-
Issue Type: Improvement (was: Bug)
> Invalid REST API request should not log the full e
[
https://issues.apache.org/jira/browse/FLINK-11256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11256:
-
Issue Type: Improvement (was: Bug)
> Referencing StreamNode objects directly in StreamE
[
https://issues.apache.org/jira/browse/FLINK-11781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11781:
-
Summary: Reject "DISABLED" as value for
yarn.per-job-cluster.include-user-jar (was: Con
[
https://issues.apache.org/jira/browse/FLINK-11867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11867:
-
Component/s: API / DataStream
> Fix empty path check in StreamExEnv#readTextFile
> -
[
https://issues.apache.org/jira/browse/FLINK-11867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11867:
-
Summary: Fix empty path check in StreamExEnv#readTextFile (was: mistaking
in checking f
[
https://issues.apache.org/jira/browse/FLINK-11819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16793592#comment-16793592
]
Xingcan Cui commented on FLINK-11819:
-
Hi [~hequn8128] and [~hustclf], sorry for the
[
https://issues.apache.org/jira/browse/FLINK-11655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11655:
-
Issue Type: Improvement (was: Bug)
> Remove `Serializable` interface from `CallAsync`
>
[
https://issues.apache.org/jira/browse/FLINK-10586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-10586:
-
Fix Version/s: (was: 1.8.0)
> Running RestServerEndpointITCase may cause Kernel Pani
[
https://issues.apache.org/jira/browse/FLINK-11343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11343:
-
Issue Type: Improvement (was: Bug)
> TaskExecutorTest is unstable on travis
> -
lamber-ken commented on issue #7987: [FLINK-11820][serialization]
SimpleStringSchema handle message record which value is null
URL: https://github.com/apache/flink/pull/7987#issuecomment-473268359
@klion26, I see, thanks.
Thi
[
https://issues.apache.org/jira/browse/FLINK-11302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11302:
-
Summary: FlinkS3FileSystem uses an incorrect path for temporary files
(was: FlinkS3File
[
https://issues.apache.org/jira/browse/FLINK-11343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16793589#comment-16793589
]
Chesnay Schepler commented on FLINK-11343:
--
master: 28cccde59abd08289c3ec553637
[
https://issues.apache.org/jira/browse/FLINK-11293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11293:
-
Issue Type: Improvement (was: Bug)
> KafkaITCase.testConcurrentProducerConsumerTopology
[
https://issues.apache.org/jira/browse/FLINK-11168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11168:
-
Issue Type: Improvement (was: Bug)
> LargePlanTest times out on Travis
> --
[
https://issues.apache.org/jira/browse/FLINK-11185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11185:
-
Issue Type: Improvement (was: Bug)
> StreamSourceOperatorWatermarksTest failed with Int
[
https://issues.apache.org/jira/browse/FLINK-11163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11163:
-
Issue Type: Improvement (was: Bug)
> RestClusterClientTest#testSendIsNotRetriableIfHttp
[
https://issues.apache.org/jira/browse/FLINK-11450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11450:
-
Issue Type: Improvement (was: New Feature)
> Port and move TableSource and TableSink to
[
https://issues.apache.org/jira/browse/FLINK-11451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11451:
-
Issue Type: Improvement (was: New Feature)
> Move *QueryConfig and TableDescriptor to f
[
https://issues.apache.org/jira/browse/FLINK-11044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11044:
-
Issue Type: Bug (was: Improvement)
> RegisterTableSink docs incorrect
> ---
1 - 100 of 273 matches
Mail list logo
