tzulitai commented on issue #7421: [FLINK-11167][runtime] Optimize
RocksDBListState#Put by removing the clear before put operation when input is
not empty
URL: https://github.com/apache/flink/pull/7421#issuecomment-452206110
Hi @klion26, the failing test is actually caused by this:
https:
klion26 commented on issue #7421: [FLINK-11167][runtime] Optimize
RocksDBListState#Put by removing the clear before put operation when input is
not empty
URL: https://github.com/apache/flink/pull/7421#issuecomment-452204524
Seems the failed tests are relevant, I'll dig into it.
--
yanghua commented on issue #7265: [FLINK-10964] SQL-client throws exception
when paging through finished batch query
URL: https://github.com/apache/flink/pull/7265#issuecomment-452201727
Travis CI failed due to FLINK-11280. cc @twalthr
-
XuQianJin-Stars commented on issue #7426: [FLINK-11279][Table API & SQL]The bug
of Error parsing ExpressionParser
URL: https://github.com/apache/flink/pull/7426#issuecomment-452197451
hi @xueyumusic can leave a contact information to add a friend?
Best，
qianjin
--
[
https://issues.apache.org/jira/browse/FLINK-10853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang closed FLINK-10853.
Resolution: Won't Do
> Provide end-to-end test for Kafka 0.9 connector
> -
yanghua commented on issue #7081: [FLINK-10853] Provide end-to-end test for
Kafka 0.9 connector
URL: https://github.com/apache/flink/pull/7081#issuecomment-452196810
@pnowojski Providing e2e tests for the 0.9/0.8 connector requires a lot of
changes to the scripts, and I don't plan to provi
yanghua closed pull request #7081: [FLINK-10853] Provide end-to-end test for
Kafka 0.9 connector
URL: https://github.com/apache/flink/pull/7081
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As t
[
https://issues.apache.org/jira/browse/FLINK-11281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
BoWang closed FLINK-11281.
--
Resolution: Duplicate
> Two test in StateBackendMigrationTestBase failes
> ---
[
https://issues.apache.org/jira/browse/FLINK-10854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang closed FLINK-10854.
Resolution: Won't Do
> Provide end-to-end test for Kafka 0.8 connector
> -
[
https://issues.apache.org/jira/browse/FLINK-11281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16736815#comment-16736815
]
BoWang commented on FLINK-11281:
Ok, this is a duplicated issue, I will close it.
> Two
[
https://issues.apache.org/jira/browse/FLINK-11281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16736812#comment-16736812
]
Tzu-Li (Gordon) Tai commented on FLINK-11281:
-
If you agree, can you close t
[
https://issues.apache.org/jira/browse/FLINK-9924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-9924:
---
Assignee: leesf (was: vinoyang)
> Upgrade zookeeper to 3.4.13
> ---
>
>
XuQianJin-Stars commented on issue #7426: [FLINK-11279][Table API & SQL]The bug
of Error parsing ExpressionParser
URL: https://github.com/apache/flink/pull/7426#issuecomment-452195525
hi @sunjincheng121
thankyou， Thanks for reminding me that I forgot to clean up the PR before
Best，
[
https://issues.apache.org/jira/browse/FLINK-10473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16736806#comment-16736806
]
Ben Manes commented on FLINK-10473:
---
FYI, Caffeine's expiration support is either a ti
[
https://issues.apache.org/jira/browse/FLINK-11281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16736809#comment-16736809
]
Tzu-Li (Gordon) Tai commented on FLINK-11281:
-
Hi, this would be a duplicate
BoWang created FLINK-11281:
--
Summary: Two test in StateBackendMigrationTestBase failes
Key: FLINK-11281
URL: https://issues.apache.org/jira/browse/FLINK-11281
Project: Flink
Issue Type: Bug
Tzu-Li (Gordon) Tai created FLINK-11280:
---
Summary: RocksDBSerializedCompositeKeyBuilder's key serializer is
not being reconfigured properly
Key: FLINK-11280
URL: https://issues.apache.org/jira/browse/FLINK-1
[
https://issues.apache.org/jira/browse/FLINK-11280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16736804#comment-16736804
]
Tzu-Li (Gordon) Tai commented on FLINK-11280:
-
I think the same goes for som
[
https://issues.apache.org/jira/browse/FLINK-11280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-11280:
Priority: Critical (was: Major)
> RocksDBSerializedCompositeKeyBuilder's key seri
[
https://issues.apache.org/jira/browse/FLINK-10961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16736798#comment-16736798
]
vinoyang commented on FLINK-10961:
--
[~avilevi] It is strange. In my test scenario, it d
sunjincheng121 commented on issue #7426: [FLINK-11279][Table API & SQL]The bug
of Error parsing ExpressionParser
URL: https://github.com/apache/flink/pull/7426#issuecomment-452188428
Hi @XuQianJin-Stars Thanks for the PR. Please clean up the PR summary. You
can refer to the PR example th
xueyumusic commented on issue #7426: [FLINK-11279][Table API & SQL]The bug of
Error parsing ExpressionParser
URL: https://github.com/apache/flink/pull/7426#issuecomment-452184779
LGTM, it is a bug and the test didn't cover..thanks, @XuQianJin-Stars
lamber-ken commented on issue #7340: [FLINK-11174] [prometheus] Flink Metrics
Prometheus label values supp…
URL: https://github.com/apache/flink/pull/7340#issuecomment-452182956
@TisonKun , +1, it's useful for me too.
This is
TisonKun commented on issue #7285: [hotfix] [resource manager] Remove
legacy(unused) class ResourceManag…
URL: https://github.com/apache/flink/pull/7285#issuecomment-452182002
cc @tillrohrmann @GJL
This is an automated mess
TisonKun opened a new pull request #7427: [hotfix] [test] Reduce test timeout
to a reasonable value
URL: https://github.com/apache/flink/pull/7427
## What is the purpose of the change
Test timeout in `AbstractQueryableStateTestBase` is set to `1 seconds`,
but maven test will fai
[
https://issues.apache.org/jira/browse/FLINK-11231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16736746#comment-16736746
]
sunjincheng commented on FLINK-11231:
-
Hi [~aljoscha], I see the `DataStram.scala `
[
https://issues.apache.org/jira/browse/FLINK-11161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-11161.
---
Resolution: Fixed
Fix Version/s: 1.8.0
Fixed in master: 79f317026bcf8f5829ed32f592c91aa2a99a4
asfgit closed pull request #7370: [FLINK-11161]Unable to import java packages
in scala-shell
URL: https://github.com/apache/flink/pull/7370
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this
XuQianJin-Stars opened a new pull request #7426: [FLINK-11279][Table API &
SQL]The bug of Error parsing ExpressionParser
URL: https://github.com/apache/flink/pull/7426
## What is the purpose of the change
*(This PR is designed to solve the problem of The bug of Error parsing
Express
[
https://issues.apache.org/jira/browse/FLINK-11279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11279:
---
Labels: pull-request-available (was: )
> The bug of Error parsing ExpressionParser
> --
[
https://issues.apache.org/jira/browse/FLINK-11279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xuqianjin updated FLINK-11279:
--
Attachment: (was: 微信截图_20190108123404.png)
> The bug of Error parsing ExpressionParser
> -
[
https://issues.apache.org/jira/browse/FLINK-11279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xuqianjin updated FLINK-11279:
--
Attachment: 20190108123404.png
> The bug of Error parsing ExpressionParser
> -
xuqianjin created FLINK-11279:
-
Summary: The bug of Error parsing ExpressionParser
Key: FLINK-11279
URL: https://issues.apache.org/jira/browse/FLINK-11279
Project: Flink
Issue Type: Task
Myasuka commented on a change in pull request #7009: [FLINK-10712] Support to
restore state when using RestartPipelinedRegionStrategy
URL: https://github.com/apache/flink/pull/7009#discussion_r245872618
##
File path:
flink-connectors/flink-connector-filesystem/src/test/java/org/apa
eaglewatcherwb commented on a change in pull request #7412:
[FLINK-10866][Runtime] 1. Explicitly enable qs server and proxy. 2. QS
URL: https://github.com/apache/flink/pull/7412#discussion_r245865984
##
File path:
flink-core/src/main/java/org/apache/flink/configuration/QueryableSta
[
https://issues.apache.org/jira/browse/FLINK-11264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16736658#comment-16736658
]
sunjincheng commented on FLINK-11264:
-
Should be fixed in FLINK-11161.
> Fail to st
[
https://issues.apache.org/jira/browse/FLINK-11082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16736665#comment-16736665
]
zhijiang commented on FLINK-11082:
--
[~NicoK] yes, these two features are in parallel fo
[
https://issues.apache.org/jira/browse/FLINK-11082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16736663#comment-16736663
]
zhijiang commented on FLINK-11082:
--
[~pnowojski], your understanding is right. It might
[
https://issues.apache.org/jira/browse/FLINK-11278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei Zhong reassigned FLINK-11278:
-
Assignee: Wei Zhong
> Add documentation for TableAPI&SQL in scala-shell
> -
sunjincheng created FLINK-11278:
---
Summary: Add documentation for TableAPI&SQL in scala-shell
Key: FLINK-11278
URL: https://issues.apache.org/jira/browse/FLINK-11278
Project: Flink
Issue Type: I
[
https://issues.apache.org/jira/browse/FLINK-10848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16736636#comment-16736636
]
Truong Duc Kien commented on FLINK-10848:
-
Yarn can return more containers than
klion26 opened a new pull request #7421: [FLINK-11167][runtime] Optimize
RocksDBListState#Put by removing the clear before put operation when input is
not empty
URL: https://github.com/apache/flink/pull/7421
## What is the purpose of the change
This pull request adjusts the clear's posi
klion26 closed pull request #7421: [FLINK-11167][runtime] Optimize
RocksDBListState#Put by removing the clear before put operation when input is
not empty
URL: https://github.com/apache/flink/pull/7421
This is a PR merged from a forked repository.
As GitHub hides the original diff on mer
klion26 commented on a change in pull request #7412: [FLINK-10866][Runtime] 1.
Explicitly enable qs server and proxy. 2. QS
URL: https://github.com/apache/flink/pull/7412#discussion_r245860682
##
File path:
flink-core/src/main/java/org/apache/flink/configuration/QueryableStateOptio
leesf commented on issue #7415: [hotfix][docs] fix typo in
addShutdownHookThread Javadoc
URL: https://github.com/apache/flink/pull/7415#issuecomment-452146491
Thanks for your reviewing @dawidwys. Updated the pr according to your
comment.
---
[
https://issues.apache.org/jira/browse/FLINK-11230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jiwei closed FLINK-11230.
-
Resolution: Fixed
> Sum of FlinkSql after two table union all.The value is too large.
>
[
https://issues.apache.org/jira/browse/FLINK-11230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jiwei updated FLINK-11230:
--
Fix Version/s: 1.7.0
> Sum of FlinkSql after two table union all.The value is too large.
> ---
hequn8128 commented on a change in pull request #7418: FLINK-11053
Documentation - update scala sample code for bucketing sink according
URL: https://github.com/apache/flink/pull/7418#discussion_r245853342
##
File path: docs/dev/connectors/filesystem_sink.md
##
@@ -117,11
vinoyang created FLINK-11277:
Summary: Queryable state IT test failed
Key: FLINK-11277
URL: https://issues.apache.org/jira/browse/FLINK-11277
Project: Flink
Issue Type: New Feature
Comp
sunjincheng121 commented on issue #7370: [FLINK-11161]Unable to import java
packages in scala-shell
URL: https://github.com/apache/flink/pull/7370#issuecomment-452134928
Thanks for the PR @shuiqiangchen !
LGTM. I will be merged the PR with small improvement.
Thanks,
Jincheng
[
https://issues.apache.org/jira/browse/FLINK-11276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-11276:
--
Affects Version/s: 1.7.0
> Slicing Window Optimization
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-11276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-11276:
--
Component/s: DataStream API
> Slicing Window Optimization
> ---
>
>
Rong Rong created FLINK-11276:
-
Summary: Slicing Window Optimization
Key: FLINK-11276
URL: https://issues.apache.org/jira/browse/FLINK-11276
Project: Flink
Issue Type: New Feature
Rep
[
https://issues.apache.org/jira/browse/FLINK-11276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong reassigned FLINK-11276:
-
Assignee: Rong Rong
> Slicing Window Optimization
> ---
>
>
Xuefu Zhang created FLINK-11275:
---
Summary: Unified Catalog APIs
Key: FLINK-11275
URL: https://issues.apache.org/jira/browse/FLINK-11275
Project: Flink
Issue Type: Improvement
Componen
sunjincheng121 commented on a change in pull request #7209:
[FLINK-10977][table] Add UnBounded FlatAggregate operator to streaming Table API
URL: https://github.com/apache/flink/pull/7209#discussion_r245833269
##
File path: docs/dev/table/tableApi.md
##
@@ -550,6 +550,82 @
sunjincheng121 commented on a change in pull request #7209:
[FLINK-10977][table] Add UnBounded FlatAggregate operator to streaming Table API
URL: https://github.com/apache/flink/pull/7209#discussion_r245833136
##
File path: docs/dev/table/tableApi.md
##
@@ -550,6 +550,82 @
sunjincheng121 commented on a change in pull request #7209:
[FLINK-10977][table] Add UnBounded FlatAggregate operator to streaming Table API
URL: https://github.com/apache/flink/pull/7209#discussion_r245831969
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flin
[
https://issues.apache.org/jira/browse/FLINK-11273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-11273.
--
Resolution: Fixed
Merged in:
master: 0b28bfd0d9
> Queryable state (rocksdb) end-to-end test f
AlphaGarden commented on a change in pull request #7312:
[FLINK-11169][runtime] fix the problem of not being reloaded for jobmanager's…
URL: https://github.com/apache/flink/pull/7312#discussion_r245770156
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/hand
EugeneYushin commented on a change in pull request #6760: [FLINK-10422] Follow
AWS specs in Kinesis Consumer
URL: https://github.com/apache/flink/pull/6760#discussion_r245743712
##
File path:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connecto
Zhenhao Li created FLINK-11274:
--
Summary: Scala 2.12 Kryo serialization bug
Key: FLINK-11274
URL: https://issues.apache.org/jira/browse/FLINK-11274
Project: Flink
Issue Type: Bug
Affects Ver
tweise commented on a change in pull request #6760: [FLINK-10422] Follow AWS
specs in Kinesis Consumer
URL: https://github.com/apache/flink/pull/6760#discussion_r245740267
##
File path:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kin
EugeneYushin commented on a change in pull request #6760: [FLINK-10422] Follow
AWS specs in Kinesis Consumer
URL: https://github.com/apache/flink/pull/6760#discussion_r245738557
##
File path:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connecto
EugeneYushin commented on a change in pull request #6760: [FLINK-10422] Follow
AWS specs in Kinesis Consumer
URL: https://github.com/apache/flink/pull/6760#discussion_r245738557
##
File path:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connecto
EugeneYushin commented on a change in pull request #6760: [FLINK-10422] Follow
AWS specs in Kinesis Consumer
URL: https://github.com/apache/flink/pull/6760#discussion_r245738168
##
File path:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connecto
[
https://issues.apache.org/jira/browse/FLINK-10742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16736088#comment-16736088
]
Nico Kruber commented on FLINK-10742:
-
Thanks [~gaoyunhaii] for the proposal and the
[
https://issues.apache.org/jira/browse/FLINK-9457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9457:
--
Labels: pull-request-available (was: )
> Cancel container requests when cancelling pending slo
kisimple opened a new pull request #7425: [FLINK-9457][ResourceManager][YARN]
Cancel container requests when canceling pending slot allocations
URL: https://github.com/apache/flink/pull/7425
## What is the purpose of the change
This PR cancels container requests when canceling pendin
[
https://issues.apache.org/jira/browse/FLINK-11127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16736052#comment-16736052
]
seye commented on FLINK-11127:
--
Our team found another solution that worked. These are the
[
https://issues.apache.org/jira/browse/FLINK-11187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16735999#comment-16735999
]
Kostas Kloudas commented on FLINK-11187:
Hi [~addis...@gmail.com] and [~ste...@a
[
https://issues.apache.org/jira/browse/FLINK-11273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter reassigned FLINK-11273:
--
Assignee: Stefan Richter
> Queryable state (rocksdb) end-to-end test fails
>
tweise commented on a change in pull request #6760: [FLINK-10422] Follow AWS
specs in Kinesis Consumer
URL: https://github.com/apache/flink/pull/6760#discussion_r245701984
##
File path:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kin
[
https://issues.apache.org/jira/browse/FLINK-10848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16735965#comment-16735965
]
Till Rohrmann commented on FLINK-10848:
---
Update, so far I was not able to reproduc
[
https://issues.apache.org/jira/browse/FLINK-11189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-11189.
Resolution: Fixed
Fix Version/s: (was: 1.7.0)
1.8.0
Fixed on
aljoscha commented on issue #7350: [FLINK-11189] Deprecated documentation for
readSequenceFile function
URL: https://github.com/apache/flink/pull/7350#issuecomment-451975941
Thanks for your contribution! I merged this
This is
aljoscha closed pull request #7350: [FLINK-11189] Deprecated documentation for
readSequenceFile function
URL: https://github.com/apache/flink/pull/7350
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenanc
[
https://issues.apache.org/jira/browse/FLINK-11270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16735958#comment-16735958
]
Aljoscha Krettek commented on FLINK-11270:
--
Yay 🥳
> Do not include hadoop in f
Timo Walther created FLINK-11273:
Summary: Queryable state (rocksdb) end-to-end test fails
Key: FLINK-11273
URL: https://issues.apache.org/jira/browse/FLINK-11273
Project: Flink
Issue Type: B
[
https://issues.apache.org/jira/browse/FLINK-11268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16735956#comment-16735956
]
Aljoscha Krettek commented on FLINK-11268:
--
Should we even deploy shaded Hadoop
twalthr commented on a change in pull request #7409: [FLINK-11064] [table]
Setup a new flink-table module structure
URL: https://github.com/apache/flink/pull/7409#discussion_r245685916
##
File path: flink-table/flink-table-api-java/pom.xml
##
@@ -0,0 +1,77 @@
+
+
+http://m
[
https://issues.apache.org/jira/browse/FLINK-11226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16735912#comment-16735912
]
vinoyang commented on FLINK-11226:
--
[~aljoscha] Although getKeySelector() is not a pub
hequn8128 commented on a change in pull request #7209: [FLINK-10977][table] Add
UnBounded FlatAggregate operator to streaming Table API
URL: https://github.com/apache/flink/pull/7209#discussion_r245673668
##
File path: docs/dev/table/tableApi.md
##
@@ -550,6 +550,82 @@ val
hequn8128 commented on a change in pull request #7209: [FLINK-10977][table] Add
UnBounded FlatAggregate operator to streaming Table API
URL: https://github.com/apache/flink/pull/7209#discussion_r245672971
##
File path: docs/dev/table/tableApi.md
##
@@ -550,6 +550,82 @@ val
hequn8128 commented on a change in pull request #7209: [FLINK-10977][table] Add
UnBounded FlatAggregate operator to streaming Table API
URL: https://github.com/apache/flink/pull/7209#discussion_r245671247
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/tab
kl0u commented on issue #7287: [FLINK-11140][streaming] Fix empty child path
check in Buckets
URL: https://github.com/apache/flink/pull/7287#issuecomment-451951504
@Matrix42 I have reviewed your PR and I have some comments. Given that the
PR is closed and I cannot submit a review, I pushed
[
https://issues.apache.org/jira/browse/FLINK-10848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16735880#comment-16735880
]
Till Rohrmann commented on FLINK-10848:
---
My guess would be that we get a different
aljoscha commented on a change in pull request #7312: [FLINK-11169][runtime]
fix the problem of not being reloaded for jobmanager's…
URL: https://github.com/apache/flink/pull/7312#discussion_r245669815
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler
[
https://issues.apache.org/jira/browse/FLINK-11169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-11169:
Assignee: Jiayong Mo
> fix the problem of not being reloaded for jobmanager's log
pnowojski commented on a change in pull request #6445: [FLINK-8302] [table] Add
SHIFT_LEFT and SHIFT_RIGHT
URL: https://github.com/apache/flink/pull/6445#discussion_r245056827
##
File path:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/ScalarOperator
pnowojski commented on a change in pull request #6445: [FLINK-8302] [table] Add
SHIFT_LEFT and SHIFT_RIGHT
URL: https://github.com/apache/flink/pull/6445#discussion_r245662829
##
File path:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/ScalarOperator
pnowojski commented on a change in pull request #6445: [FLINK-8302] [table] Add
SHIFT_LEFT and SHIFT_RIGHT
URL: https://github.com/apache/flink/pull/6445#discussion_r245667086
##
File path:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/ScalarOperator
pnowojski commented on a change in pull request #6445: [FLINK-8302] [table] Add
SHIFT_LEFT and SHIFT_RIGHT
URL: https://github.com/apache/flink/pull/6445#discussion_r245664028
##
File path:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/ScalarOperator
StefanRRichter commented on a change in pull request #7009: [FLINK-10712]
Support to restore state when using RestartPipelinedRegionStrategy
URL: https://github.com/apache/flink/pull/7009#discussion_r245663755
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/execu
StefanRRichter commented on a change in pull request #7009: [FLINK-10712]
Support to restore state when using RestartPipelinedRegionStrategy
URL: https://github.com/apache/flink/pull/7009#discussion_r245659768
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/check
StefanRRichter commented on a change in pull request #7009: [FLINK-10712]
Support to restore state when using RestartPipelinedRegionStrategy
URL: https://github.com/apache/flink/pull/7009#discussion_r245657791
##
File path:
flink-connectors/flink-connector-filesystem/src/test/java/
StefanRRichter commented on a change in pull request #7009: [FLINK-10712]
Support to restore state when using RestartPipelinedRegionStrategy
URL: https://github.com/apache/flink/pull/7009#discussion_r245660458
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/check
hequn8128 commented on a change in pull request #7209: [FLINK-10977][table] Add
UnBounded FlatAggregate operator to streaming Table API
URL: https://github.com/apache/flink/pull/7209#discussion_r245668793
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/tab
StefanRRichter commented on a change in pull request #7009: [FLINK-10712]
Support to restore state when using RestartPipelinedRegionStrategy
URL: https://github.com/apache/flink/pull/7009#discussion_r245651506
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/execu
StefanRRichter commented on a change in pull request #7009: [FLINK-10712]
Support to restore state when using RestartPipelinedRegionStrategy
URL: https://github.com/apache/flink/pull/7009#discussion_r245653474
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/check
1 - 100 of 211 matches
Mail list logo
