[
https://issues.apache.org/jira/browse/FLINK-11449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16758054#comment-16758054
]
Dawid Wysakowicz commented on FLINK-11449:
--
Ad.1 Here, I agree I think they sho
TisonKun created FLINK-11509:
Summary: Remove invalid test
ClientConnectionTest#testJobManagerRetrievalWithHAServices
Key: FLINK-11509
URL: https://issues.apache.org/jira/browse/FLINK-11509
Project: Flink
TisonKun created FLINK-11508:
Summary: Remove invalid test AkkaJobManagerRetrieverTest
Key: FLINK-11508
URL: https://issues.apache.org/jira/browse/FLINK-11508
Project: Flink
Issue Type: Sub-task
TisonKun created FLINK-11507:
Summary: Remove invalid test JobClientActorTest
Key: FLINK-11507
URL: https://issues.apache.org/jira/browse/FLINK-11507
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-11506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16758030#comment-16758030
]
xueyu commented on FLINK-11506:
---
Hi, [~chenzun], please update the issue title using Engli
[
https://issues.apache.org/jira/browse/FLINK-11506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chen Zun updated FLINK-11506:
-
Description:
{code:java}
进入sql客户端之后，执行select * from TaixFares;
Exception in thread "main" org.apache.fli
[
https://issues.apache.org/jira/browse/FLINK-11506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chen Zun updated FLINK-11506:
-
Description:
{code:java}
Exception in thread "main" org.apache.flink.table.client.SqlClientException:
U
[
https://issues.apache.org/jira/browse/FLINK-11506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chen Zun updated FLINK-11506:
-
Environment:
windows7
cygwin64
java -version
java version "1.8.0_101"
Java(TM) SE Runtime Environment
Chen Zun created FLINK-11506:
Summary: 通过sql-client.sh登录后，执行sql语句报IO异常，然后客户端中断退出
Key: FLINK-11506
URL: https://issues.apache.org/jira/browse/FLINK-11506
Project: Flink
Issue Type: Bug
C
[
https://issues.apache.org/jira/browse/FLINK-11484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16758024#comment-16758024
]
Yang Wang commented on FLINK-11484:
---
[~pijing] You do not need 200 slots because the s
[
https://issues.apache.org/jira/browse/FLINK-11362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11362:
---
Labels: pull-request-available (was: )
> Check and port TaskManagerComponentsStartupShutdow
TisonKun opened a new pull request #7632: [FLINK-11362] Port
TaskManagerComponentsStartupShutdownTest to new co…
URL: https://github.com/apache/flink/pull/7632
## What is the purpose of the change
Port TaskManagerComponentsStartupShutdownTest to
TaskExecutorTest#testTaskManagerServi
[
https://issues.apache.org/jira/browse/FLINK-11391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11391:
---
Labels: pull-request-available (was: )
> Introduce ShuffleMaster in Job Master
> --
zhijiangW opened a new pull request #7631: [FLINK-11391][shuffle] Introduce
PartitionShuffleDescriptor and ShuffleDeploymentDescriptor
URL: https://github.com/apache/flink/pull/7631
## What is the purpose of the change
*This is a sub task for introducing `ShuffleMaster` component on
[
https://issues.apache.org/jira/browse/FLINK-11362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TisonKun reassigned FLINK-11362:
Assignee: TisonKun
> Check and port TaskManagerComponentsStartupShutdownTest to new code base if
[
https://issues.apache.org/jira/browse/FLINK-11504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11504:
---
Labels: pull-request-available (was: )
> Remove invalid test JobManagerConnectionTest
> ---
TisonKun opened a new pull request #7629: [FLINK-11504] Remove invalid test
JobManagerConnectionTest
URL: https://github.com/apache/flink/pull/7629
## What is the purpose of the change
This test tests really legacy classes. We now have rpc abstractions and
their own tests.
##
TisonKun opened a new pull request #7630: [FLINK-11505] Remove invalid test
JobManagerRegistrationTest
URL: https://github.com/apache/flink/pull/7630
## What is the purpose of the change
A TaskExecutor is now registered in ResourceManager and we have
ResourceManagerTaskExecutorTest
lincoln-lil commented on issue #7583: Blink init
URL: https://github.com/apache/flink/pull/7583#issuecomment-459611450
hi, liukaiyi
the `org.apache.flink.sql.parser.impl.FlinkSqlParserImpl` is a generated
class, you can run maven local install before testing (testing the
extende
[
https://issues.apache.org/jira/browse/FLINK-11505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11505:
---
Labels: pull-request-available (was: )
> Remove invalid test JobManagerRegistrationTest
> -
TisonKun created FLINK-11505:
Summary: Remove invalid test JobManagerRegistrationTest
Key: FLINK-11505
URL: https://issues.apache.org/jira/browse/FLINK-11505
Project: Flink
Issue Type: Sub-task
TisonKun created FLINK-11504:
Summary: Remove invalid test JobManagerConnectionTest
Key: FLINK-11504
URL: https://issues.apache.org/jira/browse/FLINK-11504
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-11503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11503:
---
Labels: pull-request-available (was: )
> Remove invalid test TaskManagerLossFailsTasksTest
TisonKun opened a new pull request #7628: [FLINK-11503] Remove invalid test
TaskManagerLossFailsTasksTest
URL: https://github.com/apache/flink/pull/7628
## What is the purpose of the change
TaskManagerLossFailsTasksTest tests an instance fail would cause the
execution graph failing.
TisonKun created FLINK-11503:
Summary: Remove invalid test TaskManagerLossFailsTasksTest
Key: FLINK-11503
URL: https://issues.apache.org/jira/browse/FLINK-11503
Project: Flink
Issue Type: Sub-tas
[
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
> -
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
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
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
[
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
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-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
[
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-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-11071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
BoWang closed FLINK-11071.
--
> Dynamic proxy classes cannot be resolved when deserializing job graph
>
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-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
[
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
> ---
>
>
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
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
[
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
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
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
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
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
[
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
[
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
>
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
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
[
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
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
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
[
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
> -
[
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-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-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
> -
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
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
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
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_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.
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
[
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
[
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-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-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
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-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
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-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
[
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-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-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
>
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
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
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
[
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
>
[
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
>
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-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
[
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-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-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
> --
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-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
[
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
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
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
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_r252713595
##
File path:
flink-tests/src/test/java/org/apache/flink/test/runtime/leaderelection
1 - 100 of 315 matches
Mail list logo
