[
https://issues.apache.org/jira/browse/FLINK-11160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-11160.
Resolution: Duplicate
> Confluent Avro Serialization Schema
> ---
[
https://issues.apache.org/jira/browse/FLINK-11451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11451:
---
Labels: pull-request-available (was: )
> Move *QueryConfig and TableDescriptor to flink-tab
[
https://issues.apache.org/jira/browse/FLINK-11409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16757282#comment-16757282
]
Kezhu Wang commented on FLINK-11409:
[~aljoscha] [~dawidwys] I would like to present
[
https://issues.apache.org/jira/browse/FLINK-11451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16757275#comment-16757275
]
xueyu edited comment on FLINK-11451 at 1/31/19 2:24 PM:
Hi, [~he
[
https://issues.apache.org/jira/browse/FLINK-11451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16757275#comment-16757275
]
xueyu commented on FLINK-11451:
---
Hi, [~hequn8128] [~twalthr] I submitted the PR to move Qu
[
https://issues.apache.org/jira/browse/FLINK-11449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16757301#comment-16757301
]
Timo Walther commented on FLINK-11449:
--
Thanks for working on this [~sunjincheng121
Myasuka commented on a change in pull request #7600: [FLINK-11368][tests] Port
TaskManagerStartupTest to new code base
URL: https://github.com/apache/flink/pull/7600#discussion_r252693919
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskManagerRun
[
https://issues.apache.org/jira/browse/FLINK-11409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kezhu Wang reassigned FLINK-11409:
--
Assignee: Kezhu Wang
> Make `ProcessFunction`, `ProcessWindowFunction` and etc. pure interfac
Elango Ganesan created FLINK-11496:
--
Summary: FlinkS3 FileSysten is not handling multiple local temp
directories
Key: FLINK-11496
URL: https://issues.apache.org/jira/browse/FLINK-11496
Project: Flink
asfgit closed pull request #7532: [FLINK-11389] Fix Incorrectly use job
information when call getSerial…
URL: https://github.com/apache/flink/pull/7532
This is an automated message from the Apache Git Service.
To respond to
StefanRRichter commented on a change in pull request #7568: [FLINK-11417] Make
access to ExecutionGraph single threaded from JobMaster main thread
URL: https://github.com/apache/flink/pull/7568#discussion_r252699265
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime
[
https://issues.apache.org/jira/browse/FLINK-11389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-11389.
---
Resolution: Fixed
Fixed via
1.8.0:
446145f5ca0cd92c64a6944c19ca1ab53104030f
acf228cc5c888724
[
https://issues.apache.org/jira/browse/FLINK-11409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16757323#comment-16757323
]
Dawid Wysakowicz commented on FLINK-11409:
--
Ok, now I see your point, I don't e
[
https://issues.apache.org/jira/browse/FLINK-11496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Elango Ganesan updated FLINK-11496:
---
Description:
We think S3 Flink Filesystem when creating localTemp directory is not splitting
[
https://issues.apache.org/jira/browse/FLINK-11409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16757323#comment-16757323
]
Dawid Wysakowicz edited comment on FLINK-11409 at 1/31/19 3:00 PM:
---
tvielgouarin commented on issue #7604: [Flink 11249] FlinkKafkaProducer011 can
not be migrated to FlinkKafkaProducer
URL: https://github.com/apache/flink/pull/7604#issuecomment-459376829
hi @pnowojski ,
The Travis check doesn't pass because the migration test of
`FlinkKakfkaProducer011`
tvielgouarin edited a comment on issue #7604: [Flink 11249]
FlinkKafkaProducer011 can not be migrated to FlinkKafkaProducer
URL: https://github.com/apache/flink/pull/7604#issuecomment-459376829
hi @pnowojski ,
The Travis check doesn't pass because the migration test of
`FlinkKakfkaProdu
tillrohrmann commented on a change in pull request #7613:
[FLINK-11370][test]Check and port ZooKeeperLeaderElectionITCase to ne…
URL: https://github.com/apache/flink/pull/7613#discussion_r252704575
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/Le
[
https://issues.apache.org/jira/browse/FLINK-11451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16757322#comment-16757322
]
Timo Walther commented on FLINK-11451:
--
Thank you [~xueyu].
1. In your case, {{pri
pnowojski merged pull request #7570: [FLINK-11422] Prefer testing class to mock
StreamTask in AbstractStre…
URL: https://github.com/apache/flink/pull/7570
This is an automated message from the Apache Git Service.
To respond
pnowojski commented on issue #7570: [FLINK-11422] Prefer testing class to mock
StreamTask in AbstractStre…
URL: https://github.com/apache/flink/pull/7570#issuecomment-459380050
Thanks @TisonKun, merged :)
This is an automated
[
https://issues.apache.org/jira/browse/FLINK-11422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-11422.
--
Resolution: Fixed
merged commit e43d554 into apache:master
> Prefer testing class to mock Str
asfgit closed pull request #7527: [FLINK-11106] [yarn] Remove legacy flink-yarn
component
URL: https://github.com/apache/flink/pull/7527
This is an automated message from the Apache Git Service.
To respond to the message, pl
[
https://issues.apache.org/jira/browse/FLINK-11106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-11106.
---
Resolution: Fixed
Fixed via
e97967278904cb2706a6514ad0a13d50cc389b20
ef5242405f7977f9c330eb9
[
https://issues.apache.org/jira/browse/FLINK-11445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16757355#comment-16757355
]
sunjincheng commented on FLINK-11445:
-
Sounds good to me, looking forward the PR.
tillrohrmann commented on a change in pull request #7613:
[FLINK-11370][test]Check and port ZooKeeperLeaderElectionITCase to ne…
URL: https://github.com/apache/flink/pull/7613#discussion_r252713595
##
File path:
flink-tests/src/test/java/org/apache/flink/test/runtime/leaderelection
tillrohrmann commented on a change in pull request #7613:
[FLINK-11370][test]Check and port ZooKeeperLeaderElectionITCase to ne…
URL: https://github.com/apache/flink/pull/7613#discussion_r252712333
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/Le
tillrohrmann commented on a change in pull request #7613:
[FLINK-11370][test]Check and port ZooKeeperLeaderElectionITCase to ne…
URL: https://github.com/apache/flink/pull/7613#discussion_r252705212
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/Le
Myasuka commented on issue #7600: [FLINK-11368][tests] Port
TaskManagerStartupTest to new code base
URL: https://github.com/apache/flink/pull/7600#issuecomment-459390193
@zentol The logic of previous `testStartupWhenTaskmanagerActorPortIsUsed`
test was a bit strange, because the `port` giv
[
https://issues.apache.org/jira/browse/FLINK-11449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16757410#comment-16757410
]
Dawid Wysakowicz commented on FLINK-11449:
--
In general I like the proposal from
[
https://issues.apache.org/jira/browse/FLINK-9920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16757409#comment-16757409
]
Yun Tang commented on FLINK-9920:
-
With more detailed messages, I believe this bug happen
hequn8128 opened a new pull request #7622: [FLINK-11445][table] Deprecate
static methods in TableEnvironments
URL: https://github.com/apache/flink/pull/7622
## What is the purpose of the change
This pull request deprecates static methods in TableEnvironments and direct
to the java/s
[
https://issues.apache.org/jira/browse/FLINK-11445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11445:
---
Labels: pull-request-available (was: )
> Deprecate static methods in TableEnvironments
> --
[
https://issues.apache.org/jira/browse/FLINK-11449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16757410#comment-16757410
]
Dawid Wysakowicz edited comment on FLINK-11449 at 1/31/19 4:05 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-11449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16757410#comment-16757410
]
Dawid Wysakowicz edited comment on FLINK-11449 at 1/31/19 4:05 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-11496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Elango Ganesan updated FLINK-11496:
---
Summary: FlinkS3 FileSystem is not handling multiple local temp directories
(was: FlinkS3 F
[
https://issues.apache.org/jira/browse/FLINK-11496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Elango Ganesan updated FLINK-11496:
---
Summary: Flink S3 FileSystem is not handling multiple local temp
directories (was: FlinkS3
TisonKun opened a new pull request #7623: [FLINK-11386] Remove legacy
ContaineredJobManager
URL: https://github.com/apache/flink/pull/7623
## What is the purpose of the change
Previously, we extend ContaineredJobManager to implement MesosJobManager and
YarnJobManager. In FLIP-6 we u
[
https://issues.apache.org/jira/browse/FLINK-11386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11386:
---
Labels: pull-request-available (was: )
> Remove legacy ContaineredJobManager
>
[
https://issues.apache.org/jira/browse/FLINK-11361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TisonKun closed FLINK-11361.
Resolution: Duplicate
> Check and port RecoveryITCase to new code base if necessary
>
jgrier commented on issue #7099: [FLINK-10887] [jobmaster] Add source watermark
tracking to the JobMaster
URL: https://github.com/apache/flink/pull/7099#issuecomment-459420616
@tweise @aljoscha @StephanEwen I think this is in a good state for final
review and merge. Take a look when you g
TisonKun created FLINK-11497:
Summary: Remove invalid test JobManagerLeaderElectionTest
Key: FLINK-11497
URL: https://issues.apache.org/jira/browse/FLINK-11497
Project: Flink
Issue Type: Sub-task
TisonKun opened a new pull request #7624: [FLINK-11497] Remove invalid test
JobManagerLeaderElectionTest
URL: https://github.com/apache/flink/pull/7624
## What is the purpose of the change
LeaderElection functions are tested by `LeaderChangeClusterComponentsTest`
and `EmbeddedHaServ
[
https://issues.apache.org/jira/browse/FLINK-11497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11497:
---
Labels: pull-request-available (was: )
> Remove invalid test JobManagerLeaderElectionTest
>
[
https://issues.apache.org/jira/browse/FLINK-11498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sambi reddy updated FLINK-11498:
Remaining Estimate: 5h (was: 24h)
Original Estimate: 5h (was: 24h)
> Getting java.lang.Inst
[
https://issues.apache.org/jira/browse/FLINK-11449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16757523#comment-16757523
]
sunjincheng edited comment on FLINK-11449 at 1/31/19 5:13 PM:
[
https://issues.apache.org/jira/browse/FLINK-11449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16757523#comment-16757523
]
sunjincheng commented on FLINK-11449:
-
Thank you for your reply, I feel that the pro
sambi reddy created FLINK-11498:
---
Summary: Getting java.lang.InstantiationError when trying to
install flink 1.7.1 version through ansible
Key: FLINK-11498
URL: https://issues.apache.org/jira/browse/FLINK-11498
[
https://issues.apache.org/jira/browse/FLINK-11498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16757529#comment-16757529
]
sambi reddy commented on FLINK-11498:
-
First, I tried to install 1.7.1 version on th
Seth Wiesman created FLINK-11499:
Summary: Extend StreamingFileSink BulkFormats to support arbitrary
roll policy's
Key: FLINK-11499
URL: https://issues.apache.org/jira/browse/FLINK-11499
Project: Fli
[
https://issues.apache.org/jira/browse/FLINK-11409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16757541#comment-16757541
]
Kezhu Wang commented on FLINK-11409:
{quote}this is the pattern that we use/encourag
[
https://issues.apache.org/jira/browse/FLINK-11498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sambi reddy updated FLINK-11498:
Description:
We are trying to install flink on our cloud with the help of ansible
automation. we
[
https://issues.apache.org/jira/browse/FLINK-11498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sambi reddy updated FLINK-11498:
Description:
We are trying to install flink on our cloud with the help of ansible
automation. we
[
https://issues.apache.org/jira/browse/FLINK-11498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sambi reddy updated FLINK-11498:
Summary: Getting java.lang.InstantiationError when trying to install flink
1.7.1 version (was: G
[
https://issues.apache.org/jira/browse/FLINK-11499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Seth Wiesman updated FLINK-11499:
-
Component/s: Streaming Connectors
filesystem-connector
> Extend StreamingFileSi
stevenzwu commented on issue #7606: [FLINK-10774] Rework lifecycle management
of partitionDiscoverer in FlinkKafkaConsumerBase
URL: https://github.com/apache/flink/pull/7606#issuecomment-459455146
@tillrohrmann sorry for a late question. you mentioned `This implies that
all users of this c
walterddr commented on a change in pull request #7607: [FLINK-10076][table]
Upgrade Calcite dependency to 1.18
URL: https://github.com/apache/flink/pull/7607#discussion_r252766531
##
File path:
flink-libraries/flink-table/src/main/java/org/apache/calcite/tools/RelBuilder.java
walterddr commented on a change in pull request #7607: [FLINK-10076][table]
Upgrade Calcite dependency to 1.18
URL: https://github.com/apache/flink/pull/7607#discussion_r252780180
##
File path:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/batch/sql/SetOpera
walterddr commented on a change in pull request #7607: [FLINK-10076][table]
Upgrade Calcite dependency to 1.18
URL: https://github.com/apache/flink/pull/7607#discussion_r252764493
##
File path: flink-libraries/flink-table/pom.xml
##
@@ -96,25 +96,12 @@ under the License.
walterddr commented on a change in pull request #7607: [FLINK-10076][table]
Upgrade Calcite dependency to 1.18
URL: https://github.com/apache/flink/pull/7607#discussion_r252786140
##
File path:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/stream/table/OverW
walterddr commented on a change in pull request #7607: [FLINK-10076][table]
Upgrade Calcite dependency to 1.18
URL: https://github.com/apache/flink/pull/7607#discussion_r252764596
##
File path: flink-libraries/flink-table/pom.xml
##
@@ -267,6 +250,8 @@ under the License.
walterddr commented on a change in pull request #7607: [FLINK-10076][table]
Upgrade Calcite dependency to 1.18
URL: https://github.com/apache/flink/pull/7607#discussion_r252765823
##
File path:
flink-libraries/flink-table/src/main/java/org/apache/calcite/sql/validate/SqlValidatorIm
walterddr commented on a change in pull request #7607: [FLINK-10076][table]
Upgrade Calcite dependency to 1.18
URL: https://github.com/apache/flink/pull/7607#discussion_r252766675
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/AggSql
walterddr commented on a change in pull request #7607: [FLINK-10076][table]
Upgrade Calcite dependency to 1.18
URL: https://github.com/apache/flink/pull/7607#discussion_r252766737
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/TimeIndica
bowenli86 edited a comment on issue #7587: [FLINK-11064] [table] Setup a new
flink-table module structure
URL: https://github.com/apache/flink/pull/7587#issuecomment-459476927
nice work! @twalthr
This is an automated message
bowenli86 commented on issue #7587: [FLINK-11064] [table] Setup a new
flink-table module structure
URL: https://github.com/apache/flink/pull/7587#issuecomment-459476927
nice work!
This is an automated message from the Apache
[
https://issues.apache.org/jira/browse/FLINK-10796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li closed FLINK-10796.
Resolution: Duplicate
> Add a default external catalog (as FlinkInMemoryCatalog) to CatalogManager
> -
[
https://issues.apache.org/jira/browse/FLINK-10698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li closed FLINK-10698.
Resolution: Duplicate
> Create CatalogManager class manages all external catalogs and temporary meta
> ob
[
https://issues.apache.org/jira/browse/FLINK-10696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li closed FLINK-10696.
Resolution: Won't Fix
Release Note: existing catalog API will be replaced, thus no need to modify
ex
[
https://issues.apache.org/jira/browse/FLINK-10768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li closed FLINK-10768.
Resolution: Duplicate
> Move external catalog related code from TableEnvironment to CatalogManager
> -
Chesnay Schepler created FLINK-11500:
Summary: 1.8
Key: FLINK-11500
URL: https://issues.apache.org/jira/browse/FLINK-11500
Project: Flink
Issue Type: Bug
Reporter: Chesnay Sch
zentol merged pull request #7535: [FLINK-11382] Disable MetricFetcher if
interval is configured to 0 an…
URL: https://github.com/apache/flink/pull/7535
This is an automated message from the Apache Git Service.
To respond to
[
https://issues.apache.org/jira/browse/FLINK-11382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16757702#comment-16757702
]
Chesnay Schepler commented on FLINK-11382:
--
[~xleesf] Could you open a follow-u
jgrier opened a new pull request #7625: Backport [FLINK-10887] Add JobMaster
RPC endpoint that is used to share information across source subtasks.
URL: https://github.com/apache/flink/pull/7625
Backporting this Flink PR to our Lyft internal branch:
https://github.com/apache/flink/pull/70
jgrier commented on issue #7625: Backport [FLINK-10887] Add JobMaster RPC
endpoint that is used to share information across source subtasks.
URL: https://github.com/apache/flink/pull/7625#issuecomment-459500385
Mistake.
This
jgrier closed pull request #7625: Backport [FLINK-10887] Add JobMaster RPC
endpoint that is used to share information across source subtasks.
URL: https://github.com/apache/flink/pull/7625
This is an automated message from t
[
https://issues.apache.org/jira/browse/FLINK-10887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-10887:
-
Fix Version/s: 1.8.0
> Add source watermark tracking to the JobMaster
>
[
https://issues.apache.org/jira/browse/FLINK-11501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lakshmi Rao updated FLINK-11501:
Description:
There are instances when a Flink job that reads from Kafka can read at a
significant
[
https://issues.apache.org/jira/browse/FLINK-11501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lakshmi Rao updated FLINK-11501:
Description:
There are instances when a Flink job that reads from Kafka can read at a
significant
Lakshmi Rao created FLINK-11501:
---
Summary: Add a ratelimiting feature to the FlinkKafkaConsumer
Key: FLINK-11501
URL: https://issues.apache.org/jira/browse/FLINK-11501
Project: Flink
Issue Type
leesf commented on issue #7555: [FLINK-11373] CliFrontend cuts off reason for
error messages
URL: https://github.com/apache/flink/pull/7555#issuecomment-459555295
cc @zentol @dawidwys
This is an automated message from the Ap
leesf commented on issue #7536: [hotfix][docs] Remove redundant symbols
URL: https://github.com/apache/flink/pull/7536#issuecomment-459555384
cc @zentol
This is an automated message from the Apache Git Service.
To respond to
jgrier closed pull request #7099: [FLINK-10887] [jobmaster] Add source
watermark tracking to the JobMaster
URL: https://github.com/apache/flink/pull/7099
This is an automated message from the Apache Git Service.
To respond t
jgrier opened a new pull request #7099: [FLINK-10887] [jobmaster] Add source
watermark tracking to the JobMaster
URL: https://github.com/apache/flink/pull/7099
## What is the purpose of the change
This commit adds a JobMaster RPC endpoint that is used to for global
information shari
[
https://issues.apache.org/jira/browse/FLINK-11487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ambition closed FLINK-11487.
Resolution: Fixed
Release Note: [FLINK-4446] Remove Flume connector (now in Bahir)
> Support for wri
ambition119 closed pull request #7618: [FLINK-11487] Support for writing data
to Apache Flume
URL: https://github.com/apache/flink/pull/7618
This is an automated message from the Apache Git Service.
To respond to the message
ambition119 commented on issue #7618: [FLINK-11487] Support for writing data to
Apache Flume
URL: https://github.com/apache/flink/pull/7618#issuecomment-459574423
@sjwiesman Thank you for your comment, let me know Apache Bahir. At first I
thought that the code I wrote was not very good, bu
[
https://issues.apache.org/jira/browse/FLINK-11484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
pj updated FLINK-11484:
---
Attachment: 1.png
> Blink java.util.concurrent.TimeoutException
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-11484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16757871#comment-16757871
]
pj commented on FLINK-11484:
Thanks for your response. I notice that the all tasks in my job
tzulitai commented on issue #7601: [FLINK-11164] Check for sentinel values when
creating new Kinesis ShardIterator
URL: https://github.com/apache/flink/pull/7601#issuecomment-459578559
@aljoscha LGTM 👍
This is an automated m
[
https://issues.apache.org/jira/browse/FLINK-11071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
BoWang closed FLINK-11071.
--
> Dynamic proxy classes cannot be resolved when deserializing job graph
>
[
https://issues.apache.org/jira/browse/FLINK-11453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong reassigned FLINK-11453:
-
Assignee: Rong Rong
> Support SliceStream with forwardable pane info
> ---
[
https://issues.apache.org/jira/browse/FLINK-11454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong reassigned FLINK-11454:
-
Assignee: Rong Rong
> Support MergedStream operation
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-11451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16757923#comment-16757923
]
Hequn Cheng commented on FLINK-11451:
-
Hi, [~xueyu] I think [~twalthr]'s suggestion
dianfu opened a new pull request #7626: [FLINK-11450][table] Port and move
TableSource and TableSink to flink-table-common
URL: https://github.com/apache/flink/pull/7626
## What is the purpose of the change
*This pull request ported the following classes to flink-table-common:
[
https://issues.apache.org/jira/browse/FLINK-11450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11450:
---
Labels: pull-request-available (was: )
> Port and move TableSource and TableSink to flink-t
liukaiyi commented on issue #7583: Blink init
URL: https://github.com/apache/flink/pull/7583#issuecomment-459601393
> @ajliualiyun @KurtYoung
org.apache.flink.sql.parser.impl.FlinkSqlParserImpl is missing in blink branch
I also have this problem.
in blink branch flink-sql-pars
TisonKun created FLINK-11502:
Summary: Remove invalid test FlinkActorTest
Key: FLINK-11502
URL: https://issues.apache.org/jira/browse/FLINK-11502
Project: Flink
Issue Type: Sub-task
Com
TisonKun opened a new pull request #7627: [FLINK-11502] Remove invalid test
FlinkActorTest
URL: https://github.com/apache/flink/pull/7627
## What is the purpose of the change
`FlinkActorTest` test `FlinkActor` class, which is no longer used in FLIP-6
codebase.
## Brief change
[
https://issues.apache.org/jira/browse/FLINK-11502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11502:
---
Labels: pull-request-available (was: )
> Remove invalid test FlinkActorTest
> -
1 - 100 of 315 matches
Mail list logo
