[
https://issues.apache.org/jira/browse/FLINK-7463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
boshu Zheng reassigned FLINK-7463:
--
Assignee: boshu Zheng
> Release nascent workers on slot request timeout
> ---
hequn8128 commented on issue #7209: [FLINK-10977][table] Add UnBounded
FlatAggregate operator to streaming Table API
URL: https://github.com/apache/flink/pull/7209#issuecomment-450305587
@dianfu Thanks a lot for the review. I have addressed your comments and
rebased to the latest master.
hequn8128 commented on a change in pull request #7373: [FLINK-11227] [table]
The DescriptorProperties contains some bounds checking errors
URL: https://github.com/apache/flink/pull/7373#discussion_r244271361
##
File path:
flink-libraries/flink-table/src/test/scala/org/apache/flink/
hequn8128 commented on a change in pull request #7373: [FLINK-11227] [table]
The DescriptorProperties contains some bounds checking errors
URL: https://github.com/apache/flink/pull/7373#discussion_r244271571
##
File path:
flink-libraries/flink-table/src/test/scala/org/apache/flink/
leesf opened a new pull request #7376: [hotfix] fix ParentFirstClassLoader desc
URL: https://github.com/apache/flink/pull/7376
## What is the purpose of the change
Fix ParentFirstClassLoader desc
## Brief change log
Fix ParentFirstClassLoader desc
## Does
[
https://issues.apache.org/jira/browse/FLINK-11226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16730062#comment-16730062
]
vinoyang commented on FLINK-11226:
--
[~hequn8128] Agree with the idea of adding {{getKey
[
https://issues.apache.org/jira/browse/FLINK-11226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-11226:
Assignee: vinoyang
> Lack of getKeySelector in Scala KeyedStream API unlike Java KeyedStream
> --
[
https://issues.apache.org/jira/browse/FLINK-11175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11175:
---
Labels: pull-request-available (was: )
> The sample code describing the Processing time use
wenhuitang opened a new pull request #7375: [FLINK-11175][docs] Fix the sample
code describing the Processing tim…
URL: https://github.com/apache/flink/pull/7375
## What is the purpose of the change
This pull request corrects the sample code in Time Attributes docs.
## Bri
[
https://issues.apache.org/jira/browse/FLINK-6800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
boshu Zheng reassigned FLINK-6800:
--
Assignee: boshu Zheng
> PojoSerializer ignores added pojo fields
> ---
[
https://issues.apache.org/jira/browse/FLINK-11173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11173:
---
Labels: pull-request-available (was: )
> Proctime attribute validation throws an incorrect
wenhuitang opened a new pull request #7374: [FLINK-11173][table] Fix the
exception message of proctime attribute validation in
TableSourceUtil#validateTableSource
URL: https://github.com/apache/flink/pull/7374
## What is the purpose of the change
This pull request makes the exc
[
https://issues.apache.org/jira/browse/FLINK-11225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dongtingting updated FLINK-11225:
-
Description:
Dispatcher was revoked leadership and immediately grant leadership in some
cases l
shuiqiangchen commented on issue #7370: [FLINK-11161]Unable to import java
packages in scala-shell
URL: https://github.com/apache/flink/pull/7370#issuecomment-450272888
Hi, @hequn8128 I have updated codes according to your valuable
suggestions.Thanks a lot!
--
hequn8128 commented on a change in pull request #7370: [FLINK-11161]Unable to
import java packages in scala-shell
URL: https://github.com/apache/flink/pull/7370#discussion_r244248196
##
File path:
flink-scala-shell/src/test/scala/org/apache/flink/api/scala/ScalaShellITCase.scala
#
hequn8128 commented on a change in pull request #7370: [FLINK-11161]Unable to
import java packages in scala-shell
URL: https://github.com/apache/flink/pull/7370#discussion_r244248189
##
File path:
flink-scala-shell/src/test/scala/org/apache/flink/api/scala/ScalaShellITCase.scala
#
hequn8128 commented on a change in pull request #7370: [FLINK-11161]Unable to
import java packages in scala-shell
URL: https://github.com/apache/flink/pull/7370#discussion_r244248193
##
File path:
flink-scala-shell/src/test/scala/org/apache/flink/api/scala/ScalaShellITCase.scala
#
hequn8128 commented on a change in pull request #7370: [FLINK-11161]Unable to
import java packages in scala-shell
URL: https://github.com/apache/flink/pull/7370#discussion_r244248203
##
File path:
flink-scala-shell/src/test/scala/org/apache/flink/api/scala/ScalaShellITCase.scala
#
xccui commented on issue #7373: [FLINK-11227] [table] The DescriptorProperties
contains some bounds checking errors
URL: https://github.com/apache/flink/pull/7373#issuecomment-450170942
Thanks again for your reminding me of the bug in
`validateFixedIndexedProperties()`, @hequn8128. I wonde
[
https://issues.apache.org/jira/browse/FLINK-11227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11227:
---
Labels: pull-request-available (was: )
> The DescriptorProperties contains some bounds chec
xccui opened a new pull request #7373: [FLINK-11227] [table] The
DescriptorProperties contains some bounds checking errors
URL: https://github.com/apache/flink/pull/7373
## What is the purpose of the change
This PR aims to fix the bounds checking errors for
`validateFixedIndexedProp
Xingcan Cui created FLINK-11227:
---
Summary: The DescriptorProperties contains some bounds checking
errors
Key: FLINK-11227
URL: https://issues.apache.org/jira/browse/FLINK-11227
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-11220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16729631#comment-16729631
]
Xingcan Cui commented on FLINK-11220:
-
Hi [~sunjincheng121] and [~jark], I admit tha
[
https://issues.apache.org/jira/browse/FLINK-11226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16729620#comment-16729620
]
Hequn Cheng commented on FLINK-11226:
-
[~albert.bik...@gmail.com] Thanks for reporti
[
https://issues.apache.org/jira/browse/FLINK-10783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10783:
---
Labels: pull-request-available (was: )
> Update WindowOperatorMigrationTest for 1.7
> -
kisimple opened a new pull request #7372: [FLINK-10783] Update
WindowOperatorMigrationTest for 1.7
URL: https://github.com/apache/flink/pull/7372
## What is the purpose of the change
This pull request updates `WindowOperatorMigrationTest` for 1.7
## Brief change log
-
[
https://issues.apache.org/jira/browse/FLINK-11220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16729569#comment-16729569
]
sunjincheng commented on FLINK-11220:
-
Thanks for your reply [~jark] , [~xccui] ！
klion26 commented on issue #7351: [FLINK-11008][State Backends,
Checkpointing]SpeedUp upload state files using multithread
URL: https://github.com/apache/flink/pull/7351#issuecomment-450139159
@azagrebin thank you for your reviewing, today I have some other urgent
things to do in my compan
Albert Bikeev created FLINK-11226:
-
Summary: Lack of getKeySelector in Scala KeyedStream API unlike
Java KeyedStream
Key: FLINK-11226
URL: https://issues.apache.org/jira/browse/FLINK-11226
Project: Fl
[
https://issues.apache.org/jira/browse/FLINK-11226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Albert Bikeev updated FLINK-11226:
--
Description:
There is no simple way to access key via Scala KeyedStream API because there is
[
https://issues.apache.org/jira/browse/FLINK-11225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16729531#comment-16729531
]
TisonKun commented on FLINK-11225:
--
Hi [~dongtingting8...@163.com], this issue is likel
[
https://issues.apache.org/jira/browse/FLINK-10333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16729516#comment-16729516
]
TisonKun commented on FLINK-10333:
--
Following the ZK transaction idea, I drafted a desi
[
https://issues.apache.org/jira/browse/FLINK-10333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TisonKun updated FLINK-10333:
-
Comment: was deleted
(was: Diving into this issue, it is quite tricky that we'd better list what
proble
[
https://issues.apache.org/jira/browse/FLINK-10333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TisonKun updated FLINK-10333:
-
Comment: was deleted
(was: [~StephanEwen] infer your original proposal is to make lock and fencing
toke
[
https://issues.apache.org/jira/browse/FLINK-10333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TisonKun updated FLINK-10333:
-
Comment: was deleted
(was: Hi [~StephanEwen] and [~till.rohrmann]
With an offline discuss with [~xiaoga
[
https://issues.apache.org/jira/browse/FLINK-11224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11224:
---
Labels: pull-request-available (was: )
> Log is missing in scala-shell
> --
zjffdu opened a new pull request #7371: [FLINK-11224][scala-shell] Log is
missing in scala-shell
URL: https://github.com/apache/flink/pull/7371
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than
[
https://issues.apache.org/jira/browse/FLINK-11225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dongtingting updated FLINK-11225:
-
Description:
Dispatcher was revoked leadership and immediately grant leadership in some
cases l
dongtingting created FLINK-11225:
Summary: Error state of addedJobGraphs when Dispatcher with
concurrent revoking and granting leadership
Key: FLINK-11225
URL: https://issues.apache.org/jira/browse/FLINK-11225
Jeff Zhang created FLINK-11224:
--
Summary: Log is missing in scala-shell
Key: FLINK-11224
URL: https://issues.apache.org/jira/browse/FLINK-11224
Project: Flink
Issue Type: Bug
Component
[
https://issues.apache.org/jira/browse/FLINK-11224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang reassigned FLINK-11224:
--
Assignee: Jeff Zhang
> Log is missing in scala-shell
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-10594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16729453#comment-16729453
]
bupt_ljy commented on FLINK-10594:
--
[~dawidwys]
Hi, sorry for providing the tech desig
[
https://issues.apache.org/jira/browse/FLINK-10724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16729447#comment-16729447
]
vinoyang commented on FLINK-10724:
--
Hi [~azagrebin] I have modified the design documen
43 matches
Mail list logo
